NotCoordinatorForGroupException in a long loop

[Jamie Park <ja...@gmail.com>]

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.