Windows 7 安装Apache kafka_2.11-0.9.0.1

 
 

下载所需文件

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

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

 
 

帮助文档：http://zookeeper.apache.org/doc/current/zookeeperAdmin.html#sc_configuration

 
 

安装Zookeeper

• 进入zookeeper设置目录，E:\soft\elk\zookeeper-3.4.8\conf
• 将"zoo_sample.cfg" 复制一份，重命名为"zoo.cfg"
• 打开并编辑 并编辑dataDir=/tmp/zookeeper为指定目录为E:/soft/elk/zookeeper-3.4.8/data
• 编辑环境变量，Path加 E:\soft\elk\zookeeper-3.4.8\bin
• 运行cmd,输入zkserver ,成功如下

  

 
 

 
 

安装Kafka

打开CMD 到E:\soft\elk\kafka_2.11-0.9.0.1这个路径下

输入bin\windows\kafka-server-start.bat 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命令行中能看到相应消息

 
 

 
 

 
 

创建主题

kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

 
 

列表出主题

kafka-topics --list --zookeeper localhost:2181

 
 

生产者发送消息

kafka-console-producer --broker-list localhost:9092 --topic test

 
 

消费者

kafka-console-consumer --zookeeper localhost:2181 --topic test --from-beginning