diff --git a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/ProcessState.java b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/ProcessState.java index 33b4c3af0f1..b927b4cfe71 100644 --- a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/ProcessState.java +++ b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/ProcessState.java @@ -200,14 +200,6 @@ public class ProcessState { return this.load < 1.0; } - public int compareTo(final ProcessState other) { - int loadCompare = Double.compare(this.load, other.load()); - if (loadCompare == 0) { - return Integer.compare(other.capacity, this.capacity); - } - return loadCompare; - } - public boolean hasTask(final TaskId taskId) { return assignedTasks.contains(taskId); } diff --git a/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/assignor/ProcessStateTest.java b/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/assignor/ProcessStateTest.java index 555f0f83ed5..d2ce7482e9a 100644 --- a/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/assignor/ProcessStateTest.java +++ b/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/assignor/ProcessStateTest.java @@ -77,17 +77,6 @@ public class ProcessStateTest { assertFalse(processState.hasCapacity()); } - @Test - void shouldCompareBasedOnLoadAndCapacity() { - ProcessState processState1 = new ProcessState("process1"); - ProcessState processState2 = new ProcessState("process2"); - processState1.addMember("member1"); - processState2.addMember("member2"); - processState1.addTask("member1", new TaskId("id1", 0), true, true); - - assertTrue(processState1.compareTo(processState2) > 0); - } - @Test void shouldReturnTrueIfTaskIsAssigned() { ProcessState processState = new ProcessState("process1");