緊隨 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 POM 來幫助進行依賴管理
支援全域性單一的 EmbeddedKafkaBroker（跨多個測試類）
@RetryableTopic（非阻塞重試）的幾項增強功能
KafkaTemplate 方法現在返回 CompleteableFuture 而不是已棄用的 ListenableFuture
我很高興地宣佈 Spring for Apache Kafka 2.9.0 的釋出候選版本 (2.9.0-RC1) 現已在 Spring 里程碑倉庫中提供。
此版本不透過 Spring Boot 依賴管理提供，但可與 Boot 2.7（或 2.6）一起使用，前提是您按照本附錄中所述覆蓋 Kafka 依賴項，特別是如果您正在使用嵌入式 Kafka 代理。
此版本使用 3.2.0 kafka-clients 版本
非阻塞重試的引導現在更健壯
新錯誤處理程式模式
預設情況下，發生錯誤後，DefaultErrorHandler 會在上次輪詢的剩餘記錄上執行 seek 操作，並在下次輪詢時從代理重新獲取這些記錄。在高錯誤率和大的 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 現已釋出。
對 RabbitMQ Stream Plugin 的初步支援
使用 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 里程碑倉庫中提供。
更新：2.5.0.RELEASE 已於5月13日釋出。
亮點
kafka-clients 2.5.0（版本號對齊是巧合）。
在使用協作式再平衡時，支援對保留分割槽重新提交可重試的偏移量提交異常。
支援新的“fetch-offset-request”生產者隔離（當代理版本為 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 編譯的，並支援新的增量再平衡協議。
2.4.0 kafka-clients 與 Spring for Apache Kafka 2.3 不二進位制相容，因此如果您希望使用 2.4.0 客戶端，則必須升級到此版本。有關如何覆蓋 jar 版本的資訊，請參閱參考手冊中的附錄，特別是如果您正在使用 Spring…
