其中2.11代表的是scala的版本資訊
(1)首先去修改config目錄下的zookeeper.properties
其中datadir是快照存放位址,clientport是客戶端連線zookeeper服務的埠。
(2)修改config目錄下的server.properties,修改log.dirs和zookeeper.connect。log.dirs是日誌存放資料夾,zookeeper.connect是zookeeper連線位址(埠和clientport保持一致)。
至此,kafka單機版環境已搭建完畢。(如果對裡面的引數沒修改的話,可不修改,直接用預設的)
(1)啟動kafka自帶的zookeeper(加了-daemon,可以讓這個程序掛在後台進行,否則會發現是個阻塞程序,只能再開乙個終端進行其他操作)
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
(2)啟動kafka
(3)建立乙個topic
(4)檢視topic列表
bin/kafka-topics.sh -list -zookeeper localhost:2181
(5)建立生產者程序 (9092是預設的broker-list埠)
(6)建立消費者程序
單機版kafka的搭建
環境 centos7 jdk1.8 zookeeper3.4.10 kafka2.11 操作前開啟2181和9092埠 1.安裝zookeeper wgettar zxvf zookeeper 3.4.10.tar.gzcd zookeeper 3.4.10 conf將zoo sample.cfg複...
單機版kafka安裝
export server kafka kafka安裝需要有zookeeper註冊中心 其中 zookeeper的安裝 見centos7安裝偽分布式zookeeper root vm 0 2 centos kafka wget2.解壓 root vm 0 2 centos kafka tar zxv...
單機版kafka安裝
wget解壓安裝包 tar xzvf kafka 2.11 2.0.0.tgz修改server.properties檔案 vim kafka 2.11 2.0.0 config server.properties listeners plaintext advertised.listeners pl...