将Avro消息推送到kafka主题
我正在尝试使用<strong> kafka-node-avro <...
在kafka主题中创建多个分区，并使用kafka-node将消息发布到所有分区
我是kafka的新手，并使用kafka-node在nodeJS中实现了...
在NodeJS中创建主题时，将领导者分配给kafka主题的分区
我只有一个kafka代理，并且正在使用kafka-node在nod...
在Node JS应用中使用Kafka Consumer来表示已进行计算
所以我的问题可能涉及基于应用程序性质的一些头脑风...
如何使消费者在Node.js中自动订阅动态创建的主题
关于stackoverflow本身有几个类似的问题，但我还是要...
Kafka分区更改的侦听器-Kafka节点
我目前正在使用Nodejs和Kafka，并且正在寻找一种方法...
在用Java编写的使用者中，Kafka节点是否具有与“ max.poll.records”选项类似的配置？
最近，我正在使用Kafka-node模块在nodeJS下编写一些...
Kakfa使用者甚至在提交相同主题的第一条消息之前正在处理下一条消息
我创建了一个连接器，将集合的所有插入/更新事件推送...
Kafka节点：将消费者添加到消费者组
因此，我有一个消费群体正在运行，并正在收听来自某...
Kafka从0.11升级到2.4后，重复的消息在Node.js端流动
Kafka消息在0.11版本上正常运行。现在，我们已将版...
我的kafka-node客户端仅从零分区读取消息
我有一个简单的kafka-node ConsumerGroup设置，如下...
卡夫卡节点不断断开连接，并重新连接“卡夫卡生产者错误：NestedError refreshBrokenMetadata”
nodejs服务器以pm2作为一个实例分支启动。 我的卡夫...
您如何使用AWS中的nodejs Lambda作为生产者来将消息发送到MSK主题而不创建EC2客户端服务器？
我正在尝试在AWS中创建一个Lambda，以充当MSK主题的...
Broker 不可用 (loadMetadataForTopics) - kafka 节点消费者
node 用于我的 nodejs 代码。我有一个用于请求/响应...