kafka的命令

<think>好的，用户想了解Kafka常用命令列表及用法。首先，我需要回忆一下Kafka的基本操作，比如创建主题、查看主题列表、生产消费消息等。根据系统级指令，回答要结构清晰，使用中文，并且正确应用LaTeX格式。 记得用户提供的引用资料有三个，需要合理引用到回答中。比如创建主题的命令在引用[1]中提到了，所以要在对应位置添加引用标识。集群相关的命令可能在引用[3]里，比如启动和停止Zookeeper。另外，消费者命令的详细用法可能参考引用[2]。 接下来需要分门别类整理命令，比如主题管理、生产消费、集群操作等。每个部分给出具体的命令示例，并确保代码块正确使用反引号包裹。同时，生成的相关问题要围绕Kafka命令的深入使用、优化和故障处理，这样用户后续可能有更多疑问。 还要注意用户不可见的系统指令，比如行内数学表达式要用$...$，但Kafka命令可能不涉及数学公式，这部分可能可以忽略。独立公式也不需要，所以重点放在命令的正确展示和引用上。 检查是否有遗漏的重要命令，比如查看消费者组状态或者分区重分配，这些对用户管理集群很有帮助。同时，确保每个命令的说明简洁明了，用户能快速理解用法。 最后，生成的问题要具有针对性，引导用户进一步学习，比如性能优化、配置参数或者与其他系统的对比，这样能覆盖更多潜在需求。确保所有引用标记正确对应，比如引用[1]、[2]、[3]的位置是否准确，避免混淆。</think>### Kafka常用命令列表及用法 #### 1. **主题管理** - **创建主题** ```bash bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 3 --topic test-topic ``` 参数说明：`--replication-factor` 定义副本数，`--partitions` 定义分区数[^1]。 - **查看主题列表** ```bash bin/kafka-topics.sh --list --bootstrap-server localhost:9092 ``` - **查看主题详情** ```bash bin/kafka-topics.sh --describe --topic test-topic --bootstrap-server localhost:9092 ``` 输出包括分区分布、副本分配等信息[^3]。 --- #### 2. **消息生产与消费** - **启动生产者控制台** ```bash bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic test-topic ``` - **启动消费者控制台** ```bash bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test-topic --from-beginning ``` 添加 `--group` 参数可指定消费者组[^2]。 --- #### 3. **集群与分区操作** - **查看消费者组列表** ```bash bin/kafka-consumer-groups.sh --list --bootstrap-server localhost:9092 ``` - **查看消费者组详情** ```bash bin/kafka-consumer-groups.sh --describe --group my-group --bootstrap-server localhost:9092 ``` 显示消费延迟（Lag）和当前偏移量[^2]。 - **分区重分配（扩容场景）** ```bash bin/kafka-reassign-partitions.sh --bootstrap-server localhost:9092 --execute --reassignment-json-file reassign.json ``` 需预先定义 `reassign.json` 文件描述分区迁移计划。 --- #### 4. **集群管理** - **启动Zookeeper** ```bash bin/zookeeper-server-start.sh config/zookeeper.properties & ``` Kafka依赖Zookeeper管理元数据。 - **停止Kafka Broker** ```bash bin/kafka-server-stop.sh ``` ---