kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch 1.1 updated: KAFKA-7990: Close streams at the end in KafkaStreamsTest (#6334)
Date Wed, 27 Feb 2019 06:28:47 GMT
This is an automated email from the ASF dual-hosted git repository.

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


The following commit(s) were added to refs/heads/1.1 by this push:
     new 74f7c3a  KAFKA-7990: Close streams at the end in KafkaStreamsTest (#6334)
74f7c3a is described below

commit 74f7c3ac2469b371b5adab10c1a71c067de972b0
Author: Guozhang Wang <wangguoz@gmail.com>
AuthorDate: Tue Feb 26 22:28:02 2019 -0800

    KAFKA-7990: Close streams at the end in KafkaStreamsTest (#6334)
    
    This fix is already in 2.1+ branches, but did not get into older branches.
    
    Should be cherry-picked all the way to 0.10.2.
    
    Reviewers: Matthias J. Sax <mjsax@apache.org>
---
 streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java b/streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java
index 9770173..8d1a912 100644
--- a/streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java
@@ -424,6 +424,9 @@ public class KafkaStreamsTest {
         } finally {
             // stop the thread so we don't interfere with other tests etc
             keepRunning.set(false);
+            if (streams != null) {
+                streams.close();
+            }
         }
     }
 


Mime
View raw message