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

Reply via email to