commit 1f4c0944eafc4947f6a5cc426c3e195f40810d6d
author Guozhang Wang <wangguoz@gmail.com> Tue Feb 26 22:28:02 2019 -0800
committer Guozhang Wang <wangguoz@gmail.com> Tue Feb 26 22:29:24 2019 -0800
tree 052fc0f784796e1906e010986544a5a36fedcb99
parent fdc742b1ade420682911b3e336ae04827639cc04

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

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 832883a..adc5866 100644
--- a/streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java
@@ -358,6 +358,9 @@
         } finally {
             // stop the thread so we don't interfere with other tests etc
             keepRunning.set(false);
+            if (streams != null) {
+                streams.close();
+            }
         }
     }