You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
This repository has been archived by the owner on May 25, 2023. It is now read-only.
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 ..
Sign up for freeto subscribe to this conversation on GitHub.
Already have an account?
Sign in.
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?
The text was updated successfully, but these errors were encountered: