3

stackoverflow 本身有几个类似的问题,但我仍然要再次询问,因为我想要NodeJS中的解决方案。

情景是——

(我正在使用 kafkaJS 库)

我有两个主题 topic-A 和 topic-B,所以我订阅/topic-.*/,然后创建 topic-C,现在我希望我的消费者也自动订阅 topic-c。但这并没有发生。

我只得到一个解决方案,即我必须在每个新主题创建后停止我的消费者并重新启动它。(但是当多个主题将动态创建时,这种方法似乎很难维护)。

任何人都可以通过示例向我建议任何其他解决方案。先感谢您。

4

0 回答 0