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. >> >
signature.asc
Description: OpenPGP digital signature
