抢先一步
VMware 提供培训和认证,以加速您的进步。
了解更多我们很高兴地宣布 Spring for Apache Kafka 2.0 版本的 2.0.0.RC1 发布候选版本已发布。
正如在 1.3.0.M2 公告 中讨论的,我们正在并发发布 1.3 和 2.0,其中 1.3 包含 2.0 功能的子集,支持 Kafka 0.11.x.x 客户端,同时仍然支持 Spring Framework 4.3。 因此,1.3.0.RC1 发布候选版本也已发布。
它们可以从 Milestone 存储库 下载
repositories {
maven { url 'http://repo.spring.io/libs-milestone' }
}
compile "org.springframework.kafka:spring-kafka:2.0.0.RC1"
自从之前的公告以来,以下是添加的附加功能的摘要
支持 Spring Framework 的事务同步。
现在可以使用 KafkaAdmin 自动添加主题(对于应用程序上下文中存在的 NewTopic bean)。
AckMode.RECORD 现在可以在侦听器返回后立即正确提交偏移量。 这得益于侦听器容器中的新线程模型。
多个错误修复
这些功能也可在 1.3 版本中使用。
感谢所有社区成员的反馈和贡献!
2.0 版本的正式发布将在 Spring Framework 5.0 版本发布后不久进行。 欢迎通过常用渠道提供反馈、功能请求以及贡献
此外,spring-integration-kafka 里程碑版本(用于 spring-kafka 2.0 的 3.0.0.M2、用于 spring-kafka 1.3 的 2.3.0.RC1 以及用于 spring-kafka 1.2 的 2.2.0.M1)也可在里程碑存储库中找到。
此外,维护版本 spring-integration-kafka-2.1.2.RELEASE 也可用,它为 KafkaProducerMessageHandler 提供了 ErrorMessageStrategy 和 sendFailureChannel 支持。 同时,发布到主题的成功消息 (SendResult.getRecordMetadata()) 将作为 kafka_recordMetadata 标头与 requstMessage 一起作为有效负载发送到 outputChannel。
有关 spring-kafka、spring-integration-kafka 和 kafka-clients 版本兼容性的完整矩阵,请参见项目页面。