Spring Cloud Stream Binder Kafka broker is not available

Евгения Гребенюк 0
Viewed 37

I have a Spring Config Server application which is working with Kafka in dev environment but in local environment I keep getting:

{host} could not be established. Broker may not be available.

Is there any way to start the application in local environment even if the broker is not available and not get the warning logs?

The desired behaviour: If broker is not available, application should not have explicit warnings and should continue working.

I have tried to set fatalIfBrokerNotAvailable to false and missingTopicsFatal to false but it does not have any effect.

spring-cloud-stream-binder-kafka spring-cloud-stream apache-kafka spring
1 Answers

Unfortunately, the kafka-clients (used by the binder) does not have any API to get the status of the broker(s). So there is no way to determine the state without trying to connect. Those logs are emitted by the kafka-clients code.

Gary Russell0
Related