rocketmq

Which Component
spring-cloud-starter-stream-rocketmq

Describe the bug
When hot deployment in eclipse throw MQClientException: The producer group[mygroup] has been created before

To Reproduce
Steps to reproduce the behavior:

1. Spring boot application with devtools in Eclipse
2. Send message using org.springframework.cloud.stream.function.StreamBridge.send
3. Modify any cod

Currently, some methods in PlainPermissionManager do not have the corresponding test case in PlainPermissionManagerTest. such as
createAclAccessConfigMap, updateAclConfigFileVersion, updateGlobalWhiteAddrsConfig, deleteAccessConfig.
Does anyone want to fulfill it?

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

When I use RocketMQMessageListener annotation to enable broadcast mode, I find that the local save offset generates a different folder each time, and each folder suffix has a time stamp. After restart, I cannot read the last saved file, so I cannot consume the previously unconsumed data.

在pkg/adapter/dubboregistry/registry/listener.go里面有

type Listener interface {
Close()
WatchAndHandle()
}

在pkg/remote/zookeeper/client.go也有

type Listener interface {
Close()
WatchAndHandle()
}