搭建环境:

  1,安装JDK

    JAVA_HOME: C:\Program Files (x86)\Java\jre1.8.0_60(这个是默认安装路径,如果安装过程中更改了安装目录,把更改后的路径填上就行了)

    PATH: 在现有的值后面添加"; %JAVA_HOME%\bin"

    安装完成后打开cmd 运行“Java -version”查看当前JDK的版本,一般情况下1.7比较适用。

  2.安装zookeeper

    在运行Kafka之前我们需要先运行Zookeeper

  2.1 下载安装文件: http://zookeeper.apache.org/releases.html

  2.2 解压文件(本文解压到 D:\zookeeper-3.4.8)目录如图:

Windows上搭建Kafka-LMLPHP

   2.3 打开D:\zookeeper-3.4.8\conf,把zoo_sample.cfg重命名成zoo.cfg

   2.4 从文本编辑器里打开zoo.cfg

  2.5 把dataDir的值改成“D:\\data\\zookeeper”

  2.6 添加如下系统变量:

    ZOOKEEPER_HOME: D:\zookeeper-3.4.8

    Path: 在现有的值后面添加 ";%ZOOKEEPER_HOME%\bin;"

  2.7 在D:\zookeeper-3.4.8\bin目录下运行zkServer.cmd

  有如下显示的话说明安装Zookeeper成功:

Windows上搭建Kafka-LMLPHP

  3.安装kafka

    3.1 下载安装文件: http://kafka.apache.org/downloads.html
    3.2 解压文件(本文解压到 D:\kafka_2.11-0.10.0.1)
    3.3 打开G:\kafka_2.11-0.10.0.1\config
    3.4 从文本编辑器里打开 server.properties
    3.5 把 log.dirs的值改成 “D:\kafka_2.11-0.10.0.1\kafkaLogs”
    3.6 打开cmd 在kafka存放目录下,打开命令执行框
    3.7 输入
      .\bin\windows\kafka-server-start.bat .\config\server.properties

  4.创建topics
    4.1 打开cmd 并进入D:\kafka_2.11-0.10.0.1\bin\windows
    4.2 创建一个topic:
    kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
  5. 打开一个Producer:
    cd /d D:\kafka_2.11-0.10.0.1\bin\windows
    kafka-console-producer.bat --broker-list localhost:9092 --topic test
  6. 打开一个Consumer:
    cd /d G:\kafka_2.11-0.10.0.1\bin\windows
    kafka-console-consumer.bat --zookeeper localhost:2181 --topic test
    此时,在创建的Producer中发送信息后,在Consumer框可以接收到。说明Kafka安装部署已经完成。

05-26 19:22