以下是 Kafka 常用命令的详细汇总，包含了常见的操作命令以及使用案例，表格形式方便查看
| 命令 | 功能 | 命令格式 | 使用案例 |
|---|---|---|---|
| 查看 Kafka 版本 | 查看 Kafka 的版本信息 | bin/kafka-topics.sh --version | 获取 Kafka 版本信息：bin/kafka-topics.sh --version |
| 创建 Kafka 主题 | 创建一个新的 Kafka 主题 | bin/kafka-topics.sh --create --topic <topic_name> --partitions <num_partitions> --replication-factor <replication_factor> --bootstrap-server <broker> | 创建主题 my_topic，分区数为 3，副本数为 2：bin/kafka-topics.sh --create --topic my_topic --partitions 3 --replication-factor 2 --bootstrap-server 127.0.0.1:9092 |
| 列出 Kafka 主题 | 列出当前 Kafka 集群的所有主题 | bin/kafka-topics.sh --list --bootstrap-server <broker> | 列出 Kafka 中所有主题：bin/kafka-topics.sh --list --bootstrap-server 127.0.0.1:9092 |
| 删除 Kafka 主题 | 删除一个现有的 Kafka 主题 | bin/kafka-topics.sh --delete --topic <topic_name> --bootstrap-server <broker> | 删除主题 my_topic：bin/kafka-topics.sh --delete --topic my_topic --bootstrap-server 127.0.0.1:9092 |
| 查看主题详情 | 查看某个 Kafka 主题的详细信息 | bin/kafka-topics.sh --describe --topic <topic_name> --bootstrap-server <broker> | 查看主题 my_topic 的详情：bin/kafka-topics.sh --describe --topic my_topic --bootstrap-server 127.0.0.1:9092 |
| 启动 Kafka 服务 | 启动 Kafka 服务 | bin/kafka-server-start.sh config/server.properties | 启动 Kafka 服务：bin/kafka-server-start.sh config/server.properties |
| 停止 Kafka 服务 | 停止 Kafka 服务 | bin/kafka-server-stop.sh | 停止 Kafka 服务：bin/kafka-server-stop.sh |
| 发送消息到 Kafka 主题 | 向 Kafka 主题发送消息 | bin/kafka-console-producer.sh --topic <topic_name> --bootstrap-server <broker> | 向 my_topic 发送消息：bin/kafka-console-producer.sh --topic my_topic --bootstrap-server 127.0.0.1:9092 |
| 查看 Kafka 主题的消息 | 查看 Kafka 主题的消息 | bin/kafka-console-consumer.sh --topic <topic_name> --from-beginning --bootstrap-server <broker> | 查看 my_topic 的消息：bin/kafka-console-consumer.sh --topic my_topic --from-beginning --bootstrap-server 127.0.0.1:9092 |
| 查看 Kafka 消费者组信息 | 查看消费者组的偏移量和状态 | bin/kafka-consumer-groups.sh --describe --group <group_name> --bootstrap-server <broker> | 查看消费者组 my_group 的信息：bin/kafka-consumer-groups.sh --describe --group my_group --bootstrap-server 127.0.0.1:9092 |
以下是详细命令解析与使用案例
- 查看 Kafka 版本
查看 Kafka 集群的版本信息，帮助确认安装的 Kafka 版本。
bin/kafka-topics.sh --version
- 创建 Kafka 主题
创建一个新的 Kafka 主题，必须指定主题名称、分区数、和副本数。
bin/kafka-topics.sh --create --topic my_topic --partitions 3 --replication-factor 2 --bootstrap-server 127.0.0.1:9092
- 列出 Kafka 主题
查看当前 Kafka 集群中的所有主题，帮助了解集群的结构。
bin/kafka-topics.sh --list --bootstrap-server 127.0.0.1:9092
- 删除 Kafka 主题
删除一个不再需要的 Kafka 主题，释放资源。
bin/kafka-topics.sh --delete --topic my_topic --bootstrap-server 127.0.0.1:9092
- 查看主题详情
查看 Kafka 中某个主题的详细信息，包括分区数、副本分配情况等。
bin/kafka-topics.sh --describe --topic my_topic --bootstrap-server 127.0.0.1:9092
- 启动 Kafka 服务
启动 Kafka 服务，使用指定的配置文件启动 Kafka 服务器。
bin/kafka-server-start.sh config/server.properties
- 停止 Kafka 服务
停止 Kafka 服务，可以在集群维护时使用此命令。
bin/kafka-server-stop.sh
- 发送消息到 Kafka 主题
使用生产者命令行工具发送消息到 Kafka 主题，模拟消息推送。
bin/kafka-console-producer.sh --topic my_topic --bootstrap-server 127.0.0.1:9092
- 查看 Kafka 主题的消息
使用消费者命令行工具从 Kafka 主题中消费消息。
bin/kafka-console-consumer.sh --topic my_topic --from-beginning --bootstrap-server 127.0.0.1:9092
- 查看 Kafka 消费者组信息
查看某个消费者组的偏移量和消费状态，常用于消费进度监控。
bin/kafka-consumer-groups.sh --describe --group my_group --bootstrap-server 127.0.0.1:9092
