使用EMR-Kafka Connect进行数据迁移( 四 )

3.2创建Kafka Connect

在目的Kafka集群的task节点(例如emr-worker-3节点) , 使用curl命令通过json数据创建一个Kafka Connect 。

json数据中 , name字段代表创建的connect的名称 , 此处为connect-test;config字段需要根据实际情况进行配置 , 其中的变量说明如下表

3.3查看Kafka Connect

查看所有的Kafka Connect

查看创建的connect-test的状态

查看task的信息

3.4数据同步

在源Kafka集群创建需要同步的数据 。

3.5查看同步结果

在目的Kafka集群消费同步的数据 。

推荐阅读