SpringBoot整合Kafka中间件,下篇

小编的上篇文章,给大家演示了如何基于SpringBoot工程快速搭建Kafka消息生产者。接下来,小编再给大家演示如何基于SpringBoot工程快速搭建Kafka消息消费者。

传陆编程

第一步、创建 Spring Boot 基础工程

工程名称: springboot-kafka-consumer

工程类型: Maven 工程

第二步、编辑工程maven配置文件pom.xml

添加Kafka工程依赖

pom.xml

第三步、创建消息消费者配置信息类

记得一定不要忘记添加@Configuration注解。

BOOTSTRAP_SERVERS_CONFIG、GROUP_ID_CONFIG值没有采用硬编码的形式,而是读取资源配置注入的方式。

这个类的最主要作用就是初始化了kafkaListenerContainerFactory实例,消息监听就是通过这个监听工厂实例完成的。

消息消费配置类

第四步、创建消息消费监听类

@KafkaListener注解开启消息监听,topics指定主题

消息消费监听类

第五步、修改入口启动类

添加开启kafka注解@EnableKafka

入口启动类

第六步、修改工程资源配置文件

资源配置文件

第七步、启动运行工程

工程启动成功后,通过浏览器,访问消息生产者Restful服务

访问消息生产服务创建消息

查看消息消费者工程控制台输出日志

消费者成功坚挺到消息并消费

结束

微服务架构中引入Kafka消息系统中间件,消息生产者和消息消费者,演示完毕。

不管工程感觉如何简单,都依然希望大家能动手实践起来。就像,听别人坐过山车的感觉,听一百次,都不会体会到心悬着的感觉。期望的日志在控制台打印出来的怦然心动的感觉,自己感受一下吧。

  • 发表于:
  • 原文链接https://kuaibao.qq.com/s/20181206A0NKZ500?refer=cp_1026
  • 腾讯「云+社区」是腾讯内容开放平台帐号(企鹅号)传播渠道之一,根据《腾讯内容开放平台服务协议》转载发布内容。
  • 如有侵权,请联系 yunjia_community@tencent.com 删除。

扫码关注云+社区

领取腾讯云代金券