问题标签 [kafkajs]

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.

0 投票
0 回答
12 浏览

nestjs - 通过 NestJS 微服务模块使用 kafkaJS admin 客户端

如标题所示。是否有可能通过nestJS模块使用来自KafkaJS的管理客户端功能?我正在尝试通过 API 更详细地了解主题的创建。

0 投票
0 回答
8 浏览

apache-kafka - NestJS-Kafka 组 id 在我在代码中更新后没有改变

我正在使用 Kafka JS 连接到 kafka。在我的消费者中,最初我将我的组 id 命名为“orderable-test”,后来当我将此组 id 更新为“orderable-test-1”并重新运行我的代码时,组 id 仍然是“orderable-test”。即使我完全注释掉这个消费者并在不同的文件中编写另一个具有不同组 id 的消费者,它仍然给我这个“可订购测试”作为组 id 而不是新的。我想知道它的原因是什么,我该如何解决这个问题。

下面是我写的代码示例。