Zookeeper+Kafka的單節點standalone配置 環境描述：Ubuntu16.04 server系統，在系統上搭建Java環境，jdk的版本為1.8或更高，我的伺服器IP地址為192.168.0.106。 1.使用命令mkdir /opt/data在opt目錄下創建data目錄。 2. ...
Zookeeper+Kafka的單節點standalone配置
環境描述：Ubuntu16.04 server系統，在系統上搭建Java環境，jdk的版本為1.8或更高，我的伺服器IP地址為192.168.0.106。
1.使用命令mkdir /opt/data在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.使用命令tar -zxvf kafka_2.11-0.10.1.0.gz和tar -zxvf zookeeper-3.4.10.tar.gz對壓縮文件進行解壓，對解壓後的文件進行改名和移動位置，移動到/opt/data目錄下。
4.使用命令vim /etc/hosts增加zookeeper節點的IP如下附圖所示。
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的單節點standalone配置圓滿成功。
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刪除成功。
