This is an automated email from the ASF dual-hosted git repository. orpiske pushed a commit to branch camel-master in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit d3adf240577c5633cd7683c6f6c460368a241128 Author: Otavio Rodolfo Piske <[email protected]> AuthorDate: Mon Feb 15 09:14:17 2021 +0100 Set the port configuration to avoid the Jetty port error when creating the connect instance --- .../kafkaconnector/common/services/kafka/EmbeddedKafkaService.java | 2 ++ 1 file changed, 2 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 3ce25d3..a7e50bd 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 @@ -50,6 +50,8 @@ public class EmbeddedKafkaService implements KafkaService { Map<String, String> workerProps = new HashMap<>(); workerProps.put(WorkerConfig.OFFSET_COMMIT_INTERVAL_MS_CONFIG, String.valueOf(OFFSET_COMMIT_INTERVAL_MS)); + workerProps.put(WorkerConfig.LISTENERS_CONFIG, "http://localhost:9999";); + String pluginPaths = PluginPathHelper.getInstance().pluginPaths();
