Spring 博客

新闻和活动

Apache Kafka 2.3 版 Spring 现已推出

版本 | Gary Russell | 2019 年 10 月 2 日 | ...

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

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

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

有关更多信息，请参阅新增功能章节，以下是一些亮点

生产

可以选择每个线程使用一个生产者，以避免在刷新时阻塞其他线程。
提供了AggregatingReplyingKafkaTemplate扩展到ReplyingKafkaTemplate，用于聚合来自多个消费者的回复。

消费

您现在可以添加一个RecordInterceptor，在调用侦听器之前修改记录。
ConsumerSeekAware现在支持相对查找。
您现在可以指定在处理先前poll()的结果和发出下一个poll()之间的时间延迟。
在使用手动AckMode时，您现在可以对记录进行否定确认，容器将执行必要的查找以重放记录。
现在支持 Micrometer Timer 来监控侦听器的性能。
可以将SeekToCurrentErrorHandler配置为将某些异常视为致命异常，从而禁用重试；您现在还可以为失败的传递在重新传递尝试之间添加BackOff。
提供RetryingDeserializer以在发生（例如，访问模式注册表时的网络故障）序列化错误时重试序列化。

Kafka Streams

现在提供了RecoveringDeserializationExceptionHandler用于处理反序列化异常。
提供HeaderEnricherTransformer在流拓扑定义中添加标头。
提供MessagingTransformer允许从流定义中调用 Spring Integration 流。

其他

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

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