Skip to content

Commit b079bc8

Browse files
committed
close resource
1 parent da0c3be commit b079bc8

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinatorTest.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -116,6 +116,7 @@ public class AbstractCoordinatorTest {
116116
public void closeCoordinator() {
117117
Utils.closeQuietly(coordinator, "close coordinator");
118118
Utils.closeQuietly(consumerClient, "close consumer client");
119+
Utils.closeQuietly(mockClient, "close mock client");
119120
}
120121

121122
private void setupCoordinator() {
@@ -1506,7 +1507,6 @@ public void testWakeupAfterSyncGroupReceived() throws Exception {
15061507
awaitFirstHeartbeat(heartbeatReceived);
15071508
}
15081509

1509-
@Tag("flaky") // KAFKA-15474 and KAFKA-18310
15101510
@Test
15111511
public void testWakeupAfterSyncGroupReceivedExternalCompletion() throws Exception {
15121512
setupCoordinator();

0 commit comments

Comments
 (0)