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 &

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

例如zookeeper.connect=10.202.4.179:2181

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

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

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

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

比如

test

hello boy

按ctrl+c退出傳送訊息

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 3.啟動服務 3.1 啟動zookeeper 啟動zk有兩種方式，第一種是使用kafka自己帶的乙個zk。bin zookeeper server start.sh confi...

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