如何实现仅单个应用实例接收AMQP主题消息，达成Kafka消费者组效果

问题描述 #

我使用Apache Camel的AMQP组件监听来自ActiveMQ Artemis主题的消息。
该应用部署在Kubernetes上，共运行2个副本。
我配置了持久订阅，每个Pod使用唯一的clientId，并设置了统一的订阅名称，配置如下：

<route autoStartup=true" id="myRoute">
    <from id="_amqp_topic" uri="amqp:topic:xxx?connectionFactory=#amqpCF&amp;disableReplyTo=true&amp;transacted=false&amp;subscriptionDurable=true&amp;clientId={{container-id}}&amp;durableSubscriptionName=eventSubscription"/>
    <log loggingLevel="INFO" message="Received event: ${body}"/>
    ...
</route>

当前遇到的问题是两个Pod都会接收到同一条消息，但预期仅其中一个Pod接收。我想要实现类似Kafka的消费者组的效果，即同组内仅一个成员接收每条消息。

问题根因 #

你当前的配置逻辑本身就会导致所有副本都收到同一条消息：ActiveMQ Artemis的独立持久订阅是与clientId+持久订阅名称唯一绑定的，你给每个Pod配置了唯一的clientId，就算使用相同的订阅名称，服务端也会识别为两个完全独立的订阅，每条主题消息会分别投递给这两个订阅，自然两个Pod都会收到消息。

解决方案 #

要实现类似Kafka消费者组的同组负载均衡效果，有两种常用方案：

• 方案一：使用共享持久订阅（推荐，无需修改主题发布逻辑）
  ActiveMQ Artemis支持AMQP 1.0的共享持久订阅特性，同个订阅名称下可以挂载多个消费者，消息会按轮询策略分发给不同消费者，同一条消息只会被其中一个消费者处理。
  你只需要修改AMQP端点的配置即可：

1. 去掉clientId的唯一值配置，改为统一的固定值（也可以直接删除clientId参数，大部分场景下共享订阅不需要强制唯一clientId）
2. 新增参数subscriptionShared=true开启共享订阅
   修改后的配置示例如下：

<route autoStartup="true" id="myRoute">
    <from id="_amqp_topic" uri="amqp:topic:xxx?connectionFactory=#amqpCF&amp;disableReplyTo=true&amp;transacted=false&amp;subscriptionDurable=true&amp;clientId=my-service-group&amp;subscriptionShared=true&amp;durableSubscriptionName=eventSubscription"/>
    <log loggingLevel="INFO" message="Received event: ${body}"/>
    ...
</route>

注意：修改配置前需要先删除Artemis上之前创建的两个旧独立持久订阅，避免旧订阅残留持续累积消息。

• 方案二：改用点对点队列模式
  如果你的业务场景允许修改消息投递的地址类型，直接将主题改为ANYCAST类型的队列，所有副本都监听同一个队列，天然就是单条消息仅被一个消费者消费的逻辑，无需额外的订阅配置。

内容的提问来源于stack exchange，提问作者codependent