apache / apache/rocketmq-connect

rocketmq-replicator optimization

Open
#132 0 comments 1 reaction 0 assignees View on GitHub
enhancement
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

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.