我很高兴地宣布 Spring for Apache Kafka 1.1.0.RELEASE 现已在 spring release repo 和 Maven Central 中可用。

出于一些社区需求，我们决定跳过 Release Candidate (RC) 阶段，直接发布 General Availability (GA) 版本。

与之前的 Milestone 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 也已发布。

一如既往，欢迎随时与我们联系，提出任何问题、反馈或贡献！

项目主页 | 文档 | 问题跟踪 | 帮助