Spring for Apache Kafka 3.2.0, 3.1.5 和 3.0.17 現已釋出

釋出 | Soby Chacko | 2024 年 5 月 21 日 | ...

代表團隊和社群中所有貢獻者，我們很高興宣佈 Spring for Apache Kafka 3.2.0 已正式釋出。

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 中的某些限制，Embeddedkafka 中的 KRaft 模式預設是停用的。如果有人想在 KRaft 模式下嘗試 EmbeddedKafka，他們必須透過 EmbeddedKafka 上的 kraft 屬性來啟用它。此外，新的消費者組協議僅在 kraft 模式下工作，因此在測試此新協議時，由於上述 KafkaClusterTestKit 的限制，我們不建議在啟用 kraft 模式的情況下使用 EmbeddedKafka。要測試新的消費者組協議，我們推薦使用 KRaft 模式下的真實 broker。更多資訊，請參閱此處。
支援以程式設計方式在消費者上強制執行再平衡。
框架中對 Kafka Streams 支援的互動式查詢新 API。
事務 ID 字尾的自定義。
在非阻塞重試中，提供一種基於異常型別路由到不同 DLT 的方式。
非同步的 Kafka Listener 返回型別。
AfterRollbackProcessor 的改進，以跳過持續失敗的整個記錄批次。
類級別 @KafkaListener 支援非阻塞重試。更多詳細資訊請參閱此處
RetryTopicConfiguration 的改進
新 API 方法，用於根據使用者提供的函式定位到偏移量。更多資訊，請參閱參考文件。
@PartitionOffset 支援定位位置。
刪除了 Spring for Apache Kafka 中許多特定於 Apache Kafka 的原生執行時提示，轉而支援 graalvm-reachability-metadata 中的相同支援。