Kafka在window上安装部署

1.准备工作  

①jdk

•  具体自行百度安装jdk,配置好 JAVA_HOME和path,
• 下载地址:   http://www.oracle.com/technetwork/java/javase/downloads/index.html,
•  注意,  选择1.8的版本,然后环境变量JAVA_HOME,不要选择默认的"C:Program FilesJavajdk1.8.0_151" , 因为文件夹路径不能有空格,后面可能启动kafka服务出错.

②zookeeper

• 下载安装包：http://zookeeper.apache.org/releases.html#download
• 解压目录: D:Tool,

  1.进入Zookeeper设置目录，D:Toolzookeeper-3.4.13conf
  2. 将“zoo_sample.cfg”重命名为“zoo.cfg”
  3. 在文本编辑器（如notepad）中打开zoo.cfg
  4. 找到并编辑dataDir=D:/Tool/zookeeper-3.4.13/tmp (可以自定义文件夹)
  5. 与Java中的做法类似，我们在系统环境变量中添加：
  　　a. 在系统变量中添加ZOOKEEPER_HOME =D:Toolzookeeper-3.4.13
  　　b. 编辑path系统变量，添加为路径 %ZOOKEEPER_HOME%in;
  6. 在zoo.cfg文件中修改默认的Zookeeper端口（默认端口2181,可以不用修改）

• 测试 : 打开新的cmd，输入zkServer，运行Zookeeper,成功如下所示,

③kafka

• 下载 http://kafka.apache.org/downloads.html,注意要下载二进制版本的,

              

解压到目录 D:Toolkafka_2.11-2.1.1

1. 编辑文件Kafka配置文件， D:Toolkafka_2.11-2.1.1configserver.properties
2. 找到并编辑log.dirs=D:Toolkafka_2.11-2.1.1kafka-log, (自定义文件夹)
3. 找到并编辑zookeeper.connect=localhost:2181。表示本地运行(默认的可以不改)
4. Kafka会按照默认，在9092端口上运行，并连接zookeeper的默认端口：2181。
 

二、运行和测试

注意：在启动Kafka前，先运行Zookeeper实例。 (前面的cmd命令:zkserver)

①启动Kafka服务器

　　新建cmd窗口:
      cd D:Toolkafka_2.11-2.1.1 

     .inwindowskafka-server-start.bat .configserver.properties

     

②创建主题

    新建cmd窗口:
    cd D:Toolkafka_2.11-2.1.1inwindows
    kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic haha

     

③创建生产者

    新建cmd窗口:
    cd D:Toolkafka_2.11-2.1.1inwindows
    kafka-console-producer.bat --broker-list localhost:9092 --topic haha

    

④创建消费者

    新建cmd窗口:
    cd D:Toolkafka_2.11-2.1.1inwindows
    kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic haha --from-beginning

    

⑤生产消息并消费