0x01 下载并运行kafka

1. 下载kafka

网址：http://kafka.apache.org）

ps:所有apache的顶级项目网址均为：xxx.apache.org

a. 向下拉，本次下载kafka_2.11-1.0.0.tgz版本：

b. 下载好后解压（如：E:\SmallTools\kafka_2.11-1.0.0）：

2. 启动zookeeper、启动kafka

a. 按键盘win+R，输入cmd，点击运行：

输入：

e:

回车，输入（需改为自己的解压路径）：

cd E:\SmallTools\kafka_2.11-1.0.0\bin\windows

b.启动kafka内置的zookeeper：

zookeeper-server-start.bat ../../config/zookeeper.properties

c. 再启动一个cmd窗口，进入windows目录，启动kafka：

kafka-server-start.bat ../../config/server.properties

0x02 简单发布订阅消息系统实现

1. 创建topic

a. 新建cmd并进入windows目录，创建topic

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

--topic zufang-topic

b. 查看topic

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

2. 启动生产者

a. 启动一个生产者

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

执行后出现">"，处于待输入状态，任意输入内容：

hello shaonaiyi

https://blog.csdn.net/shaock2018/

wechat:shaonaiyi888

3. 启动消费者

a. 重新开一个cmd，启动一个消费者（–from-beginning表示从头开始消费）

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

可能跟之前所接触的脚本不太一样，请查看官网：

特别注意参数：
–broker-list --zookeeper localhost:2181
换成了
–bootstrap-server localhost:9092
.sh与.bat
此前为：

kafka-console-consumer.sh --broker-list --zookeeper localhost:2181 --topic zufang-topic --from-beginning

4. 结果展示

a. 回车后可以接受到了从生产者的cmd发过来的消息：

b. 情况一览：

kafka-console-producer.bat窗口发送bigdata，kafka-console-consumer.bat窗口可以实时接受到：

0xFF 总结

注意系统不同，.sh与.bat文件不同，注意执行的cmd窗口，不能输入的时候就要重开窗口，不能关闭之前启动的zookeeper与kafka窗口

本教程为了简便，使用了内置的zookeeper，实际生产上，会安装独立的zookeeper本教程为了简便，使用了内置的zookeeper，实际生产上，会安装独立的zookeeper

kafka与zookeeper均可以安装分布式，此处为简便教程，请自行查阅资料或者查看本博客的教程

windows上的安装kafka等组件体验效果其实并不好，建议自己在自己的服务器或者自己搭建一个centos虚拟机，自行安装一台服务器。