[kafka] branch 1.1 updated: KAFKA-7990: Close streams at the end in KafkaStreamsTest (#6334)

[guozhang]

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 <wangg...@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 <mj...@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();
+            }
         }
     }