Skip to content

Commit 9ffd189

Browse files
frank-lamfrank-lam
committed
update Kafka toc
1 parent adbb297 commit 9ffd189

File tree

6 files changed

+106
-1
lines changed

6 files changed

+106
-1
lines changed

‎notes/MicroService/kafka/README.md‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@
1111
| Ⅲ | 深入浅出 Kafka（三）集群化部署 | 集群下的，宿主机和容器的两种部署方式 | |
1212
| Ⅳ | [深入浅出 Kafka（四）架构深入](kafka-tutorial-4_%E6%9E%B6%E6%9E%84%E6%B7%B1%E5%85%A5.md) | 深入理解 Kafka 的架构细节 | √ |
1313
| Ⅴ | [深入浅出 Kafka（五）Kafka API](kafka-tutorial-5_kafka-api.md) | Kafka API 接口使用 | √ |
14-
| Ⅵ | 深入浅出 Kafka（六）Spring Kafka API | Kafka 与 SpringBoot 框架整合，常见 API 接口使用 | |
14+
| Ⅵ | [深入浅出 Kafka（六）Spring Kafka API](kafka-tutorial-6_spring-kafka-api.md) | Kafka 与 SpringBoot 框架整合，常见 API 接口使用 | √ |
1515
| Ⅶ | 深入浅出 Kafka（七）监控 | Kafka Monitor，Kafka Manager | |
1616

1717

‎notes/MicroService/kafka/kafka-tutorial-1_初识.md‎

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,18 @@
1+
2+
<!-- TOC -->
3+
4+
- [深入浅出 Kafka（一）初识](#深入浅出-kafka一初识)
5+
- [一、定义](#一定义)
6+
- [二、消息队列（Message Queue）](#二消息队列message-queue)
7+
- [传统消息队列的应用场景](#传统消息队列的应用场景)
8+
- [使用消息队列的好处](#使用消息队列的好处)
9+
- [消息队列的两种模式](#消息队列的两种模式)
10+
- [1. 点对点（Queue，不可重复消费）](#1-点对点queue不可重复消费)
11+
- [2. 发布/订阅（Topic，可以重复消费）](#2-发布订阅topic可以重复消费)
12+
- [三、Kafka基础架构](#三kafka基础架构)
13+
- [参考资料](#参考资料)
14+
15+
<!-- /TOC -->
116
# 深入浅出 Kafka（一）初识
217

318
> 开始前，可以阅读 Kafka 官方介绍：[Kafka 中文文档 - ApacheCN](http://kafka.apachecn.org/intro.html)

‎notes/MicroService/kafka/kafka-tutorial-2_单节点部署.md‎

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,27 @@
1+
<!-- TOC -->
2+
3+
- [深入浅出 Kafka（二）单节点部署](#深入浅出-kafka二单节点部署)
4+
- [系统环境](#系统环境)
5+
- [一、宿主机部署](#一宿主机部署)
6+
- [安装 Zookeeper（可选择，自带或是独立的 zk 服务）](#安装-zookeeper可选择自带或是独立的-zk-服务)
7+
- [下载 Kafka](#下载-kafka)
8+
- [启动 Zookeeper 服务（可选择，自带或是独立的 zk 服务）](#启动-zookeeper-服务可选择自带或是独立的-zk-服务)
9+
- [启动 Kafka 服务](#启动-kafka-服务)
10+
- [创建 Topic](#创建-topic)
11+
- [查看 Topic](#查看-topic)
12+
- [产生消息](#产生消息)
13+
- [消费消息](#消费消息)
14+
- [删除 Topic](#删除-topic)
15+
- [查看描述 Topic 信息](#查看描述-topic-信息)
16+
- [二、容器化部署](#二容器化部署)
17+
- [1 Zookeeper + 1 Kafka](#1-zookeeper--1-kafka)
18+
- [与容器内的开发环境交互](#与容器内的开发环境交互)
19+
- [三、Kafka 配置说明](#三kafka-配置说明)
20+
- [参考资料](#参考资料)
21+
22+
<!-- /TOC -->
23+
24+
125
# 深入浅出 Kafka（二）单节点部署
226

327
> 单节点部署环境，主要用于学习与调试。集群化部署方案，请访问「深入浅出 Kafka（三）集群化部署」；若部署完单节点想进一步学习，请转向「深入浅出 Kafka（四）架构深入」。

‎notes/MicroService/kafka/kafka-tutorial-4_架构深入.md‎

Lines changed: 29 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,32 @@
1+
<!-- TOC -->
2+
3+
- [深入浅出 Kafka（四）架构深入](#深入浅出-kafka四架构深入)
4+
- [一、Kafka 工作流程及文件存储机制](#一kafka-工作流程及文件存储机制)
5+
- [二、Kafka 生产者](#二kafka-生产者)
6+
- [1. 分区策略](#1-分区策略)
7+
- [（1）分区的原因](#1分区的原因)
8+
- [（2）分区的原则](#2分区的原则)
9+
- [2. 数据可靠性保证](#2-数据可靠性保证)
10+
- [（1）副本数据同步策略](#1副本数据同步策略)
11+
- [（2）ISR](#2isr)
12+
- [（3）ack 应答机制](#3ack-应答机制)
13+
- [（4）ack 参数设置(asks)](#4ack-参数设置asks)
14+
- [（4）数据一致性问题（故障处理）](#4数据一致性问题故障处理)
15+
- [3. Exactly Once 语义](#3-exactly-once-语义)
16+
- [三、Kafka 消费者](#三kafka-消费者)
17+
- [1. 消费方式](#1-消费方式)
18+
- [2. 分区分配策略](#2-分区分配策略)
19+
- [3. offset 的维护](#3-offset-的维护)
20+
- [四、Kafka 高效读写数据](#四kafka-高效读写数据)
21+
- [1. 顺序写磁盘](#1-顺序写磁盘)
22+
- [2. 零拷贝技术](#2-零拷贝技术)
23+
- [五、Zookeeper 在 Kafka 中的作用](#五zookeeper-在-kafka-中的作用)
24+
- [六、Kafka 事务](#六kafka-事务)
25+
- [1. Producer事务事务](#1-producer事务事务)
26+
- [2. Consumer **事务**](#2-consumer-事务)
27+
28+
<!-- /TOC -->
29+
130
# 深入浅出 Kafka（四）架构深入
231

332
## 一、Kafka 工作流程及文件存储机制

‎notes/MicroService/kafka/kafka-tutorial-5_kafka-api.md‎

Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,26 @@
1+
<!-- TOC -->
2+
3+
- [深入浅出 Kafka（五）Kafka API](#深入浅出-kafka五kafka-api)
4+
- [一、Producer API](#一producer-api)
5+
- [1. 消息发送流程](#1-消息发送流程)
6+
- [2. 异步发送 API](#2-异步发送-api)
7+
- [（1）不带回调函数的异步（AsyncProducer）](#1不带回调函数的异步asyncproducer)
8+
- [（2）带回调函数的异步（CallbackProducer）](#2带回调函数的异步callbackproducer)
9+
- [3. 同步发送 API](#3-同步发送-api)
10+
- [（1）同步发送（SyncProducer）](#1同步发送syncproducer)
11+
- [二、Consumer API](#二consumer-api)
12+
- [1. 自动提交 offset](#1-自动提交-offset)
13+
- [2. 手动提交 offset](#2-手动提交-offset)
14+
- [（1）同步提交 commitSync offset](#1同步提交-commitsync-offset)
15+
- [（2）异步提交 commitAsync offset](#2异步提交-commitasync-offset)
16+
- [（3）数据漏消费和重复消费分析](#3数据漏消费和重复消费分析)
17+
- [3. 自定义存储 offset](#3-自定义存储-offset)
18+
- [三、自定义 Interceptor](#三自定义-interceptor)
19+
- [1. 拦截器原理](#1-拦截器原理)
20+
- [2. 拦截器案例](#2-拦截器案例)
21+
22+
<!-- /TOC -->
23+
124
# 深入浅出 Kafka（五）Kafka API
225

326
## 一、Producer API

‎notes/MicroService/kafka/kafka-tutorial-6_spring-kafka-api.md‎

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,17 @@
1+
<!-- TOC -->
2+
3+
- [深入浅出 Kafka（六）Spring Kafka API](#深入浅出-kafka六spring-kafka-api)
4+
- [一、Producer](#一producer)
5+
- [1. KafkaProducer](#1-kafkaproducer)
6+
- [2. KafkaProducerConfig](#2-kafkaproducerconfig)
7+
- [二、Consumer](#二consumer)
8+
- [3. KafkaConsumer](#3-kafkaconsumer)
9+
- [4. KafkaConsumerConfig](#4-kafkaconsumerconfig)
10+
- [三、配置文件](#三配置文件)
11+
- [四、pom 依赖](#四pom-依赖)
12+
- [参考资料](#参考资料)
13+
14+
<!-- /TOC -->
115
# 深入浅出 Kafka（六）Spring Kafka API
216

317
　　在上一节中学习了如何通过 Kafka API 的方式进行生产者和消费者及其配置，但是主要是通过手动编写 Java 代码的方式实现。在项目开发中，我们主要会使用到 SpringBoot 框架，这里就将带你 SpringBoot 与 Kafka 整合，通过注解和配置的方式轻松集成。

0 commit comments

Comments
 (0)