我们很高兴地宣布 Spring for Apache Kafka 1.3 版本的 Milestone 2 可用。

可从 Milestone Repository 下载。

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

（Milestone 1 有一个阻塞性问题）。

功能上，1.3.x 系列提供了 2.0 系列（需要 Spring Framework 5.0 和 Java 8）的一个子集，但支持 Java 7 项目和 Spring Framework 4.3.x。

主要目的是提供对 0.11.0.0 Apache Kafka 客户端功能的早期访问，但这里是摘要

• Apache Kafka 0.11.0.0 客户端；

• 由 KIP-62 促进的改进的监听器容器线程模型；

• 凭借新的 Apache Kafka 基础，我们通过新的 executeInTransaction() 操作引入了 KafkaTransactionManager 和 KafkaTemplate 中的本地事务支持；

• 现在可以为 KafkaListenerContainer 提供 TransactionManager，以在事务边界内执行轮询和偏移提交，并将 Kafka 事务与某些外部事务管理器同步。

• 还提供了对新 Kafka Headers 功能的支持。现在您可以发送和接收带有任何任意标头的消息，例如使用一些 correlationKey 标头构建请求-回复场景；

• 现在可以为 KafkaEmbedded JUnit 类/Spring Bean 提供任何任意的 brokerProperties；

• KafkaAdmin 可用于通过扫描应用程序上下文中 NewTopic Bean 来自动创建主题。

此外，Apache Kafka 的 Spring Integration 扩展 2.3.0.M2 可用于集成 Spring for Apache Kafka 1.3 基础。特别是，KafkaProducerMessageHandler 可以提供 KafkaHeaderMapper，如果 Jackson JSON 处理器存在于类路径中，则默认使用 DefaultKafkaHeaderMapper。它还包括对错误处理的增强。

spring-integration-kafke 2.2.0.M1 也可用于 spring-kafka 1.2.x。它包括上面提到的增强的错误处理。

有关 spring-kafka、spring-integration-kafka 和 kafka-clients 版本兼容性的完整矩阵，请参阅 项目页面。

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

1.3.0 版本的通用可用性预计将在 9 月份与 2.0.0.RELEASE 一起发布。欢迎通过常规渠道提供反馈、功能请求以及贡献。

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