在一个场景中，我有n个使用者（所有使用者都有一个流/没有分区），每个使用者都订阅了一组单独的主题，如何处理生产者添加的新主题？我应该为每个添加的主题创建新的使用者吗？或者我可以将此主题添加到已经工作的消费者中吗(怎么做？）或者最好保持1个消费者组有n个消费者，而不在n个消费者（流）之间划分主题？
p1iqtdky1#
如前所述，在同一消费群体的消费者之间划分主题的初始配置一点也不好。消费者将无法彼此故障切换，因为他们有不同的主题列表。Kafka将发布不必要的重新平衡。您不需要为每个添加的主题添加使用者—最好从一开始就使用所有此类主题，将它们添加到/mytopics这样的公共路径中/*最好按分区划分主题，如果需要，可以添加新分区。这将是透明的，不需要努力。
1条答案
按热度按时间p1iqtdky1#
如前所述，在同一消费群体的消费者之间划分主题的初始配置一点也不好。消费者将无法彼此故障切换，因为他们有不同的主题列表。Kafka将发布不必要的重新平衡。
您不需要为每个添加的主题添加使用者—最好从一开始就使用所有此类主题，将它们添加到/mytopics这样的公共路径中/*
最好按分区划分主题，如果需要，可以添加新分区。这将是透明的，不需要努力。