我们很高兴地宣布 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