三个核心选举原则：（1）Zookeeper集群中只有超过半数以上的服务器启动，集群才能正常工作；（2）在集群正常工作之前，myid小的服务器给myid大的服务器投票，直到集群正常工作，选出Leader；（3）选出Leader之后，之前的服务器状态由Looking改变为Following，以后的服务器都是Follower。下面以一个简单的例子来说明整个选举的过程：假设有五台服...

1.继承Runnable接口package com.vince.xq.kafka.thread;public class ThreadOne implements Runnable {private int i;public ThreadOne(int i) {this.i=i;}@Overridepublic void run() {try {Thread.sleep(1000);

1.引入pom 文件2.读kafka 数据sink 到mysql 里面sink mysql 出现相关问题处理参考：flink-table-connector-mysql-sink,程序直接退出，不报错，数据没sink到mysql表中 - 代码先锋网 (codeleading.com)3.读kafka 数据sink 到kafka4.读kafka 数据print可通过可配置话的方式去实现，sql 放在

一、背景：临近双11大促，为避免流量峰值较高，电商公司都会对系统进行压测。一直做实时数据计算，应用是基于Flink做的，接收kafka消息，进行数据统计，包括：pv、uv、dau、单量、成交额等等。为了保证应用在大促期间不出问题，需要进行实时计算程序进行压测。由于统计的数据分为两类(流量数据、订单数据)，对这两类数据进行不同方式的压测。二、压测准备(1)压测时间选择：一般...

在kafka connect 同步 mysql 主从数据库下载以下文件,解压，放置到kafka的libs目录kafka-connect-jdbc-4.1.1从这里选择适合的mysql connectormysql-connector-java-8.0.16.jar将里面的jar文件提取出来，也放到kafka的libs目录在co...

1.问题定位(接入监控系统，在关键点位加入监控点)2.HBase表优化实践发现HBase数据保存以及查询一直耗时较高，联系HBase同事，做了限流处理，解决限流3.HBase优化之后，发现仍然耗时较大，看到大部分请求走HBase，上面再做一层缓存，用redis做缓存，调用数量明显减少4.请求接口监控，增加缓存，减少请求接口数量5.最后kafka消费终于上去了，...

在用户体验、监控、运维管控上进行了平台化、可视化、智能化的建设，提供一系列特色的功能，极大地方便了用户和运维人员的日常使用，让普通运维人员都能成为Kafka专家。开发文档：https://github.com/didi/KnowStreaming/blob/master/docs/dev_guide/%E6%9C%AC%E5%9C%B0%E6%BA%90%E7%A0%81%E5%90%AF%E5%

在用户体验、监控、运维管控上进行了平台化、可视化、智能化的建设，提供一系列特色的功能，极大地方便了用户和运维人员的日常使用，让普通运维人员都能成为Kafka专家。开发文档：https://github.com/didi/KnowStreaming/blob/master/docs/dev_guide/%E6%9C%AC%E5%9C%B0%E6%BA%90%E7%A0%81%E5%90%AF%E5%

诸葛子房，现任职于某知名互联网公司，担任中国Hbase技术社区委员，了解互联网金融、大数据相关知识；爱生活、想要在某个领域有所成就；仍然在学习的路上继续努力着，希望把自己的正能量传递给更多的人。另著有公众号:子房小语，公众号分享互联网求职、面试、工作经历，欢迎大家关注。...

(6)提升自己的英文能力，很多人认为英文能力不强，不能看懂英文文档，说实话，可能前期确实有些难受，看英文文档，特别是在zeppelin的英文文档，刚开始会很不适应，但是随着看多了之后，只剩少量单词不懂，然后就去使用翻译软件来解决，能看到下面关于一个pr的沟通，前后沟通了40-50次对话，全程英文，但是理解起来其实也没有那么复杂，只有少量单词不懂的时候，会去查一下，然后就是怎么去回复别人，一般也是一