[camel-kafka-connector] 05/17: Adjust the emdedded Kafka service to the updated interface from Camel 3.7

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git

commit 86ce43c92928c8a7eaf87d43ed04cf47eea509cc
Author: Otavio Rodolfo Piske <opi...@redhat.com>
AuthorDate: Fri Nov 13 14:03:06 2020 +0100

    Adjust the emdedded Kafka service to the updated interface from Camel 3.7
---
 .../kafkaconnector/common/services/kafka/EmbeddedKafkaService.java  | 6 ++++++
 1 file changed, 6 insertions(+)

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 3ef2c06..4c43ae0 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
@@ -79,11 +79,17 @@ public class EmbeddedKafkaService implements KafkaService {
     }
 
     @Override
+    public void registerProperties() {
+        // NO-OP
+    }
+
+    @Override
     public void initialize() {
         if (!started) {
             cluster.start();
             started = true;
 
+            registerProperties();
             LOG.info("Kafka bootstrap server running at address {}", 
getBootstrapServers());
         }
     }