You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by gi...@apache.org on 2020/11/17 01:28:54 UTC
[camel-kafka-connector] 07/09: Adjust the emdedded Kafka service to
the updated interface from Camel 3.7
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 <op...@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());
}
}