亲爱的 Spring 社区：

我们很高兴地宣布 Spring Integration Kafka Support 1.1 GA 现已发布。使用发布仓库配合 Maven 或 Gradle

compile "org.springframework.integration:spring-integration-kafka:1.1.1.RELEASE"

或下载分发存档进行体验。

概述

之所以在 1.0 GA 发布后不久就推出了下一个补丁版本，主要原因是为了解决即将发布的 Spring XD 1.1.1 和 1.2 版本中一些关键的 修复。此外，本次发布还提供了消息生成流式传输场景的性能改进，这需要升级到 Spring Integration 4.1，这也是 Spring XD 的最低要求。

本次发布还引入了一个更重要的功能，即手动确认，允许在需要时稍后提交消息的 offset。为此，Spring Integration Kafka 引入了 Acknowledgment 接口。当 KafkaMessageDrivenChannelAdapter#autoCommitOffset 设置为 false 时，消息中会添加一个 KafkaHeaders.ACKNOWLEDGMENT 头，其中包含一个 Acknowledgment 对象。拥有这个消息头后，您始终可以在下游流程中决定是否 acknowledge() 这个 Kafka 消息。

如果您直接使用 KafkaMessageListenerContainer，现在可以注册一个 AcknowledgingMessageListener。

public interface AcknowledgingMessageListener {
	void onMessage(KafkaMessage message, Acknowledgment acknowledgment);
}

这样做会禁用自动 offset 更新，您可以使用 Acknowledgment 参数的 acknowledge() 方法来触发 offset 更新。

下一步？

我们的计划是继续进行 1.2 版本的开发。这将是一个关键的升级，将支持 Kafka 0.8.2，可能不兼容旧版本。此外，我们还将为 Kafka Adapter 中的重试机制暴露更多可配置选项。还有更多！

项目主页 | JIRA | 问题 | [贡献] (https://github.com/spring-projects/spring-integration/blob/master/CONTRIBUTING.md) | StackOverflow (spring-integration 标签)