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

• 现在可以为 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 一起发布。 欢迎通过常用渠道提供反馈、功能请求，当然还有贡献

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