spring-cloud-alibaba Sequential consumption and simultaneous consumption issues

ybzsozfc 于 4个月前发布在 Spring

关注(0)|答案(2)|浏览(123)

有两个问题请教一下：
1.在之前开源的rocketMq当中，是可以通过选择队列的方式让同一类型的消息实现顺序消费，现在这个SCS该如何操作实现顺序消费呢。
2.spring.cloud.stream.rocketmq.bindings..producer.sync和spring.cloud.stream.rocketmq.bindings..consumer.orderly是否需要一起配置呢

There are two questions to ask:

In the previous open source rocketMq, it is possible to order the same type of messages to achieve sequential consumption by selecting a queue. Now how does this SCS operate to achieve sequential consumption?
2.spring.cloud.stream.rocketmq.bindings..producer.sync and spring.cloud.stream.rocketmq.bindings..consumer.orderly need to be configured together?

spring-cloud-alibaba

来源：https://github.com/alibaba/spring-cloud-alibaba/issues/1046

2条答案

按热度按时间

h5qlskok1#

For Q1: need set partition key, refer PartitionSelectorStrategy & partition configuration items, make sure in the same message queue. It has been supported in 2.1.1, 2.0.1, 1.5.1 BUILD-SNAPSHOT version and we have released SNAPSHOT version in sonatype snapshot repository, RELEASE version will be release next week.

For Q2: yes, orderly should be true

赞(0）回复(0）举报 4个月前

mutmk8jj2#

我也实现了顺序消费和配置的版本在2.1.0中本来今天打算提交的发现了这个
非常期待2.1.1 版本

赞(0）回复(0）举报 4个月前