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

<h2>1、简介 {#1简介}</h2> <p><a href="https://kafka.apache.org/"><em>Apache Kafka</em></a> 是一个功能强大的分布式流平台，被广泛用于构建实时数据管道和流应用。然而，Kafka 在运行过程中可能会遇...

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

<h2>1、概览 {#1概览}</h2> <p>本文将带你了解从 Kafka 命令行（CLI）发送 Key/Value 消息的两种方法。</p> <p>在处理金融交易、预订、在线购物等实时事件驱动系统中，确保特定 Topic 上消息的有序性是一个常见需求。在这种情况下，我们应该为发送到这些 Topic 的事件使用 &l...

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 厉飞雨 阅读(179) 评论(0) 赞(13)

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

2024-11-13 厉飞雨 阅读(203) 评论(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 厉飞雨 阅读(624) 评论(0) 赞(20)

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