注意：kafka的运行依赖于zookeeper，所以在运行kafka之前我们需要安装并运行zookeeper
下载安装文件： http://kafka.apache.org/downloads.html
1 解压文件（本文解压到 d:\kafka_2.9.2-0.8.2.2）
2 打开d:\kafka_2.9.2-0.8.2.2\config\ server.properties
3 把 log.dirs的值改成 log.dirs=d:\data\logs\kafka
4 d:\kafka_2.9.2-0.8.2.2\bin文件夹下的.sh命令脚本是在shell下运行的，此文件夹下还有个 windows文件夹，里面是windows下运行的.bat命令脚本
5 在d:\kafka_2.9.2-0.8.2.2文件夹中”shift+鼠标右键”点击空白处打开命令提示窗口
6 输入并执行一下命令以打开kafka:
.\bin\windows\kafka-server-start.bat .\config\server.properties
如果运行提示java内存不够之类的：
可以修改kafka-server-start.bat里面的配置。
一般都需要去掉kafka-run-class.bat里面的 -xx:+usecompressedoops 才能运行。
7.创建topics
7.1在d:\kafka_2.9.2-0.8.2.2\bin\windows文件夹中”shift+鼠标右键”点击空白处打开命令提示窗口
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
8.打开一个producer
8.1在d:\kafka_2.9.2-0.8.2.2\bin\windows文件夹中”shift+鼠标右键”点击空白处打开命令提示窗口
kafka-console-producer.bat --broker-list localhost:9092 --topic test
9.打开一个consumer
9.1在d:\kafka_2.9.2-0.8.2.2\bin\windows文件夹中”shift+鼠标右键”点击空白处打开命令提示窗口
kafka-console-consumer.bat --zookeeper localhost:2181 --topic test
注意：以上打开的窗口不要关闭
然后就可以在producer控制台窗口输入消息了。在消息输入过后，很快consumer窗口就会显示出producer发送的消息：
如对本文有疑问， 点击进行留言回复！！
SpringBoot引用阿里easyexcel，Excel导出返回浏览器下载
HashMap、Hashtable、ConcurrentHashMap三者间的异同
解决RecycleView 中Item包含Edittext时，滑动view复用导致数据错乱的问题
多线程、同步工作原理、死锁案例、Lock接口、线程的生命周期的讲解及实现
我要评论
网友评论