windows下安裝kafka、zookeeper

前言

安裝kafka以前必須安裝jdk與zookeeper。
我安裝的是jdk8，安裝步驟這裏省略。

1.安裝zookeeper

1.到這個地址下載穩定版本的zookeeper版本，http://mirrors.shu.edu.cn/apache/zookeeper/ 。我下載的是當前最穩定的版本3.4.12。

2.解壓到當前目錄文件，到config目錄下面，找到zoo_sample.cfg文件，將其名字修改爲zoo.cfg。
3.編輯zoo.cfg文件，修改dataDir=D:/softCommon/zookeeper/zookeeper-3.4.12/data。將dataDir的目錄設置成如上位置。
4.進入到zookeeper的bin目錄下啓動zookeeper。個人目錄是：
5.啓動成功。

2.安裝kafka

1.到這個地址下載kafka版本,http://kafka.apache.org/downloads.html， 我下載的是2.12-2.1.0版本。
2.進入kafka的安裝目錄，到config目錄下，修改server.properties文件，主要修改以下兩個地方
log.dirs=D:\softCommon\kafka\kafka_2.12-2.1.0\logs zookeeper.connect=localhost:2181
說明：log.dirs表示kafka輸出日誌位置;zookeeper.connect表示kafka鏈接哪一個zookeeper服務器。
3.啓動kafka
輸入命令：D:\softCommon\kafka\kafka_2.12-2.1.0>.\bin\windows\kafka-server-start.bat .\config\server.properties
注意如上命令是在kafka的安裝目錄下D:\softCommon\kafka\kafka_2.12-2.1.0>

3.應用kafka

3.1 建立主題
進入kafka的安裝目錄，D:\softCommon\kafka\kafka_2.12-2.1.0\bin\windows>
kafka建立topic命令：kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
--create 建立主題
--zookeeper 鏈接到哪一個zookeeper服務器(支持多個)
--replication-factor 每一個分區的副本數
--partitions 分區數
--topic 主題名稱
如上命令的理解：建立一個主題命名test，test只有一個分區，每一個分區只有一個副本數，該kafka鏈接的zookeeper服務器localhost:2181
3.2 建立producer
進入kafka的安裝目錄，D:\softCommon\kafka\kafka_2.12-2.1.0\bin\windows>
kafka建立producer命令：kafka-console-producer.bat --broker-list localhost:9092 --topic test
--broker-list kafka集羣包含多個服務，其中每一個服務稱爲broker
--topic 主題名稱
如上命令的理解：建立生產者的服務只有一個，即本機的localhost:9092， 生產者向主題爲test的topic發消息。
3.3 建立consumer
進入kafka的安裝目錄，D:\softCommon\kafka\kafka_2.12-2.1.0\bin\windows>
kafka建立consumer命令:>kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
--bootstrap-server kafka消費服務器指定，這裏指定本地kafka來消費
--topic 消費主題名稱
--from-beginning 表示從topic中第一條消息開始消費
如上命令的理解：消費者從主題爲test的topic中消費消息，從第一條開始消費。
3.4 列出全部topic
命令：kafka-topics.bat -list -zookeeper localhost:2181
3.5 刪除topic
命令：kafka-topics.bat --delete --zookeeper localhost:2181 --topic test6
--delete 刪除命令