简介
Kafka 是一个由 LinkedIn 开发的分布式消息系统，它于2011年年初开源，现在由著名的 Apache 基金会维护与开发。 Kafka 使用 Scala 实现，被用作 LinkedIn 的活动流和运营数据处理的管道，现在也被诸多互联网企业广泛地用作数据流管道和消息系统， Kafka 是基于消息发布﹣订阅模式实现的消息系统。
下载
官网下载链接：https://kafka.apache.org/downloads
我下载的是Scala 2.12 - kafka_2.12-3.1.0.tgz
安装
kafka只需要解压下载的压缩包就行了，我这里解压的路径是D:\kafka_2.12-3.1.0，kafka的运行需要依赖zookeeper，有关zookeeper的Windows安装请看这里，当前版本已经内置了zookeeper，所以不需要再安装zookeeper。
配置
想要启动kafka需要修改kafka配置文件和zookeeper配置文件，配置文件都在跟目录下面的config文件夹下。
kafka配置
kafka 服务端配置在server.properties中。
kafka配置需要修改两处配置文件：listeners 和 log.dirs
- listeners：服务器监听的地址，修改如下：
listeners=PLAINTEXT://localhost:9092
log.dirs：日志文件
修改为自定义的日志目录，我的是
log.dirs=D:/kafka_2.12-3.1.0/logs
zookeeper配置
zookeeper配置文件为zookeeper.properties，只需修改一处，
dataDir：zookeeper存储数据的路径
修改自定义的目录，要用反斜杠/
dataDir=D:/kafka_2.12-3.1.0/data
测试
接下来进入测试阶段：
进入kafka安装根目录下，地址栏输入cmd，然后回车，通过命令行启动之后都不要关闭窗口。
启动zookeeper
先启动zookeeper，启动命令如下：
.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties
启动kafka
再在地址栏输入cmd
启动kafka-server
.\bin\windows\kafka-server-start.bat .\config\server.properties
如果启动kafka失败，并出现以下异常，删除logs文件夹下的meta.properties文件即可。
The Cluster ID xxxx doesn’t match stored clusterId Some(finN2zUTRWaXMomXCknRew) in meta.properties. The broker is trying to join the wrong cluster. Configured zookeeper.connect may be wrong.
启动kafka-topics
创建一个名为test的topic
命令如下：
.\bin\windows\kafka-topics.bat --create --bootstrap-server localhost:2181 --replication-factor 1 --partitions 1 --topic test
启动之后，kafka-topics处于等待创建topic状态，一段时间内如果不createTopic，kafka-topics将自动断开
启动生产者
命令如下：
.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test
启动生产者之后就可以发送消息了
启动消费者
命令如下：
.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test
启动消费者之后生产者发送的消息，消费者端就能收到了。
在生产端发送消息，可以看到消费端就收到了
至此，消息队列kafka就安装完毕了。
能力一般，水平有限，如有错误，请多指出。
如果对你有用点个关注给个赞呗
