Zookeeper+Kafka的單節點配置
環境描述：Ubuntu16.04 server系統，在系統上搭建Java環境，jdk的版本為1.8或更高，我的服務器IP地址為192.168.0.106。
1. 使用命令在根目錄下的opt目錄下創建data目錄。
mkdir /opt/data
2. 在Apache官網http://www.apache.org/dyn/closer.cgi/zookeeper/和https://www.apache.org/dyn/closer.cgi?path=/kafka/0.10.0.0/kafka_2.10-0.10.0.0.tgz
上下載zookeeper和kafka的壓縮包，我下載的是zookeeper-3.4.10.tar.gz和kafka_2.11-0.10.1.0.gz。
3. 使用命令對zookeeper和kafka壓縮文件進行解壓，對解壓后的文件進行改名和移動位置，移動到/opt/data目錄下。
tar -zxvf zookeeper-3.4.10.tar.gz tar -zxvf kafka_2.11-0.10.1.0.gz
4. 使用命令增加zookeeper節點的IP如下附圖所示。
vim /etc/hosts
5. 使用命令
cd /opt/data/zookeeper/conf
進入zookeeper目錄下的conf目錄，使用命令
cp zoo_sample.cfg zoo.cfg
復制文件zoo.cfg，使用命令
vim zoo.cfg
修改該文件。同時，在/opt/data/zookeeper下創建data目錄和logs目錄，在/opt/data/zookeeper/data下創建文件myid，使用命令
echo 1 > myid
在文件myid中寫入1。
============================================================================================================================================
在此zookeeper的配置已經完成。
============================================================================================================================================
6. 使用命令
vim /opt/data/kafka/config/server.properties
修改kafka的配置文件，同時使用命令
mkdir /opt/data/kafka/kafka-logs
創建目錄，修改內容如下附圖所示。
============================================================================================================================================
在此kafka的配置已經完成。
============================================================================================================================================
測試zookeeper和kafka的配置是否成功：
1. 啟動zookeeper：在/opt/data/zookeeper目錄下使用命令
bin/zkServer.sh start
啟動zookeeper。使用命令
bin/zkServer.sh status
查看zookeeper的狀態，如果現實如下圖所示的狀態表示zookeeper配置成功。
2.啟動kafka：在/opt/data/kafka目錄下使用命令
bin/kafka-server-start.sh config/server.properties
啟動kafka，顯示以下信息為成功啟動kafka。
3. 創建會話topic：打開新的終端(我們暫記為終端1)，在/opt/data/kafka目錄下使用命令
bin/kafka-topics.sh --create --zookeeper 192.168.0.106:2181 --replication-factor 1 --partitions 1 --topic test1
創建會話test1，使用命令
bin/kafka-topics.sh --list --zookeeper 192.168.0.106:2181
查看會話列表，顯示以下信息為成功創建會話。
4.啟動生產者Producer發消息：在/opt/data/kafka目錄下使用命令
bin/kafka-console-producer.sh --broker-list 192.168.0.106:9092 --topic test1
啟動消息生產者。
5.啟動消費者Consumer接收消息：再打開一個新的終端(我們暫記為終端2)，在/opt/data/kafka目錄下使用命令
bin/kafka-console-consumer.sh --bootstrap-server 192.168.0.106:9092 --from-beginning --topic test1
來接收消息。
6.在生產者Producer所在的終端1里隨便輸入一些內容，消費者Consumer所在的終端2將會實時的捕獲終端1里發出的消息。如下表示成功建立會話，kafka和zookeeper的單節點配置圓滿成功。
7.刪除會話topic：在/opt/data/kafka目錄下使用命令
bin/kafka-topics.sh --delete --zookeeper 192.168.0.106:2181 --topic test1
再使用命令
bin/kafka-topics.sh --list --zookeeper 192.168.0.106:2181
查看會話是否存在，如下圖所示，表示會話test1刪除成功。
