Kafka 幂等实现剖析

什么是幂等幂等 这个词原是数学领域中的概念,指的是某些操作或函数能够被执行多次,但每次得到的结果都是不变的。 下面通过几个简单的例子说明一下。 比如在乘法运算中,让数字乘以 1 就是一个幂等操作,因为不管你执行多少次这样的运算,结果都是相同的。再比如,取整函数(floor 和 ceiling)是幂等函数,那么运行 1 次 floor(3.4) 和 100 次 floor(3.4),结果是一样...

💧 Posted on kafka幂等

Kafka Producer 源码篇

Kafka 系列文章列表Kafka 版本:2021-11 trunk 分支(当前最新版本3.0.0) 在 Kafka 中,客户端由 Java 语言实现,服务端由 Scala 语言来实现的,在使用 Kafka 时,客户端是用户最先接触到部分,因此,kafka系列文章的源码分析也会从客户端端开始,今天讲的是 Producer 端发送模型的实现。 在看这篇源码分析之前,不了解发送端原理的同学,...

💧 Posted on kafkaproducer

Kafka Producer 原理篇

Kafka 系列文章列表Kafka 版本:2021-11 trunk 分支(当前最新版本3.0.0) 一个正常的生产者逻辑需要具备以下几个步骤: 配置生产者客户端参数以及创建相应的生产者实例 构建待发送的消息 发送消息 关闭生产者实例

💧 Posted on kafkaproducer

Kafka中的基本概念

本文主要介绍一下kafka中的基本概念,主要包括:Producer、Consumer、topic、partition、offset、broker、ISR、AR、HW、LEO等。

💧 Posted on kafka

kafka 如何保障数据可靠性?

Kafka 中采用了多副本的机制,这是大多数分布式系统中惯用的手法,以此来实现水平扩展、提供容灾能力、提升可用性和可靠性等。 我们对此可以引申出一系列的疑问:

💧 Posted on kafka可靠性