Spring Boot Kafka概览及其优雅实现发布订阅功能

本文旨在深入剖析 Spring Kafka 的核心机制与实战应用，内容涵盖广泛且细节丰富，建议读者保持耐心，逐步消化。本文基于 Spring Kafka 2.3.3 及 Spring Boot 2.2.0 版本文档编写，旨在帮助开发者在 Spring 生态中高效集成 Apache Kafka。通过 Spring Boot 的自动配置能力，结合 spring.kafka.* 前缀的参数，Kafka 的集成变得极为便捷。此外，Spring Boot 提供的嵌入式 Kafka 代理极大地简化了测试流程。

文章目录

• • 1 前言
  • 2 Spring Kafka功能概览
  • • 2.1 自动创建主题
    • 2.2 发送消息
    • 2.3 接收消息
    • • 2.3.1 消息监听器
  • • 2.3.1.1 消息监听器容器
    • 2.3.1.2 使用KafkaMessageListenerContainer
    • 2.3.1.3 使用 ConcurrentMessageListenerCont