kafka环境搭建(windows)

原文引用：https://www.jianshu.com/p/f7037105db46

zookeeper

• zookeeper

  下载地址：http://apache.fayea.com/zookeeper/current/

•  

  

• 解压E:\study\kafka_work\zookeeper-3.4.12，创建data文件夹

  

• 进入到conf目录，然后复制zoo_sample.cfg为zoo.cfg

•  

  

修改zoo.cfg中的dataDir

• 启动Zookeeper，进入 bin 目录，执行 zkServer.cmd

  

Kafka

• 下载

  地址： http://kafka.apache.org/downloads.html

  

• 解压，建立一个空文件夹 logs

  

###

• 进入config目录，编辑 server.properties 文件

  

修改log.dirs

运行

• cmd进入kafka文件夹，我的是E:\study\kafka_work\kafka_2.12-1.1.0，执行下面命令

  .\bin\windows\kafka-server-start.bat .\config\server.properties

注意：如果遇到上图无法加载主类问题，请执行SET CLASSPATH=.;

测试

• cmd 进入E:\study\kafka_work\kafka_2.12-1.1.0\bin\windows目录，创建一个topic

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

打开一个Producer

• 执行命令，打开生产者

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

  

• 现在有4个cmd窗口，
  1. zookeeper
  2. kafka
  3. producer
  4. consumer
• 下面，我们在3号窗口(Producer)输入一些字符，就会看到4号窗口马上就收到消息

注意事项

• 在搭建时如果提示: 错误: 找不到或无法加载主类 Files\Java\jdk1.8.0_141\lib\dt.jar;D:\Program,请执行命令 set classpath=.;
• zookeeper 默认端口号为 2181
• kafka 默认端口号为 9092
• produce（发送消息者）启动时参数使用的是kafka的端口号（默认9092），而consumer（接收消息者）启动时使用的是zookeeper端口号（默认2181）