kafka裡的一些管理指令碼

2022-03-01 13:32:23 字數 1011 閱讀 7985

kafka-server-start指令碼 ------啟動kafka server

kafka-server-stop指令碼 ------關閉kafka server

kafka-topics指令碼 --------------負責kafka中topic相關操作。如:建立topic,查詢topic詳細資訊,新增分割槽並完成新增的副本等等

kafka-preferred-replica-election指令碼 ----------------觸發指定的分割槽進行「優先副本」的選舉,這樣可以讓分割槽leader副本在集群中分布更均勻

kafka-reassign-partition指令碼 --------------主要有三個功能:1.生成副本遷移方案;2.觸發副本遷移操作,即將遷移方案寫入到zookeeper中,從而觸發partitionreassignedlistener處理;3.檢測指定分割槽的副本遷移是否完成

kafka-console-producer指令碼 -----------------控制台版本的生產者,我們可以在控制台輸入訊息的key-value,通過該指令碼傳送給服務端

kafka-console-consumer指令碼 -----------控制台版本的消費者,我們可以指定訂閱的topic,使用指令碼從服務端拉取訊息並輸出到控制台

kafka-consumer-groups指令碼 --------------主要有兩個功能:1.查詢當前所有consumer group;2.獲取指定consumer group的詳細資訊

dumplogsegments

可由kafka-run-class指令碼執行,主要負責解析輸出指定的日誌檔案和索引檔案中的內容,還可以實現索引檔案的驗證。

kafka-producer-perf-test指令碼--------------- 測試生產者的各項效能指標

kafka-consumer-perf-test指令碼--------------- 測試消費者的各項效能指標

kafka-mirrir-maker指令碼-------------- 實現了資料在多個集群的同步,可用於kafka集群的映象製作

kafka的一些指令碼命令

1.啟動kafka服務 啟動zookeeper bin zookeeper server start.sh config zookeeper.properties 啟動kafka bin kafka server start.sh config server.properties 2.建立乙個主題 ...

kafka的一些引數

python操作kafka 需求,如果topic不存在,不允許自動建立 每個topic的分割槽個數,更 多的partition會產生更多的segment file num.partitions 2 是否允許自動建立topic 若是false,就需要通過命令建立topic auto.create.to...

RMAN的一些指令碼

confifure controlfile autobackup format device type disk to uo1 backup f configure controlfile autobackup on drop tablespace test including contents a...