尊敬的 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 標籤)