From c6e216db9acbe83530e7f6a4f38acb89d3a7865e Mon Sep 17 00:00:00 2001 From: asahi Date: Wed, 12 Nov 2025 14:52:25 +0800 Subject: [PATCH] =?UTF-8?q?doc:=20kafka=E6=96=87=E6=A1=A3=E6=96=B0?= =?UTF-8?q?=E5=A2=9E=E7=9B=AE=E5=BD=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- mq/kafka/kafka.md | 51 +++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 51 insertions(+) diff --git a/mq/kafka/kafka.md b/mq/kafka/kafka.md index 9827b9b..a7063ae 100644 --- a/mq/kafka/kafka.md +++ b/mq/kafka/kafka.md @@ -1,3 +1,54 @@ +- [Apache Kafka](#apache-kafka) + - [Introduction](#introduction) + - [Topic and Logs](#topic-and-logs) + - [Distribution](#distribution) + - [Producers](#producers) + - [Consumers](#consumers) + - [multi-tenancy(多租户)](#multi-tenancy多租户) + - [Guarantees](#guarantees) + - [Kafka Storage System](#kafka-storage-system) + - [Quick Start](#quick-start) + - [Start the server](#start-the-server) + - [Create a topic](#create-a-topic) + - [Send Some Message](#send-some-message) + - [Start a consumer](#start-a-consumer) + - [Setting multi-broker cluster](#setting-multi-broker-cluster) + - [APIS](#apis) + - [Producer API](#producer-api) + - [Consumer API](#consumer-api) + - [Stream API](#stream-api) + - [Admin API](#admin-api) + - [Configuration](#configuration) + - [Broker Configs](#broker-configs) + - [Broker Configs 动态更新](#broker-configs-动态更新) + - [动态更新Password Configs](#动态更新password-configs) + - [在启动broker之前更新zookeeper password config](#在启动broker之前更新zookeeper-password-config) + - [Design](#design) + - [Motivation](#motivation) + - [Persistence](#persistence) + - [filesystem store structure](#filesystem-store-structure) + - [Constant Time Suffices](#constant-time-suffices) + - [效率](#效率) + - [small I/O](#small-io) + - [byte copying](#byte-copying) + - [端对端的批量压缩](#端对端的批量压缩) + - [生产者](#生产者) + - [负载均衡](#负载均衡) + - [异步发送](#异步发送) + - [消费者](#消费者) + - [push vs pull](#push-vs-pull) + - [consumer position](#consumer-position) + - [静态成员](#静态成员) + - [消息传递语义](#消息传递语义) + - [复制](#复制) + - [分区备份](#分区备份) + - [broker节点的活跃状态定义](#broker节点的活跃状态定义) + - [ISR](#isr) + - [消息提交的定义](#消息提交的定义) + - [acks](#acks) + - [最小写入副本数](#最小写入副本数) + + # Apache Kafka ## Introduction Apache Kafka是一个分布式的stream平台,具有如下三个核心功能: