Spring Cloud Stream Binder Kafka Broker不可用

vsaztqbk  于 2022-09-18  发布在  Spring
关注(0)|答案(1)|浏览(205)

我有一个Spring配置服务器应用程序,它在dev环境中与Kafka一起工作,但在本地环境中,我一直收到:

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

有没有办法在本地环境中启动应用程序,即使代理不可用并且没有获得警告日志?

所需的行为:如果代理不可用,应用程序不应该有明确的警告,应该继续工作。

我尝试将fatalIfBrokerNotAvailable设置为False,并将missingTopicsFatal设置为False,但没有任何效果。

68bkxrlz

68bkxrlz1#

不幸的是,Kafka客户端(由绑定器使用)没有任何API来获取代理的状态。因此,在不尝试连接的情况下无法确定状态。这些日志是由Kafka客户端代码发出的。

相关问题