SpringforApacheKafka(spring-kafka)项目将Spring核心概念应用于基于Kafka的消息传递解决方案的开发。它提供了一个“模板”作为发送消息的高级抽象。它还通过@KafkaListener注解和“侦听器容器(listenercontainer)”为消息驱动的POJO提供支持。
这些库促进了依赖注入和声明的使用。在所有这些用例中，你将看到SpringFramework中的JMS支持和SpringAMQP中的RabbitMQ支持的相似之处。
功能特性
KafkaTemplate
KafkaMessageListenerContainer
@KafkaListener
KafkaTransactionManager
带嵌入式kafka服务器的spring-kafka-testjar包
评论