kafka入门，Kafka 副本(十三)

9月前作者：Long long ago. 分类：Toy博客阅读(33) 违法举报

这篇具有很好参考价值的文章主要介绍了kafka入门，Kafka 副本(十三)。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

Kafka副本

副本基本信息

1）Kafka副本作用，提高数据可靠性
2）Kafka默认副本1个，生产环境一般配置2个，保证数据可靠性，太多副本会增加磁盘存储空间，增加网络上数据传输，降低效率
3）Kafka中副本份为：Leader和Follower，kafka生产者只会把数据发往Leader,然后Follower找Leader进行同步数据
4）Kafka分区中的所有副本统称为AR
AR=ISR+OSR
ISR,表示和Leader保持同步的集合Follower集合。如果Follower长时间未向Leader发送通信请求和同步数据，则该Follower将被踢出ISR,该事件阈值由replica.lag.time.max.ms参数设定，默认30s,leader发送故障之后，就会从ISR中选举新的leader
OSR,表示Follower与Leader副本同步时，延迟过多的副本

Leader选举流程

kafka集群中有一个broker的Controller会被选举为Controller Leader，复制管理集群broker的上下线，所有topic的分区副本分配和Leader选举等工作
controller的信息同步工作是依赖于Zookeeper的。
kafka配置副本,kafka,分布式文章来源地址https://www.toymoban.com/news/detail-633352.html

到了这里，关于kafka入门，Kafka 副本(十三)的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：如若内容造成侵权/违法违规/事实不符，请点击违法举报进行投诉反馈，一经查实，立即删除！

分享到：

领支付宝红包赞助服务器费用

ELK分布式日志收集快速入门-（一）-kafka单体篇

JDK 安装教程自行百度-这个比较简单。 zookeeper zookeeper安装参考地址（(2条消息) 快速搭建-分布式远程调用框架搭建-dubbo+zookper+springboot demo 演示_康世行的博客-CSDN博客）修改zookeeper配合文件启动成功开放端口号下载kafka安装包安装遇到的问题（由于网站证书不安全导致）解

2023年04月08日
浏览(39)
【大数据工具】Kafka伪分布式、分布式安装和Kafka-manager工具安装与使用

Kafka 安装包下载地址：https://archive.apache.org/dist/kafka/ 1. Kafka 伪分布式安装 1. 上传并解压 Kafka 安装包使用 FileZilla 或其他文件传输工具上传 Kafka 安装包： kafka_2.11-0.10.0.0.tgz 解压安装包 2. 编辑配置文件 3. 拷贝并修改配置文件分别修改 server2.properties、server3.properties 4. 创建日志

2024年02月14日
浏览(45)
分布式消息服务kafka

什么是消息中间件？消息中间件是分布式系统中重要的组件，本质就是一个具有接收消息、存储消息、分发消息的队列，应用程序通过读写队列消息来通信。例如：在淘宝购物时，订单系统处理完订单后，把订单消息发送到消息中间件中，由消息中间件将订单消息分发到下

2024年02月01日
浏览(43)
【分布式应用】kafka集群、Filebeat+Kafka+ELK搭建

主要原因是由于在高并发环境下，同步请求来不及处理，请求往往会发生阻塞。比如大量的请求并发访问数据库，导致行锁表锁，最后请求线程会堆积过多，从而触发 too many connection 错误，引发雪崩效应。我们使用消息队列，通过异步处理请求，从而缓解系统的压力。消息队

2024年02月16日
浏览(45)
【分布式技术】消息队列Kafka

目录一、Kafka概述二、消息队列Kafka的好处三、消息队列Kafka的两种模式四、Kafka 1、Kafka 定义 2、Kafka 简介 3、Kafka 的特性五、Kafka的系统架构六、实操部署Kafka集群步骤一：在每一个zookeeper节点上完成kafka部署编辑步骤二：传给其他节点步骤三：启动3个节点 kafka管理

2024年01月23日
浏览(51)
分布式 - 消息队列Kafka：Kafka 消费者的消费位移

01. Kafka 分区位移对于Kafka中的分区而言，它的每条消息都有唯一的offset，用来表示消息在分区中对应的位置。偏移量从0开始，每个新消息的偏移量比前一个消息的偏移量大1。每条消息在分区中的位置信息由一个叫位移（Offset）的数据来表征。分区位移总是从 0 开始，假设一

2024年02月12日
浏览(46)
分布式 - 消息队列Kafka：Kafka消费者的分区分配策略

Kafka 消费者负载均衡策略？ Kafka 消费者分区分配策略？ 1. 环境准备创建主题 test 有5个分区，准备 3 个消费者并进行消费，观察消费分配情况。然后再停止其中一个消费者，再次观察消费分配情况。 ① 创建主题 test，该主题有5个分区，2个副本： ② 创建3个消费者CustomConsu

2024年02月13日
浏览(42)
分布式 - 消息队列Kafka：Kafka生产者发送消息的方式

不管是把Kafka作为消息队列、消息总线还是数据存储平台，总是需要一个可以往Kafka写入数据的生产者、一个可以从Kafka读取数据的消费者，或者一个兼具两种角色的应用程序。 Kafka 生产者是指使用 Apache Kafka 消息系统的应用程序，它们负责将消息发送到 Kafka 集群中的一个或多

2024年02月13日
浏览(40)
分布式 - 消息队列Kafka：Kafka消费者分区再均衡(Rebalance)

01. Kafka 消费者分区再均衡是什么？消费者群组里的消费者共享主题分区的所有权。当一个新消费者加入群组时，它将开始读取一部分原本由其他消费者读取的消息。当一个消费者被关闭或发生崩溃时，它将离开群组，原本由它读取的分区将由群组里的其他消费者读取。分区

2024年02月12日
浏览(37)
分布式 - 消息队列Kafka：Kafka 消费者消费位移的提交方式

最简单的提交方式是让消费者自动提交偏移量，自动提交 offset 的相关参数： enable.auto.commit：是否开启自动提交 offset 功能，默认为 true; auto.commit.interval.ms：自动提交 offset 的时间间隔，默认为5秒；如果 enable.auto.commit 被设置为true，那么每过5秒，消费者就会自动提交 poll() 返

2024年02月12日
浏览(43)