We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 362b6c5 commit eb2920dCopy full SHA for eb2920d
src/itest/java/se/yolean/kafka/topic/client/service/IntegrationTestConfigLocalhost.java
@@ -7,9 +7,11 @@
7
8
public class IntegrationTestConfigLocalhost extends AbstractModule {
9
10
+ public static final int KAFKA_LISTENER_PORT = 9094;
11
+
12
@Override
13
protected void configure() {
- bind(String.class).annotatedWith(Names.named("config:bootstrap")).toInstance("localhost:9092");
14
+ bind(String.class).annotatedWith(Names.named("config:bootstrap")).toInstance("localhost:" + KAFKA_LISTENER_PORT);
15
16
bind(String.class).annotatedWith(Names.named("config:adminTopic")).toInstance("_topic_declarations");
17
0 commit comments