root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

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
This commit is contained in:
Eno Thereska 2017-01-13 11:11:17 -08:00 committed by Guozhang Wang
parent f6fee34a2d
commit d1956d4b6c
2 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java
View File

@ -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.");

4
tests/kafkatest/tests/streams/streams_smoke_test.py
View File

@ -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.