我们很高兴地宣布 Spring for Apache Kafka 2.0 版本的 里程碑 3 现已可用。

可从 Milestone Repository 下载。

repositories {
    maven { url 'http://repo.spring.io/libs-milestone' }
}
compile "org.springframework.kafka:spring-kafka:2.0.0.M3"

自 上次发布公告 以来，以下功能已包含在当前的里程碑版本中：

• 基于 Apache Kafka 0.11.0.0 客户端版本；

• 基于新的 Apache Kafka 基础，我们引入了 KafkaTransactionManager 以及通过新的 executeInTransaction() 操作在 KafkaTemplate 中支持事务；

• 现在可以为 KafkaListenerContainer 提供 TransactionManager，以便在事务边界内执行轮询和偏移量提交；

• 还提供了 Kafka 消息头支持。现在您可以发送和接收带有任意消息头的消息，例如使用某个 correlationKey 消息头构建请求-回复场景；

• 提供了 ConsumerAwareErrorHandler，用于在发生错误时管理 Consumer 状态；

• 现在可以为 KafkaEmbedded 提供任意的 brokerProperties。

感谢所有社区成员的反馈和贡献！

2.0 版本预计将于 9 月份正式发布（在 Spring Framework 5.0 发布后不久）。欢迎通过常规渠道提供反馈、功能请求以及贡献！

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