kafka环境搭建(windows)

发表于

kafka环境搭建(windows)

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

zookeeper

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

    1527840168103

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

    1527840259527

修改zoo.cfg中的dataDir

1527840343846

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

    1527840452421

Kafka

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

    1527840597418

###

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

    1527840638873

修改log.dirs

1527840699576

运行

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

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

1527840858400

注意：如果遇到上图无法加载主类问题，请执行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

1527841299963

  • 执行命令，打开生产者

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

    1527841450736

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

1527841688385

注意事项

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