Spring Boot集成Apache kafka

简介

Spring for Apache Kafka项目将Spring核心概念应用于基于Kafka的消息传递解决方案的开发。 Spring 官方提供“template”作为发送消息的高级抽象。 还利用@KafkaListener注解和“listener container”来为消息驱动的POJO提供支持。

步骤

1.pom.xml添加maven依赖

Spring Boot集成Apache kafka

具体的版本对应关系如下:

Spring Boot集成Apache kafka

2.application.yml配置kafka

Spring Boot集成Apache kafka

3.发送消息

Spring Boot集成Apache kafka

4.接收消息

Spring Boot集成Apache kafka


分享到:


相關文章: