多域数据复制

• 输入格式为IP:port或host:port；

• 支持输入多个主机地址，同时需要使用英文“,”隔开；

• 若主机使用的是Kafka默认对外开放的端口，则此处端口号默认使用31000

• 开启：开启定时复制时，系统将在指定的时间点、持续时间执行多域复制任务

• *执行周期：设置多域复制定时任务的开启时间。例如设置执行周期为“08:00”表示系统将在每天上午的8点开启多域复制任务；

• *持续时间：设置多域复制任务开启后的持续时间。例如设置持续时间为“4”表示系统开启多域复制任务后，任务将持续执行4小时。

• 关闭：关闭定时复制时，系统默认全天执行多域复制任务，即实时复制。

• 执行周期默认为00:00；

• 持续时间默认单位为“小时”不可修改，默认值为“5”，输入值应＞0且≤23；

• 默认关闭，即系统默认全天执行多域复制任务

• 从最新的数据开始：复制任务将从源端Kafka的最新数据开始复制，即复制到目的端的数据不包括源端kafka缓冲中的数据；
• 从最早的数据开始：复制任务将从源端Kafka的最早数据开始复制，即从源端Kafka缓冲中最早时间的数据开始复制（Kafka 默认数据保留周期为 7 天）。

-

• 开启：开启限速策略后，需填写" *限速大小”（单位MB /s）设置速度上限，系统将基于此限制复制任务的网络传输速度。

• 关闭：默认情况下不开启限速策略，即系统默认不对复制任务的网络传输速度予以限制。

 提示：建议您在网络高峰期或带宽资源有限的情况下开启此功能，以保证其他业务的正常运行。

在数据来源下拉框中选择需要复制的数据来源，支持设置以下三种来源：

• 原始数据：表示复制任务将复制源端的原始数据，完成复制后，目的端可以留存并管理来自源端的原始数据；

• 解析后数据：表示复制任务将源端解析后的格式化数据传输并复制到目的端，可减少目的端数据处理的压力；

注意：当两个多域复制任务互为源端和目标端时，两任务的数据来源不能同时选择“解析后数据”，否则会导致循环复制！

• 自定义topic：当复制场景有明确的数据范围时，可在"*自定义topics"的文本框中填写正则表达式或topic名称以指定需复制的topic列表（通过键入回车键可添加多个自定义topic）。完成复制后，目的端可以留存并管理来自源端的自定义原始数据。

说明：

◆ 复制任务源端topic变动说明

• AnyRobot会对“运行中”任务的源端topic变动情况进行轮询（时间间隔默认为10分钟）：当源端需复制数据的topic发生变动时（如：新增或减少topic、新增topic的分区数），AnyRobot会在每次轮询时获取到topic的变动信息，并根据已配置的“复制开始策略”自动复制新增的topic及topic分区的数据；

• 针对“运行中”的任务，若您删除了此类任务关联的源端需复制的topic后，再重新创建同名topic，则会面临丢失数据的风险，请谨慎操作！

 ◆ 复制任务目的端数据类型说明

• 当数据来源选择“原始数据”时，若原始数据无数据类型，则数据复制到目的端后其数据类型为“kafka_topic”；

• 当数据来源选择“自定义topic”时，若原始数据无数据类型，则数据复制到目的端后其数据类型为源端Kafka的topic名称（即假设配置的自定义topic的名称为“abc”，则数据复制到目的端后其数据类型为“abc”）。

自定义topics的文本框内容需遵循以下限制：

• 当数据来源选择"自定义topic"时，topic不能为空；

• topic不能为.*，不能以anyrobot_data-replicator和__开头，且不能包含中文；

• 可填写多个topic，最多不能超过10个