Spring for Apache Kafka 2.5.0 RC1更新

Spring for Apache Kafka (spring-kafka) 2.5.0 RC1 发布了。

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

此版本亮点包括:

kafka-clients 2.5.0

支持新的“提取偏移请求(fetch-offset-request)”防护程序,需要的生产者更少。

支持静态组成员身份。

与 Micrometer 更多地集成。

Optional Delivery Attempts 头

RecoveringBatchErrorHandler 可以提交部分批处理并从批处理中的失败记录中重播(在侦听器的配合下);现在这是批处理侦听器的默认设置。

KafkaTemplate 中的可重写生产者属性,允许多个模板使用同一生产者工厂。

提供了简单的 String 序列化器和反序列化器。

JsonDeserializer 中创建的类型灵活性更大。

详情查看更新说明:

https://spring.io/blog/2020/04/30/spring-for-apache-kafka-2-5-0-release-candidate