我正在尝试使用Kafka控制台生成器将消息发送到在同一台计算机上运行的Kafka代理.我跑的时候
echo "Hello world" | ./kafka-console-producer.sh --broker-list localhost:9092 --topic test
我收到以下错误消息:
[2016-06-29 15:00:44,069] ERROR Error when sending message to topic test with key: null, value: 11 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)
org.apache.kafka.common.errors.TimeoutException: Batch containing 1 record(s) expired due to timeout while requesting metadata from brokers for test-0
当我检查Kafka代理是否正在侦听端口9092时,它就在那里并且正在运行.如何调试为什么命令行生产者不能连接到代理？谢谢!
apache-kafka ×1