Kafka單機版環境搭建及使用教程

2021-10-23 00:24:00 字數 1662 閱讀 5139

其中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...