领先一步
VMware 提供培训和认证,助您加速进步。
了解更多我们很高兴地宣布 Spring for Apache Kafka 2.0 版本的 2.0.0.RELEASE 已正式可用。
正如在 2.0 RC1 发布公告 中提到的,1.3 GA 版本也已发布,支持使用 Kafka 0.11.x.x 客户端和 Spring Framework 4.3.x 应用程序。
它们可从 Release Repository 和 Maven Central 下载。
repositories {
maven { url 'http://repo.spring.io/release' }
}
compile "org.springframework.kafka:spring-kafka:2.0.0.RELEASE"
这是历时 6 个月,将 Java 8 和 Spring Framework 5 的愿景融入 Spring for Apache Kafka 项目所取得的成果,以下是我们目前为止的总体进展:
Apache Kafka 0.11.x.x 客户端
事务支持
Header 映射
Kafka Streams 支持
现在可以使用 KafkaAdmin 自动添加 Topic(针对应用程序上下文中存在的 NewTopic Bean)
为 @KafkaListener 支持 errorHandler 和 groupId;还支持 Consumer 参数解析
@EmbeddedKafka 用于测试支持
其中许多功能在 1.3 版本中也可用。
感谢所有社区成员的反馈和贡献!
此外,次要版本 spring-integration-kafka-2.3.0.RELEASE 也已发布。此版本利用 spring-kafka-1.3.0.RELEASE 基础,并提供了一些功能来支持 Apache Kafka 0.11.x.x 客户端。
有关 spring-kafka、spring-integration-kafka 和 kafka-clients 版本兼容性的完整矩阵,请参阅项目页面。