Hi everyone,
I’m using Apache Kafka with Spring and encountering an issue where I see the following error message:
Disconnecting from node 1 due to request timeout
It seems like this error indicates a disconnection from the Kafka broker due to a request timeout. I’m looking to implement a mechanism to automatically handle disconnections and retry connecting to the Kafka cluster.
Could anyone provide advice or examples on how to configure Kafka with Spring to automatically attempt reconnection after a disconnection? I’m particularly interested in understanding how to set up retry logic or any relevant configurations that can help manage such scenarios more effectively.
Thank you in advance for your assistance!