Kafka 命令速查
共 20 条 Kafka 命令行工具速查，覆盖 Topic 管理、生产与消费、消费组、配置与运维 四组场景。支持搜索与分类筛选，点击命令即可复制。
Topic 管理
脚本位于 $KAFKA_HOME/bin。
| 命令 | 说明 |
|---|---|
| 列出所有 topic | |
| 创建 topic（分区数 / 副本数） | |
| 查看 topic 分区、副本与 ISR | |
| 增加分区数（不能减少） | |
| 删除 topic |
生产与消费
用自带控制台脚本快速收发消息。
| 命令 | 说明 |
|---|---|
| 从控制台一行一条发送消息 | |
| 带 key 发送（key:value 格式） | |
| 从头消费并打印消息 | |
| 以消费组身份消费（可记录位点） | |
| 打印 key 与 value |
消费组
查看与重置位点。
| 命令 | 说明 |
|---|---|
| 列出所有消费组 | |
| 查看消费组位点与积压（LAG） | |
| 把位点重置到最早（需先停止消费） | |
| 把位点重置到最新 | |
| 删除消费组（需无活跃成员） |
配置与运维
查看配置、日志目录与集群启动。
| 命令 | 说明 |
|---|---|
| 查看 topic 的动态配置 | |
| 修改 topic 配置（如保留时长） | |
| 查看各 broker 的日志目录占用 | |
| 后台启动 broker（ZooKeeper 模式） | |
| KRaft 模式格式化存储目录 |
使用说明
Kafka 命令行工具速查：Topic 管理、生产与消费、消费组、配置与运维；支持搜索与分类筛选，点击命令即可复制。
- 按用途点分类：Topic 管理、生产与消费、消费组、配置与运维。
- 点「命令」列复制，替换 --bootstrap-server 地址、topic 与消费组名后执行。
- 排查消息积压：用 kafka-consumer-groups.sh --describe 看各分区 LAG。
- 重放历史消息：停掉消费后 --reset-offsets 重置位点，再重启消费。
常见问题
- 分区数能减少吗？
- 不能。Kafka 只支持增加分区；增加后已有的按 key 分区消息可能改变落点，需谨慎。分区数应在创建时就规划好。
- 怎么查看消费有没有积压？
- 用 kafka-consumer-groups.sh --describe --group <组名>，看 LAG 列：LAG 即该分区「最新位点 - 消费位点」的差值，持续增大说明消费跟不上。
- 重置位点会丢消息吗？
- 重置本身只是移动消费位置，不删除数据；但把位点设到 latest 会跳过旧消息，设到 earliest 会重放。执行前务必先停止该组的消费者。
- ZooKeeper 模式和 KRaft 模式有什么区别？
- 老版本用 ZooKeeper 管理集群元数据；新版本（KRaft）去掉了 ZooKeeper，用 kafka-storage.sh format 初始化、由 Kafka 自身管理元数据，部署更简单。
延伸阅读
相关工具
RBT
Robot Framework 速查
*** Test Cases *** / robot / 关键字 速查
GTLG
Gatling 速查
Simulation / inject / check / feeder 速查
LCST
Locust 速查
HttpUser / @task / --headless / 分布式 速查
MDB
MariaDB 速查
mariadb CLI / SQL / mariadb-dump 速查
CBSE
Couchbase 速查
N1QL / Collection / get/upsert 速查
SCYA
ScyllaDB 速查
cqlsh / CREATE TABLE / nodetool 速查