1. 下載、解壓Kafka安裝包

wget http://archive.apache.org/dist/kafka/0.10.1.0/kafka_2.10-0.10.1.0.tgz
tar -xzvf kafka_2.10-0.10.1.0.tgz
mv kafka_2.11-0.8.2.1 /usr/local/kafka #移動到安裝目錄

2、配置kafka

mkdir /usr/local/kafka/log/kafka #建立kafka日誌目錄

cd /usr/local/kafka/config #進入配置目錄

vi server.properties #編輯修改kafka相應的引數

broker.id=0

port=9092 #埠號

host.name=192.168.0.11 #伺服器IP地址，修改為自己的伺服器IP

log.dirs=/usr/local/kafka/log/kafka #日誌存放路徑，上面建立的目錄

zookeeper.connect=localhost:2182 #zookeeper地址和埠，單機配置部署，localhost:2182

:wq! #儲存退出
 

3、配置zookeeper

mkdir /usr/local/kafka/zookeeper #建立zookeeper目錄

mkdir /usr/local/kafka/log/zookeeper #建立zookeeper日誌目錄

cd /usr/local/kafka/config #進入配置目錄

vi zookeeper.properties #編輯修改相應的引數

dataDir=/usr/local/kafka/zookeeper #zookeeper資料目錄

dataLogDir=/usr/local/kafka/log/zookeeper #zookeeper日誌目錄

clientPort=2181

maxClientCnxns=100

tickTime=2000

initLimit=10

syncLimit=5

:wq! #儲存退出
 

4.啟動

啟動zookeeper
/usr/local/kafka/bin/zookeeper-server-start.sh  /usr/local/kafka/config/zookeeper.properties &
啟動kafaka
/usr/local/kafka/bin/kafka-server-start.sh /usr/local/kafka/config/server.properties &

5.kafka shell命令：

./kafka-topics.sh --zookeeper 192.168.226.129:2182  --describe --topic  orderTopic  ；檢視名字為orderTopic的topic

./kafka-topics.sh --zookeeper 192.168.226.129:2182 --list   ；檢視topic 列表