我正在尝试创建一个“警报”应用程序，它必须处理来自多个Kafka主题的信息。存在数千个主题，但实际上，根据警报配置，在任何给定时间只需要处理几百个主题。如果我不断用“订阅”更新我的主题列表，那么重新平衡的延迟可能会延迟我的警报。如何有效地实现订阅一组不断变化的主题的消费者组？
sshcrbum1#
我想说今天的答案是使用assign（）而不是subscribe，手动添加新的主题分区，根据需要删除任何未使用的分区。不过，退一步问一下，如果主题的数量是静态的，并通过键识别要监视的对象，是否更有意义，对您可能会有所帮助。那会让你的生活更轻松。
1条答案
按热度按时间sshcrbum1#
我想说今天的答案是使用assign（）而不是subscribe，手动添加新的主题分区，根据需要删除任何未使用的分区。不过，退一步问一下，如果主题的数量是静态的，并通过键识别要监视的对象，是否更有意义，对您可能会有所帮助。那会让你的生活更轻松。