Linux下圖示安裝Kafka
阿新 • • 發佈:2018-11-09
一:Kafka的下載安裝.
1. Kafka官網.
2. 官網下載.
3. Linux下wget+url即可.
wget http://mirror.bit.edu.cn/apache/kafka/2.0.0/kafka_2.12-2.0.0.tgz
4. 解壓到指定的目錄.
tar -zxvf kafka_2.12-2.0.0.tgz -C /usr/local
Kafka的目錄.
配置檔案的目錄.(config)
二 . Kafka的配置啟動.
2.1 vim server.properties.
broker.id=0(broker的全域性唯一編號,不能重複).
log.dirs=/tmp/kafka-logs
zookeeper.connect=192.168.217.134:2181(ZooKeeper叢集配置多個).
zookeeper.connection.timeout.ms=6000
2.2 啟動Zookeeper.
2.3 啟動Kafka.
kafka目錄下:sh bin/kafka-server-start.sh config/server.properties
jps(另外一個視窗執行命令)
啟動生產者:(生產三條訊息.Hello,Kafka,Test).
sh kafka-console-producer.sh --broker-list localhost:9092 --topic testkafka
啟動消費者:
0.9以下的版本使用這個--zookeeper引數.
0.9以上的版本使用如下的方式啟動消費者.
sh kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic testkafka --from-beginning
輸出三條訊息.
啟動三個終端.(啟動一個kafka Server一個終端,生產者一個終端,消費者一個終端).
關閉(Ctrl+C).