一、kafka 安装

官网安装地址

安装前提，kafka安装运行最低支持jdk7；本篇演示版本是基于jdk1.8；

目前，Kafka已经内置了zookeeper，不需要单独下载zookeeper

windows下载后解压即可

二、启动

1.启动zookeeper

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

这边会报一个奇葩的错误，命令行太长，直接将压缩包解压到根目录或者桌面进行操作

尽量减少文件夹名字长度或不要嵌套太多层文件夹

启动成功

2.启动kafka

启动kafka服务端命令

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

启动成功

三、使用

1.创建Topic

bin/windows/kafka-topics.bat --create --bootstrap-server localhost:9092 --topic test --partitions 1 --replication-factor 1

上述命令创造了test主题

2.查看Topic

bin/windows/kafka-topics.bat --list --bootstrap-server localhost:9092

3.发送消息

前面介绍Kafka专业术语中已经阐述，Kafka使用过程中首先需要消息生产者发送消息，那么消费者才可以读取到消息。

启动一个终端A，执行下面命令，

> bin/windows/kafka-console-producer.bat --broker-list localhost:9092 --topic test
> hello

当执行producer脚本后，会出现消息输入提示符，这是我们可以输入消息(数据)，然后它会发送到对应的服务器(Broker)。

4.接收消息

现在管道中已经有了数据，接下来我就可以使用消费者去读取数据。

另外启动一个终端B，执行下面命令，

> ./bin/windows/kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test 
hello world