lianetm commented on PR #16844: URL: https://github.com/apache/kafka/pull/16844#issuecomment-2313175166
> I wonder if we should also do the same on timeouts. Did we in the old implementation? Good point @dajac . It's not explicitly handled in the classic or new consumer, but we do get the behaviour in both, because timeouts as treated as disconnections at the network layer level ([handledTimedoutRequests](https://github.com/apache/kafka/blob/62dc982ce9ce76b299a628d50648e3529fd88e63/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java#L866)). So if the request times out, the network client disconnects from the node, ending up in the `DisconnectExeption` that both consumer handle to mark the coordinator unknown. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
