Spring KafkaSpring 的 Kafka 抽象

Spring for Apache Kafka (spring-kafka) 项目将 Spring 核心概念应用于基于 Kafka 的消息传递解决方案的开发。它提供了一个“模板”作为发送消息的高级抽象。它还通过 @KafkaListener 注解和“侦听器容器(listener container)”为消息驱动的 POJO 提供支持。

这些库促进了依赖注入和声明的使用。在所有这些用例中，你将看到 Spring Framework 中的 JMS 支持和 Spring AMQP 中的 RabbitMQ 支持的相似之处。

功能特性

• KafkaTemplate

• KafkaMessageListenerContainer

• @KafkaListener

• KafkaTransactionManager

• 带嵌入式 kafka 服务器的 spring-kafka-test jar 包