环境搭建
1.安装jdk系统环境(如果不会的可以百度一下进行配置和安装jdk)
2.Zookeeper部署和环境配置
3.kafka部署和使用
- Zookeeper和kafka下载：
1.zookeeper 下载地址：http://mirror.bit.edu.cn/apache/zookeeper/
2.kafka 下载地址：https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/
小编使用的版本的百度网盘下载：
zookeeper：
链接：https://pan.baidu.com/s/1eh8cUFRHoXPbiQShSwgnSA
提取码：3jn4
kafka：
链接：https://pan.baidu.com/s/1Eq141GrqApHEM_YufQDGIg
提取码：9q32
zookeeper下载安装
下载zookeeper并解压，小编的解压如下：
image.png
-
进入F:\zookerper\apache-zookeeper-3.6.1-bin\conf 找到zoo_sample.cfg并重命名为：zoo.cfg 如下图：
image.png -
编辑zoo.cfg 找到dataDir和dataLogDir并修改，如果没有就直接添加即可
image.png
zookeeper测试：
- 进入：F:\zookerper\apache-zookeeper-3.6.1-bin\bin
-
使用cmd执行：zkServer.cmd 如下图：
image.png -
启动zookeeper客户端：新建cmd执行命令：zkCli.cmd -server 127.0.0.1:2181 如下图：
image.png -
使用zookeeper客户端，进行测试create、get、set命令，效果如下图：
image.png
配置zookeeper环境变量
image.png
image.png
-
测试环境变量是否成功,使用cmd 执行命令:zkserver，成功如下图：
image.png
kafka下载和使用
-
1.下载kafka并解压 到：F:\kafkaserver\kafka_2.13-2.5.0
image.png - 2.打开F:\kafkaserver\kafka_2.13-2.5.0\config\server.properties
-
3.找到log.dirs并配置log.dirs=F:\kafkaserver\data\logs\kafka
image.png - 4.进入F:\kafkaserver\kafka_2.13-2.5.0\bin\windows 使用cmd执行命令：
.\kafka-server-start.bat F:\kafkaserver\kafka_2.13-2.5.0\config\server.properties
注意：如果没有启动zookeeper会报下面的错误，只要先启动zookeeper就可以了
image.png
-
5.正常启动如下(注意：下面的两个窗口，后面的操作都不能关闭~~)：
image.png
kafka创建一个主题topics
- 在F:\kafkaserver\kafka_2.13-2.5.0\bin\windows 使用新的cmd
.\kafka-topics.bat --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1 --topic demos
image.png
image.png
开启一个producer生产者
- 在F:\kafkaserver\kafka_2.13-2.5.0\bin\windows 使用新的cmd
.\kafka-console-producer.bat --broker-list 127.0.0.1:9092 --topic demos
image.png
启动一个消费者：
- 在F:\kafkaserver\kafka_2.13-2.5.0\bin\windows 使用新的cmd
.\kafka-console-consumer.bat --bootstrap-server 127.0.0.1:9092 -topic demos
image.png
测试生产和消费
image.png
image.png
总结：zookeeper和Kafka整合完成！~~~希望小编能帮助到您。
