一、kafka的副本机制 由于Producer和Consumer都只会与Leader角色的分区副本相连，所以kafka需要以集群的组织形式提供主题下的消息高可用。kafka支持主备复制，所以消息具备高可用和持久性。 一个分区可以有多个副本，这些副本保存在不同的broker上。每个分区 ...

（二）Kafka动态增加Topic的副本(Replication) 1. 查看topic的原来的副本分布 2. 增加Topic的副本的json文件的编写 vi addReplicas.json 3. 执行topic增加副本操作 4. 查看执行的状态 5. 观察 ...

工作案例: 大数据开发用系统脚本自动在kafka建topic,检查后才发现副本数只有1个,存在数据丢失的风险。需要立刻把副本数改为3个。 开始干活，首先想到的是下面的命令： ${BIN_PATH}/kafka-topics.sh --zookeeper ...

动态调整副本数 PUT /ptt-new-2018-11/_settings{ "number_of_replicas": 2} 重建索引， 增加节点后要重建索引。 日志报错为网络读写错误。 write and flush on the network layer failed ...

shell 脚本： 1）列出只有一个副本的topic，保存到一个文件中： 2）执行扩容副本操作 ...

是指手动写扩充replicas的配置文件，然后使用工具进行操作。 　　 参考官网site：http://kafka.apache.org/documentation.html#basic_ops_automigrate 　　1.首先创建一个三分区一副本的topic，并查看详细信息 ...

　　前段时间在Kafka QQ群中有人问及此事——关于Java consumer如何动态修改topic订阅的问题。仔细一想才发现这的确是个好问题，因为如果简单地在另一个线程中直接持有consumer实例然后调用subscribe进行修改，consumer端必然会抛出异常 ...

总结/朱季谦 接触kafka开发已经两年多，也看过关于kafka的一些书，但一直没有怎么对它做总结，借着最近正好在看《Apache Kafka实战》一书，同时自己又搭建了三台kafka服务器，正好可以做一些总结记录。 本文主要是记录如何在kafka集群服务器上创建topic，查看topic列表 ...