步骤4
执行GDR 和GDS 初始化安装。
init-up-connect --clearAllConnector # 删除当前confluent 下所有connector
#IF(初始化GDR)
init-up-connect
--coorHost=192.168.6.89:5258 # 本域up 的一个coordinator 节点的ip 和端口。多个节
点用','分割
--localPipeNum=3 # 本域内各引擎之间数据管道数
--kafkahost=10.10.10.11 # kafka 集群的节点IP --kafkaport=9092 # kafka 集群
的port
# IF(初始化GDR 和GDS)
init-up-connect
--coorHost=192.168.6.89:5258 # 本域up 的一个coordinator 节点的ip 和端口。多个节
点用','分割
--localPipeNum=3 # 本域内各引擎之间数据管道数
--outRemotePipeInfo=domain-89:2 # 本域的标识 和 从本域流出到其它域的数据管道数，
用':'分割
--RemoteCrossServerInfo=192.168.6.88:7911 # 其它域接收跨域数据的一个主机IP 和端口
--inRemotePipeInfo=domain-88:2 # 其它域的标识 和 从其它域流入到本域的数据管道
数，用':'分割
--LocalCrossServerPort=7911 # 本域接收跨域数据的端口
--kafkahost=10.10.10.11 # kafka 集群的节点IP
--kafkaport=9092 # kafka 集群的port
#IF(使用kerbers 认证)增加如下参数
--keytabUser=KEYTABUSER kerbors keytab user
--keytabPath=KEYTABPATH kerbors keytab path
只使用GDR 的初始化例子(只使用域内数据流转)。
GBase UP 产品手册 4 管理员指南
文档版本04（2021-04-21） 南大通用数据技术股份有限公司 204
init-up-connect --coorHost=192.168.6.89:5258 --localPipeNum=30
使用GDR 和GDS 的初始化例子（使用域内和跨域数据流转）。
GBaseUP1 初始化命令
init-up-connect
--coorHost=192.168.6.89:5258
--localPipeNum=30
--outRemotePipeInfo=up1:20
--RemoteCrossServerInfo=192.168.6.199:7911
--inRemotePipeInfo=up2:20
--LocalCrossServerPort=7911
--kafkahost=10.10.10.11
GBaseUP2 初始化命令
init-up-connect
--coorHost=192.168.6.88:5258
--localPipeNum=30
--outRemotePipeInfo=up2:20
--RemoteCrossServerInfo=192.168.6.97:7911
--inRemotePipeInfo=up1:20
--LocalCrossServerPort=7911
--kafkahost=192.168.6.199
步骤5
再次查看kafka connect 集群上运行的connector。curl 10.10.10.11:8083/
Connectors。
步骤6
登陆gccli 执行show processlist 可以看到如下任务。
ataflow 'up_remote_up1_1' get task
dataflow 'up_local_1' get task
步骤7
修改gclusterd 配置文件中up_kfk_connect_hosts 参数值，
指定kafka connect 集群的
所有节点IP 和端口，多个节点用','分割。
up_kfk_connect_hosts= 10.10.10.11:8083,10.10.10.12:8083,10.10.10.13:8083