天天看點

CDH內建kafka

添加kafka   (所有程式包都是放在cm主機上面)

  1.下載下傳kafka包http://archive.cloudera.com/kafka/parcels/latest/

   把包放到parcel-repo 目錄

CDH內建kafka

2.下載下傳csd包http://archive.cloudera.com/csds/kafka/

放到csd目錄

CDH內建kafka

3.配置設定kafka包并激活

CDH內建kafka
CDH內建kafka

注意:如果進度卡在“已解壓”,直接傳回重新進來就會看到“激活”

4添加kafka角色

CDH內建kafka

預設選項即可

安裝後啟動報錯Java heap space (如下圖)

需要修改Java記憶體,預設50M,這點很奇怪,安裝過程中沒提示讓設定記憶體,結果執行完安裝後無法啟動

CDH內建kafka

進入kafka選“配置”,

繼續閱讀