We had some discussion in the community slack. As we don't have debug level log, it's hard to tell what happened exactly.
On Wed, Oct 23, 2019 at 9:52 PM Matthias J. Sax <matth...@confluent.io> wrote: > Seems like Amuthan created a ticket: > https://issues.apache.org/jira/browse/KAFKA-9073 > > Let's move the discussion to the ticket. > > > -Matthias > > On 10/21/19 1:19 PM, Boyang Chen wrote: > > 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. > >> > > > >
