spring 整合kafka监听消费的配置过程

2023-07-04 17:38:31 269

前言

最近项目里有个需求，要消费kafka里的数据。之前也手动写过代码去消费kafka数据。但是转念一想。既然spring提供了消费kafka的方法。就没必要再去重复造轮子。于是尝试使用spring的API。

项目技术背景，使用springMVC，XML配置和注解相互使用。kafka的配置都是使用XML方式。

整合过程

1.引入spring-kafka的依赖包

org.springframework.kafka spring-kafka 2.2.0.RELEASE

2.在spring的xml文件里增加配置项，也可以单独创建一个spring-context-XX.xml文件。

2.自定义消费者类，消费者类依然可以使用注解。

/** *getmsgfromkafka */ @Component publicclassPayPalConsumerimplementsMessageListener{ privatestaticLoggerlogger=LoggerFactory.getLogger(PayPalConsumer.class); @Autowired privateXXServiceXXService; @Override publicvoidonMessage(ConsumerRecordauthorizeRecord){ Stringvalue=authorizeRecord.value(); if(StringUtils.isEmpty(value)){ logger.warn("receivemessagefromkafkaisnull"); return; } logger.info("receivemessagefromkafkais{}",value); } }

使用这个步骤配置，一次性过。非常顺利。

到此这篇关于spring整合kafka监听消费的配置过程的文章就介绍到这了,更多相关spring整合kafka内容请搜索毛票票以前的文章或继续浏览下面的相关文章希望大家以后多多支持毛票票！

声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。

spring 整合kafka监听消费的配置过程

前言

整合过程

热门推荐

随机推荐