我有一个将消息写入主题/分区的生产者。为了保持顺序,我想使用单个分区,并且我希望 12 个消费者读取该单个分区中的所有消息(没有消费者组,所有消息都应该发送给所有消费者)。这是可以实现的吗?我读过一些论坛,每个分区只有一个消费者可以阅读。
您可以使用SimpleConsumer
为了准确实现您的要求 - 没有消费者组,所有消费者都可以读取单个分区。然而,这种方法意味着您必须自己处理偏移量存储和代理故障处理。
另一种选择是将高级消费者与不同的消费者组一起使用(您可以为每个消费者分配一个随机的 UUID)。这样,您将能够与所有消费者一起使用一个主题/分区,并能够提交偏移量并处理代理中断。
“只有单个消费者可以消费主题/分区”的规则仅适用于消费者组,例如只有一个消费者 IN GROUP 可以同时消费一个主题/分区。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)