今天剛接觸kafka，網上很多kafka的安裝，這裡只講單機版的安裝以及安裝過程中遇到的問題。
軟體

• JDK1.8（jdk-8u131-linux-x64.rpm）
• zookeeper （zookeeper-3.4.10.tar.gz）
• kafka （kafka_2.12-2.0.0.tgz）

一、JDK安裝
kafka的使用依賴於zookeeper，zk要執行在jvm之上，所以啊，咱們也先安裝jdk.
如果不安裝jdk啟動zk的時候會出現以下問題

Error contacting service. It is probably not running.

二、zookeeper安裝

wget http://mirrors.hust.edu.cn/apache/zookeeper/zookeeper-3.4.10/zookeeper-3.4.10.tar.gz

解壓縮

tar -zxvf zookeeper-3.4.10.tar.gz

編輯配置檔案

cd zookeeper-3.4.10/conf/
cp zoo_sample.cfg zoo.cfg
vi zoo.cfg

配置如下

tickTime=2000
initLimit=10
syncLimit=5
dataDir=/opt/data/zookeeper
dataLogDir
 
=/var/log/kafka/zk
clientPort=2181
server.1=10.9.201.142:2888:3888

進入bin目錄使用zkServer.sh啟動zk

./zkServer.sh start

檢視啟動情況

./zkServer.sh status

三、安裝kafka
kafka版本如下

下載2.11版

wget http://mirrors.hust.edu.cn/apache/kafka/2.0.0/kafka_2.12-2.0.0.tgz

解壓縮

tar -zxvf kafka_2.12-2.0.0.tgz

啟動kafka

cd kafka_2.12
 
-2.0.0
cd bin/
./kafka-server-start.sh ../config/server.properties &

使用jps檢視啟動情況

[root@centos7 bin]# jps
19815 Kafka
19032 QuorumPeerMain
33307 Jps

QuorumPeerMain是zk的程序。

四、測試kafka
建立一個topic

./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test_kafka

檢視建立的topic

[[email protected] bin]# ./kafka-topics.sh --list --zookeeper localhost:2181
__consumer_offsets
test_kafka

啟動消費者

./kafka-console-consumer.sh --bootstrap-server localhost:2181 --topic test_kafka --from-beginning

注意：新版的kafka只能使用–bootstrap-server來啟動，zookeeper的指令已經被取消了。

在新的shell中啟動生產者

./kafka-console-producer.sh --broker-list localhost:9092 --topic test_kafka

啟動之後輸入訊息，在消費者的shell中就可以接收到生產者中輸入的資訊。

到這裡kafka的單機安裝就結束了。