From fca6e998d2a6f65a23ca15f416fda297e9193fbf Mon Sep 17 00:00:00 2001 From: Luke Chen Date: Tue, 2 Jun 2020 12:22:03 +0800 Subject: [PATCH] KAFKA-10081: remove an unused local variable to pass spotbugsMain check --- .../kafka/clients/consumer/internals/AbstractStickyAssignor.java | 1 - 1 file changed, 1 deletion(-) diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java index d4e023cc098a8..353a225c8fcd0 100644 --- a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java +++ b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java @@ -274,7 +274,6 @@ private Map> generalAssign(Map par Map prevAssignment = new HashMap<>(); prepopulateCurrentAssignments(subscriptions, currentAssignment, prevAssignment); - boolean isFreshAssignment = currentAssignment.isEmpty(); // a mapping of all topic partitions to all consumers that can be assigned to them final Map> partition2AllPotentialConsumers = new HashMap<>();