小编的上篇文章,给大家演示了如何基于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消息系统中间件,消息生产者和消息消费者,演示完毕。
不管工程感觉如何简单,都依然希望大家能动手实践起来。就像,听别人坐过山车的感觉,听一百次,都不会体会到心悬着的感觉。期望的日志在控制台打印出来的怦然心动的感觉,自己感受一下吧。
领取专属 10元无门槛券
私享最新 技术干货