[jira] [Created] (KAFKA-15531) Ensure coordinator node is removed upon disconnection exception

[Philip Nee (Jira)]

Philip Nee created KAFKA-15531:
----------------------------------

             Summary: Ensure coordinator node is removed upon disconnection 
exception
                 Key: KAFKA-15531
                 URL: https://issues.apache.org/jira/browse/KAFKA-15531
             Project: Kafka
          Issue Type: Bug
          Components: consumer
            Reporter: Philip Nee
            Assignee: Philip Nee


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)