Spring for Apache Kafka 2.8.0 已经发布,Spring for Apache Kafka 将 Spring 核心概念应用于基于 Kafka 的消息传递解决方案的开发,它提供了一个“模板”作为发送消息的高级抽象。它还通过 @KafkaListener 注解和“侦听器容器(listener container)”为消息驱动的 POJO 提供支持。
Spring for Apache Kafka 2.8.0 值得关注的变化包括:
- 该版本使用
kafka-clients3.0.0 版本 - 现在支持不按顺序的手动提交
- 同一个 container factory 现在可以同时用于批处理和记录监听器
- 独立的记录和批处理错误的处理程序已被普通的错误处理程序所取代
- 现在可以使用
KafkaTemplate来接收从已知分区/offsets 发来的特定记录
更多详情可查看:https://docs.spring.io/spring-kafka/docs/2.8.x/reference/html/#whats-new-part
暂无更多评论