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

鼓励所有用户升级到这些版本

• 2.3.0.RELEASE (新)

• 2.2.9.RELEASE (维护)

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

有关更多信息，请参阅“新增内容”章节，但这里有几个亮点：

生产

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

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

消费

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

• `ConsumerSeekAware` 现在支持相对查找。

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

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

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

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

• 提供了 `RetryingDeserializer` 来在发生诸如访问 schema registry 的网络故障时重试反序列化。

Kafka Streams

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

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

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

其他

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

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