新征程软件技术平台
首页
JAVA
JAVA
基础
JVM
并发
计算机基础
计算机基础
数据结构与算法
数据库
数据库
MySQL
Redis
Elasticsearch
常用框架
常用框架
Spring
SpringBoot
SpringCloud
MyBatis
Apache ShardingSphere
系统设计
系统设计
设计模式
秒杀系统
源码分析
中间件
中间件
Kafka
ZooKeeper
RocketMQ
zhengcheng 开发指南
更新日志
GitHub
(opens new window)
#
Kafka 如何保证消息的顺序
首先
Kafka
给出了以下保证:
由生产者发送给特定主题分区的消息会以发送的顺序追加(
appended
)。也就是说,如果一条消息
M1
被同一个生产者以
M2
来发送,并且
M1
先发,那么
M1
的
offset
就会比
M2
更小,并且先出现在日志中。
一个消费者实例会按消息在日志中的存储顺序看到它们。
对于副本因子为
N
的主题,我们可以承受
N-1
个服务器发生故障而保证提交到日志的消息不会丢失。
←
SpringBoot 配置多 Kafka 中心
Kafka 重试机制
→