Spring for Apache Kafka (spring-kafka) 项目将 Spring 的核心概念应用于基于 Kafka 的消息传递解决方案的开发。它提供了一个“模板”作为发送消息的高级抽象。它还为消息驱动的 POJO 提供支持,其中包含注释和“侦听器容器”。这些库促进使用依赖项注入和声明性。在所有这些情况下,您都会看到与 Spring Framework 中的 JMS 支持和 Spring AMQP 中的 RabbitMQ 支持的相似之处。@KafkaListener
特征
KafkaTemplate
KafkaMessageListenerContainer
@KafkaListener
KafkaTransactionManager
spring-kafka-test带有嵌入式 Kafka 服务器的 jar
Kafka 客户端和 Spring Boot 兼容性
使用上面的支持选项卡了解有关受支持版本的信息。
Apache Kafka 的 Spring 基于纯 Java jar。以下是兼容性矩阵:kafka-clients