Spring for Apache Kafka 2.1 RC1 和 2.0.1 & 1.3.1 发布

发布 | Artem Bilan | 2017年11月9日 | ...

我们很高兴地宣布 Spring for Apache Kafka 2.1 版本的第一个候选发布版本。

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

如此快速发布主要版本的原因是最近发布的 Apache Kafka 1.0.0 版本。此版本没有关键功能，但 kafka.admin 和 kafka.streams 中引入了一些重大更改。因此，此版本主要代表与 Apache Kafka 1.0.0 的兼容性。

弃用 KafkaEmbedded 中的 bounce() 和 waitUntilSynced()，因为 AdminUtils 中相应的 API 已被移除。
KStreamBuilderFactoryBean 现在使用 StreamsBuilder 而不是已弃用的 KStreamBuilder。
@EmbeddedKafka.brokerProperties() 可以使用属性占位符进行配置。
@KafkaListener 属性中的 SpEL 表达式现在可以简化使用，因为 BeanFactory 解析器随 TemplateAwareExpressionParser 一起提供。
引入了 NonResponsiveConsumerEvent 来跟踪 ListenerContainer 的状态，以便检测目标 Broker 可能不可用。
引入了 SeekToCurrentErrorHandler，允许在发生异常后 seek() 消费者。

2.1 版本是即将推出的 Spring Boot 2.0 中 Kafka 自动配置的基础。

维护版本 2.0.1 已发布，并提供了一些关键错误修复、与 Apache Kafka 1.0.0 的兼容性以及为 2.1 版本移植的功能。

1.3.1 版本的发布主要目的是支持 Apache Kafka 1.0.0 并提供关键错误修复。

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

Spring 博客