环境搭建

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整合完成！~~~希望小编能帮助到您。