Kafka是一种高吞吐量的分布式发布订阅消息系统,它可以处理消费者在网站中的所有动作流数据。
kafka一般与zookeeper联合使用
首先安装zookeeper,博客上有,这就不详细说明了
1.在41虚拟机上解压文件,修改配置文件
vim server.properties
2.启动kafka,查看
3…在42虚拟机上解压文件,修改配置文件
4.启动kafka,查看
5.在43虚拟机上解压文件,修改配置文件
6.启动kafka,查看
7.进入41虚拟机当中,执行命令
./bin/kafka-topics.sh --create --zookeeper 10.0.0.41:2181 --replication-factor 2 --partitions 3 --topic msg
./bin/kafka-topics.sh --list --zookeeper 10.0.0.41:2181
效果: