我们很高兴地宣布以下版本现已发布。

建议所有用户升级到这些版本

• 2.3.0.RELEASE (新版本)

• 2.2.9.RELEASE (维护版本)

2.3.0 版本是该项目最新系列中的第一个版本。

有关更多信息，请参阅 What’s New 章节，以下是一些亮点

生产

• 可以选择为每个线程使用一个生产者，以避免刷新时阻塞其他线程。

• AggregatingReplyingKafkaTemplate 扩展被提供给 ReplyingKafkaTemplate，用于聚合来自多个消费者的回复。

消费

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

• ConsumerSeekAware 现在支持相对查找。

• 现在您可以指定处理前一个 poll() 的结果和发出下一个 poll() 之间的时间延迟。

• 当使用手动 AckMode 时，您现在可以否定确认一条记录，容器将执行必要的查找以重播该记录。

• Micrometer Timer 现在支持监控监听器性能。

• SeekToCurrentErrorHandler 可以配置为将某些异常视为致命异常，从而禁用重试；您现在还可以在失败交付的重试尝试之间添加 BackOff。

• RetryingDeserializer 被提供用于在发生例如访问模式注册表的网络故障时，重试序列化。

Kafka Streams

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

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

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

其他

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

项目页面 | GitHub | 问题 | 文档 | Stack Overflow | Gitter