Kafka——windows安装_windows 安卓kafaka

下载地址：Apache Kafka

下载完毕后解压tar包，目录结构如下：

 

配置

下载完成后，需要配置一下才能启动。

在config目录的server.properties文件中调整一下日志的存放目录

 

先启动zookeeper

在bin/windows目录下的执行启动命令（最好命令行执行，因为这样才能看到错误信息，不然报错了的话就会一闪而逝...）

 

这是什么鬼...

命令提示符行字符串限制 - Windows Client | Microsoft Docs

很奇妙的限制，我们把文件的路径往前移动一下吧...

zookeeper-server-start.bat D:\Users\kafka_2.13-2.8.0\config\zookeeper.properties

 

 

我移动到了D盘的Users目录下，就搞定了...而且这里启动zk的时候需要指定zk的配置文件路径

在启动kafka

同样在bin/windows目录下运行如下命令，如果没有调整kafka默认的端口就是9092

kafka-server-start.bat D:\Users\kafka_2.13-2.8.0\config\server.properties

测试

topic 创建一个topic（主题），名称为topicTest

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

查看已有的topic

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

 生产消费

创建一个消息生产者（Producer），同时创建一个消息消费者（Consumer），去接收消息生产者发来的消息。

创建一个消息生产者（Producer）

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

创建一个消息消费者（Consumer）

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic topicTest --from-beginning

 

在生产者的命令行中，敲入回车，消费者就会收到该信息，当然因为这里是命令行，所以有中文乱码的情况出现。

启动脚本

每次都输入命令很麻烦，所以做了两个启动脚本来启动ZK跟Kafka

zk

@echo the zk server
title zk-server
D:\Users\kafka_2.13-2.8.0\bin\windows\zookeeper-server-start.bat D:\Users\kafka_2.13-2.8.0\config\zookeeper.properties

kafka

@echo the Kafka server
title kafka-server
D:\Users\kafka_2.13-2.8.0\bin\windows\kafka-server-start.bat D:\Users\kafka_2.13-2.8.0\config\server.properties