Kafka - 专题

投稿

Kafka

收录了11篇文章 · 9人关注

KafkaProducer Sender 线程详解（含详细的执行流程图）
温馨提示：本文基于 Kafka 2.2.1 版本。上文《源码分析 Kafka 消息发送流程》已经详细介绍了 KafkaProducer s...

中间件兴趣圈 0 0
源码分析Kafka 消息拉取流程
本节重点讨论 Kafka 的消息拉起流程。 @TOC １、KafkaConsumer poll 详解消息拉起主要入口为：KafkaConsum...

中间件兴趣圈 0 0

Kafka 之压缩算法&Hash算法
Kafka 支持的压缩算法还挺多的，这一篇来站在Kafka的角度看一下压缩算法。就当前情况来说，支持GZIP、Snappy、LZ4 这三种压缩算...

0.1 邹志全 0 3
Kafka 交付语义机制详解
上一篇提到了如何利用ISR完成“消息不丢失”，接下来看看如何整体来说，如何实现Kafka的交付语义。Kafka 或者所有的消息队列中都存在的交付...

0.1 邹志全 0 2
Kafka “高吞吐” 之顺序访问与零拷贝
前言上一篇所说的micr-batch 其实主要是针对producer 来实现的，Kafka整体吞吐量高可不只是依赖于micr-batch这一点...

0.1 邹志全 0 2
Kafka “高性能” mirc-batch
前言最开始在Kafka 概述中提到了mirc-batch（微批处理），mirc-batch是Kafka 高性能的一个非常重要的原因，这一下子就...

0.1 邹志全 0 3
Kafka “不丢消息” ISR LEO&HW解析
前言上一篇介绍的ISR的不丢消息的种种备份及冗余机制的所有的核心逻辑都是围绕着HW值、LEO值来展开的，如何合理的更新和存储显得尤为重要。首...

0.1 邹志全 0 2

Kafka “不丢消息” ISR 机制解析
许多消息都会各种保证自己的产品不会丢消息或者消息丢失概率较小，但是靠谱的很少，而且消息队列丢消息排查起来是非常麻烦的，所以大多数在使用的过程中都...

0.3 邹志全 0 4
Kafka consumer 解析
上一篇说了Kafka consumer的处理逻辑、实现原理及相关的特点，本篇来看看Kafka 另一个client Consumer，作为生产者消...

0.2 邹志全 0 2
Kafka producer 解析
前言 Kafka 作为一个消息系统，其中很大的一个用途就是作为业务上的解耦，而它实现的模式就是经典的生产者消费者模式。毫无疑问，就出现了prod...

0.1 邹志全 0 2