windows下kafka配置入门 示例

实验平台与软件：

操作系统：windows7 32  位

java 开发包: jdk1.8.0_144

集群: zookeeper-3.3.6

消息队列: kafka_2.11-0.11.0.1

安装序列：

1.  jdk安装预配置

jdk-8u144-windows-i586_8.0.1440.1.exe

点击安装："下一步" ...

  环境变量配置：

1）计算机/属性/高级系统设置/高级/环境变量，在系统变量中新建变量：JAVA_HOME    值：C:\Program

Files\Java\jdk1.8.0_144(根据安装路径调整)

2）再新建变量:Classpath ,值：.;%JAVA_HOME%\lib;%JAVA_HOME%\lib\tools.jar

3）最后在系统变量：Path 的值后加上： %JAVA_HOME%\bin;%JAVA_HOME%\jre\bin;

测试

 打开CMD命令窗口输入：java -version

回车执行，如果能正常显示java版本 说明安装配置成功

注意：

1）多个环境变量值之间需用分号隔开

2）Classpath值前面有一小点

2. zookeeper 安装配置

1）压缩包解压：zookeeper-3.3.6

2）目录下新建data 文件夹

3）conf目录，然后复制zoo_sample.cfg为zoo.cfg

4）修改zoo.cfg 中的dataDir=D:\zookeeper-3.3.6\zookeeper-3.3.6\data

(根据解压路径做相应调整)

3.启动zookeeper

  进入 bin 目录，执行 zkServer.cmd

在bin目录 :shift + 鼠标右键  -> 打开命令窗口

输入：zkServer.cmd  回车执行

4 kafka配置

压缩包解压：D:\kafka_2.11-0.11.0.1

进入config目录，编辑 server.properties 文件

log.dirs=D:\kafka_2.11-0.11.0.1\logs在路径D:\kafka_2.11-0.11.0.1下执行CMD命令：

.\bin\windows\kafka-server-start.bat .\config\server.properties在路径bin\window下
1）创建 topic :

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

2) 创建 producer:


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


3) 创建 consummer:


kafka-console-consumer.bat --zookeeper localhost:2181 --topic test.topic


5 测试
下面，我们在窗口(Producer)输入一些字符，就会看到consummer窗口马上就收到消息。