前言:
目前大家对“kafka spring集成”都比较关切,同学们都需要分析一些“kafka spring集成”的相关内容。那么小编同时在网络上搜集了一些对于“kafka spring集成””的相关知识,希望同学们能喜欢,看官们一起来了解一下吧!单位,新突击做了一个项目,用的新技术比较多一些,说是新技术,只是我之前没有接触过,kafka是其中之一。
因为项目用到了spring,所以在使用很多开源框架的时候,都选择使用spring进行集成。而kafka的使用,我们是使用到了spring-integration-kafka。
pom.xml
项目使用maven进行构建,使用spring-integration-kafka的话,需要引入相关jar包:
spring选择的是4.1.6.RELEASE:
发送消息
配置文件:topic="test" 需要修改成对应的topoc的名称
kafka.properties:
代码
消息接收
配置文件
代码
标签: #kafka spring集成