我们很高兴地宣布 Spring for Apache Kafka 2.3 版本的第二个里程碑版本 - 2.3.0.M2 现已推出。

亮点

• 可以配置 SeekToCurrentErrorHandler 以不重试某些异常。

• 新的 RecoveringDeserializationExceptionHandler 可以从 Kafka Streams 应用程序中失败的反序列化操作中恢复，例如将失败的消息发送到死信主题。

• 新的 HeaderEnricher 变换器可以添加到 Kafka Streams 拓扑中以添加标头。

• 新的 MessagingTransformer 可用于在 Kafka Streams 拓扑中调用 Spring Integration 流。

• 新的 AggregatingReplyingKafkaTemplate 可以发送记录并等待来自多个消费者的响应。

有关更多信息，请参阅文档中的“新增功能”章节和更改日志。

• M1 的更改日志

• M2 的更改日志

此外，Spring Integration for Apache Kafka (spring-integration-kafka) 3.2.0.M2 也已推出；它基于 Spring for Apache Kafka 2.3 和 Spring Integration 5.2。

• KafkaMessageSource 消费者现在可以暂停/恢复。

• KafkaMessageSource 消费者现在可以配置为在每次轮询时检索多条记录。

• 现在所有组件都可使用 XML 配置。

有关更多信息，请参阅Spring Integration 章节。

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