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/local/kafka
bin/zookeeper-server-start.sh config/zookeeper.properties
cd /usr/local/kafka
bin/kafka-server-start.sh config/server.properties
接下來用producer生產點資料
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic hzau然後再次開啟新的終端或者直接按ctrl+c退出。然後使用consumer來接收資料,輸入如下命令
便可以看到剛才產生的2條資訊。說明kafka安裝成功
kafka安裝與測試
基於linux centos7.0環境先進行測試學習 producer即生產者，向kafka集 送訊息，在傳送訊息之前，會對訊息進行分類，即topic，topic即主題，通過對訊息指定主題可以將訊息分類，消費者可以只關注自己需要的topic中的訊息 consumer即消費者，消費者通過與kafka集...
kafka 集群安裝與安裝測試
一 集群安裝 解壓 tar zxvf kafka 2.9.2 0.8.1.tgz rpm ivh sbt.rpm 3.更新scala環境 sbt update sbt package sbt assembly package dependency sbt sbt dependency 不同版本命令不...
Kafka安裝測試
wget 2 上傳至linux下並解壓 3 啟動服務 3.1 啟動zookeeper 啟動zk有兩種方式，第一種是使用kafka自己帶的乙個zk。bin zookeeper server start.sh config zookeeper.properties 另一種是使用其它的zookeeper，...