基本信息
源码名称：Canal kafka实例
源码大小：0.07M
文件格式：.zip
开发语言：Java
更新时间：2020-11-19
   友情提示：（无需注册或充值，赞助后即可获取资源下载链接）

     嘿，亲！知识可是无价之宝呢，但咱这精心整理的资料也耗费了不少心血呀。小小地破费一下，绝对物超所值哦！如有下载和支付问题，请联系我们QQ(微信同号)：813200300

本次赞助数额为： 2 元　
   源码介绍

Canal读取mysql binlog数据变化，发送kafka处理数据变更。

│  canal-demo.iml
│  canal.iml
│  pom.xml
│          
├─src
│  └─main
│      └─java
│          └─com
│              └─uptng
│                  └─canal
│                      │  AbstractCanalClientTest.java
│                      │  BaseCanalClientTest.java
│                      │  ClusterCanalClientTest.java
│                      │  SimpleCanalClientExample.java
│                      │  SimpleCanalClientPermanceTest.java
│                      │  SimpleCanalClientTest.java
│                      │  
│                      └─kafka
│                              AbstractKafkaTest.java
│                              CanalKafkaClientExample.java
│                              CanalKafkaClientFlatMessageExample.java
│                              CanalKafkaOffsetClientExample.java
│                              KafkaClientRunningTest.java
│                              
└─target
    ├─classes
    │  └─com
    │      └─uptng
    │          └─canal
    │              │  AbstractCanalClientTest.class
    │              │  BaseCanalClientTest.class
    │              │  ClusterCanalClientTest.class
    │              │  SimpleCanalClientExample.class
    │              │  SimpleCanalClientPermanceTest.class
    │              │  SimpleCanalClientTest.class
    │              │  
    │              └─kafka
    │                      AbstractKafkaTest.class
    │                      CanalKafkaClientExample.class
    │                      CanalKafkaClientFlatMessageExample.class
    │                      CanalKafkaOffsetClientExample.class
    │                      KafkaClientRunningTest.class
    │                      
    └─generated-sources
        └─annotations