我很高兴地宣布，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 占位符对象支持 空有效负载 概念；

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

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

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

master 已切换到 1.1.1 版本以立即进行维护响应。我们还将很快开始 1.2 版本。我们的计划是

• 为 KStreams 提供一流的支持；

• 实现 Spring Boot 基础设施；

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

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

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

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