我希望在使用KafkaJS从Kafka topic进行消费的同时实现retry逻辑,因此基本上,我将有两个主题main-topic和retry-topic,我将读取自-〉main-topic如果处理失败|- 〉retry topic因此,使用一个consumer来监听两个主题(main和retry)是不是一个糟糕的做法,因为kafka允许使用同一个消费者监听多个主题。
Kafka topic
retry
main-topic
retry-topic
retry topic
consumer
main
kafka
xuo3flqw1#
这一点也不坏。使用一个使用者可能遇到的唯一问题是主题可能需要不同的配置(连接设置、反序列化程序等)。在这种情况下,可以创建两个单独的使用者示例,而不是一个示例同时订阅两个示例。
1条答案
按热度按时间xuo3flqw1#
这一点也不坏。
使用一个使用者可能遇到的唯一问题是主题可能需要不同的配置(连接设置、反序列化程序等)。在这种情况下,可以创建两个单独的使用者示例,而不是一个示例同时订阅两个示例。