我是kafka的新手，并使用kafka-node在nodeJS中实现了它。我想在一个主题中创建3个分区，并同时将消息发布

我有一个简单的kafka-node ConsumerGroup设置，如下所示- <pre><code>&#39;use strict&#39;; const kafka = require(&#39;kafk

请原谅我对服务器和防火墙的了解有限。 我目前正在运行一个 Kafka（nodejs 实现，node-rdkafka）生产

我正在尝试使用 kafka-node 将我们的应用程序与 Kafka 集成。我从插件站点获取示例代码并尝试对其进行模

kafka-node地址：https://www.npmjs.com/package/kafka-node下面代码只是消费信息的constkafka=require("kafka-node");constClient=kafka.KafkaClient;constOffset=kafka.Offset;constConsumer=kafka.Consumer;functiontoKafka(){constclient=newClient({

我正在尝试使用<strong> kafka-node-avro </strong> 库可将数据推送到现有主题。 我已经使用curl和主题将

我只有一个kafka代理，并且正在使用kafka-node在nodeJS中实现kafka。我想创建一个包含3个分区的主题。在执

所以我的问题可能涉及基于应用程序性质的一些头脑风暴。 我有一个Node JS应用程序，可以将消息

关于stackoverflow本身有几个类似的问题，但我还是要再问一次，因为我想在<strong> NodeJS </strong>中找到解决

我目前正在使用Nodejs和Kafka，并且正在寻找一种方法来检测主题中分区数量的变化（当前使用<code>kafka-nod

最近，我正在使用Kafka-node模块在nodeJS下编写一些代码，并且我想控制每次使用的最大轮询数。在大多数

我创建了一个连接器，将集合的所有插入/更新事件推送到同一主题（1个分区）。用于处理插入事件消息

因此，我有一个消费群体正在运行，并正在收听来自某个主题的消息。如何将更多消费者实例添加到消

Kafka消息在0.11版本上正常运行。现在，我们已将版本从0.11升级到2.4。升级后，我们可以启动kafka，看不

nodejs服务器以pm2作为一个实例分支启动。 我的卡夫卡选项： <pre><code>export const kafkaTopics = [&#39;c

我正在尝试在AWS中创建一个Lambda，以充当MSK主题的生产者。所有的AWS文档都说要创建一个新的EC2实例，

node 用于我的 nodejs 代码。我有一个用于请求/响应的 api。 首先，我发出一个请求 <code>http://localhost:3000/nu

鉴于整个 kafka 管道相当繁重， 并且需要相当多的资源。 我想模拟一个话题， 以便我可以独立/单

我在 nodejs 中使用 kafka-node 模块。 我想确定主题是否存在。 var kafka = require('kafka-node'); 客户端 = 新

我想在节点上使用 kafka，并试图找出最适合使用的库。 我从 kafka-node 开始，但看起来 node-rdkafka 或