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;
         }
     }