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

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

Any question or RocketMQ proposal please use our mailing lists.

FEATURE REQUEST

1. Please describe the feature you are requesting.
   2.2.2版本添加了namespace配置，但是对于@RocketMQMessageListener，需要在每个注解中设置namespace，
   能否通过rocketmq.consumer.namespace设置默认的namespace？

2. Provid

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