apache / apache/rocketmq-connect
rocketmq-replicator optimization
- Dominant language
- Java
- Stars
- 141
- Forks
- 120
- PR merge metrics
- No merged PRs in 30d
Description
After rocketmq-replicator adapt to the new conenct api merge, the pull code is run and the following problems are found:
Fixed:
1. The message content is inconsistent. The message content after synchronization is {"MessageExt": "original message content "}
2. Message attributes are not synchronized
Function:
1. When synchronizing messages from the source cluster to the target cluster, we can define filtering rules to synchronize only the filtered messages
Optimization:
1. Keep replicator and Runtime versions of some of the same dependencies the same to prevent conflicts
replicator适配了新的connect api合并后,拉取代码运行了下,主要发现以下几点问题:
修复:
1.消息同步内容不一致,同步后的消息内容为{"MessageExt": "原消息内容"}
2.消息属性没有同步
功能:
1.源和目标集群消息同步时,可以定义过滤规则,只同步过滤后的消息
优化:
1.保持replicator和runtime中的一些相同依赖包版本相同,防止冲突
Contributor guide
Assessment
This issue has not been assessed yet.