Linux下搭建kafka環境

apache官網

tar -xzf kafka_2.10-0.8.2.2.tgz

cd kafka_2.10-0.8.2.2

3. 啟動服務

3.1 啟動zookeeper

啟動zk有兩種方式，第一種是使用kafka自己帶的乙個zk。

bin/zookeeper-server-start.sh config/zookeeper.properties &

另一種是使用其它的zookeeper，可以位於本機也可以位於其它位址。這種情況需要修改config下面的sercer.properties裡面的zookeeper位址 。例如zookeeper.connect=10.202.4.179:2181

3.2 啟動 kafka

bin/kafka-server-start.sh config/server.properties

4.建立topic

bin/kafka-topics.sh –create –zookeeper 10.202.4.179:2181 –replication-factor 1 –partitions 1 –topic test

建立乙個名為test的topic，只有乙個副本，乙個分割槽。

通過list命令檢視剛剛建立的topic

bin/kafka-topics.sh -list -zookeeper 10.202.4.179:2181

5.啟動producer並傳送訊息啟動producer

bin/kafka-console-producer.sh –broker-list localhost:9092 –topic test

啟動之後就可以傳送訊息了

比如 test

hello boy

按ctrl+c退出傳送訊息

6.啟動consumer

bin/kafka-console-consumer.sh –zookeeper 10.202.4.179:2181 –topic test –from-beginning

啟動consumer之後就可以在console中看到producer傳送的訊息了

可以開啟兩個終端，乙個傳送訊息，乙個接受訊息。

Linux下搭建kafka環境

apache官網 tar xzf kafka 2.10 0.8.2.2.tgz cd kafka 2.10 0.8.2.2 啟動zk有兩種方式，第一種是使用kafka自己帶的乙個zk。bin zookeeper server start.sh config zookeeper.properties ...

Linux下kafka環境搭建

一 安裝jdk 首先檢查是否安裝了jdk，如果沒安裝則先安裝jdk kafka 2.10 0.10.0.1.tgz 三 解壓與配置 1.將壓縮包放到安裝目錄下解壓 tar zxvf kafka 2.10 0.10.0.1.tgz 2.資料夾重新命名 mv kafka 2.10 0.10.0.1 ka...

Linux環境下kafka集群搭建

kafka集群的搭建比較簡單,分以下三步完成.1 解壓 2 配置並分發安裝包 1 配置kafka環境變數 2 修改kafka配置項 log.dir和zookeeper.connect 3 啟動kafka集群 1 修改kafka集群broker的brokerid，遵循0,1,2,3 2 分別啟動bro...