龙空技术网

Kafka的实际使用:spring-integration-kafka

会点代码的大叔 681

前言:

目前大家对“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集成