CentOS 安裝並運行Kafka

1、下載Kafka

http://mirrors.hust.edu.cn/apache/kafka/2.1.1/

2、定位到/usr/local，創建kafka文件夾，進入此文件夾后解壓kafka（可自行選擇安裝目錄）

tar -xzf kafka_2.11-2.1.1.tgz

3、運行內置zookeeper

cd /usr/local/kafka/kafka_2.11-2.1.1/bin/

./zookeeper-server-start.sh ../config/zookeeper.properties &

4、配置偽分布式kafka

復制三份server.properties（自選數量），每份修改如下幾個配置

# Kafka broker節點唯一標識. 
broker.id=0
# 端口號(偽分布式不能沖突)
port=9092
# 對客戶端提供的服務地址和端口號
advertised.listeners=PLAINTEXT://192.168.56.20:9092 
# Kafka日志存放路徑(路徑自行創建)
log.dirs=/home/hadoop/kafka/broker-0

# Kafka broker節點唯一標識. 
broker.id=1
# 端口號(偽分布式不能沖突)
port=9093
# 對客戶端提供的服務地址和端口號
advertised.listeners=PLAINTEXT://192.168.56.20:9093
# Kafka日志存放路徑(路徑自行創建)
log.dirs=/home/hadoop/kafka/broker-1

# Kafka broker節點唯一標識. 
broker.id=2
# 端口號(偽分布式不能沖突)
port=9094
# 對客戶端提供的服務地址和端口號
advertised.listeners=PLAINTEXT://192.168.56.20:9094
# Kafka日志存放路徑(路徑自行創建)
log.dirs=/home/hadoop/kafka/broker-2

5、運行Kafka

# 方式一
./kafka-server-start.sh ../config/server0.properties &
./kafka-server-start.sh ../config/server1.properties &
./kafka-server-start.sh ../config/server2.properties &

# 方式二
nohup ./kafka-server-start.sh ../config/server0.properties &
nohup ./kafka-server-start.sh ../config/server1.properties &
nohup ./kafka-server-start.sh ../config/server2.properties &

# 方式三
./kafka-server-start.sh -daemon ../config/server0.properties
./kafka-server-start.sh -daemon ../config/server1.properties
./kafka-server-start.sh -daemon ../config/server2.properties

6、驗證

如何驗證Kafka安裝成功：查看topic列表即可：./kafka-topics.sh --list --zookeeper zkHost:zkPort