1、下载地址选择二进制的推荐版本
2、选择推荐的镜像下载地址,点击后直接下载,现在完成后解压文件,并进入\bin\windows目录下。
3、启动zookeeper服务器:请查看Windows安装z1ookeeper
4、按住shift+右键→在此处打开命令窗口,输入此命令:kafka-server-start.bat ..\..\config\server.properties,发现会报错 “找不到或无法加载主类 Files\Java\jdk\dt.jar;C:\Program Kafka”
5、解决办法是找到windows下的:(1)氯短赤亻kafka-server-start.bat文件,编辑。 给 %CLASSPATH% 加上双引号 "%CLASSPATH%",如下图修改后下该地方:set COMMAND=%JAVA% %KAFKA_HEAP_OPTS% %KAFKA_JVM_PERFORMANCE_OPTS% %KAFKA_JMX_OPTS% %KAFKA_LOG4J_OPTS% -cp %CLASSPATH% %KAFKA_OPTS% %*(2)再次运行4中的命令,发现可以了。(3)不过此时还抛出了一个异常说是某个文件中发现了某个异常的冒号”:“,没找解决方法,因为程序可以正常运行。 javax.management.MalformedObjectNameException: Invalid character ':' in value part of propert(4)注意此时不要关闭此窗口,因为下面创建topic等要开着这个窗口。如果关闭了此窗口,重新启动,会发现抛出大量的错误,说日志文件已经被其他进程占用(不知道为什么),解决方法是把D:\tmp\kafka-logs(默认)目录下的文件全部删除,不知道有没有好的解决方法?
6、创建主题:mytopics。按照5中的方式,打开命令窗口,输入:kafka-topics.bat --create --zookeeper localhost:2181 --replicat足毂忍珩ion-factor 1 --partitions 1 --topic mytopicsTest创建主题成功。查看主题命令:kafka-topics.bat --list --zookeeper localhost:2181
7、打开生产者,发送数据给主题。按照5,输入:kafka-console-producer.bat --broker-list localhost:9092 --topic mytopicsTest输入:my name is xyx 回车确认。
8、打开消费者,接收消息。按照5,输入:kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic mytopicsTest --from-beginning 发现消费者接收到了消息:my name is xyx。
9、继续在生产者输入各种字符,发现消费者依次会显示出来。 至此就安装好了kafka,并测试通过。