spring cloud stream rocketmq 确认ack

在 Spring Cloud Stream RocketMQ 中，消费者收到消息后需要进行确认（ack），以告知 RocketMQ 该消息已经被消费。确认可以使用手动确认或自动确认两种方式。

手动确认需要在配置文件中添加以下配置：

spring.cloud.stream.rocketmq.bindings.<channelName>.consumer.enable-auto-commit=false

然后在消费者中手动确认ack：

@EnableBinding(MyChannels.class)
public class MyConsumer {
    @StreamListener(MyChannels.INPUT)
    public void receiveMessage(String payload, @Headers MessageHeaders headers, Acknowledgment acknowledgment) {
        try {
            // 手动确认ack
            acknowledgment.acknowledge();
        } catch (Exception e) {
            // 处理异常
        }
    }
}

自动确认则需要在配置文件中添加以下配置：

spring.cloud.stream.rocketmq.bindings.<channelName>.consumer.enable-auto-commit=true

注意，自动确认可能会导致消息重复消费的情况，因此建议在一些重要的业务场景中使用手动确认。