我们很高兴宣布 Spring for Apache Kafka 2.0 版本的第一个里程碑 2.0.0.M1 发布。

2.0 系列中的重要新功能包括

• 在 KafkaTemplate 中支持时间戳。

• 查找主题的开头/结尾。

• 由 KIP-62 促成的新线程模型 - 现在使用者客户端不依赖于频繁调用的 poll()，线程模型简单得多；避免了内部 pause() / resume() 处理的需要。 侦听器现在始终在使用者线程上调用。 反过来，这促进了

• 提供了 ConsumerAwareMessageListener（和 BatchConsumerAwareMessageListener），因此侦听器实现可以访问 Consumer<?, ?> 对象以执行诸如 pause()、resume()、metrics() 等操作。

• @KafkaListener POJO 方法现在可以使用 @SendTo 注释，将方法结果发送到其他主题。

  @KafkaListener(id = "replyingListener", topics = "inTopic") @SendTo("replyTopic") public String replyingListener(String in) { return in.toUpperCase(); }

有关更多信息，请参见 使用 @SendTo 转发侦听器结果。

• @KafkaListener 注释现在具有 errorHandler 属性，允许为每个注释配置自定义错误处理程序。 以前，您必须为每个注释使用不同的容器工厂。

• spring-kafka-test 中的嵌入式 kafka 服务器 JUnit @Rule 现在可以作为 Spring Bean 提供（并自动连接到您的测试中）。 为了进一步简化，框架可以自动为您声明 bean；只需将 @EmbeddedKafka 添加到您的测试类中即可。 有关更多信息，请参见 @EmbeddedKafka 注释。

此外，基于此 spring-kafka 里程碑，Spring Integration Kafka 扩展的第一个 3.0 里程碑已发布 (3.0.0.M1)。

这两个项目的里程碑版本都可以在 Spring 里程碑仓库中找到。

我们非常感谢迄今为止收到的反馈（和贡献）。

注意

不幸的是，spring-kafka pom 存在对 spring-messaging-5.0.0.BUILD-SNAPSHOT 的不正确的传递依赖。 我们不建议在生产中使用里程碑版本，但是为了为测试提供一个稳定的平台，您应该将此依赖项覆盖为 5.0.0.M5。

2.0 版本的正式发布预计将在初夏（Spring Framework 5.0 发布后不久）。 欢迎通过常用渠道提供反馈、功能请求，当然还有贡献

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