首页 文章

使用Windows子系统运行的Kafka的连接超时

提问于
浏览
1

我在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 回答

  • 0

    我有一个类似的问题,我解决了它从控制台测试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

相关问题