From 65e3bd6d75c6512e68bb33436afe703ce5e8db3c Mon Sep 17 00:00:00 2001 From: Parag Jain Date: Mon, 14 Aug 2017 16:18:05 -0500 Subject: [PATCH 1/2] add localhost as advertised hostname --- .../test/java/io/druid/indexing/kafka/KafkaIndexTaskTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/extensions-core/kafka-indexing-service/src/test/java/io/druid/indexing/kafka/KafkaIndexTaskTest.java b/extensions-core/kafka-indexing-service/src/test/java/io/druid/indexing/kafka/KafkaIndexTaskTest.java index a6bc82afe8ae..3035ec811101 100644 --- a/extensions-core/kafka-indexing-service/src/test/java/io/druid/indexing/kafka/KafkaIndexTaskTest.java +++ b/extensions-core/kafka-indexing-service/src/test/java/io/druid/indexing/kafka/KafkaIndexTaskTest.java @@ -245,7 +245,7 @@ public static void setupClass() throws Exception zkServer.getConnectString(), null, 1, - ImmutableMap.of("num.partitions", "2") + ImmutableMap.of("num.partitions", "2", "advertised.host.name", "localhost") ); kafkaServer.start(); From e365510607071ae621deb1cf93227a13b7a1d515 Mon Sep 17 00:00:00 2001 From: Parag Jain Date: Mon, 14 Aug 2017 16:42:16 -0500 Subject: [PATCH 2/2] set advertised.host.name to localhost for test kafka broker --- .../test/java/io/druid/indexing/kafka/KafkaIndexTaskTest.java | 2 +- .../src/test/java/io/druid/indexing/kafka/test/TestBroker.java | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/extensions-core/kafka-indexing-service/src/test/java/io/druid/indexing/kafka/KafkaIndexTaskTest.java b/extensions-core/kafka-indexing-service/src/test/java/io/druid/indexing/kafka/KafkaIndexTaskTest.java index 3035ec811101..a6bc82afe8ae 100644 --- a/extensions-core/kafka-indexing-service/src/test/java/io/druid/indexing/kafka/KafkaIndexTaskTest.java +++ b/extensions-core/kafka-indexing-service/src/test/java/io/druid/indexing/kafka/KafkaIndexTaskTest.java @@ -245,7 +245,7 @@ public static void setupClass() throws Exception zkServer.getConnectString(), null, 1, - ImmutableMap.of("num.partitions", "2", "advertised.host.name", "localhost") + ImmutableMap.of("num.partitions", "2") ); kafkaServer.start(); diff --git a/extensions-core/kafka-indexing-service/src/test/java/io/druid/indexing/kafka/test/TestBroker.java b/extensions-core/kafka-indexing-service/src/test/java/io/druid/indexing/kafka/test/TestBroker.java index 9e7f69140f89..598cb5a21a68 100644 --- a/extensions-core/kafka-indexing-service/src/test/java/io/druid/indexing/kafka/test/TestBroker.java +++ b/extensions-core/kafka-indexing-service/src/test/java/io/druid/indexing/kafka/test/TestBroker.java @@ -77,6 +77,7 @@ public void start() props.setProperty("log.dirs", directory.toString()); props.setProperty("broker.id", String.valueOf(id)); props.setProperty("port", String.valueOf(new Random().nextInt(9999) + 10000)); + props.setProperty("advertised.host.name", "localhost"); props.putAll(brokerProps); final KafkaConfig config = new KafkaConfig(props);