apache-kafka - 与运行 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 毫秒加上逗留时间
任何想法 ?
解决方案
我有一个类似的问题,我解决了它从控制台测试kafka,如下所示:
创建主题:bin/kafka-topics.sh --zookeeper zooker-domain:2181 --create --topic test --replication-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 --新消费者 --topic 测试 --from-beginning --bootstrap-server kafka-domain:9092 --partition 0
(而不是域,您可以直接使用 IP)。
我用 kafka 0.11.0.1 对其进行了测试,它可以工作。
如果您仍然有问题,请尝试:https ://stackoverflow.com/a/51071306/2493852
推荐阅读
- python - ValueError: Solver lbfgs 仅支持“l2”或“none”惩罚,得到 l1 惩罚
- c++ - 如何初始化双指针字符数组,如下所示?
- c++ - #define ANSWERSIZE 5 中的“数字常量之前的预期不合格 ID”
- css - 如何使用 Ant Design 制作响应式网格?
- reactjs - React JS 中的内联样式函数中的 if 语句
- javascript - Apollo 服务器 2.0 不能与 join-monster-graphql-tools-adapter 和 oracle 一起使用
- modelica - URI 到文件的映射
- git - git push 同一命名空间中的分支
- python - Folium TypeError:输入类型不支持 ufunc 'isnan'
- angular - ReferenceError:元素未定义 Angular Fullcalendar