我们很高兴地宣布 Apache Kafka 1.3 版本的 Spring 框架 里程碑 2 发布。

您可以从 里程碑存储库 下载。

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

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

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

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

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

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

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

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

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

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

1.3.0 版本的正式发布预计将在 9 月份与 2.0.0.RELEASE 同时发布。欢迎通过常规渠道提供反馈、功能请求以及当然还有贡献。

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