Repository: kafka Updated Branches: refs/heads/trunk f6fee34a2 -> d1956d4b6
HOTFIX: Added another broker to smoke test Author: Eno Thereska <eno.there...@gmail.com> Reviewers: Guozhang Wang <wangg...@gmail.com> Closes #2362 from enothereska/hotfix-smoke-test-2-brokers Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/d1956d4b Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/d1956d4b Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/d1956d4b Branch: refs/heads/trunk Commit: d1956d4b6c3ab30cba78bc6f6034ec20303e4801 Parents: f6fee34 Author: Eno Thereska <eno.there...@gmail.com> Authored: Fri Jan 13 11:11:17 2017 -0800 Committer: Guozhang Wang <wangg...@gmail.com> Committed: Fri Jan 13 11:11:17 2017 -0800 ---------------------------------------------------------------------- .../kafka/streams/processor/internals/InternalTopicManager.java | 3 +-- tests/kafkatest/tests/streams/streams_smoke_test.py | 4 ++-- 2 files changed, 3 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/d1956d4b/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java ---------------------------------------------------------------------- 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 5794e30..8bb5a3d 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."); http://git-wip-us.apache.org/repos/asf/kafka/blob/d1956d4b/tests/kafkatest/tests/streams/streams_smoke_test.py ---------------------------------------------------------------------- diff --git a/tests/kafkatest/tests/streams/streams_smoke_test.py b/tests/kafkatest/tests/streams/streams_smoke_test.py index f921afd..a824d92 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.
