From eb2920ddac7dbae76c823051e0d8e987e6a24e71 Mon Sep 17 00:00:00 2001 From: Staffan Olsson Date: Tue, 28 Nov 2017 09:23:34 +0100 Subject: [PATCH] I'm using docker-compose locally, with an extra advertised.listeners Something like https://github.com/Yolean/kubernetes-kafka/pull/78 --- .../topic/client/service/IntegrationTestConfigLocalhost.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/itest/java/se/yolean/kafka/topic/client/service/IntegrationTestConfigLocalhost.java b/src/itest/java/se/yolean/kafka/topic/client/service/IntegrationTestConfigLocalhost.java index 84d8894..896feca 100644 --- a/src/itest/java/se/yolean/kafka/topic/client/service/IntegrationTestConfigLocalhost.java +++ b/src/itest/java/se/yolean/kafka/topic/client/service/IntegrationTestConfigLocalhost.java @@ -7,9 +7,11 @@ public class IntegrationTestConfigLocalhost extends AbstractModule { + public static final int KAFKA_LISTENER_PORT = 9094; + @Override protected void configure() { - bind(String.class).annotatedWith(Names.named("config:bootstrap")).toInstance("localhost:9092"); + bind(String.class).annotatedWith(Names.named("config:bootstrap")).toInstance("localhost:" + KAFKA_LISTENER_PORT); bind(String.class).annotatedWith(Names.named("config:adminTopic")).toInstance("_topic_declarations");