之前在windows上安装老是失败原因是 电脑上原来装有IBMＭＱ,启动kafka报'此时不应有\IBM\WebSphere' 错.

1.首先要准备好jdk环境

2.安装zookeeper ,配置下日志存放位置,端口等(测试使用,默认就好)

3.配置kafka. config/server.properties 主要配置下zk的地址端口等.其他暂时用默认就行.

4.运行kafka

    进入kafka安装目录,打开命令行:

    .\bin\windows\kafka-server-start.bat .\config\server.properties

5创建topic:

进入kafka bin目录,打开命令行:

创建test topic

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

6.创建provider&consumer:

进入kafka bin目录,打开命令行

provider:

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

消费者:

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

这时候如果在topic命令行中输入任何字符并且敲入回车,在消费者端看见输出则简单的环境安装成功.