2024-11-13 厉飞雨 阅读(328) 评论(0) 赞(13)

<p>本文将带你了解如何使用 <a href="/spring-boot/">Spring Boot</a> 和 <a href="/spring-kafka/">Spring Kafka</a> 管理 Kafka 消费者偏移量（Offset）。</p> <p&...

2024-11-13 厉飞雨 阅读(180) 评论(0) 赞(13)

<h2>1、简介 {#1简介}</h2> <p>本文将带你了解如何在 <a href="/spring/">Spring</a> 中为 Apache Kafka 配置死信队列。</p> <h2>2、死信队列 {#2死信队列}</h2> <p>死信队列（...

2024-11-13 厉飞雨 阅读(204) 评论(0) 赞(16)

1、简介 {#1简介} ----------- [Apache Kafka](https://kafka.apache.org/) 是一个分布式流平台，擅长处理海量实时数据流。Kafka 将数据组织成 Topic（主题），并进一步将 Topic 划分为 Partition（分区）。每个分区都是一个独立的 Channel（通道），可实现并行处理和容错。 本文将带你了解如何把数...

2024-11-13 厉飞雨 阅读(182) 评论(0) 赞(13)

1、概览 {#1概览} ----------- 本文将带你了解 [Spring Kafka](/spring-kafka/) 中的 "Trusted Packages" 功能，了解其背后的动机以及用法。 2、先决条件 {#2先决条件} --------------- 一般来说，Spring Kafka 模块允许我们指定一些关于发送的 POJO 的元数据...

2024-11-13 厉飞雨 阅读(202) 评论(0) 赞(14)

<h2>1、概览 {#1概览}</h2> <p><a href="https://kafka.apache.org/">Apache Kafka</a> 是一个功能强大、分布式、容错的流处理系统。在之前的教程中，介绍了 <a href="/spring-kafka/">...

2024-10-26 厉飞雨 阅读(309) 评论(0) 赞(14)

<h2><a href="#一-什么是kafka">#</a> （一）什么是Kafka {#一-什么是kafka}</h2> <p>Kafka是一个分布式的基于<strong>发布/订阅模式</strong>的消息队列，同时它又是一个分布式的事件流平台。既可作为消息队列，又可...

2024-10-26 厉飞雨 阅读(173) 评论(0) 赞(16)

<h2><a href="#一-生产者的原理">#</a> （一）生产者的原理 {#一-生产者的原理}</h2> <p>当有数据要从生产者发往消费者的时候，在kafka底层有这样一套流程。首先生产者调用send方法发送消息后，会先经过一层拦截器，接着进入序列化器。序列化器主要用于对消息的Key和Va...

2024-10-23 厉飞雨 阅读(625) 评论(0) 赞(20)

<p>嗨，你好呀，我是<strong>猿java</strong></p> <p>Log 是Kafka的核心组件之一，用于持久化存储消息，为了有效管理存储空间和保证系统性能，Kafka 提供了日志保留和数据清理策略。这篇文章，我将详细分析它们的工作原理。</p> <h1>日志保留期 {#日志保留...

2024-10-23 厉飞雨 阅读(341) 评论(0) 赞(19)

<p>嗨，你好，我是<strong>猿java</strong></p> <p>在很长一段时间里，ZooKeeper都是 Kafka的标配，现如今，Kafka官方已经在慢慢去除ZooKeeper，Kafka 为什么要抛弃 Zookeeper？这篇文章我们来聊聊其中的缘由。</p> <h1>Kaf...

2024-10-23 厉飞雨 阅读(182) 评论(0) 赞(12)

<p>嗨，你好呀，我是<strong>猿java</strong></p> <p>Kafka作为一款优秀的分布式消息中间件，内部也存在一些选举机制，这篇文章，我们将详细地分析 Kafka如何实现选择 Leader？</p> <h1>Kafka集群整体架构 {#Kafka集群整体架构}</h...