我很高兴地宣布 Spring for Apache Kafka 1.1.0.RELEASE 现在可以在 Spring 发布仓库 和 Maven Central 中找到。

由于一些社区要求，我们决定绕过候选发布 (RC) 阶段并立即发布正式版 (GA)。

自上次里程碑 2 以来，没有太多变化，但以下是 Spring Kafka 1.1 的所有更改摘要

• Apache Kafka 0.10 升级；

• 通过 BatchMessageListener 以及通过 @KafkaListener 注解配置支持批量消息；

• 通过 KafkaNull 占位符对象支持 null payload 概念；

• 您现在可以从侦听器执行 seek 操作 - 这允许在使用组管理时由 Kafka 分配分区时设置初始偏移量。您还可以在初始化后执行任意 seek 操作；

• 允许将初始偏移量设置为相对于当前偏移量；

• KafkaTemplate 现在提供对 Producer 上的 metrics 和 partitionsFor 方法的访问。

master 已切换到 1.1.1 版本，以便立即进行维护。 此外，我们即将开始版本 1.2。 我们的计划是

• 为 KStreams 提供一流的支持；

• 实施 Spring Boot 基础设施；

• 为一些有趣的社区 请求 提供解决方案。

完全基于 Spring Kafka 1.1 的 spring-integration-kafka 版本 2.1.0.RELEASE 也可用。

与往常一样，最后，请随时与我们联系，提出任何问题、反馈或贡献！

项目页面 | 文档 | 问题 | 帮助