gomudayya opened a new pull request, #22375: URL: https://github.com/apache/kafka/pull/22375
When a broker's advertised host changes (e.g. a Kafka pod is rescheduled with a new hostname), `NetworkClient` keeps using the channel bound to the old host. TCP keepalive can mask this, silently routing requests to another broker that now owns the old address. The same occurs when only the resolved IP changes. After a successful metadata update, close any connection whose cached host differs from the latest metadata, or whose bound IP is no longer in the resolved set for that host. Unit tests cover host-change and IP-change cases, and verify the channel is closed after the next metadata update. -- 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]
