MINOR: close producer instance in AbstractJoinIntegrationTest
Reviewers: Guozhang Wang
@@ -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);
}
