使用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集群消费同步的数据 。
推荐阅读
- 金铲铲之战|金铲铲之战新赛季最强阵容:学院名流永恩,低分段玩家谨慎使用
- 激战2|MMORPG集体放大招?魔兽、FF14、激战2均使用End迎来主线剧情终章!
- 拉克罗斯|《宝可梦》使用虫系精灵的馆主阿笔,常用精灵不少都能Mega?
- 光环|梦幻西游:使用第三种打造方式,武器和衣服是可以拥有三加属性的
- adc|英雄联盟手游:为何会玩的小炮能5杀?学一学3技能的使用吧
- 史诗之路|DNF:别接盘时间结晶!史诗之路无限门票解析,两个角色可使用
- 卡牌|哈利波特:能力独特的4张卡,对手使用强度爆表,自己用却很垃圾
- 原神|原神:一个月卡低练度党的托马使用感想
- 剑道|易大师的第四次攻击会暴击,主动使用后,下次攻击必定暴击
- 王者荣耀|王者荣耀钥匙口令使用方法 王者荣耀钥匙口令怎么用