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

Kafka生产者幂等性/事务

Kafka生产者幂等性/事务

  • 幂等性
  • 事务

Kafka 消息交付可靠性保障:

  • Kafka 默认是:至少一次
  • 最多一次 (at most once) : 消息可能会丢失,但绝不会被重复发送
  • 至少一次 (at least once) : 消息不会丢失,但有可能被重复发送
  • 精确一次 (exactly once) : 消息不会丢失,也不会被重复发送

Kafka 实现精确一次的两种机制:

  • 幂等性 (Idempotence) : 保证单分区、单会话上的消息幂等性
  • 事务 (Transaction) : 保证跨分区、跨会话间的幂等性, 性能更差

幂等性

幂等 : 某些操作执行多次,但每次结果都是一样的

  • 幂等性好处:安全地重试任何幂等性操作,不会破坏系统状态

Kafka-0.11.0.0 引入幂等性 Producer

Producer 幂等性启动:

props.put("enable.idempotence", ture);
// 或
props.put(ProducerConfig.ENABLE_IDEMPOTENCE_CONFIG, true);

Kafka 自动实现消息的重复去重:

  • 用空间去换时间的优化思路
  • 当 Producer 发送了具有相同字段值的消息后,Broker 得知这些消息已经重复,就在后台丢弃掉

幂等性 Producer 的作用范围

  • 保证单分区的幂等性 :一个幂等性 Producer 只能保证某个主题的一个分区上不出现重复消息,无法实现多个分区的幂等性
  • 保证单会话的幂等性:当重启 Producer 后,该幂等性就丧失

事务

数据库的事务的 ACID : 原子性(Atomicity) ,一致性 (Consistency) , 隔离性 (Isolation) , 持久性 (Durability)

隔离性 :并发执行的事务彼此相互隔离,互不影响

已提交读 (read committed) :

  • 无脏读 : 当读取数据库时,只能看到已提交的数据
  • 无脏写 : 当写入数据库时,只能覆盖掉已提交的数据

Kafka-0.11 支持事务 :

  • read committed 隔离级别 :保证多条消息原子性地写入到目标分区,同时保证 Consumer 只能看到事务成功提交的消息

事务型 Producer 的作用范围:

  • 跨分区的幂等性:保证消息原子性地写入到多个分区中。要么全部写入成功,要么全部失败
  • 跨会话的幂等性:Producer 重启后,依然能精确一次处理

设置事务型 Producer :

  • 开启 enable.idempotence = true
  • 设置 Producer 端 transctional.id

调整 Producer 代码 :

  • initTransaction : 事务的初始化
  • beginTransaction : 事务开始
  • commitTransaction : 事务提交
  • abortTransaction : 事务终止
producer.initTransactions();try {producer.beginTransaction();//保证 Record1 和 Record2 为一个事务统一提交 Kafkaproducer.send(record1);producer.send(record2);producer.commitTransaction();
} catch (KafkaException e) {producer.abortTransaction();
}

写入失败消息,也会写入到日志中 :

  • Consumer 读取事务型 Producer 消息时,要设置 isolation.level

isolation.level 取值:

  • read_uncommitted (默认值) : Consumer 能读到 Kafka 写入的任何消息。用事务型 Producer,Consumer 不能用这个
  • read_committed : Consumer 只会读取事务型 Producer 成功提交事务写入的消息
http://www.lryc.cn/news/37714.html

相关文章:

  • JavaWeb--案例(Axios+JSON)
  • css制作动画(动效的序列帧图)
  • 【设计模式】装饰器模式
  • Nginx配置实例-反向代理案例一
  • Java中IO流中字节流(FileInputStream(read、close)、FileOutputStream(write、close、换行写、续写))
  • C#完全掌握控件之-combbox
  • STL的空间配置器(allocator)
  • linux系统莫名其妙的环境变量问题
  • 使用 Microsoft Dataverse 简化的连接快速入门
  • PLSQL Developer 安装指南
  • 腾讯云企业网盘2.5版本全新发布啦!!!
  • Excel职业版本(4)
  • 3-2 SpringCloud快速开发入门:Ribbon 实现客户端负载均衡
  • ChatGPT,乌合之众的疯狂
  • 代码随想录刷题-数组-长度最小的子数组
  • 成功解决安装MySQL5.7提示公钥GPG密钥配置为file:///etc/pki/rpm-gpg/RPM-GPG-KEY-mysql
  • vue配置环境变量
  • js学习3(数组)
  • 不用写代码也能开发,产品经理是怎么做到的?
  • Android源码分析 - Parcel 与 Parcelable
  • 数字孪生与 UWB 技术创新融合:从单点测量到全局智能化
  • 蓝桥杯嵌入式PWM_IN(打开中断)
  • 蓝桥杯集训·每日一题Week1
  • 25k的Java开发常问的ThreadLocal问题有哪些?
  • R语言基础(四):数据类型
  • 批处理命令--总结备忘「建议收藏」
  • 面试知识点梳理及相关面试题(十一)-- docker
  • k8s--services(微服务)
  • 【Java开发】设计模式 01:单例模式
  • 10、go工程化与标准库