命令行操作
使用 Kafka 自带脚本进行 Topic 管理、控制台生产/消费、消费者组查看等基本操作。
Windows 下请新开一个 cmd 窗口来执行以下命令（不要关闭正在运行 Kafka 的窗口）。
Topic 管理
Topic（主题）用于区分不同类型的业务消息。
创建 Topic
# 语法
.\bin\windows\kafka-topics.bat --create --topic <Topic名称> --bootstrap-server localhost:9092 --partitions <分区数> --replication-factor <副本数>参数说明：
| 参数 | 含义 |
|---|---|
--topic |
指定 Topic 名称 |
--partitions |
指定分区数（影响并行消费能力） |
--replication-factor |
指定副本数（影响数据可靠性） |
示例：
.\bin\windows\kafka-topics.bat --create --topic my-topic --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1创建成功时显示：Created topic my-topic.
查看已创建的 Topic
# 语法
.\bin\windows\kafka-topics.bat --list --bootstrap-server localhost:9092参数说明：
--list：列出所有已存在的 Topic
设置 Topic 消息保留时间
kafka-configs.bat --bootstrap-server localhost:9092 --entity-type topics --entity-name my-topic --alter --add-config retention.ms=10000参数说明：
| 参数 | 含义 |
|---|---|
--entity-type |
配置类型（此处为 topics） |
--entity-name |
对应的实体名称 |
--alter |
表示修改已有配置 |
--add-config |
添加/修改配置项 |
成功显示：Completed updating config for topic my-topic.
删除 Topic
kafka-topics.bat --bootstrap-server localhost:9092 --delete --topic my-topic删除成功后显示空行（无报错即为成功）。
生产与消费
生产消息
新开一个 cmd 窗口：
.\bin\windows\kafka-console-producer.bat --topic order --bootstrap-server localhost:9092进入交互模式后，输入任意内容并按回车即可发送一条消息。按 Ctrl+C 退出。
消费消息
.\bin\windows\kafka-console-consumer.bat --topic order --from-beginning --bootstrap-server localhost:9092参数说明：
| 参数 | 含义 |
|---|---|
--topic |
指定要订阅的 Topic 名称 |
--from-beginning |
从最早的消息开始读取。如果不加此参数，则默认从上次的 Offset 处开始读取（Offset 由 Kafka 维护） |
--partition |
指定从哪个分区读取 |
--offset |
指定从第几条消息开始读取 |
--group |
指定消费者组 |
消费者组
不需要事先手动创建消费者组——直接在消费命令中通过 --group 指定即可自动创建。
.\bin\windows\kafka-console-consumer.bat --topic order --from-beginning --group testgroup --bootstrap-server localhost:9092核心规则：
- 同一消费者组内的多个消费者共同消费一个 Topic，每条消息只会被组内的一个消费者处理（竞争消费）
- 如果需要多个应用同时消费同一 Topic 的全量消息，需要为每个应用创建不同的消费者组
- 每个消费者组会独立维护自己的 Offset（消费进度）
查看消费者组信息
.\bin\windows\kafka-consumer-groups.bat --bootstrap-server localhost:9092 --describe --group testgroup输出内容包括每个分区的当前 Offset、消费延迟（Lag）等关键信息。
集群
Zookeeper 模式
内容待补充。
KRaft 模式
内容待补充。