canal client leader

//选举

RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);

CuratorFramework client = CuratorFrameworkFactory.builder().connectString(zookeeper).sessionTimeoutMs(5000).connectionTimeoutMs(3000).retryPolicy(retryPolicy).namespace("canalClient").build();

client.start();

IszLogger.error("=====");

CanalConnector connector = getCanalConnector(connectorType);

connector.connect();

connector.subscribe(subscribeReg);

IszLogger.error("*****");

// 选举Leader 启动

@SuppressWarnings("resource")

final LeaderLatch latch = new LeaderLatch(client,"/canalClient");

latch.addListener(new LeaderLatchListener() {

public void isLeader() {

//启动监听

IszLogger.error("leader==============");

subscribeAndDealCanal();

}

public void notLeader() {

IszLogger.error("not leader==============");

}

});

try {

latch.start();

IszLogger.error("start阻塞==============");

latch.await();

IszLogger.error("通过阻塞================");

} catch (Exception e) {

e.printStackTrace();

}

转载于:https://www.cnblogs.com/lovlos/p/7237957.html

canal client leader相关推荐

mysql数据实时同步：Canal安装部署、kafka安装、zk安装、mysql安装、Canal Server+Canal Client HA，Canal+mysql+Kafka，相关验证（学习笔记）
目录 Canal安装部署 1.1. 服务器准备 1.2. 设置主机名并配置hosts 1.3. 免密设置 1.4. 设置ntp时间 1.5. 关闭防火墙 1.6. 关闭selinux 1.7. 安装J ...
canal 日志中 ERROR c.a.otter.canal.client.adapter.es.support.ESTemplate ...document missing 产生的可能的原因
canal 日志中经常会有日志信息 2019-08-14 15:02:24.843 [pool-2-thread-1] ERROR c.a.otter.canal.client.adapter.es. ...
canal的java客户端_GitHub - cjl1001/canal-client: spring boot canal starter 易用的canal 客户端 canal client...
易用的canal 客户端 easy canal client 介绍 canal 是阿里巴巴mysql数据库binlog的增量订阅&消费组件使用该客户端前请先了解canal,https://g ...
canal - 数据同步工具
一.应用场景在前面Echarts - 实现图表显示中,我们使用了服务调用(统计表中的信息通过调用用户模块服务来获取)获取统计信息,这样耦合度高,效率相对较低,目前有另一种方法,通过实时同步数据库表的 ...
canal+zookeeper+mysql高可用配置
一.部署环境 1.基础环境: 软件版本作用 Linux Centos7.1,8g Jdk 1.8.0_151 canal 1.1.1 canal server端,与mysql和zookeeper交 ...
MySQL增量订阅消费组件Canal POC
POC的目的: 1.与MYSQL的对接方式,配置文档 2.订阅的延迟 3.订阅后宕机消息会不会丢失 4.能不能从指定的点开始重新订阅 5.高并发写入的时候,日志的顺序是否还能保持,不考虑消费的情况订阅 ...
数据同步的终极解决方案，阿里巴巴开源的Canal框架当之无愧！！
写在前面在当今互联网行业,尤其是现在分布式.微服务开发环境下,为了提高搜索效率,以及搜索的精准度,会大量使用Redis.Memcached等NoSQL数据库,也会使用大量的Solr.Elastics ...
谈谈对 Canal（增量数据订阅与消费）的理解--大数据平台技术栈系列(3)
之前说了,大数据平台技术栈 (可点击查看),今天就来说说其中的Cannal 来源:朱小厮, blog.csdn.net/u013256816/article/details/52475190 概述 c ...
教你如何用阿里canal
什么是canal? 阿里巴巴 B2B 公司,因为业务的特性,卖家主要集中在国内,买家主要集中在国外,所以衍生出了同步杭州和美国异地机房的需求,从 2010 年开始,阿里系公司开始逐步的尝试基于数据库的 ...

canal client leader

canal client leader相关推荐

最新文章

热门文章