[kafka] branch 2.0 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 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 <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 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();
+            }
         }
     }