SQL Server2008的安装,SQLServer2008的安装......
2023-02-22 271 安装
springboot-kafka一个简单例子
来源：互联网
2023-02-20 17:15:07 515
想在springboot中使用kafka，结合了官网的例子，自己创建了一个简单的测试程序，不过首先要安装kafka和zookeeper，我这个是本地测试的，所以在本地安装了Windows版本的kafka和zookeeper，远程的改下配置也可以。
如果安装好了，基本上没多大问题，只需要些许代码，就可以跑起来程序。
首先要明白，kafka有两个部分，一个是生产者：负责向kafka发送信息，发送的时候会指定topic；一个是消费者，消费者负责监听某个topic，如果topic有消息，就会自动接收。
kafka还有两个概念：分区和组。分区是说，生产者生产的消息可以存储到不同的分区中；组是说，一个组可以有多个消费者，但是对于一个消息，进入了某个组，只能被组内的一个消费者消费。
8创建一个简单的springboot项目
3Windows安装k1afka并测试通过
4Windows安装zookeeper
工具/原料
- kafka
- springboot
方法/步骤
引入springboot-kafka的jar包依赖。
在application.properties添加配置信息，本机安装的kafka的ip和端口号，9092默认端口。消费者的组名称。
创建生产者服务，声明成spring组件，注入KafkaTemplate，send方法的第一个参数是topic的名称，第二个参数是数据。
创建消费者服务，开启监听，如果获取到数据，则输出接受到的数据。
创建restController，调用生产者，往kafka发送4个消息。
启动zookeeper服务，点击zkServer运行。
启动kafka：kafka-server-start.bat ....configserver.properties，注意进入.bat所在的当前目录下启动
启动项目，请求kafkaSender，返回success。
查看日志：发现接收到了消息。
以上方法由办公区教程网编辑摘抄自百度经验可供大家参考！
上一篇：Shell中后台起动并启用dump文件 下一篇：centos 7安装FPM
相关文章
