适用于 Apache Kafka 2.0 的 Spring 版本 3 发布

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

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 并在 KafkaTemplate 中通过新的 executeInTransaction() 操作提供了事务支持；
现在，KafkaListenerContainer 可以使用 TransactionManager 来执行轮询和偏移量提交，并带有事务边界；
还提供了 Kafka 标头支持。现在，您可以使用任何任意标头发送和接收消息，例如，使用一些 correlationKey 标头构建请求-回复场景；
提供 ConsumerAwareErrorHandler 用于在发生错误时管理 Consumer 状态；
现在，KafkaEmbedded 可以使用任何任意 brokerProperties。

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

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

Spring 博客