我有一个Spring配置服务器应用程序,它在dev环境中与Kafka一起工作,但在本地环境中,我一直收到:
{host} could not be established. Broker may not be available.
有没有办法在本地环境中启动应用程序,即使代理不可用并且没有获得警告日志?
所需的行为:如果代理不可用,应用程序不应该有明确的警告,应该继续工作。
我尝试将fatalIfBrokerNotAvailable
设置为False,并将missingTopicsFatal
设置为False,但没有任何效果。
1条答案
按热度按时间68bkxrlz1#
不幸的是,Kafka客户端(由绑定器使用)没有任何API来获取代理的状态。因此,在不尝试连接的情况下无法确定状态。这些日志是由Kafka客户端代码发出的。