Hey Amuthan, I replied you on the Slack community. Feel free to choose either continue the discussion here or in Slack.
Boyang On Mon, Oct 21, 2019 at 1:06 PM Amuthan <mr.amut...@gmail.com> wrote: > I have a Kafka stream application that stores the incoming messages into a > state store, and later during the punctuation period, we store them into a > big data persistent store after processing the messages. > > The application consumes from 120 partitions distributed across 40 > instances. The application has been running fine without any problem for > months, but all of a sudden some of the instances failed because of a > stream thread exception saying > > ```java.lang.IllegalStateException: No current assignment for partition > <app_name>-<store_name>-changelog-98``` > > > > And other instances are stuck in the REBALANCING state, and never comes out > of it. >
