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

2022 Alibaba Summer of Code

Welcome to the open source world! If you haven't planned how to spend this summer, come to the Alibaba Summer of Code and coding with us! 💻

Alibaba Summer of Code is a global program focused on engaging students directly in open source software development. Under the guidance of the mentor in the Alibaba open source project, students can experience software dev

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()
}