安裝Java
- 下載JDK http://www.oracle.com/technetwork/java/javase/downloads/index.html
- chmod +x jdk-8u131-linux-x64.rpm
- cd /usr/java (進(jìn)入要將Java安裝到的目錄，如果沒有請(qǐng)自己創(chuàng)建)
- rpm -ivh ~/jdk-8u131-linux-x64.rpm
- echo "export JAVA_HOME=/usr/java/jdk1.8.0_131" >> /etc/profile
安裝Kafka
- 下載 https://www.apache.org/dyn/closer.cgi?path=/kafka/0.11.0.0/kafka_2.11-0.11.0.0.tgz
- tar xzf kafka_2.11-0.11.0.0.tgz, mv kafka_2.11-0.11.0.0 /opt/
- export KAFKA_HOME=/opt/kafka_2.11-0.11.0.0
- export PATH=$PATH:$KAFKA_HOME/bin
創(chuàng)建一個(gè)單節(jié)點(diǎn)單broker集群
- 啟動(dòng)zookeeper服務(wù)：bin/zookeeper-server-start.sh config/zookeeper.properties
- 啟動(dòng)Kafka Broker：bin/kafka-server-start.sh config/server.properties
測(cè)試
- 創(chuàng)建一個(gè)Topic: bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic kafkatopic
- 查看topic列表: bin/kafka-topics.sh --list --zookeeper localhost:2181
- 起一個(gè)發(fā)往 kafkatopic 的生產(chǎn)者：bin/kafka-console-producer.sh --broker-list localhost:9092 --topic kafkatopic,隨便輸入寫數(shù)據(jù)作為消息發(fā)送
- 起一個(gè)消費(fèi)者：bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic kafkatopic --from-beginning
