window下载并且安装kafka

安装zookeeper

kafka运行需要有jdk+zookeeper环境才能够使用,jdk的安装和环境变量的配置就不介绍了,这里需要先安装zookeeper.可以从官网上下载

https://www.apache.org/dyn/closer.cgi/zookeeper/

清华镜像：https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/

• 将下载下来的包解压一下,然后在conf目录下将zoo_sample.cfg改成zoo.cfg,如图

• 

• 之后打开zoo.cfg将里面的dataDir的路径改一下,我这里修改成下面的

  dataDir=E:\Software\data\logs\zookeeper

• 之后把zookeeper配到环境变量里面,它的配置和jdk的配置类似

• 运行zookeeper,在cmd里面输入zkserver会出现下面的就便是安装成功

• 

  

安装kafka

kafka:http://kafka.apache.org/downloads

清华镜像：https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/

• 将下载下来的安装包解压,并进入到conf目录下面找到server.properties文件

• 找到并编辑

  log.dirs=E:\Software\data\logs\kafka
  zookeeper.connect=localhost:2181

• 之后进入到kafka的目录下执行下面的命令,可以使用在文件夹的空白处按着shift加鼠标右键打开命令窗口

  .inwindowskafka-server-start.bat .configserver.properties
  ​
  !每次运行kafka的时候都要把这个和上面的zkserver开启

• 之后可以测试一下创建一个主题

  .inwindowskafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

• 之后开启生产者,进入到bin/windows目录下使用命令窗口

  .kafka-console-producer.bat --broker-list localhost:9092 --topic test

• 开启消费者,进入到bin/windows目录下使用命令窗口

  .kafka-console-consumer.bat --zookeeper localhost:2181 --topic test

• 之后可以在生产者那个窗口随意输入一些信息,之后就能在消费者那边看到输入的信息