多域数据复制

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

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

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

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

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

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

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

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

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

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

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

-

• 开启：开启限速策略后，需填写" *限速大小”（单位MiB /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输入格式需为string格式，不能为.*，不能以anyrobot_data-replicator，.*.ar.dr和__开头，且不能包含中文；

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

设置允许此复制任务占用的CPU上限，默认为1（单位C）

提示：建议您根据并行的复制任务数量以及集群的CPU资源使用情况调整此任务占用的CPU上限，以保证多任务正常运行的同时实现资源的合理利用。

• 输入的限额数值应为整数，需＞0且≤8，单位为C

 设置允许此复制任务占用的内存上限，默认为2048（单位MiB）

提示：建议您根据并行的复制任务数量以及集群的内存资源使用情况调整此任务占用的内存上限，以保证多任务正常运行的同时实现资源的合理利用。

• 输入的限额数值应为整数，需＞0且≤8192，单位为MiB