尊敬的 Spring 社区：

我们很高兴地宣布 Spring Integration Kafka 支持 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 的最低版本要求。

另一个重要特性是，此版本引入的手动确认，其中消息的偏移量可以稍后按需提交。为此，Spring Integration Kafka 引入了Acknowledgment接口。当KafkaMessageDrivenChannelAdapter#autoCommitOffset设置为false时，会将KafkaHeaders.ACKNOWLEDGMENT头添加到消息中，其中包含一个Acknowledgment对象。拥有该消息头，您始终可以在下游流程中决定是否确认()Kafka 消息。

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

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

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

接下来做什么？

我们计划开发 1.2 版本。它将是对 Kafka 0.8.2 的重大升级，可能不向后兼容。此外，我们将公开更多可配置选项，以便在 Kafka 适配器中支持重试。还有更多！

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