我们今天遇到一个问题，Kakfa 消费者无法连接到任何代理，并且日志中没有错误消息。它无法连接，因为它是通过 SSL 连接的，并且指向错误的信任库。但是，尽管在这种情况下是由于 SSL 故障，但我已经看到其他情况下消费者无法连接，并且日志中没有错误消息。
有没有办法配置 Kafka 消费者，以便在消费者无法连接到代理时记录错误消息？我正在寻找一种通用解决方案，而不是特定于 SSL 连接问题。
(我们正在使用:org.apache.kafka:kafka-clients:0.9.0.1 和 org.springframework.kafka:spring-kafka:1.0.4.RELEASE)
最佳答案
- 考虑将您的客户端升级到较新版本的
kafka-clients(在更高版本中，一些操作如seek开始抛出而不是挂起 - 这会让您知道问题更快) - 设置 log4j，尤其是
org.apache.kafka.clients.NetworkClient类(如果找不到代理，它会记录) - 考虑配置
default.api.timeout.ms或旧版本metadata.fetch.timeout.ms以更快地超时
关于apache-kafka - Kafka 消费者无提示连接到代理失败，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/53190995/