我们今天遇到了一个问题，一个kakfa消费者无法连接到任何代理，并且日志中没有错误消息。它无法连接，因为它是通过ssl连接的，并且指向错误的信任库。但是，尽管在本例中是由于ssl失败造成的，但我也看到过其他情况，消费者无法连接，并且日志中没有错误消息。
有没有办法配置kafka使用者，以便在使用者无法连接到代理时记录错误消息？我正在寻找一个通用的解决方案，而不是特定的ssl连接问题。
（我们使用： org.apache.kafka:kafka-clients:0.9.0.1 以及 org.springframework.kafka:spring-kafka:1.0.4.RELEASE )
1条答案
按热度按时间pvabu6sv1#
考虑将客户端升级到更新版本的
kafka-clients（在以后的版本中，有些操作seek开始投掷而不是悬挂-这会让你更快地了解问题）设置log4j，尤其是
org.apache.kafka.clients.NetworkClient类（如果找不到代理，则记录）考虑配置
default.api.timeout.ms或者在旧版本中metadata.fetch.timeout.ms更快地暂停