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

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

如此快速发布 point release 的一般原因是 最近发布的 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 版本兼容性的完整矩阵。

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