我在困难的时间进行故障排除,应该是一个简单的卡夫卡问题.
我试图从kafak-console-producer发布一些消息.当我输入“嗨”我得到：
/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日志…
我在quick-start中描述的方式运行kafka服务器
我可以创建主题&形容它.
一个可能重要的一点是,卡夫卡& zookeeper正在docker-container中运行(172.17.0.21)我正在创建主题并从主机发送消息.
请注意(kafka-server)9092& (zk)2181是开放的,可以从主机访问,我已经使用netstat&远程登录.
最佳答案
