首先要安装jdk环境
可以参考:https://www.cnblogs.com/pxblog/p/10512886.html
下载kafka
地址:http://kafka.apache.org/downloads.html
上传到服务器 解压
进入目录
先启动自带zookeeper,我用的后台运行的方式
nohup bin/zookeeper-server-start.sh config/zookeeper.properties -d &
启动好之后 启动kafka
nohup bin/kafka-server-start.sh config/server.properties -d &
测试
进入bin目录
执行:
./kafka-console-producer.sh --broker-list localhost:9092 --topic yvioo
然后可以随便输入一些数据
打开新的终端执行
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic yvioo --from-beginning
这里会显示上面输入的数据
原文:https://www.cnblogs.com/pxblog/p/14814112.html