文章目录
一、安装zookeeper
1.下载zookeeper:zookeeper下载
此文使用版本:apache-zookeeper-3.6.4
2.添加配置文件
在config目录下复制一份zoo_sample.cfg文件到同级目录，然后更改名称为zoo.cfg
tickTime=2000
initLimit=10
syncLimit=5
clientPort=2181
dataDir=D:\\xxx\\apache-zookeeper-3.6.4-bin\\data
dataLogDir=D:\\xxx\\apache-zookeeper-3.6.4-bin\\log
3.配置windows系统环境变量(可以百度)
1).新建zookeeper系统变量
变量名:ZOOKEEPER_HOME
变量值:D:\xxx\apache-zookeeper-3.6.4-bin
2).添加配置path
%ZOOKEEPER_HOME%\bin
4.随便打开一个cmd
1).cmd启动zookeeper服务端运行
C:\Users\xxx>zkCli
2).cmd启动zookeeper客户端(可以不用启动，截图略)
C:\Users\xxx>zkCli
二、安装kafka
1.下载kafka
kafka 下载
此文下载的kafka版本:kafka_2.12-3.5.1
2.修改config目录下的server.properties
zookeeper.connect=localhost:2181
log.dirs=D:\\xxx\\kafka_2.12-3.5.1\\logs
server.properties配置完后，需要在kafka_2.12-3.5.1目录下建logs目录
三，开始运行zookeeper和kafka
1.运行一个zookeeper server
2.启动kafka 服务
启动服务(进到kafka安装文件目录)
.\bin\windows\kafka-server-start.bat .\config\server.properties
3.运行kafka 创建topic,查看topic等
进入解压kafka对应的盘，执行bat命令
#创建主题
.\kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 5 --topic test
#查询主题
.\kafka-topics.bat --bootstrap-server localhost:9092 --list
#启动消费者消费消息
.\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
#启动生产者
.\kafka-console-producer.bat --broker-list localhost:9092 --topic test
总结:上面总共开启了3个cmd。zookeeper配置环境变量，在cmd中可以不指定路径，直接执行。kafka没有配置环境变量，要有路径执行。
其他
1).当向kafka中发送数据时，发送的明明是中文没有乱码，程序读取时是乱码。在排查时发现开启一个cmd 消费刚刚发送的topic数据，发现已经乱码了。下面是解决kafka中文乱码问题:
1.打开Kafka的配置文件server.properties，可以使用文本编辑器打开。
2.在文件中查找producer.encoding属性，如果没有则可以手动添加。
3.将属性值设置为所需的编码格式，例如UTF-8。
4.保存文件并重启Kafka服务。
或使用命令指定utf-8
设置完成后，使用kafka-console-producer命令发送消息时，就会使用所设置的编码格式。例如：
.\kafka-console-producer --broker-list localhost:9092 --topic test --property "producer.encoding=UTF-8"
该命令将使用UTF-8编码格式发送消息到名为test的主题。