親愛的 Spring 社群：

我們很高興宣布 Spring Integration Kafka 支援 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 時，一個 KafkaHeaders.ACKNOWLEDGMENT 標頭會加入到訊息中，其中包含一個 Acknowledgment 物件。有了這個訊息標頭，您隨時可以決定是否在下游流程中 acknowledge() 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 標籤)