我在解决一个应该很简单的kafka问题时遇到了一些困难。
我正在尝试从 kafka控制台生产者
发布一些消息。当我键入 'hi' 时,出现以下错误:
/opt/kafka/bin/kafka-console-producer.sh --topic test --broker-list 172.17.0.21:9092
hi
[2016-01-25 12:56:19,839] ERROR Error when sending message to topic test with key: null, value: 2 bytes with error: Batch Expired (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)
我似乎找不到任何kafka-log4j-logs...
我按照 快速入门 中所述的方式运行kafka服务器。
我可以创建主题并进行描述。
一个可能重要的注意事项是kafka和zookeeper在docker容器中运行(172.17.0.21
),我从主机创建主题并发送消息。
请注意,(kafka-server) 9092 和 (zk) 2181 端口都开放且可从主机访问,我使用 netstat 和 telnet 进行了确认。