Java实现读取canal中binlog数据

package we.com.canal;

import com.alibaba.otter.canal.client.CanalConnector;
import com.alibaba.otter.canal.client.CanalConnectors;
import com.alibaba.otter.canal.common.utils.AddressUtils;
import com.alibaba.otter.canal.protocol.CanalEntry.RowData;
import com.alibaba.otter.canal.protocol.CanalEntry.EventType;
import com.alibaba.otter.canal.protocol.CanalEntry.RowChange;
import com.alibaba.otter.canal.protocol.CanalEntry.EntryType;
import com.alibaba.otter.canal.protocol.CanalEntry.Entry;
import com.alibaba.otter.canal.protocol.CanalEntry.Column;
import com.alibaba.otter.canal.protocol.Message;
import java.net.InetSocketAddress;
import java.util.List;

/**
 * @author yangxin_ryan
 * 代码实现了读取canal中采集过来的mysql的binlog日志
 */
public class SimpleCanalClientExample {

    public static void main(String[] args) {
        // 参数分别为IP，port, 对应的destination(数据库的名字)，username, password
        CanalConnector connector = CanalConnectors.

最后

以上就是迷人往事为你收集整理的Java实现读取canal中binlog数据的全部内容，希望文章能够帮你解决Java实现读取canal中binlog数据所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。