alibaba/spring-cloud-alibaba

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

Open

#791 aberto em 31 de jul. de 2019

Ver no GitHub
 (24 comments) (2 reactions) (1 assignee)Java (29.106 stars) (8.513 forks)batch import
area/rocketmqcontribution welcomegood first issuekind/enhancement

Description

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

Guia do colaborador

Pilha de tecnologia
java
Domain
backendcloud
Tipo Issue
feature
DifficultyDificuldade de implementação estimada para um novo contribuidor, de 1 para alterações muito pequenas a 5 para trabalho de nível especializado.
4
Tempo estimadoUm intervalo de tempo aproximado para um colaborador experiente investigar, implementar, testar e preparar um pull request.
3-5 days
Status da atividadeQuão disponível o issue aparece agora: novo, ativo, obsoleto, bloqueado ou aguardando entrada do mantenedor.
blocked
ClarityCom que clareza o issue explica a mudança esperada, os critérios de aceitação e a próxima etapa.
mostly clear
Prerequisites
JavaSpring Cloud StreamRocketMQ conceptsDistributed messaging
Simpatia para novatosUma pontuação de 1 a 100 que estima o quão acessível este issue é para colaboradores iniciantes.
30
Direção de pesquisa
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.