KafkaJS使用一个消费者从多个主题消费

kxxlusnw  于 2022-12-26  发布在  Apache
关注(0)|答案(1)|浏览(122)

我希望在使用KafkaJSKafka topic进行消费的同时实现retry逻辑,因此基本上,我将有两个主题main-topicretry-topic,我将
读取自-〉main-topic
如果处理失败|- 〉retry topic
因此,使用一个consumer来监听两个主题(mainretry)是不是一个糟糕的做法,因为kafka允许使用同一个消费者监听多个主题。

xuo3flqw

xuo3flqw1#

这一点也不坏。
使用一个使用者可能遇到的唯一问题是主题可能需要不同的配置(连接设置、反序列化程序等)。在这种情况下,可以创建两个单独的使用者示例,而不是一个示例同时订阅两个示例。

相关问题