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

[gu...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

guozhang pushed a commit to branch 0.11.0
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/0.11.0 by this push:
     new 6de49c8  KAFKA-7990: Close streams at the end in KafkaStreamsTest (#6334)
6de49c8 is described below

commit 6de49c864c22ceb14d0915b82d59c56a564d7a80
Author: Guozhang Wang <wa...@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 064d7b8..dc995a1 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 class KafkaStreamsTest {
         } finally {
             // stop the thread so we don't interfere with other tests etc
             keepRunning.set(false);
+            if (streams != null) {
+                streams.close();
+            }
         }
     }