精 Kafka問題與解決

2021-09-08 16:55:10 字數 662 閱讀 6523

問題:

1.網域名稱解析失敗

vim /etc/hosts

127.0.0.1 kafka

2.模擬kafka掛掉

kil -9 22789

kafka-server-stop.sh

3.修改broker.id失敗

需要同步修改meta.properties中的id

4.沒有刪除topic

(1)命令刪除

vi config/server.properties  

delete.topic.enable=true

重啟kafka就可以看到效果了

(2)zk刪除1

zkcli.sh

ls /brokers/topics    顯示節點內容

rmr /brokers/topics/mytopic    刪除節點內容

(3)zk刪除2

ls /admin/delete_topics/topic

(3)檔案刪除

刪除kafka儲存目錄

server.properties檔案log.dirs配置,預設為"/home/kafka-logs" 相關topic目錄

rm -rf mytopic-0 mytopic-1 mytopic-2

總結:如果命令不行就結合zk刪除和檔案刪除

kafka解決的問題

假設你意氣風發,要開發新一代的網際網路應用,以期在網際網路事業中一展巨集圖。借助雲計算,很容易開發出如下原型系統 web應用 部署在雲伺服器上,為個人電腦或者移動使用者提供的訪問體驗。sql資料庫 為web應用提供資料持久化以及資料查詢。本質上,這是乙個資料整合問題。沒有任何乙個系統能夠解決所有的事...

精 Kafka單機版安裝與測試

偽分布式中kafka中已經整合了zookeeper 2.解壓kafka tar zxvf kafka 2.11 0.10.0.1.tgz 3.移動到下面資料夾 home software kafka 2.11 0.10.0.1 4.配置檔案 vi etc profile export kafka h...

解決Kafka重複消費問題

某服務 用了springboot spring kafka 處理kafka訊息時,發現每條訊息處理時間長達60 秒。幾百條訊息處理完後,又重新從第一條開始重複消費。kafka消費者有兩個配置引數 max.poll.interval.ms 兩次poll操作允許的最大時間間隔。單位毫秒。預設值30000...