关于 spring-cloud-starter-stream-rocketmq 2.2.3.RELEASE 版本 BindingProperties#consumer#multiplex 属性支持情况。 · alibaba/spring-cloud-alibaba#1999

(1 comment) (0 reactions) (0 assignees)Java (29,106 stars) (8,513 forks)batch import

area/rocketmqcontribution welcomegood first issuekind/enhancement

説明

关于 spring-cloud-starter-stream-rocketmq 2.2.3.RELEASE 版本 BindingProperties#consumer#multiplex 属性支持情况. 看了spring-cloud-stream multiplex属性介绍，就是为了支持让单个消费组支持订阅多个Topic 而定义的一个标准. 是否有计划支持此属性？目前只能单个消费组对应单个Topic，这种还是会造成很大程度的资源浪费，而且也不太灵活.

RocketMq 本身不就支持同一个ProductGroup 下可以发送普通消息，延迟消息，顺序消息，无非事务消息因为要回查所以需要单独配置一个唯一的ProductGroup；同理同一个ConsumerGroup 订阅消息时，普通消息、延迟消息、事务消息都可以是同一个消费组，但是顺序消息因为要保证顺序所以需要单独使用ConsumeMessageOrderlyService,所以一般都是顺序消息单独一个消费组。

为什么 spring-cloud-starter-stream-rocketmq 还要延续RocketMq-Spring 这种不合理的模式呢(1个组对应 1个Topic)?请教一下!

下图红框的地方，改造一下不就可以支持了吗？(topic 和 bysql || tags )

2021-03-17_003334

コントリビューターガイド

技術スタック: java
領域: backendcloud
Issue 種別: feature
難度: 4
推定時間: 1-2 days
活動状況: stale
明確さ: mostly clear
前提条件: Basic understanding of Spring Cloud StreamKnowledge of Apache RocketMQ
初心者向け度: 20
調査方針: This issue requests support for the 'multiplex' property in BindingProperties#consumer of spring cloud stream rocketmq. The current implementation maps one consumer group to one topic. To implement this, examine the source code for consumer binding configuration in the spring cloud alibaba repository, specifically the RocketMQ binder module. Modify the binding logic to allow a single consumer group to subscribe to multiple topics, as defined by the multiplex property. Review the existing configuration classes and the consumer creation process to introduce support for a list of topics per binding.