From 6de49c864c22ceb14d0915b82d59c56a564d7a80 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 064d7b83cff9..dc995a192d8d 100644
--- a/streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java
@@ -342,6 +342,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();
+            }
         }
     }