问题标签 [kafka-node]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
node.js - 在 KafkaJS 中添加 keystore 和 truststore 配置
我正在尝试访问我们的 DevOps 团队创建的 Kafka 集群，但我无法访问它，因为我不知道如何在KafkaJS / Kafka-node
npm 中设置配置，我已经在 GitHub 上提出了这个问题但是不想在这个测试部分等待太多。我收到了来自 devops 团队的keyStore& JKS 文件和密码。trustStore
即使我尝试在没有此配置的情况下访问集群，我也会收到以下错误。
提前致谢！
node.js - 使用 kafka-node 在 javascript 中轮询 kafka 消费者
我想在消费者端实现消息轮询（消息数不是字节。）。我正在使用 nodejs 和 kafka-node 库。
apache-kafka - 无法使用 kafka-node 向 kafka Producer 发送消息
我正在使用 Kafka 框架提供的默认 server.properties/zookeeper.properties 文件。
我正在尝试创建一个简单的 NodeJS 应用程序，它将向 Producer 发送消息并使用它们。
下面是 NodeJS 代码。
配置.js
nodejs-producer.js
kafka 版本 = 2.8.0 kafka 节点版本 = 5.0.0
我收到错误消息 - 错误：LeaderNotAvailable
如何解决这个问题？我尝试在 server.properties 文件中使用不同的值，例如adverted.listeners，但没有得到解决方案。
node.js - 如何使用 kafka-node 从 Kafka 主题中删除消息
我创建了一个生产者和一个消费者，以使用“kafka-node”包发送和消费来自 Kafka 主题的消息。生产者和消费者通过 API 调用。POST 方法用于向主题发送消息，而 GET 方法用于从消费者的主题中获取消息。
当我在向 KAFKA 发送消息后调用消费者 API 时，之前的所有消息都在consumer.on('message', function(message){}).
我只需要从生产者发送的最后一条消息。
生产者.js
消费者.js
路由器.js
index.js
如何在不使用任何数组或任何东西的情况下获取最后一条消息。
有什么办法可以删除主题吗？
谢谢，
node.js - 如何使用 NodeJs 消费来自 Kafka 消费者的最新消息？
我创建了一个 NodeJS 应用程序来将数据插入到 MongoDB 集合中。此数据库插入是通过使用 Kafka 完成的。Kafka-node 是我用来调用 Kafka 的插件。
我可以创建主题并向生产者级别的消费者发送消息。消息和主题取自 POST 请求。
这就是我所说的卡夫卡。参数是主题和消息。
每次我调用此 API 时，生产者都会创建一条新消息并将其发送给消费者。在每次调用中，之前的所有消息都会返回给消费者。
我已经使用fromOffset: 'earliest'andfromOffset: 'latest'选项来限制以前的消息，但不起作用。
谁能给我一个建议？卡夫卡节点的版本
我用过的代码
谢谢，