tencent cloud

        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-stream-rocketmq</artifactId>
            <version>2021.0.5.0</version>
           <exclusions>    
             <exclusion>        
                 <groupId>org.apache.rocketmq</groupId>        
                 <artifactId>rocketmq-client</artifactId>    
             </exclusion>    
             <exclusion>        
                 <groupId>org.apache.rocketmq</groupId>        
                 <artifactId>rocketmq-acl</artifactId>    
              </exclusion>
           </exclusions>
        </dependency>
        <dependency>    
            <groupId>org.apache.rocketmq</groupId>    
            <artifactId>rocketmq-client</artifactId>    
            <version>4.9.7</version>
        </dependency>
        <dependency>    
            <groupId>org.apache.rocketmq</groupId>    
            <artifactId>rocketmq-acl</artifactId>    
            <version>4.9.7</version>
        </dependency>

spring:
  cloud:
    stream:
      rocketmq:
        binder:
          # Full name of the service address
          name-server: rmq-xxx.rocketmq.ap-bj.public.tencenttdmq.com:8080
          # Role name
          secret-key: admin
          # Role key
          access-key: eyJrZXlJZ...
          # producer group
          group: producerGroup
        bindings:
          # Channel name, corresponding to the channel name under spring.cloud.stream.bindings
          Topic-TAG1-Input:
            consumer:
              # Subscribed tag type, configured according to real consumer conditions (all messages are subscribed to by default)
              subscription: TAG1
          # Channel name
          Topic-TAG2-Input:
            consumer:
              subscription: TAG2
      bindings:
        # Channel name
        Topic-send-Output:
          # Specify topic, corresponding to the created topic name
          destination: TopicTest
          content-type: application/json
        # Channel name
        Topic-TAG1-Input:
          destination: TopicTest
          content-type: application/json
          group: consumer-group1
        # Channel name
        Topic-TAG2-Input:
          destination: TopicTest
          content-type: application/json
          group: consumer-group2

spring:
     cloud:
       stream:
         rocketmq:
           bindings:
             # Channel name, corresponding to the channel name under spring.cloud.stream.bindings
             Topic-test1:
               consumer:
                 # Subscribed tag type, configured according to real consumer conditions (all messages are subscribed to by default)
                 tags: TAG1
             # Channel name
             Topic-test2:
               consumer:
                 tags: TAG2
           binder:
             # Full name of the service address
             name-server: rocketmq-xxx.rocketmq.ap-bj.public.tencenttdmq.com:8080
             # Role name
             secret-key: admin
             # Role key
             access-key: eyJrZXlJZ...
         bindings:
           # Channel name
           Topic-send:
             # Specified topic 
             destination: topic1
             content-type: application/json
             # Use the full name of the group
             group: group1
           # Channel name
           Topic-test1:
             destination: topic1
             content-type: application/json
             group: group1
           # Channel name
           Topic-test2:
             destination: topic1
             content-type: application/json
             group: group2

/**
 * Custom channel binder
 */
public interface CustomChannelBinder {

    /**
     * Send the message (message producer)
     * Bind the channel name specified in the configuration settings.
     */
    @Output("Topic-send-Output")
    MessageChannel sendChannel();


    /**
     * Receive Message 1 (Consumer 1)
     * Bind the channel name specified in the configuration settings.
     */
    @Input("Topic-TAG1-Input")
    MessageChannel testInputChannel1();

    /**
     * Receive Message 2 (Consumer 2)
     * Bind the channel name specified in the configuration settings.
     */
    @Input("Topic-TAG2-Input")
    MessageChannel testInputChannel2();
}


@EnableBinding({CustomChannelBinder.class})

@Service
public class StreamConsumer {
    private final Logger logger = LoggerFactory.getLogger(StreamDemoApplication.class);

    /**
     * Monitor channel (designated by channel name in configuration)
     *
     * @param messageBody message content
     */
    @StreamListener("Topic-TAG1-Input")
    public void receive(String messageBody) {
        logger.info("Receive1: Message received via stream, messageBody = {}", messageBody);
    }

    /**
     * Monitor channel (designated by channel name in configuration)
     *
     * @param messageBody message content
     */
    @StreamListener("Topic-TAG2-Input")
    public void receive2(String messageBody) {
        logger.info("Receive2: Message received via stream, messageBody = {}", messageBody);
    }
}

2023-02-23 19:19:00.441  INFO 21958 --- [nio-8080-exec-1] c.t.d.s.controller.StreamController      : Send: Message sent via stream, messageBody = GenericMessage [payload={"key":"value"}, headers={id=3f28bc70-da07-b966-a922-14a17642c9c4, timestamp=1677151140353}]
2023-02-23 19:19:01.138  INFO 21958 --- [nsumer-group1_1] c.t.d.s.StreamDemoApplication            : Receive1: Message received via stream, messageBody = {"headers":{"id":"3f28bc70-da07-b966-a922-14a17642c9c4","timestamp":1677151140353},"payload":{"key":"value"}}