Skip to content

11. Kafka 网络协议详解 ​

本章深入分析 Kafka 自定义网络协议的实现,包括请求/响应格式、版本协商、消息编解码等核心机制。

章节目录 ​

文档内容难度
01-protocol-overview.md协议概述⭐
02-request-response-format.md请求响应格式⭐⭐
03-message-format.md消息格式演进⭐⭐⭐
04-version-negotiation.md版本协商机制⭐⭐
05-serialization.md序列化机制⭐⭐
06-network-client.mdNetworkClient 实现⭐⭐⭐
07-security-protocol.md安全协议⭐⭐

核心概念速查 ​

协议层次 ​

┌─────────────────────────────────────────────┐
│              应用层协议                      │
│  - Produce/Fetch/Metadata 等请求             │
├─────────────────────────────────────────────┤
│              消息格式层                      │
│  - RecordBatch / Record                      │
├─────────────────────────────────────────────┤
│              传输层协议                      │
│  - TCP + Kafka 自定义帧格式                  │
└─────────────────────────────────────────────┘

关键请求类型 ​

ApiKey名称说明
0Produce生产消息
1Fetch拉取消息
3Metadata获取元数据
8OffsetCommit提交 Offset
9OffsetFetch获取 Offset
10FindCoordinator查找协调器
11JoinGroup加入消费组
14SyncGroup同步消费组

学习路径 ​

快速了解 ​

  1. 协议概述

深入理解 ​

  1. 请求响应格式
  2. 消息格式
  3. 序列化机制

高级特性 ​

  1. 版本协商
  2. NetworkClient
  3. 安全协议

相关章节 ​


上一章: 10. Consumer 消费者

教程完结 🎉