1.安装java
brew cask install java
1.下载kafka(Source download)
https://kafka.apache.org/downloads
解压目录到 /usr/local/kafka
2.启动zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties
3.启动kafka
bin/kafka-server-start.sh config/server.properties
4.创建一个主题"article"
bin/kafka-topics.sh --create --topic article --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1
5.启动Producer客户端发送消息
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic article
启动后,输入任意内容后按enter键即会推到队列。按ctrl+C退出。
6.消费消息
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic article --from-beginning
如果有--from-beginning,则会从队列头开始拉出全部内容。如果不加,则仅从启动后拉取新的消息。
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。
扫码关注腾讯云开发者
领取腾讯云代金券
Copyright © 2013 - 2025 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号:粤B2-20090059 深公网安备号 44030502008569
腾讯云计算(北京)有限责任公司 京ICP证150476号 | 京ICP备11018762号 | 京公网安备号11010802020287
Copyright © 2013 - 2025 Tencent Cloud.
All Rights Reserved. 腾讯云 版权所有