alibaba/spring-cloud-alibaba

spring-cloud-starter-stream-rocketmq期望支持阿里云RocketMQ定时消息(不是延时消息)

Open

Aperta il 31 lug 2019

Vedi su GitHub
 (24 commenti) (2 reazioni) (1 assegnatario)Java (29.106 star) (8513 fork)batch import
area/rocketmqcontribution welcomegood first issuekind/enhancement

Descrizione

现象：使用ONS连接阿里云RocketMq，可支持阿里云RocketMQ定时消息(不是延时消息) ，使用rocketmq stream binder则不能支持，只能支持到延时消息 。

Guida contributor

Tech stack
java
Dominio
backendcloud
Tipo issue
feature
DifficoltàQuanto dovrebbe essere impegnativa per un nuovo contributor.
4
Tempo stimatoTempo stimato per completare e verificare uno scope piccolo.
3-5 days
Stato attivitàQuanto è probabile che la issue sia ancora attiva e reviewable.
blocked
ChiarezzaQuanto chiaramente la issue descrive problema, scope e risultato atteso.
mostly clear
Prerequisiti
JavaSpring Cloud StreamRocketMQ conceptsDistributed messaging
Adatta ai principiantiQuanto la issue è adatta a contributor alla prima esperienza.
30
Direzione di ricerca
The issue requests support for scheduled messages (not just delay messages) in the RocketMQ stream binder. Currently, the binder only supports delay messages via the RocketMQ native API. To implement, one should examine the RocketMQ client SDK's scheduled message API (e.g., using `setStartDeliverTime` with a future timestamp). The ONS client already supports this; the binder's ONS implementation can be used as reference. Key files to modify are likely in the `spring cloud stream binder rocketmq` directory, particularly the producer configuration. The existing comments and assigned maintainer may provide further guidance.