Spring-Boot and Kafka : How to handle broker not available?

6
votes

While the spring-boot app is running and if I shutdown the broker completely ( both kafka and zookeeper ) I am seeing this warn in console for infinite amount of time.

[org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] WARN o.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-1, groupId=ResponseReceiveConsumerGroup] Connection to node 2147483647 could not be established. Broker may not be available.

Is there a way in Spring Boot to handle this gracefully instead of infinite logs on console ?

1
javaspringspring-bootapache-kafkaspring-kafka
I believe those are kafka library logs, when consumer or producer starts it will try to identify brokers for every time intervals – Deadpool
Increase the reconnect.backoff.ms. – Gary Russell

1 Answers

2
votes

Increase the reconnect.backoff.ms property (see Kafka docs).

The default is only 50ms.