spring cloud alibaba stream RocketMQ use delay message is invalidation

[Lil-Kr]

spring cloud alibaba version

• alibaba version: 2.2.1.RELEASE
• spring-cloud-starter-stream-rocketmq: 2.2.1.RELEASE

yml properties

• Producer

  spring:
  cloud:
  stream:
    rocketmq:
      default:
        producer:
          vipChannelEnabled: false
      binder:
        name-server: 192.168.88.20:9876
    bindings:
      delay-output:
        producer:
          sync: true
        destination: stream-delay-topic
        group: delay-group

• Consumer

  spring:
  application:
  name: stream-server02-9011
  cloud:
  stream:
    rocketmq:
      default:
        producer:
          vipChannelEnabled: false
      binder:
        name-server: 192.168.88.20:9876
    bindings:
      delay-input:
        producer:
          sync: true
        destination: stream-delay-topic
        group: delay-group

code

• Producer

  @GetMapping("delay/{msg}")
  public String delay(@PathVariable("msg") String msg) {
      boolean msg1 = mySource1.delayOutput().send (
              MessageBuilder
                      .withPayload("延迟消息: " + msg)
                      .setHeader(MessageConst.PROPERTY_DELAY_TIME_LEVEL,"3") // 设置延迟级别为3, 10 秒后消费。
                      .setHeader(MessageConst.PROPERTY_TAGS,msg)
                      .build()
      );
  
      return String.valueOf(msg1);
  }

• Consumer

  
  @Slf4j
  public class ConsumerStream {
  
  @StreamListener(MySink.DELAY_INPUT)
  public void delay01(String msg) {
      log.info("延迟消费: {}", msg);
  }

}

the question is :  **ths delayed consumption is invalidation,  actual effect is immediately consume**

[zkzlx]

this question had been resolved in this pr #2013 . please use new version,there are many changes in the way of use. at present, there is no manual, please refer to the internal example.

com.alibaba.cloud spring-cloud-alibaba-dependencies 2.2.5.RocketMQ.RC2 pom

[Lil-Kr]

use to version:

Spring Cloud Version	Spring Cloud Alibaba Version	Spring Boot Version	spring-cloud-starter-stream-rocketmq	RocketMQ
Spring Cloud Hoxton.SR8	2.2.5.RELEASE	2.3.2.RELEASE	follow alibaba	4.7.x

all right? and..... What is the currently recommended version combination? Is it recommended to use RocketMQ in combination with Spring Cloud Stream?

[zkzlx]

use to version:

Spring Cloud Version Spring Cloud Alibaba Version Spring Boot Version spring-cloud-starter-stream-rocketmq RocketMQ Spring Cloud Hoxton.SR8 2.2.5.RELEASE 2.3.2.RELEASE follow alibaba 4.7.x all right? and..... What is the currently recommended version combination? Is it recommended to use RocketMQ in combination with Spring Cloud Stream?

2.2.5.RocketMQ.RC2 is a beta version, it needs to be manually replaced, the release version is still in preparation. you can see the new manual

[github-actions[bot]]

This issue has been open 30 days with no activity. This will be closed in 7 days.

[github-actions[bot]]

This issue has been automatically marked as stale because it hasn't had any recent activity.If you think this should still be open, or the problem still persists, just pop a reply in the comments and one of the maintainers will (try!) to follow up. Thank you for your interest and contribution to the Sping Cloud Alibaba Community.