apache / apache/rocketmq-connect
if connector restart, if will lose data.
Open
- Dominant language
- Java
- Stars
- 141
- Forks
- 120
- PR merge metrics
- No merged PRs in 30d
Description
Because consumer data into blockingQueue, if connector restart, it will lose data.
https://github.com/apache/rocketmq-connect/blob/85da68c92f599f0a289c0e63de919ca417289f69/connectors/aliyun/rocketmq-connect-rocketmq/src/main/java/org/apache/rocketmq/connect/rocketmq/RocketMQSourceTask.java#L112C43-L112C56
Contributor guide
Assessment
This issue has not been assessed yet.