MQ-Windows安装Zookeeper与Kafka及测试发送数据

Zookeeper 和 Kafka 下载地址

Zookeeper: http://www.apache.org/dyn/closer.cgi/zookeeper/

Kafka :http://kafka.apache.org/downloads.html

安装Zookeeper

我的 安装路径  G:\install\zookeeper\zookeeper-3.4.9\zookeeper-3.4.9

  • 进入zookeeper设置目录,你的安装路径\conf
  • 将”zoo_sample.cfg” 复制一份,重命名为”zoo.cfg”
  • 打开并编辑 并编辑dataDir=/tmp/zookeeper为指定目录为     你的安装路径/data
  • 编辑环境变量,Path加    ;你的安装路径\bin
  • 运行cmd,输入zkserver ,成功如下
  • 我这里做成了bat 文件
  • start 你的路径\bin\zkServer.cmd

安装Kafka

打开CMD 到 你的kafka安装路径

输入bin\windows\kafka-server-start.bat 你的kafka安装路径\config\server.properties

 

现在Kafka已经准备好并开始运行,下面来创建主题

创建主题

输入

kafka-topics.bat –create –zookeeper localhost:2181 –replication-factor 1 –partitions 1 –topic test1

创建Producer及Consumer来测试一下。

 

输入

kafka-console-producer.bat –broker-list localhost:9092 –topic test1

 

再打开一个cmd,输入

kafka-console-consumer.bat –zookeeper localhost:2181 –topic test1

 

在producer命令行中任意输入内容,回车;在其他consumer命令行中能看到相应消息