kafka的listeners配置错误导致主线程阻塞
kafka 如何体现消息的顺序性
Rebalance机制分析
Kafka有哪几处地方有分区分配的概念?
Kafka 是如何实现精确一次(exactly once)语义的?

Kafka 系列(八):如何避免消息丢失?

本文主要从 Producer、Broker、Consumer 等 3 个方面分析了 Kafka 应该如何配置才能避免消息丢失。 1. 概述在使用 MQ 的时候最大的问题就是消息丢失,常见的丢失情况如下:

💧 Posted on kafka

Kafka 系列(七):kafka 对性能的优化

性能问题一般常出现在三个地方: 网络 磁盘 复杂度 在 kafka 中性能的优化主要体现在三个方面: Producer Consumer Borker kafka 作为一个分布式队列,网络和磁盘更是优化的重中之重。kafka 中的优化手段主要有以下几种: 压缩 缓存 批量 并发 算法

💧 Posted on kafka性能优化

Kafka 系列(六):幂等实现剖析

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

💧 Posted on kafka幂等

Kafka 系列(五):如何保障数据可靠性?

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

💧 Posted on kafka可靠性
Kafka 消费者