You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by gi...@apache.org on 2021/12/10 10:29:13 UTC
[druid] branch 0.22.1 updated: TestKafkaExtractionCluster: Shut down Kafka, ZK in @After. (#11963)
This is an automated email from the ASF dual-hosted git repository.
gian pushed a commit to branch 0.22.1
in repository https://gitbox.apache.org/repos/asf/druid.git
The following commit(s) were added to refs/heads/0.22.1 by this push:
new a35367e TestKafkaExtractionCluster: Shut down Kafka, ZK in @After. (#11963)
a35367e is described below
commit a35367e99c635fe5eb892a5de2ae537a7a3ce35e
Author: Gian Merlino <gi...@gmail.com>
AuthorDate: Sat Nov 20 15:17:05 2021 -0800
TestKafkaExtractionCluster: Shut down Kafka, ZK in @After. (#11963)
---
.../org/apache/druid/query/lookup/TestKafkaExtractionCluster.java | 7 +++++++
1 file changed, 7 insertions(+)
diff --git a/extensions-core/kafka-extraction-namespace/src/test/java/org/apache/druid/query/lookup/TestKafkaExtractionCluster.java b/extensions-core/kafka-extraction-namespace/src/test/java/org/apache/druid/query/lookup/TestKafkaExtractionCluster.java
index d72a7ac..2cf7b23 100644
--- a/extensions-core/kafka-extraction-namespace/src/test/java/org/apache/druid/query/lookup/TestKafkaExtractionCluster.java
+++ b/extensions-core/kafka-extraction-namespace/src/test/java/org/apache/druid/query/lookup/TestKafkaExtractionCluster.java
@@ -91,6 +91,9 @@ public class TestKafkaExtractionCluster
{
zkServer = new TestingCluster(1);
zkServer.start();
+ closer.register(() -> {
+ zkServer.stop();
+ });
kafkaServer = new KafkaServer(
getBrokerProperties(),
@@ -99,6 +102,10 @@ public class TestKafkaExtractionCluster
false);
kafkaServer.startup();
+ closer.register(() -> {
+ kafkaServer.shutdown();
+ kafkaServer.awaitShutdown();
+ });
log.info("---------------------------Started Kafka Broker ---------------------------");
log.info("---------------------------Publish Messages to topic-----------------------");
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org