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 8f5add8419be2e69f768d19cf4d460f11532d36a Author: Otavio Rodolfo Piske <[email protected]> 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()); } }
