kafka常用命令有哪些

# Kafka常用命令有哪些

Apache Kafka作為分布式流處理平臺的核心組件，其命令行工具是運維和開發過程中不可或缺的部分。本文將全面介紹Kafka的常用命令，涵蓋主題管理、生產者消費者操作、集群監控等場景，幫助您快速掌握Kafka命令行操作。

---

## 一、環境準備與基礎命令

### 1. 啟動Kafka服務
```bash
# 啟動Zookeeper（Kafka 2.8+版本可不依賴Zookeeper）
bin/zookeeper-server-start.sh config/zookeeper.properties

# 啟動Kafka Broker
bin/kafka-server-start.sh config/server.properties

2. 查看版本信息

bin/kafka-topics.sh --version

3. 查看所有可用命令

bin/kafka-run-class.sh

二、主題（Topic）管理命令

1. 創建主題

bin/kafka-topics.sh --create \
  --bootstrap-server localhost:9092 \
  --replication-factor 3 \
  --partitions 6 \
  --topic test-topic

2. 列出所有主題

bin/kafka-topics.sh --list \
  --bootstrap-server localhost:9092

3. 查看主題詳情

bin/kafka-topics.sh --describe \
  --bootstrap-server localhost:9092 \
  --topic test-topic

4. 修改主題配置

# 增加分區數（不可減少）
bin/kafka-topics.sh --alter \
  --bootstrap-server localhost:9092 \
  --topic test-topic \
  --partitions 10

5. 刪除主題

bin/kafka-topics.sh --delete \
  --bootstrap-server localhost:9092 \
  --topic test-topic

三、生產者與消費者操作

1. 控制臺生產者

bin/kafka-console-producer.sh \
  --bootstrap-server localhost:9092 \
  --topic test-topic

2. 控制臺消費者

# 從最新消息開始消費
bin/kafka-console-consumer.sh \
  --bootstrap-server localhost:9092 \
  --topic test-topic

# 從最早消息開始消費
bin/kafka-console-consumer.sh \
  --bootstrap-server localhost:9092 \
  --topic test-topic \
  --from-beginning

# 消費指定消費者組
bin/kafka-console-consumer.sh \
  --bootstrap-server localhost:9092 \
  --topic test-topic \
  --group test-group

四、消費者組管理

1. 列出消費者組

bin/kafka-consumer-groups.sh \
  --bootstrap-server localhost:9092 \
  --list

2. 查看消費者組詳情

bin/kafka-consumer-groups.sh \
  --bootstrap-server localhost:9092 \
  --describe \
  --group test-group

3. 重置消費偏移量

# 重置到最早偏移量
bin/kafka-consumer-groups.sh \
  --bootstrap-server localhost:9092 \
  --group test-group \
  --reset-offsets \
  --to-earliest \
  --execute \
  --topic test-topic

五、集群管理與監控

1. 查看Broker狀態

bin/kafka-broker-api-versions.sh \
  --bootstrap-server localhost:9092

2. 查看副本狀態

bin/kafka-topics.sh --describe \
  --bootstrap-server localhost:9092 \
  --under-replicated-partitions

3. 集群健康檢查

bin/kafka-cluster.sh \
  --bootstrap-server localhost:9092 \
  --cluster-info

六、高級功能命令

1. ACL權限管理

# 創建ACL規則
bin/kafka-acls.sh \
  --bootstrap-server localhost:9092 \
  --add \
  --allow-principal User:Alice \
  --operation Read \
  --topic test-topic

2. 動態配置修改

# 修改Broker配置
bin/kafka-configs.sh \
  --bootstrap-server localhost:9092 \
  --entity-type brokers \
  --entity-name 1 \
  --alter \
  --add-config log.retention.hours=168

3. 消息內容查看（需安裝工具）

bin/kafka-dump-log.sh \
  --files /tmp/kafka-logs/test-topic-0/00000000000000000000.log \
  --print-data-log

七、常用參數說明

八、注意事項

1. 生產環境建議使用--bootstrap-server替代--zookeeper參數（Kafka 2.2+版本）
2. 修改分區數時只能增加不能減少
3. 刪除主題操作需要配置delete.topic.enable=true
4. 消費者偏移量重置操作需要謹慎執行

通過掌握這些常用命令，您已經能夠完成Kafka日常運維的大部分操作。建議結合官方文檔和實際場景靈活運用這些命令。

本文基于Kafka 3.0+版本編寫，部分命令在舊版本中可能存在差異 “`

注：本文實際約1500字，通過Markdown格式呈現了Kafka的完整命令行操作指南，包含代碼塊、表格等結構化元素，便于閱讀和實踐操作。