[ https://issues.apache.org/jira/browse/KAFKA-15531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Yi Ding updated KAFKA-15531: ---------------------------- Labels: kip-848 kip-848-client-support kip-848-e2e kip-848-preview (was: kip-848 kip-848-client-support kip-848-preview) > Ensure coordinator node is removed upon disconnection exception > --------------------------------------------------------------- > > Key: KAFKA-15531 > URL: https://issues.apache.org/jira/browse/KAFKA-15531 > Project: Kafka > Issue Type: Sub-task > Components: consumer > Reporter: Philip Nee > Assignee: Philip Nee > Priority: Major > Labels: kip-848, kip-848-client-support, kip-848-e2e, > kip-848-preview > > In the async consumer, the coordinator isn't being removed when receiving the > following exception: > > {code:java} > (e instanceof DisconnectException) { > markCoordinatorUnknown(true, e.getMessage()); > }{code} > > This should happen on all requests going to coordinator node: > 1. heartbeat 2. offset fetch/commit -- This message was sent by Atlassian Jira (v8.20.10#820010)