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);

Reply via email to