(kafka) branch trunk updated: KAFKA-17204: KafkaStreamsCloseOptionsIntegrationTest.before leaks AdminClient (#16692)

[mj...@apache.org]

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

mjsax 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 a07294a7327 KAFKA-17204: KafkaStreamsCloseOptionsIntegrationTest.before leaks AdminClient (#16692)
a07294a7327 is described below

commit a07294a732704b5322df6611088d8d33bc7d3048
Author: TengYao Chi <ki...@gmail.com>
AuthorDate: Sat Jul 27 01:32:39 2024 +0800

    KAFKA-17204: KafkaStreamsCloseOptionsIntegrationTest.before leaks AdminClient (#16692)
    
    To avoid a resource leak, we need to close the AdminClient after the test.
    
    Reviewers: Lianet Magrans <li...@gmail.com>, Matthias J. Sax <ma...@confluent.io>
---
 .../streams/integration/KafkaStreamsCloseOptionsIntegrationTest.java     | 1 +
 1 file changed, 1 insertion(+)

diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/KafkaStreamsCloseOptionsIntegrationTest.java b/streams/src/test/java/org/apache/kafka/streams/integration/KafkaStreamsCloseOptionsIntegrationTest.java
index c7c34600fc8..d7ce484ba55 100644
--- a/streams/src/test/java/org/apache/kafka/streams/integration/KafkaStreamsCloseOptionsIntegrationTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/integration/KafkaStreamsCloseOptionsIntegrationTest.java
@@ -90,6 +90,7 @@ public class KafkaStreamsCloseOptionsIntegrationTest {
 
     @AfterAll
     public static void closeCluster() {
+        Utils.closeQuietly(adminClient, "admin");
         CLUSTER.stop();
     }