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 304215e6f462b2632b067e4d26ac5af3359e510a Author: Otavio Rodolfo Piske <opi...@redhat.com> AuthorDate: Wed Mar 3 16:35:41 2021 +0100 Remove duplicate slashes (//) on Netty tests They were added to work-around CAMEL-16280 --- .../apache/camel/kafkaconnector/netty/sink/CamelSinkNettyITCase.java | 2 +- .../camel/kafkaconnector/netty/source/CamelSourceNettyITCase.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/tests/itests-netty/src/test/java/org/apache/camel/kafkaconnector/netty/sink/CamelSinkNettyITCase.java b/tests/itests-netty/src/test/java/org/apache/camel/kafkaconnector/netty/sink/CamelSinkNettyITCase.java index 20b6814..19cc77c 100644 --- a/tests/itests-netty/src/test/java/org/apache/camel/kafkaconnector/netty/sink/CamelSinkNettyITCase.java +++ b/tests/itests-netty/src/test/java/org/apache/camel/kafkaconnector/netty/sink/CamelSinkNettyITCase.java @@ -90,7 +90,7 @@ public class CamelSinkNettyITCase extends CamelSinkTestSupport { .withTopics(topicName) .withProtocol("tcp") // TODO https://github.com/apache/camel-kafka-connector/issues/924 - .withHost("//" + NetworkUtils.getHostname()) + .withHost(NetworkUtils.getHostname()) .withPort(port) // disconnect so that it won't keep mock server socket forever .withDisconnect(true) diff --git a/tests/itests-netty/src/test/java/org/apache/camel/kafkaconnector/netty/source/CamelSourceNettyITCase.java b/tests/itests-netty/src/test/java/org/apache/camel/kafkaconnector/netty/source/CamelSourceNettyITCase.java index 2d76e27..30d9926 100644 --- a/tests/itests-netty/src/test/java/org/apache/camel/kafkaconnector/netty/source/CamelSourceNettyITCase.java +++ b/tests/itests-netty/src/test/java/org/apache/camel/kafkaconnector/netty/source/CamelSourceNettyITCase.java @@ -81,7 +81,7 @@ public class CamelSourceNettyITCase extends CamelSourceTestSupport { .withKafkaTopic(topicName) .withProtocol("tcp") // TODO https://github.com/apache/camel-kafka-connector/issues/924 - .withHost("//" + NetworkUtils.getHostname()) + .withHost(NetworkUtils.getHostname()) .withPort(port) // one-way as test client doesn't receive response .withSync(false);