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.
