如果代理地址不正确，Kafka 控制台生产者不会失败

Kafka console producer does not fail if broker address is incorrect

我运行以下命令（其中<incorrect port>是一个数字）：

bin/kafka-console-producer.sh --broker-list localhost:<incorrect port> --topic some-topic

而且这个过程没有失败，它继续进行，就好像没有任何问题一样

有没有办法在 kafka-console-producer.sh 启动时检查目标代理端口是否有代理在启动时监听该端口？

我在 osx 10.12.3

上使用 kafka 0.10.2.0

这是设计使然...生产者只是假设代理最终将在指定端口可用。但是，生产者应该在某个时候超时（IIRC 默认为 5 分钟）。您可以通过 request.timeout.ms 或 metadata.fetch.timeout.ms.

减少超时配置以更早地获取错误