緊隨 Spring Framework 6.1 的釋出，我很高興宣佈 Spring for Apache Kafka 和 Spring AMQP (Spring for RabbitMQ) 的 3.1 版本現已釋出。
有關詳細內容，請參閱各專案的 3.1.0、3.1.0-RC1 和 3.1.0-M1 版本釋出說明 - Spring for Apache Kafka 和 Spring AMQP。
另請參閱文件中的“新增內容”部分以瞭解亮點：Spring for Apache Kafka Spring AMQP。
我很高興宣佈 Spring for Apache Kafka 和 Spring for RabbitMQ 的新主要版本（3.0.0）現已釋出。
這些專案的 3.0.x 版本有以下常見變更：
它們依賴於 Java 17 或更高版本
它們依賴於 Spring Framework 6.0.x
支援建立 GraalVM 原生應用
支援 Micrometer 可觀測性和追蹤
現在提供 Bill of Materials POMs，以幫助依賴管理
支援全域性單一的 EmbeddedKafkaBroker（跨多個測試類）
對 @RetryableTopic（非阻塞重試）的幾項增強
KafkaTemplate 方法現在返回 CompleteableFuture 而非已棄用的 ListenableFuture
我很高興宣佈 Spring for Apache Kafka 2.9.0 候選版本 (2.9.0-RC1) 現已在 Spring Milestone 倉庫中釋出。
此版本並非由 Spring Boot 依賴管理提供，但只要按照此附錄所述覆蓋 Kafka 依賴，即可與 Boot 2.7（或 2.6）一起使用，特別是當您使用嵌入式 Kafka Broker 時。
此版本使用 3.2.0 版本的 kafka-clients
非阻塞重試的引導過程現在更加健壯
新的錯誤處理器模式
預設情況下，發生錯誤後，DefaultErrorHandler 會對上次拉取的剩餘記錄執行 seek 操作，並在下次拉取時從 broker 重新獲取這些記錄。在高錯誤率和大型 max.poll.records 的情況下，這會給網路帶來不必要的壓力。因此，錯誤處理器有一個新的屬性 seekAfterError，當設定為 false 時，不再對記錄進行 seek 操作，而是將剩餘記錄保留在記憶體中，並在下次拉取時暫停消費者（如果錯誤處理器配置為使用 ContainerPausingBackOffHandler，則暫停多次拉取...）
最近釋出的 Spring AMQP 版本（2.4.0、2.3.12、2.2.20）包含針對 CVE-2021-22095 的修復，該漏洞可能導致處理超大訊息時發生潛在的 OutOfMemoryError。
Spring Boot 2.6.0 和 2.5.7 版本將分別引入 spring-amqp 的 2.4.0 和 2.3.12 版本。Boot 2.4.x 的使用者應將 spring-amqp 和 spring-rabbit 版本覆蓋為 2.3.12；Spring Boot 2.3.x 的使用者應將版本覆蓋為 2.2.20。
我很高興宣佈 Spring AMQP 2.4.0 版本現已釋出。
使用 Spring Framework 的 RMI 支援進行遠端呼叫的支援已棄用
有關此版本中所有變更的資訊，請參閱新增內容。
我很高興宣佈 Spring for Apache Kafka 2.7.0 版本現已釋出。
此版本包含一項重要增強功能，這是一項社群貢獻。失敗的投遞可以轉發到一系列主題以進行延遲重新投遞。
用示例描述最佳
@RetryableTopic(attempts = "5", backoff = @Backoff(delay = 1000, multiplier = 2.0))
@KafkaListener(id = "sk270", topics = "sk270")
public void listen(String in, @Header(KafkaHeaders.RECEIVED_TOPIC) String topic) {
LOG.info(in + " from " + topic);
throw new RuntimeException("test");
}
@DltHandler
public void…2.5.0.RC1 候選版本現已在 Spring milestone 倉庫中釋出。
更新：2.5.0.RELEASE 已於 5 月 13 日釋出。
亮點
kafka-clients 2.5.0（版本號對齊是巧合）。
使用協作式 rebalancing 時，支援對保留分割槽的可重試偏移量提交異常進行重新提交。
支援新的“fetch-offset-request”生產者柵欄（當 broker 版本為 2.5 或更高時），需要更少的生產者。
支援靜態組成員資格。
與 Micrometer 更多的整合。
可選的投遞嘗試次數頭。
RecoveringBatchErrorHandler 可以提交部分批次，並從批次中的失敗記錄重新開始重放（需要監聽器配合）；這現在是批次監聽器的預設行為。
為了支援上週釋出的 Apache Kafka 2.4.0 版本，我很高興宣佈 Spring for Apache Kafka 2.4 - 2.4.0.RELEASE - 已在 Maven Central 中釋出。
此版本在功能上與 2.3.x 版本基本等同，但針對 2.4.0 版本的 kafka-clients 進行編譯，並支援新的增量 rebalancing 協議。
2.4.0 版本的 kafka-clients 與 Spring for Apache Kafka 2.3 不進行二進位制相容，因此如果您希望使用 2.4.0 客戶端，必須升級到此版本。有關如何覆蓋 jar 版本的資訊，請參閱參考手冊的附錄，特別是如果您正在使用 Spring...
