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

描述

贡献者指南

技术栈

java

领域

backendcloud

议题类型

feature

难度面向新贡献者的预计实现难度，1 表示很小改动，5 表示专家级工作。

4

预计时间有经验贡献者完成调查、实现、测试并准备 pull request 的粗略时间范围。

3-5 days

活动状态议题当前的可参与程度：新鲜、活跃、陈旧、阻塞或等待维护者输入。

blocked

清晰度议题是否清楚说明期望改动、验收标准和下一步。

mostly clear

前置要求

JavaSpring Cloud StreamRocketMQ conceptsDistributed messaging

新手友好度1-100 的估计分数，表示该议题对首次贡献者的友好程度。

30

研究方向

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.