tencent cloud

 yum install java-1.8.0-openjdk-devel 

  // 从云API获取密钥,填写到此处
     context.setSecretId("AKIDfdsfdsfsdt1331431sdfds"); 请填写您从云API获取的secretID
     context.setSecretKey("test111usdfsdfsddsfRkeT"); 请填写
     您从云API获取的secretKey
 // 在数据迁移服务里面通过数据订阅获取到对应的ip,port,填写到此处
     context.setServiceIp("10.66.112.181"); 请填写您从数据订阅配置获取到的IP
     context.setServicePort(7507);
     请填写您从数据订阅配置获取到的PORT
     final DefaultSubscribeClient client = new DefaultSubscribeClient(context);
 // 填写对应要同步的数据库和表名,并修改对应要落地存储的文件名.
     final String targetDatabase = "test"; 填写您所要订阅的库名
     final String targetTable = "alantest"; 填写您所要订阅的表名

     final String fileName = "test.alan.txt"; 填写您希望落在本地的文件名

       client.addClusterListener(listener);
 // 通过数据迁移订阅的配置选项获取到dts-channel的配置信息,填写到此处
 client.askForGUID("dts-channel-e4FQxtYV3It4test"); 请填写您从数据订阅获取的通道dts的名称
     client.start();

java -XX:-UseGCOverheadLimit -Xms2g -Xmx2g -classpath .:binlogsdk-2.6.0-release.jar LocalDemo

[root@VM_71_10_centos ~]# cat test.alan.txt  
checkpoint:144251@3@357589@317713
record_id:000001000000000004D9110000000000000001
record_encoding:utf8
fields_enc:latin1,utf8
gtid:4f21864b-3bed-11e8-a44c-5cb901896188:1562
source_category:full_recorded
source_type:mysql
table_name:alantest
record_type:INSERT
db:test
timestamp:1523356039
primary:
Field name: id
Field type: 3
Field length: 2
Field value: 26
Field name: name
Field type: 253
Field length: 4
Field value: alan