rocketmq

组件：
spring-cloud-starter-stream-rocketmq
问题版本：
2.2.7.RELEASE; 2021.0.1.0

问题详情：
stream-rocketmq 2.2.6.RELEASE 升级到 2.2.7.RELEASE 后，无法正常conmit offset

重现步骤：
1.运行的demo如下，使用 AcknowledgmentCallback.noAutoAck() 关闭自动ack，打印之后再 ack

 @Bean
    public ApplicationRunner poller(PollableMessageSource dest1In) {
        return args -> {
            while (true) {
                if (!dest1In.

Bump Junit4 to Junit5 can bring us a lot of benefits.

The issue tracker is ONLY used for bug report and feature request.

Any question or RocketMQ proposal please use our mailing lists.

BUG REPORT

1. Please describe the issue you observed:

• What did you do (The steps to reproduce)?

org.apache.rocketmq.connect.hudi.connector.HudiSinkConnector

defaultKeyValue.put(HudiConnec

In rockemq-client-go, many log use fmt to print. Now, we have rlog, maybe we should replace fmt to rlog?

What would you like to be added:
A Fault injection filter should provide configurable error injection capabilities, such as delay, error local reply. it is best to have more detailed routing-based configuration capabilities

Why is this needed:
Because this is the ability that is required in the testing phas