kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: HOTFIX: Added another broker to smoke test
Date Fri, 13 Jan 2017 19:11:20 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk f6fee34a2 -> d1956d4b6


HOTFIX: Added another broker to smoke test

Author: Eno Thereska <eno.thereska@gmail.com>

Reviewers: Guozhang Wang <wangguoz@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.thereska@gmail.com>
Authored: Fri Jan 13 11:11:17 2017 -0800
Committer: Guozhang Wang <wangguoz@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.


Mime
View raw message