kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Seweryn Habdank-Wojewodzki (JIRA)" <j...@apache.org>
Subject [jira] [Created] (KAFKA-5530) Balancer is dancing with KStream all the time, and due to that Kafka cannot work :-)
Date Wed, 28 Jun 2017 07:51:00 GMT
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)

Mime
View raw message