我们很高兴地宣布 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 消费者现在可以配置为在每次 poll 时检索多条记录。

• 所有组件现在都提供 XML 配置。

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

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