尊敬的 Spring 社区：

我们很高兴地宣布 Spring Integration Kafka Support 1.1 GA 现已发布。 使用 Release Repository 与 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 时，会将包含 Acknowledgment 对象的 KafkaHeaders.ACKNOWLEDGMENT 标头添加到消息中。有了该消息头，您始终可以在下游流程中决定是否 acknowledge() Kafka 消息。

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

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

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

下一步是什么？

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

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