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消息系统中间件，消息生产者和消息消费者，演示完毕。

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