技術標籤：Kafka

kafka-之/bin/內部指令碼的使用（包括分割槽重分配、消費者組消費情況、索引檔案檢視）

1 topic相關操作

kafka-topic.sh --create --zookeeper zkhost:2181 --partitions 1 --replication-factor 2 --topic topic_name  # 建立topic
kafka-topic.sh --zookeeper zkhost:2181 --list  # 列出所有的topic
kafka-topic.sh --describe #描述topic
kafka-topic.sh --delete	# 刪除topic
 

kafka-topic.sh --alter # 修改topic的分割槽和副本資訊，但是不能刪除分割槽

2 消費者組相關

# 檢視叢集正在消費的消費組的情況
kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list
>>radom_group_id 

# 檢視該消費者組的所有消費者對所消費topic的消費情況，滯後情況，LEO情況
kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group radom_group_id
 

具體查詢樣例如下圖：

3 日誌索引相關

# 檢視索引檔案的詳情
kafka-dump-log.sh --files 00000000000000000000.index
>>>>>>>
(base) bogon:topic1-0 shufang$ kafka-dump-log.sh --files 00000000000000000000.index 
Dumping 00000000000000000000.index
offset: 45 position: 4140  #代表團一個RecordBatch
offset: 90 position: 8266  #代表另一個RecordBatch


# 檢視日誌檔案詳情
kafka-dump-log.sh --files 00000000000000000000.log #1
 

kafka-run-class.sh kafka.tools.DumpLogSegments --files  /00000000000000000000.log #2

具體查詢樣例如下：

4 壓力測試相關

kafka壓力測試、生產者、消費者效能測試操作指令碼執行請參考本人部落格：

https://blog.csdn.net/shufangreal/article/details/111299613

5 分割槽重分配相關（負載均衡操作）

優先副本選舉、分割槽重分配、副本資料複製限流操作

這個操作可以參考本人部落格：https://blog.csdn.net/shufangreal/article/details/111277503