You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Yogesh BG (JIRA)" <ji...@apache.org> on 2018/07/26 17:32:00 UTC
[jira] [Created] (KAFKA-7209) Kafka stream does not rebalance when
one node gets down
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)