我们很高兴地宣布 Spring for Apache Kafka 2.0 版本的第三里程碑版本已发布。

可以从里程碑仓库下载

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 基础，我们在 KafkaTemplate 中引入了 KafkaTransactionManager 和事务支持，通过新的 executeInTransaction() 操作；

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

• 同时提供了 Kafka 标头支持。现在您可以发送和接收带有任意标头的消息，例如使用一些 correlationKey 标头构建请求-响应场景；

• 提供 ConsumerAwareErrorHandler 以在发生错误时管理 Consumer 状态；

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

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

预计 2.0 版本的正式发布将在 9 月（紧随 Spring Framework 5.0 版本之后）。欢迎通过常用渠道提供反馈、功能请求和贡献

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