kafka-commits mailing list archives

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

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


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

commit 1158c743cdeb0c3da01c0b500cdb3bbf083412aa
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 491334f..0ac1ebf 100644
--- a/streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java
@@ -456,6 +456,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