赞
踩
生产中使用到的中间件使用心得记录,感兴趣可以关注我一起学习~
硬件:mac
软件:kafka v3.0.0
通过brew安装,会默认直接安装最新的版本
brew install kafka
安装完后,启动zookeeper、kafka
- brew services start zookeeper
-
- brew services start kafka
启动完后,创建一个topic
kafka-topics --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 3 --topic test_1
创建一个生产者producer
kafka-console-producer --bootstrap-server localhost:9092 --topic test_1
创建一个消费者
- kafka-console-consumer --bootstrap-server localhost:9092 --topic test_1 --from-beginning
-
--from-beginning参数为从头开始消费
测试
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。