[jira] [Created] (KAFKA-5530) Balancer is dancing with KStream all the time, and due to that Kafka cannot work :-)

["Seweryn Habdank-Wojewodzki (JIRA)" <ji...@apache.org>]

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)