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


分享到:


相關文章: