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

[github-bot]

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

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

commit c44814929589da452aa85a1abd3ff591a3261ca6
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 caffbf1..4f3ec89 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());
         }
     }