Kafka安裝測試

2021-10-10 21:36:13 字數 1148 閱讀 4013

wget

2、上傳至linux下並解壓

3、啟動服務

3.1、啟動zookeeper

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

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

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

3.2啟動kafka

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

4、建立topic

bin/kafka-topics.sh --create --zookeeper 192.168.52.128:2181(localhost:2181) --replication-factor 1 --partitions 1 --topic test

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

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

bin/kafka-topics.sh -list -zookeeper 192.168.52.128:2181 (localhost:2181)

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

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

啟動之後就可以傳送訊息了,例如:

6、啟動customer

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

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

kafka安裝及其測試

解壓命令 tar zxvf 檔案安裝包 4 1 zookeeper後台啟動 zookeeper server start.sh daemon opt kafka kafka 2.11 1.0.0 config zookeeper.properties 4 2 kafka後台啟動 kafka serv...

Kafka安裝與測試

tar zxf kafka 2.11 2.1.0.tgz c usr local sudo mv usr local kafka 2.11 2.1.0.tgz usr local kafka sudo chown r hadoop usr local kafka 啟動zookeeper cd usr...

kafka安裝與測試

基於linux centos7.0環境先進行測試學習 producer即生產者,向kafka集 送訊息,在傳送訊息之前,會對訊息進行分類,即topic,topic即主題,通過對訊息指定主題可以將訊息分類,消費者可以只關注自己需要的topic中的訊息 consumer即消費者,消費者通過與kafka集...