Yogesh BG created KAFKA-7209: -------------------------------- Summary: Kafka stream does not rebalance when one node gets down Key: KAFKA-7209 URL: https://issues.apache.org/jira/browse/KAFKA-7209 Project: Kafka Issue Type: Bug Components: streams Affects Versions: 0.11.0.1 Reporter: Yogesh BG
I use kafka streams 0.11.0.1session timeout 60000, retries to be int.max and backoff time default I have 3 nodes running kafka cluster of 3 broker and i am running the 3 kafka stream with same [application.id|http://application.id/] each node has one broker one kafka stream application everything works fine during setup i bringdown one node, so one kafka broker and one streaming app is down now i see exceptions in other two streaming apps and it never gets re balanced waited for hours and never comes back to norma is there anything am missing? i also tried looking into when one broker is down call stream.close, cleanup and restart this also doesn't help can anyone help me? One thing i observed lately is that kafka topics with partitions one gets reassigned but i have topics of 16 partitions and replication factor 3. It never settles up -- This message was sent by Atlassian JIRA (v7.6.3#76005)