当我尝试创建一个新的 KafkaClient 时，我必须指定我的节点的IP和Node.js上的端口2181 .
KafkaClient
我正在通过Kafka对我的数据库进行大量插入，每次我让它一夜之间运行我得到 CONNECTION_LOSS[-4] 错误，这必须与Zookeeper有关 .
CONNECTION_LOSS[-4]
在其他语言中，Kafka端口9092适用于 生产环境 /消费，而不是 Node.js .
Node.js
如何解决此问题并避免这些连接错误，并使用端口9092而不是2181？
您使用的是什么版本的Kafka？
在0.9.0之前，需要从消费者到Zookeeper的连接，因为消费者使用Zookeeper来保存偏移量 .
从 0.9.0 开始，偏移量保存在名为 __consumer_offsets 的特定主题中，因此客户端需要的唯一连接是您正在讨论的端口_2539835上的Kafka代理（引导程序） .
0.9.0
__consumer_offsets
在任何情况下都要记住，Kafka需要在端口 2181 上的Zookeeper上进行连接以执行所有其他操作（控制器选举，主题信息等） .
2181
这不是关于使用端口 9092 而不是 2181 .
9092
1 回答
您使用的是什么版本的Kafka？
在0.9.0之前，需要从消费者到Zookeeper的连接，因为消费者使用Zookeeper来保存偏移量 .
从
0.9.0开始，偏移量保存在名为__consumer_offsets的特定主题中，因此客户端需要的唯一连接是您正在讨论的端口_2539835上的Kafka代理（引导程序） .在任何情况下都要记住，Kafka需要在端口
2181上的Zookeeper上进行连接以执行所有其他操作（控制器选举，主题信息等） .这不是关于使用端口
9092而不是2181.