Windows上搭建Kafka

搭建环境:

  1,安装JDK

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

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

    安装完成后打开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)目录如图:

   2.3 打开D:zookeeper-3.4.8conf,把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%in;"

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

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

  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.1config
    3.4 从文本编辑器里打开 server.properties
    3.5 把 log.dirs的值改成 “D:kafka_2.11-0.10.0.1kafkaLogs”
    3.6 打开cmd 在kafka存放目录下,打开命令执行框
    3.7 输入
      .inwindowskafka-server-start.bat .configserver.properties

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

原文地址:https://www.cnblogs.com/wanghp/p/7160965.html