問題:
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...