適用於 Apache Kafka 3.2.0、3.1.5 和 3.0.17 的 Spring 版本現已推出

發行版本 | Soby Chacko | 2024 年 5 月 21 日 | ...

謹代表團隊以及社群中所有貢獻者，我們很高興宣布 Spring for Apache Kafka 3.2.0 正式 GA 版本發布。

Spring for Apache Kafka 3.2.0

3.2.0 GA 版本包含新增功能、功能增強、錯誤修正和文件更新。如需 3.2.0 版本中所有變更的詳細資訊，請參閱 https://github.com/spring-projects/spring-kafka/releases/tag/v3.2.0。

即將推出的 Spring Boot 3.3.0 將包含 Spring for Apache Kafka 的 3.2.0 版本。

由於這是 3.2.x 系列中的第一個 GA 版本，以下回顧 Spring for Apache Kafka 這個新世代版本中包含的所有增強功能和特色。

此版本使用 Kafka Client 3.7.0 版本，其中導入了新的消費者群組協定。這作為搶先體驗功能包含在 3.7.0 用戶端中，不適合在生產環境中使用。目前我們僅建議將新的消費者群組協定用於測試目的。預設情況下，Spring for Apache Kafka 中使用傳統消費者，並且在測試新的消費者群組協定時，必須使用 group.protocol 消費者屬性選擇加入。如需更多資訊，請參閱此處。
這是一個新的範例應用程式，示範了新的消費者群組協定的搶先體驗版本。
由於 KafkaClusterTestKit 中的某些限制，KRaft 模式在 Embeddedkafka 中預設為停用。如果有人想在 KRaft 模式下嘗試 EmbeddedKafka，他們必須透過 EmbeddedKafka 上的 kraft 屬性啟用它。此外，新的消費者群組協定僅在 kraft 模式下運作，因此，在測試此新協定時，由於上述 KafkaClusterTestKit 中的限制，我們建議不要使用啟用 kraft 模式的 EmbeddedKafka。若要測試新的消費者群組協定，我們建議在 KRaft 模式下使用真實的 Broker。如需更多資訊，請參閱此處。
能夠以程式設計方式在 Consumer 上強制重新平衡。
框架中 Kafka Streams 支援中用於互動式查詢的新 API。
交易 ID 後綴的自訂功能。
提供一種方法，可根據非阻塞重試中的例外類型路由到不同的 DLT。
非同步 Kafka Listener 傳回類型。
AfterRollbackProcessor 的改進，可略過持續失敗的整批記錄。
類別層級 @KafkaListener 上的非阻塞重試支援。如需更多詳細資訊，請參閱此處
RetryTopicConfiguration 改進
新的 API 方法，可根據使用者提供的函式搜尋偏移量。如需更多資訊，請參閱參考文件。
@PartitionOffset 支援搜尋位置。
移除 Spring for Apache Kafka 中許多 Apache Kafka 特定的原生執行階段提示，優先採用 graalvm-reachability-metadata 中的相同支援。