我有200个Kafka用户,他们可以做这些事情中的任何一个,1.他们可以订阅200个不同的主题,并将消费敏感的消息。2.所有200个消费者可以订阅单个topic。
问题: 1.创建200个或更多的topic是一个好的设计吗? 2.在第二个场景中,我们如何实现发布到topic的消息只根据某个参数发送给特定的消费者。
发布于 2020-04-09 13:20:28
Kafka将复制文件用于主题,由于它使用基于偏移量的消息传输,主题数量对性能没有直接影响,因此这不是问题。
你不能基于一个参数来做到这一点,如果你需要将一条消息传递给一个消费者,那么你需要将所有消费者分组到一个消费者组中,并让整个组都收听一个主题。这样,消息将只由该消费者组中的一个消费者使用。
如果您需要顺序(有序)消息消费,那么您只需要创建一个分区的Kafka主题。
https://stackoverflow.com/questions/61114209
复制相似问题