diff --git a/clients/src/test/java/org/apache/kafka/test/MockSelector.java b/clients/src/test/java/org/apache/kafka/test/MockSelector.java index 2d7c1517d82c7..3560c3535aa73 100644 --- a/clients/src/test/java/org/apache/kafka/test/MockSelector.java +++ b/clients/src/test/java/org/apache/kafka/test/MockSelector.java @@ -83,6 +83,7 @@ public void close(String id) { removeSendsForNode(id, completedSends); removeSendsForNode(id, initiatedSends); + ready.remove(id); for (int i = 0; i < this.connected.size(); i++) { if (this.connected.get(i).equals(id)) {