Spring for Apache Kafka 2.0 GA 版已正式发布。可从 Release Repository 和 Maven Central 下载:
repositories { maven { url 'http://repo.spring.io/release' } } compile "org.springframework.kafka:spring-kafka:2.0.0.RELEASE"
如 2.0 RC1 发布说明中提到的,1.3 GA 也支持使用 Spring Framework 4.3.x 应用程序的 Kafka 0.11.x.x 客户端。
6 个月的开发工作主要是为 Spring for Apache Kafka 项目带去对 Java 8 和 Spring Framework 5 的支持:
Apache Kafka 0.11.x.x
client
Transactions support
Headers mapping
Kafka Streams support
KafkaAdmin
is now available to automatically add topics (for NewTopic
beans present in the application context)
errorHandler
and groupId
support for @KafkaListener
; also Consumer
argument resolution
@EmbeddedKafka
for testing support
此外,还有 spring-integration-kafka-2.3.0.RELEASE 的小版本更新,该版本使用 spring-kafka-1.3.0.RELEASE 基础,并提供一些功能来支持 Apache Kafka 0.11.x.x 客户端。
详情请参阅发布主页 。