Spring for Apache Kafka 2.3 发布

Spring for Apache Kafka 2.3 发布了。Spring for Apache Kafka（spring-kafka）项目将核心 Spring 概念应用于基于 Kafka 的消息传递解决方案。它提供了一个“模板”作为发送消息的高级抽象，还为带有 @KafkaListener 注解和“侦听器容器（listener container）”的消息驱动的 POJO 提供支持。这些库促进了依赖注入和声明的使用。

此版本更新主要内容包括：

Producing

• 在每个线程中可选使用生产者，以避免在刷新时阻塞其它线程。

• 提供了对 ReplyingKafkaTemplate 的 AggregatingReplyingKafkaTemplate 扩展，以汇总来自多个消费者的回复

Consuming

• 现在可以在调用侦听器之前添加一个 RecordInterceptor 来修改记录。

• ConsumerSeekAware 现在支持相对搜寻。

• 现在可以指定在处理上一个 poll() 结果与发出下一​​个 poll() 之间的延迟。

• 使用手动 AckMode 时，现在可以消极地确认记录，并且容器将执行必要的搜索以重播记录。

Kafka Streams

• 现在提供了 RecoveringDeserializationExceptionHandler 用于处理反序列化异常。

• 提供了 HeaderEnricherTransformer 以在流拓扑定义中添加标头。

• 提供了 MessagingTransformer 以允许从流定义中调用 Spring Integration 流。

Miscellaneous

• 提供了委托序列化器和反序列化器实现，以允许发送/接收包含不同类型的记录。

详情查看更新说明：

https://spring.io/blog/2019/10/02/spring-for-apache-kafka-2-3-is-now-available