我很高興地宣佈 Spring for Apache Kafka 1.1.0.RELEASE 現在已在 spring release repo 和 Maven Central 中提供。

由於社群的一些要求，我們決定跳過候選版本 (RC) 階段，並立即發佈正式版 (GA)。

自之前的 Milestone 2 以來沒有太多變更，但以下是所有 Spring Kafka 1.1 變更的摘要

• Apache Kafka 0.10 升級；

• 透過 BatchMessageListener 以及透過 @KafkaListener 註解配置支援批次訊息；

• 透過 KafkaNull 佔位符物件支援 null payload 概念；

• 您現在可以從監聽器執行 seek 操作 - 這樣可以在使用群組管理時，在 Kafka 分配分割區時設定初始偏移量。您也可以在初始化後執行任意的 seek 操作；

• 允許將初始偏移量設定為相對於目前偏移量；

• KafkaTemplate 現在提供對 Producer 上的 metrics 和 partitionsFor 方法的存取權。

master 已切換到 1.1.1 版本，以便立即進行維護反應。此外，我們將很快啟動 1.2 版本。我們的計畫是

• 為 KStreams 提供一流的支援；

• 實作 Spring Boot 基礎架構；

• 為一些有趣的社群 requests 提供解決方案。

完全基於 Spring Kafka 1.1 的 spring-integration-kafka 版本 2.1.0.RELEASE 也已推出。

與往常一樣，請隨時與我們聯繫，提供任何問題、反饋或貢獻！

專案頁面 | 文件 | 議題 | 協助