Replicator 参数配置
Replicator 参数配置说明
Last updated
Replicator 参数配置说明
Last updated
参数
类型
是否必须
描述
样例数据
source-rocketmq
String
是
源rocketmq
192.168.1.2:9876
target-rocketmq
String
是
目的rocketmq
192.168.1.2:9876
replicator-store-topic
String
是
存储所有源消息的Topic
replicator-store-topic
task-divide-strategy
Integer
否
任务划分策略
默认是0,指按照topic划分
white-list
String
是
主题白名单和多个字段,用逗号分隔
topic-1,topic-2
target-cluster
String
是
RocketMQ目的集群名称
DefaultCluster
source-cluster
String
是
RocketMQ源集群名称
DefaultCluster
task-parallelism
String
否
任务并行度,默认值为1,一个任务将负责多个主题的值大于1
2
source-record-converter
String
是
源数据的converter
io.openmessaging.connect.runtime.converter.JsonConverter
topic.rename.format
String
Yes
Topic重命名方式
rename-${topic}(Topic会被重命名为rename-xxx)