如何与ActiveMQ队列一样实现kafka？

问题描述

如果我们有一个ActiveMQ队列的使用者1和使用者2，则不会将相同的消息传递给这两个使用者。它会像向消费者1传递一组消息，向消费者2传递另一组消息一样。春季我们将如何使用Apache Kafka做同样的事情？

解决方法

请了解更多什么是Apache Kafka及其偏移管理如何工作。使用这种架构，您要问的是不可能的：我们必须保留偏移量的顺序，因此组中只有一个使用者要处理来自同一分区的所有消息。

您可以在同一组中有两个使用者，在同一主题中有两个分区，但是只有一个使用者要从一个分区读取。您将永远不会像ActiveMQ队列那样出现循环行为。