抢先一步
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
版本兼容性的完整矩阵,请参见项目页面。