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

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() 可使用属性占位符进行配置。

• 由于 TemplateAwareExpressionParser 提供了 BeanFactory 解析器，现在可以简化 @KafkaListener 属性中的 SpEL 表达式。

• 引入了 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 版本兼容性的完整矩阵，请参阅项目页面。

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