From d1956d4b6c3ab30cba78bc6f6034ec20303e4801 Mon Sep 17 00:00:00 2001 From: Eno Thereska Date: Fri, 13 Jan 2017 11:11:17 -0800 Subject: [PATCH] HOTFIX: Added another broker to smoke test Author: Eno Thereska Reviewers: Guozhang Wang Closes #2362 from enothereska/hotfix-smoke-test-2-brokers --- .../streams/processor/internals/InternalTopicManager.java | 3 +-- tests/kafkatest/tests/streams/streams_smoke_test.py | 4 ++-- 2 files changed, 3 insertions(+), 4 deletions(-) diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java index 5794e30a2c8..8bb5a3df653 100644 --- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java +++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java @@ -66,8 +66,7 @@ public class InternalTopicManager { streamsKafkaClient.createTopics(topicsToBeCreated, replicationFactor, windowChangeLogAdditionalRetention); return; } catch (StreamsException ex) { - log.debug("Could not create internal topics: " + ex.getMessage()); - log.debug("Retry #" + i); + log.warn("Could not create internal topics: " + ex.getMessage() + ". Retry #" + i); } } throw new StreamsException("Could not create internal topics."); diff --git a/tests/kafkatest/tests/streams/streams_smoke_test.py b/tests/kafkatest/tests/streams/streams_smoke_test.py index f921afdfdc8..a824d926573 100644 --- a/tests/kafkatest/tests/streams/streams_smoke_test.py +++ b/tests/kafkatest/tests/streams/streams_smoke_test.py @@ -27,7 +27,7 @@ class StreamsSmokeTest(KafkaTest): """ def __init__(self, test_context): - super(StreamsSmokeTest, self).__init__(test_context, num_zk=1, num_brokers=1, topics={ + super(StreamsSmokeTest, self).__init__(test_context, num_zk=1, num_brokers=2, topics={ 'echo' : { 'partitions': 5, 'replication-factor': 1 }, 'data' : { 'partitions': 5, 'replication-factor': 1 }, 'min' : { 'partitions': 5, 'replication-factor': 1 }, @@ -46,7 +46,7 @@ class StreamsSmokeTest(KafkaTest): self.processor3 = StreamsSmokeTestJobRunnerService(test_context, self.kafka) self.processor4 = StreamsSmokeTestJobRunnerService(test_context, self.kafka) - @cluster(num_nodes=7) + @cluster(num_nodes=8) def test_streams(self): """ Start a few smoke test clients, then repeat start a new one, stop (cleanly) running one a few times.