我在Windows 10笔记本电脑上的Windows SubSystem for Linux下安装了Kafka 1.1.0和Zookeeper 3.4.12 . 我能够在我停留在ubuntu时生成和消费消息,但是当我想从windows(使用java程序或使用工具kafka-console-producer.bat)生成消息时,我有以下错误:
[2018-05-11 15:31:01,449] ERROR使用key发送消息到主题测试时出错:null,值:15个字节,带错误:(org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)org.apache .kafka.common.errors.TimeoutException:对于test-0过期1条记录:自批量创建加上停留时间以来已经过去了1534毫秒
任何的想法 ?
1 回答
我有一个类似的问题,我解决了它从控制台测试kafka像这样:
创建主题:bin / kafka-topics.sh --zookeeper zooker-domain:2181 --create --topic test --rerelication-factor 1 --partitions 1
插入消息:bin / kafka-console-producer.sh --broker-list kafka-domain:9092 - topic test
消费消息:(旧api)bin / kafka-console-consumer.sh --zookeeper zookeeper-domain:2181 - topic test --from-beginning
(或使用新的api)bin / kafka-console-consumer.sh --new-consumer --topic test --from-beginning --bootstrap-server kafka-domain:9092 --partition 0
(而不是可以直接使用IP的域) .
我用kafka 0.11.0.1测试了它,它的工作原理 .
如果您仍有问题请尝试:https://stackoverflow.com/a/51071306/2493852