FusionInsight Kafka刪除Topic失敗原因及解決方案

一、無權限

創(chuàng)建Topic會報錯“ERROR kafka.admin.AdminOperationException: Error while deleting topic topicName

解決辦法是使用具有kafkaadmin權限的用戶。

二、“topic.enable”配置為false

FusionInsight Manager頁面“集群->Kafka->配置->全部配置”查看Kafka服務端delete.topic.enable參數(shù)配置。

如果參數(shù)設置為false，改為true后保存并重啟kafka服務。

三、節(jié)點異常或節(jié)點磁盤下線或數(shù)據(jù)目錄異常

1. 節(jié)點異常

FusionInsight Manager頁面“集群->Kafka->實例”查看各個實例狀態(tài)是否是良好。

2. 磁盤下線

FusionInsight Manager有沒有“數(shù)據(jù)目錄狀態(tài)異常”的告警。Topic副本所在節(jié)點server.log日志中搜“offline”關鍵字和“checkpoint file”關鍵字查看磁盤是否下線或因checkpoint文件問題沒有上線。搜“cannot allocate memory”關鍵字查看是否內(nèi)存不足導致。搜“No space left”關鍵字查看是否磁盤寫滿。

注意：出現(xiàn)“數(shù)據(jù)目錄狀態(tài)異常”的告警后，只有重啟告警節(jié)點才可以使磁盤重新上線。

3. 數(shù)據(jù)目錄權限異常

節(jié)點上Kafka數(shù)據(jù)目錄（一般是“/srv/BigData/kafka/dataX/kafka-logs”）目錄權限是否正常。

四、刪除后又自動創(chuàng)建Topic

FusionInsight Manager頁面“集群->Kafka”查看controller所在主機節(jié)點，此節(jié)點上Kafka日志目錄中查看controller.log，如果日志中有“Deletion of topic topicName successfully completed”和“New topics: [Set(topicName)]”說明topic又被自動創(chuàng)建。

五、Controller未執(zhí)行刪除

如果controller.log日志中只有“Starting topic deletion”日志而未打印具體的執(zhí)行成功或失敗的日志，可嘗試切controller，步驟如下：

1. 進FI客戶端（例如/opt/hadoopclient）

2. 執(zhí)行zkCli.sh -server zk業(yè)務IP：24002/kafka

3. 執(zhí)行get /controller

4. 若獲取到controller信息，執(zhí)行deleteall /controller和get /controller。

FusionInsight Kafka

版權聲明：本文內(nèi)容由網(wǎng)絡用戶投稿，版權歸原作者所有，本站不擁有其著作權，亦不承擔相應法律責任。如果您發(fā)現(xiàn)本站中有涉嫌抄襲或描述失實的內(nèi)容，請聯(lián)系我們jiasou666@gmail.com 處理，核實后本網(wǎng)站將在24小時內(nèi)刪除侵權內(nèi)容。