Docker 运行 Kafka

这一课你将能做到

1. 用 Docker Compose 拉起单节点 KRaft 模式 Broker（无 ZooKeeper），并用 localhost:9092 作为 bootstrap
2. 创建 3 分区 Topic，用 kafka-topics --describe 核对分区数与副本因子
3. 用 kafka-console-producer/consumer 完成「先发后收 / 从头消费」闭环，并写出 Spring 的连接配置

为什么要学

概念图再熟，没有 Broker 就无法验证分区、offset 与消费组行为。本地用 KRaft 单节点 最省事：新版 Kafka 已用内置 Raft 元数据管理替代 ZooKeeper，一个容器搞定，和你跑 Redis 的 Compose 体验一致。

本课目标是 能起、能建、能收发：搭好后，后面 Java 客户端、Spring Kafka、Streams 全部连这个 localhost:9092。生产要多 Broker、副本 ≥ 2、监听器安全（SASL/SSL），那些是上线话题，不阻碍今天动手。

人话：先在自己机器上开一扇 9092 的门，后面所有代码都敲这扇门。

先建立图像

你的电脑
  docker compose
    └── kafka 容器（KRaft：broker + controller 同进程）
          监听 9092  ←──  宿主机 localhost:9092
          监听 9093  ←──  controller 内部用
          分区日志存容器内（实验数据可丢）

终端 A: kafka-console-consumer  (订阅 Topic)
终端 B: kafka-console-producer  (追加记录)
Spring: spring.kafka.bootstrap-servers=localhost:9092

项	实验取值	生产直觉
模式	KRaft 单节点	多 controller quorum / 多 broker
replication-factor	1	≥ 2（常见 3）
分区数	3（方便看分摊）	按吞吐与消费者数规划
数据	可随时 down -v 清空	挂卷、有备份与监控

跟着做

步骤 1：准备 Compose 文件

在实验目录新建 docker-compose.yml（KRaft 单节点，无 ZooKeeper）：

services:
  kafka:
    image: apache/kafka:3.9.0
    container_name: kafka-lab
    ports:
      - "9092:9092"
    environment:
      # 单节点同时扮演 broker 与 controller（KRaft）
      KAFKA_NODE_ID: 1
      KAFKA_PROCESS_ROLES: broker,controller
      KAFKA_LISTENERS: PLAINTEXT://0.0.0.0:9092,CONTROLLER://0.0.0.0:9093
      # 广播给客户端的地址必须是宿主机能访问到的
      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://localhost:9092
      KAFKA_CONTROLLER_LISTENER_NAMES: CONTROLLER
      KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT
      KAFKA_CONTROLLER_QUORUM_VOTERS: 1@localhost:9093
      # 单节点必须把内部 topic 副本降为 1，否则启动/建 topic 会失败
      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
      KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR: 1
      KAFKA_TRANSACTION_STATE_LOG_MIN_ISR: 1
      KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS: 0