[kafka] branch trunk updated: MINOR: close producer instance in AbstractJoinIntegrationTest (#5459)

[guozhang]

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

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


The following commit(s) were added to refs/heads/trunk by this push:
     new 924466a  MINOR: close producer instance in AbstractJoinIntegrationTest 
(#5459)
924466a is described below

commit 924466ad627d96fd1851722fdbb02dd6cd71eafa
Author: Manikumar Reddy O <manikumar.re...@gmail.com>
AuthorDate: Sat Aug 4 22:11:09 2018 +0530

    MINOR: close producer instance in AbstractJoinIntegrationTest (#5459)
    
    Reviewers: Guozhang Wang <wangg...@gmail.com>
---
 .../apache/kafka/streams/integration/AbstractJoinIntegrationTest.java   | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/streams/src/test/java/org/apache/kafka/streams/integration/AbstractJoinIntegrationTest.java
 
b/streams/src/test/java/org/apache/kafka/streams/integration/AbstractJoinIntegrationTest.java
index cddf590..0c1a99d 100644
--- 
a/streams/src/test/java/org/apache/kafka/streams/integration/AbstractJoinIntegrationTest.java
+++ 
b/streams/src/test/java/org/apache/kafka/streams/integration/AbstractJoinIntegrationTest.java
@@ -53,6 +53,7 @@ import java.util.Collection;
 import java.util.Iterator;
 import java.util.List;
 import java.util.Properties;
+import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicBoolean;
 
 import static org.hamcrest.MatcherAssert.assertThat;
@@ -163,6 +164,7 @@ public abstract class AbstractJoinIntegrationTest {
 
     @After
     public void cleanup() throws InterruptedException {
+        producer.close(0, TimeUnit.MILLISECONDS);
         CLUSTER.deleteAllTopicsAndWait(120000);
     }