Hi, org.apache.kafka.common.errors.NotCoordinatorForGroupException: This is not the correct coordinator for this group.
When there is an under-replication partition, it causes our stream-application to stall with NotCoorindatorForGroupException. This retriableException goes on in a loop for a long time. Eventually the right coordinator is found but I am not sure what the coordinator change does NOT get detected during heartbeats. I also noticed the Coordinator object becomes null in AbstractCoordinator class. Any help will be appreciated. Thanks.
