kafka:
Kafka是一种高吞吐量的分布式发布订阅消息系统,它可以处理消费者在网站中的所有动作流数据。 这种动作(网页浏览,搜索和其他用户的行动)是在现代网络上的许多社会功能的一个关键因素。
异步处理,把非关键的流程异步化掉,提高系统性能
下载地址:
选择对应的版本,下载压缩包
解压
修改配置 config 目录下 server.properties
启动(在kafka目录执行)
.\bin\windows\kafka-server-start.bat .\config\server.properties // 启动之前先启动zookeeper
创建个主题(在kafka目录执行)
.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
开启生产者,进入到bin/windows目录下使用命令窗口(在kafka目录执行)
.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test
开启消费者,进入到bin/windows目录下使用命令窗口(在kafka目录执行)
.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
zookeeper连接: