stackoverflow 本身有几个类似的问题,但我仍然要再次询问,因为我想要NodeJS中的解决方案。
情景是——
(我正在使用 kafkaJS 库)
我有两个主题 topic-A 和 topic-B,所以我订阅/topic-.*/,然后创建 topic-C,现在我希望我的消费者也自动订阅 topic-c。但这并没有发生。
我只得到一个解决方案,即我必须在每个新主题创建后停止我的消费者并重新启动它。(但是当多个主题将动态创建时,这种方法似乎很难维护)。
任何人都可以通过示例向我建议任何其他解决方案。先感谢您。