緊接著 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 的可觀察性和追蹤
現在提供物料清單 POM 以協助進行相依性管理
支援全域單一 EmbeddedKafkaBroker (跨多個測試類別)
針對 @RetryableTopic 的多項增強功能 (非阻塞重試)
KafkaTemplate 方法現在會傳回 CompleteableFuture 而不是已棄用的 ListenableFuture
我很高興宣布 Spring for Apache Kafka 2.9.0 的候選版本現已於 Spring Milestone Repo 中提供 (2.9.0-RC1)。
此版本不是由 Spring Boot 相依性管理所提供，但只要您如 此附錄 中所述，覆寫 Kafka 相依性，就可以與 Boot 2.7 (或 2.6) 搭配使用，特別是如果您使用內嵌的 Kafka 代理程式。
此版本使用 3.2.0 kafka-clients 版本
非阻塞重試引導現在更加強大
新的錯誤處理常式模式
預設情況下，發生錯誤後，DefaultErrorHandler 會在上次輪詢中對剩餘記錄執行搜尋，並在下次輪詢時從代理程式重新擷取它們。 在高錯誤率和大型 max.poll.records 的情況下，這可能會對網路造成不必要的壓力。 因此，錯誤處理常式有一個新的屬性 seekAfterError，當設定為 false 時，不會搜尋記錄，而是將剩餘記錄保留在記憶體中，並暫停消費者進行下次輪詢 (如果錯誤處理常式設定為使用 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 repo 中提供。
更新：2.5.0.RELEASE 已於 5 月 13 日發布。
重點
kafka-clients 2.5.0 (版本號碼的對齊是巧合)。
支援在使用協同重新平衡時，重新提交可重試的偏移量提交例外狀況，以用於保留的分割區。
支援新的 "fetch-offset-request" 處理常式 fencing (當代理程式為 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…
