当前位置: 首页 > article >正文

kafka发送消费核心参数与设计原理详解

核心参数详解:

发送端参数:

发送方式:默认值一般都是1:

重试参数 :

 批量参数:

消费端参数: 

自动提交参数:

如果是false,就是说消费完后不提交位移。也就是说比如之前消费的1-5.第N次还是消费到1-5.如果是false。那么第一次消费1-3,第二次消费4-5:默认是true:我们一般用false。因为会有消息丢失和消息重复消费的问题可能发生。那么我们就得手设置提交了:

 比如我们设置了false,那么下面这个自动提交间隔参数就没用了。

 同步提交和异步提交:

 消费指定分区参数:

发消息的时候给分区0和1都发送消息了:

消费的时候只消费了0分区的: 

 消息回溯消费参数:

 指定offset消费参数:

 指定时间点消费参数:

 这个参数:

 这几个参数线上出问题的时候用得到:

心跳参数: 

 这个参数:

 springboot整合kafka:

提交参数的配置可选项:

 像这样:如果是上面配置的话 需要加上这个参数提交:

 但是如果这里是batch:

 就不需要手动提交,这个方法结束的时候,springboot会帮你提交:

 这两个参数都是需要像上面那样在java代码里手动提交的:

原理:

进入到zk,就可以看到总控制器是broker0;这个controller节点是broker在启动的时候就创建的。谁先启动谁就是总控制器。但是是批量启动broke的话,那么就牵扯到ZK的ZAB协议选举来决定谁是总控制器了。

找的就是ISR的节点,按照这个顺序来作为新的leader 


http://www.kler.cn/a/331094.html

相关文章:

  • 【Python】用Python构建高效的应用程序健康检查与监控系统
  • 云计算服务中 数据的所有权是谁的
  • python装饰器学习案例
  • 从0入门自主空中机器人-2-2【无人机硬件选型-PX4篇】
  • Bert中文文本分类
  • C语言简单测试总结
  • 《pyqt+open3d》open3d可视化界面集成到qt中
  • cloud-(Nacos)--注册中心原理-服务注册-服务发现
  • C# Blazor Server 调用海康H5Player播放摄像头画面
  • STM32 实现 UDP 广播通信
  • 从零到一:编写你的第一个PHP API
  • Spring Boot项目中使用MyBatis
  • 利用vue-capper封装一个可以函数式调用图片裁剪组件
  • 在 Qt 项目中使用 spdlog 的全攻略
  • 【硬件模块】SG90舵机模块
  • Veritus netbackup 管理控制台无法连接:未知错误
  • 【力扣 | SQL题 | 每日三题】力扣1264, 1113, 1098, 1082
  • CSP-J 2023 T1小苹果 T2公路
  • 一、Spring Boot集成Spring Security之自动装配
  • Gazebo安装,ubuntu22
  • Linux云计算 |【第四阶段】RDBMS1-DAY3
  • django创建一个新的应用
  • 什么是 Angular 开发中的 Dumb components
  • PowerBI概述
  • 滚雪球学Oracle[4.3讲]:PL/SQL控制结构与循环的深入解析与优化
  • python三局两胜游戏