我们很高兴地宣布适用于 Apache Kafka 的 Spring 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 发布候选版本也已可用。

它们可从 里程碑存储库 下载。

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

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