码农知识堂 - 1000bd
  •   Python
  •   PHP
  •   JS/TS
  •   JAVA
  •   C/C++
  •   C#
  •   GO
  •   Kotlin
  •   Swift
  • kafka同步副本集及关键参数


            上篇文章讲了副本机制是什么,一文读懂kafka内部怎么运行的-CSDN博客 这里深挖下同步副本集及里面的关键参数。副本会去leader副本拉去数据追加到自己日志中。

                    我们知道kafka副本的作用是提高系统的高可用。当leader副本挂了时,会从候选副本集中选者一个当leader副本继续对外提供服务。那么这个候选副本其实就是同步副本集,如果副本的数据和leader副本数据差太多时,该副本会被踢出同步副本集,如果数据追上来了则又加入该副本集。那么怎么才叫差太多呢?

            replica.lag.time.max.ms=10,默认10秒。如果副本超过10秒没有发起数据拉取操作,则认为该副本太落后了,剔出同步副本集。被剔除的副本叫非同步副本集。那么非同步副本集能够作为候选副本吗?答案是能。unclean.leader.election.enable=true 则表示可以从非同步副本集选择出leader副本。但是这样就可能丢失数据了,谨慎使用。

            下面还有几个关键参数:

            replication.factor=3 指定主题有3个副本

            min.insync.replicas=3 最少同步副本集个数,当同步副本集个数大于等于该数时才算写入成功。

            acks参数:消息写入时要求确认的副本个数。

            acks=0时,生产者不管leader副本端的处理情况,只管发送。最高吞吐量。

            acks=all或-1时,必须等到同步副本集都成功写入时,才响应成功。最高持久性,最低吞吐量。

            acks=1,只需要leader broker写入成功,无需管其他副本。(默认)

            

            

  • 相关阅读:
    【Ubuntu】使用WSL安装Ubuntu
    joblib嵌套式并行运行方式
    【原创】mitmdump 安装证书至手机系统证书
    基于Python实现的某宝服装类销售评论数据提取
    RNA 25. SCI文章中估计组织浸润免疫细胞和基质细胞群的群体丰度(MCP-counter)
    处理器 Handler 详解
    在 GeoServer 上发布 Shapefile 文件作为 WMS 数据
    CPU资源控制
    linux-快捷执行历史命令
    第2-1-2章 传统方式安装FastDFS-附FastDFS常用命令
  • 原文地址:https://blog.csdn.net/zzy916853616/article/details/136377120
  • 最新文章
  • 攻防演习之三天拿下官网站群
    数据安全治理学习——前期安全规划和安全管理体系建设
    企业安全 | 企业内一次钓鱼演练准备过程
    内网渗透测试 | Kerberos协议及其部分攻击手法
    0day的产生 | 不懂代码的"代码审计"
    安装scrcpy-client模块av模块异常,环境问题解决方案
    leetcode hot100【LeetCode 279. 完全平方数】java实现
    OpenWrt下安装Mosquitto
    AnatoMask论文汇总
    【AI日记】24.11.01 LangChain、openai api和github copilot
  • 热门文章
  • 十款代码表白小特效 一个比一个浪漫 赶紧收藏起来吧!!!
    奉劝各位学弟学妹们,该打造你的技术影响力了!
    五年了,我在 CSDN 的两个一百万。
    Java俄罗斯方块,老程序员花了一个周末,连接中学年代!
    面试官都震惊,你这网络基础可以啊!
    你真的会用百度吗?我不信 — 那些不为人知的搜索引擎语法
    心情不好的时候,用 Python 画棵樱花树送给自己吧
    通宵一晚做出来的一款类似CS的第一人称射击游戏Demo!原来做游戏也不是很难,连憨憨学妹都学会了!
    13 万字 C 语言从入门到精通保姆级教程2021 年版
    10行代码集2000张美女图,Python爬虫120例,再上征途
Copyright © 2022 侵权请联系2656653265@qq.com    京ICP备2022015340号-1
正则表达式工具 cron表达式工具 密码生成工具

京公网安备 11010502049817号