diff --git a/clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinatorTest.java b/clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinatorTest.java index 969de83c328ff..84113d016b671 100644 --- a/clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinatorTest.java +++ b/clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinatorTest.java @@ -116,6 +116,7 @@ public class AbstractCoordinatorTest { public void closeCoordinator() { Utils.closeQuietly(coordinator, "close coordinator"); Utils.closeQuietly(consumerClient, "close consumer client"); + Utils.closeQuietly(mockClient, "close mock client"); } private void setupCoordinator() {