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       

        FilesJavajdk1.8.0_144(根据安装路径调整)  

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

   3）最后在系统变量：Path 的值后加上： %JAVA_HOME%in;%JAVA_HOME%jrein;  

  测试

 打开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.6zookeeper-3.3.6data

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

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.1logs

在路径D:kafka_2.11-0.11.0.1下执行CMD命令：

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

在路径binwindow下
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窗口马上就收到消息。