首页 > 解决方案 > 与运行 Windows 子系统的 Kafka 的连接超时

问题描述

我已经在我的 Windows 10 笔记本电脑上的 Windows SubSystem for Linux 下安装了带有 Zookeeper 3.4.12 的 Kafka 1.1.0。当我留在 ubuntu 中时,我能够生成和使用消息,但是当我想从 Windows 生成消息时(使用 java 程序或工具 kafka-console-producer.bat)我有以下错误:

[2018-05-11 15:31:01,449] ERROR 向主题测试发送消息时出错,键:null,值:15 字节,错误:(org.apache.kafka.clients.producer.internals.ErrorLoggingCallback) org.apache .kafka.common.errors.TimeoutException:test-0 的 1 条记录过期:自批处理创建以来已经过去了 1534 毫秒加上逗留时间

任何想法 ?

标签: apache-kafkakafka-producer-api

解决方案


我有一个类似的问题,我解决了它从控制台测试kafka,如下所示:

  1. 创建主题:bin/kafka-topics.sh --zookeeper zooker-domain:2181 --create --topic test --replication-factor 1 --partitions 1

  2. 插入消息:bin/kafka-console-producer.sh --broker-list kafka-domain:9092 --topic test

  3. 消费消息:(旧 api)bin/kafka-console-consumer.sh --zookeeper zookeeper-domain:2181 --topic test --from-beginning
    (或使用新 api)bin/kafka-console-consumer.sh --新消费者 --topic 测试 --from-beginning --bootstrap-server kafka-domain:9092 --partition 0

(而不是域,您可以直接使用 IP)。

我用 kafka 0.11.0.1 对其进行了测试,它可以工作。

如果您仍然有问题,请尝试:https ://stackoverflow.com/a/51071306/2493852


推荐阅读