環境：CentOS release 6.5 (Final)

1.kafka服務依賴jdk1.7，所以要先裝好jdk

  下載jdk包到伺服器上，但官網上已經沒有這個版本的了，在百度雲盤存了一個。

 下載地址：連結：https://pan.baidu.com/s/1zn4MbanbH20Mviscza3ETQ 密碼：jrks

-rw-r--r--. 1 root root 153512879 Aug 24 16:35 /opt/jdk-7u79-linux-x64.tar.gz

下載完成後解壓

[[email protected] ~]# cd /opt/
[[email protected]
 
 opt]# tar zxvf jdk-7u79-linux-x64.tar.gz
[[email protected] opt]# mkdir java
[[email protected] opt]# mv jdk1.7.0_79 java/
[[email protected] opt]# cd java/jdk1.7.0_79/
[[email protected] jdk1.7.0_79]# java -version
java version "1.7.0_79"
Java(TM) SE Runtime Environment (build 1.7.0_79-b15)
Java HotSpot(TM) 64-Bit Server VM (build 24.79-b02, mixed mode)
 

以上安裝完成。

2.下載kafka

選擇自己需要的版本，我這裡使用的是kafka_2.11-1.0.0.tgz

[[email protected] ~]# cd /opt/
[[email protected] opt]#wget https://archive.apache.org/dist/kafka/1.0.0/kafka_2.11-1.0.0.tgz
[[email protected] opt]# tar -xzf kafka_2.11-1.0.0.tgz
[[email protected] opt]# cd kafka_2.11-1.0.0

啟用zookeeper

[[email protected] kafka_2.11-1.0.0]# bin/zookeeper-server-start.sh config/zookeeper.properties

啟用kafka

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

config/server.properties檔案可以編輯修改(listeners=PLAINTEXT://192.168.xx.xxx:9092) 

有多個訪問者時，cp server.properties server1.properties 同樣修改listeners值即可。可複製多份

檢視伺服器是否已啟用成功：↓↓↓↓↓↓↓↓

[[email protected] kafka_2.11-1.0.0]# netstat -tunlp|egrep "(2181|9092)"
tcp        0      0 :::9092                     :::*                        LISTEN      10265/java          
tcp        0      0 :::2181                     :::*                        LISTEN      12997/java

建立topic

[[email protected] kafka_2.11-1.0.0]# bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

檢視topic

[[email protected] kafka_2.11-1.0.0]# bin/kafka-topics.sh --list --zookeeper localhost:2181
test

啟動生產者

[[email protected] kafka_2.11-1.0.0]# bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
>hello cookie
>good morning

啟動消費者

[[email protected] kafka_2.11-1.0.0]# bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
hello cookie
good morning