You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2017/01/13 19:11:20 UTC
kafka git commit: HOTFIX: Added another broker to smoke test
Repository: kafka
Updated Branches:
refs/heads/trunk f6fee34a2 -> d1956d4b6
HOTFIX: Added another broker to smoke test
Author: Eno Thereska <en...@gmail.com>
Reviewers: Guozhang Wang <wa...@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 <en...@gmail.com>
Authored: Fri Jan 13 11:11:17 2017 -0800
Committer: Guozhang Wang <wa...@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.