领先一步
VMware 提供培训和认证,助您加速进步。
了解更多Spring for Apache Kafka (spring-kafka) 项目将核心 Spring 概念应用于基于 Kafka 的消息解决方案的开发。它提供了一个“模板”作为发送消息的高级抽象。它还通过 @KafkaListener 注解和一个“监听器容器”为消息驱动的 POJO 提供支持。这些库促进了依赖注入和声明式编程的使用。在所有这些情况下,您会看到与 Spring 框架中 JMS 支持和 Spring AMQP 中 RabbitMQ 支持的相似之处。
KafkaTemplate
KafkaMessageListenerContainer
@KafkaListener
KafkaTransactionManager
可重试主题(Retryable Topics)
带有嵌入式 kafka 服务器的 spring-kafka-test jar
有关支持版本的信息,请使用上方的支持选项卡。
Spring for Apache Kafka 基于纯 Java 的 kafka-clients jar。以下是兼容性矩阵:
| Spring for Apache Kafka 版本 | Spring Integration for Apache Kafka 版本 | kafka-clients |
Spring Boot |
|---|---|---|---|
| 3.3.x | 6.4.x | 3.8.0 到 3.9.0 | 3.4.x |
| 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 兼容性矩阵
要覆盖 Apache Kafka 客户端版本,请参阅覆盖 Spring Boot 依赖项。