Seweryn Habdank-Wojewodzki created KAFKA-5530:
-------------------------------------------------
Summary: Balancer is dancing with KStream all the time, and due to
that Kafka cannot work :-)
Key: KAFKA-5530
URL: https://issues.apache.org/jira/browse/KAFKA-5530
Project: Kafka
Issue Type: Bug
Affects Versions: 0.10.2.1
Environment: Linux, Windows
Reporter: Seweryn Habdank-Wojewodzki
Attachments: streamer-2.zip, streamer.zip
Hi,
I think I found much easier way to reproduce the same behaviour.
I am doing more less suche setup in the code:
{code:java}
// loop over the inTopicName(s) {
KStream<String, String> stringInput = kBuilder.stream( STRING_SERDE,
STRING_SERDE, inTopicName );
stringInput.filter( streamFilter::passOrFilterMessages ).map( ndmNormalizer
).to( outTopicName );
// } end of loop
streams = new KafkaStreams( kBuilder, streamsConfig );
streams.cleanUp();
streams.start();
{code}
And if there are *_num.stream.threads=4_* but there are 2 or more nut less than
num.stream.threads inTopicNames, then complete application startup is totally
self-blocked, by writing endless:
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
