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 删除命令