领先一步
VMware 提供培训和认证,助您快速提升。
了解更多Apache Kafka 的 Spring (spring-kafka) 项目将核心 Spring 概念应用于基于 Kafka 的消息传递解决方案的开发。它提供了一个“模板”作为发送消息的高级抽象。它还为使用 @KafkaListener
注解和“监听器容器”的消息驱动 POJO 提供支持。这些库促进了依赖注入和声明式使用。在所有这些情况下,您将看到与 Spring 框架中的 JMS 支持和 Spring AMQP 中的 RabbitMQ 支持的相似之处。
KafkaTemplate
KafkaMessageListenerContainer
@KafkaListener
KafkaTransactionManager
spring-kafka-test
jar 包含嵌入式 Kafka 服务器
有关支持的版本的详细信息,请参阅上面的“支持”选项卡。
Spring for Apache Kafka 基于纯 Java kafka-clients
jar 包。以下是兼容性矩阵:
Spring for Apache Kafka 版本 | Spring Integration for Apache Kafka 版本 | kafka-clients |
Spring Boot |
---|---|---|---|
3.2.x | 6.3.x | 3.7.0 | 3.3.x |
3.1.x | 6.2.x | 3.6.0 | 3.2.x |
3.0.x | 3.3.2 到 3.6.0 | ||
重要: 此矩阵是客户端兼容性矩阵;有关客户端/代理兼容性的完整讨论,请参阅 Kafka 兼容性矩阵
使用 Maven 或 Gradle 进行版本管理时,这些版本将被传递引用。
Spring Boot 1.5 (已结束生命周期) 用户应使用 1.3.x (Boot 依赖项管理默认情况下将使用 1.1.x,因此应覆盖它)。
Spring Boot 2.1 (已结束生命周期) 用户应使用 2.2.x (Boot 依赖项管理将使用正确的版本)。
Spring Boot 2.2 (已结束生命周期) 用户应使用 2.3.x (Boot 依赖项管理将使用正确的版本,或将版本覆盖为 2.4.x)。
Spring Boot 2.3 (已结束支持) 用户应使用 2.5.x(Boot 依赖管理将使用正确的版本,或覆盖版本至 2.6.x)。
Spring Boot 2.4 (已结束支持) 用户应使用 2.6.x(Boot 依赖管理将使用正确的版本,或覆盖版本至 2.7.x)。
Spring Boot 2.5 (已结束支持) 用户应使用 2.7.x(Boot 依赖管理将使用正确的版本)。
Spring Boot 2.6 用户应使用 2.8.x(Boot 依赖管理将使用正确的版本)。
Spring Boot 2.7 用户应使用 2.8.x 或 2.9.x(Boot 依赖管理将使用 2.8.x 版本)。
要在 Boot 2.7.x 中使用 2.9.x;请参阅 覆盖 Spring Boot 依赖项。
Spring Boot 3.0.x 使用 kafka-clients
3.3.2
Spring Boot 3.1.x 使用 kafka-clients
3.4.1
使用 Spring Initializr 启动您的应用程序。