卡夫卡控制台生产者不失败

Question

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

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

而且犯规失败的过程中，它会继续仿佛什么是错的

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

我使用的是卡夫卡0.10.2.0在OSX 10.12.3

Answer 1

这是由设计...制片只是假定，该券商将获得可在指定的端口最终。但是，制片人应该在某个时间点超时（IIRC默认为5分钟）。您可以通过request.timeout.ms或metadata.fetch.timeout.ms减少超时配置以获取错误。