From 74f7c3ac2469b371b5adab10c1a71c067de972b0 Mon Sep 17 00:00:00 2001
From: Guozhang Wang <wangguoz@gmail.com>
Date: Tue, 26 Feb 2019 22:28:02 -0800
Subject: [PATCH] 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>
---
 .../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 9770173f9945..8d1a9126b48a 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 void apply(final String key, final String value) {
         } finally {
             // stop the thread so we don't interfere with other tests etc
             keepRunning.set(false);
+            if (streams != null) {
+                streams.close();
+            }
         }
     }