前提：使用kafka2.0 旧版指定服务器用--zookeeper ，新版用--bootstrap-server ...[作者空间]

auto.offset.reset 参数 earliest： 当各分区下有已提交的offset时，从提交的offs...[作者空间]

kafka架构 基础概念 核心架构如上图所示：主要功能包括了 生产者发送消息给 Kafka 服务器。 消费者从 K...[作者空间]

KAFKA 先安装完zookeeper，小规模用可以用新版kafka自带的zookeeper。 下载 修改配置 启...[作者空间]

官方文档解释 auto.offset.reset: What to do when there is no ini...[作者空间]

一、Springboot与Spring-kafka版本关系二、概念知识三、SpringBoot 操作 Kafka ...[作者空间]

前言 上一篇介绍的ISR的不丢消息的种种备份及冗余机制的所有的核心逻辑都是围绕着HW值、LEO值来展开的，如何合理...[作者空间]

许多消息都会各种保证自己的产品不会丢消息或者消息丢失概率较小，但是靠谱的很少，而且消息队列丢消息排查起来是非常麻烦...[作者空间]

Kafka consumer的offset提交机制有以下两种 手动提交 同步提交consumer.commitSy...[作者空间]

为了便于说明问题,假设这里只有一个Kafka集群,集群中只有一个Kafka节点，也就是只有一台物理机。在这个Kaf...[作者空间]