You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2020/11/28 12:34:32 UTC
[camel-kafka-connector] 02/04: Do not nullify the cluster reference
on the embedded kafka service.
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 0f94c14995fc0733f4a77e1f7fbdcdbb5dee091c
Author: Otavio Rodolfo Piske <op...@redhat.com>
AuthorDate: Fri Nov 27 17:00:54 2020 +0100
Do not nullify the cluster reference on the embedded kafka service.
This ensures that the embedded kafka service is compatible with JUnit's 5 class life cycle
---
.../camel/kafkaconnector/common/services/kafka/EmbeddedKafkaService.java | 1 -
1 file changed, 1 deletion(-)
diff --git a/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafka/EmbeddedKafkaService.java b/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafka/EmbeddedKafkaService.java
index caffbf1..3ef2c06 100644
--- a/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafka/EmbeddedKafkaService.java
+++ b/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafka/EmbeddedKafkaService.java
@@ -94,7 +94,6 @@ public class EmbeddedKafkaService implements KafkaService {
if (started) {
cluster.stop();
- cluster = null;
started = false;
}
}