Skip to content

Commit a1fd6ee

Browse files
committed
feat: producer processing flow
1 parent cbf22c2 commit a1fd6ee

File tree

7 files changed

+462
-8
lines changed

7 files changed

+462
-8
lines changed

docs/.vitepress/config.mts

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -58,12 +58,14 @@ export default defineConfig({
5858
{ text: '02-kafka命令合集', link: '/notes/kafka/02-kafka-cli' },
5959
{ text: 'Kafka源码系列', items: [
6060
{
61-
text: 'Producer生产者', collapsed: true, items: [
61+
text: 'Producer', collapsed: true, items: [
6262
{ text: 'KafkaProducer源码 - 初始化', link: '/notes/kafka/source-code/producer/producer-init' },
63+
{ text: 'KafkaProducer源码 - 核心流程', link: '/notes/kafka/source-code/producer/producer-processing-flow' },
64+
6365
]
6466
},
6567
{
66-
text: 'Consumer消费者', items: [
68+
text: 'Consumer', items: [
6769
]
6870
}
6971
]

docs/index.md

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -38,6 +38,8 @@ features:
3838
icon:
3939
src: /kafka.svg
4040
details: Apache Kafka 是一个开源分布式事件流平台,被数千家公司用于高性能数据管道、流分析、数据集成和任务关键型应用程序。
41+
link: notes/kafka/kafka-category
42+
linkText: Kafka学习笔记
4143

4244
---
4345

docs/notes/kafka/kafka-category.md

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,13 +1,14 @@
11
---
2-
title: Kafka资料合集
2+
title: Kafka学习笔记
33
tags: kafka
44
---
55

6-
# Kafka文章合集
6+
# Kafka学习笔记
77

88
* [Kakfa概述](./01-intro.md)
99
* [Kafka命令合集](./02-kafka-cli.md)
1010
* Kafka源码系列
11-
* Producer生产者
11+
* Producer
1212
* [KafkaProducer源码 - 初始化](./source-code/producer/producer-init.md)
13-
* 消费者Consumer
13+
* [KafkaProducer源码 - 初始化](./source-code/producer/producer-processing-flow.md)
14+
* Consumer
175 KB
Loading
320 KB
Loading

docs/notes/kafka/source-code/producer/producer-init.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
---
2-
title: Kafka资料合集
2+
title: KafkaProducer源码 - 初始化
33
tags: kafka
44
outline: 'deep'
55
---
@@ -8,7 +8,7 @@ outline: 'deep'
88

99
### <Badge type="tip" text="Kafka" /> <Badge type="tip" text="3.9.0" />
1010

11-
> 此篇介绍原文来自 hsfxuebao 博客 [kafka源码系列](https://juejin.cn/post/7008882455868342285)。原文使用的Kafka版本是0.10.2。本文将代码内容更新到了3.9.0,并且相应的内容也做了修改和补充
11+
> 此篇介绍原文来自 hsfxuebao 博客 [kafka源码系列](https://juejin.cn/post/7008882455868342285)。原文使用的Kafka版本是0.10.2。本文将代码内容更新到了3.9.0,增加了自己的解读,部份内容也做了修改和补充
1212
1313
## 1. Kafka Producer 使用
1414

docs/notes/kafka/source-code/producer/producer-processing-flow.md

Lines changed: 449 additions & 0 deletions
Large diffs are not rendered by default.

0 commit comments

Comments
 (0)