kafka环境搭建(windows)

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

zookeeper

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

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

  •  

修改zoo.cfg中的dataDir

 

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

Kafka

  • 解压，建立一个空文件夹 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-producer.bat --broker-list localhost:9092 --topic test.topic

 

  • 执行命令，打开生产者

    
 

    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）