[kafka] branch trunk updated: MINOR: AbstractCoordinatorTest should close coordinator explicitly (#10001)

[chia7712]

This is an automated email from the ASF dual-hosted git repository.

chia7712 pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 23de8cb  MINOR: AbstractCoordinatorTest should close coordinator 
explicitly (#10001)
23de8cb is described below

commit 23de8cbe12ae9e8f1795f507dbf7705bacb56d21
Author: Chia-Ping Tsai <chia7...@gmail.com>
AuthorDate: Sat Jan 30 20:03:15 2021 +0800

    MINOR: AbstractCoordinatorTest should close coordinator explicitly (#10001)
    
    Reviewers: Jason Gustafson <ja...@confluent.io>
---
 .../kafka/clients/consumer/internals/AbstractCoordinatorTest.java | 8 ++++++++
 1 file changed, 8 insertions(+)

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 f59735b..c88cf74 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
@@ -51,7 +51,9 @@ import org.apache.kafka.common.utils.LogContext;
 import org.apache.kafka.common.utils.MockTime;
 import org.apache.kafka.common.utils.Time;
 import org.apache.kafka.common.utils.Timer;
+import org.apache.kafka.common.utils.Utils;
 import org.apache.kafka.test.TestUtils;
+import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.Test;
 
 import java.nio.ByteBuffer;
@@ -102,6 +104,12 @@ public class AbstractCoordinatorTest {
     private final String leaderId = "leaderId";
     private final int defaultGeneration = -1;
 
+    @AfterEach
+    public void closeCoordinator() {
+        Utils.closeQuietly(coordinator, "close coordinator");
+        Utils.closeQuietly(consumerClient, "close consumer client");
+    }
+
     private void setupCoordinator() {
         setupCoordinator(RETRY_BACKOFF_MS, REBALANCE_TIMEOUT_MS,
             Optional.empty());