kafka streams doesn't rebalance when one broker is down

[yogeshbelur]

I am using 0.11.0 streams

I have 3 nodes running kafka cluster of 3 broker

and i am running the 3 kafka stream with same 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?

[debasishg]

I suggest you ask this question on kafka user mailing list. This Scala wrapper does nothing more than wrapt the Java APIs - hence it is unlikely someone will be able to help you here ..