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数据内容请搜索靠谱客的其他文章。