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 <[email protected]> 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; } }
