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