我们很高兴地宣布 Spring for Apache Kafka 2.0 版本的 2.0.0.RC1 release candidate 已发布。

正如在 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 release candidate 也已可用。

它们可从 Milestone Repository 下载

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 版本兼容性的完整矩阵，请参阅项目页面。

项目主页 | 问题 | 贡献 | 帮助 | 聊天