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 客戶端版本 3.7.0，該版本引入了新的消費者組協議。此功能在 3.7.0 客戶端中作為早期訪問功能包含，不適用於生產環境。目前，我們建議僅將新的消費者組協議用於測試目的。預設情況下，Spring for Apache Kafka 使用經典消費者，而在測試新的消費者組協議時，必須透過 group.protocol 消費者屬性進行選擇加入。有關更多資訊，請參閱此處。
這裡有一個新的示例應用程式，演示了新消費者組協議的早期訪問版本。
Embeddedkafka 中的 KRaft 模式預設停用，因為 KafkaClusterTestKit 存在某些限制。如果有人想在 KRaft 模式下嘗試 EmbeddedKafka，他們必須透過 EmbeddedKafka 上的 kraft 屬性啟用它。此外，新的消費者組協議僅在 kraft 模式下執行，因此，在測試此新協議時，我們建議不要將 EmbeddedKafka 與啟用的 kraft 模式一起使用，因為 KafkaClusterTestKit 存在上述限制。為了測試新的消費者組協議，我們建議使用 KRaft 模式下的真實代理。有關更多資訊，請參閱此處。
能夠以程式設計方式在 Consumer 上強制進行再平衡。
框架中 Kafka Streams 支援的互動式查詢新 API。
對事務 ID 字尾的自定義。
在非阻塞重試中，提供一種根據異常型別路由到不同 DLT 的方法。
非同步 Kafka Listener 返回型別。
對 AfterRollbackProcessor 的改進，以跳過持續失敗的整個記錄批次。
類級別 @KafkaListener 的非阻塞重試支援。更多詳情請參閱此處。
RetryTopicConfiguration 改進
新的 API 方法，用於根據使用者提供的函式查詢偏移量。有關更多資訊，請參閱參考文件。
@PartitionOffset 對查詢位置的支援。
為了在 graalvm-reachability-metadata 中獲得相同的支援，移除了 Spring for Apache Kafka 中許多特定於 Apache Kafka 的原生執行時提示。