Gary Russell

Gary Russell

校友
博文Gary Russell

Spring for Apache Kafka 和 Spring for RabbitMQ 的新主要版本

釋出 | 2022年11月21日 | ...

我很高興地宣佈 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 來幫助進行依賴管理

Spring for Apache Kafka

  • 支援全域性單一的 EmbeddedKafkaBroker(跨多個測試類)

  • @RetryableTopic(非阻塞重試)的幾項增強功能

  • KafkaTemplate 方法現在返回 CompleteableFuture 而不是已棄用的 ListenableFuture

Spring for Apache Kafka 2.9.0 已釋出

釋出 | 2022年8月2日 | ...

我很高興地宣佈 Spring for Apache Kafka 2.9.0 現已釋出。

此版本不透過 Spring Boot 依賴管理提供,但可與 Boot 2.7(或 2.6)一起使用,前提是您按照本附錄中所述將 Kafka 依賴項覆蓋為 3.2.0,特別是如果您正在使用嵌入式 Kafka 代理。

請參閱釋出候選版本公告以瞭解此版本中的顯著變化。

有關此版本中所有更改的資訊,請參閱新功能

專案頁面 | GitHub | 問題 | 文件 | Stack Overflow | Gitter

Spring for Apache Kafka 2.9 釋出候選版本現已釋出

釋出 | 2022年7月7日 | ...

我很高興地宣佈 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 (Spring for RabbitMQ) 安全報告

工程 | 2021年11月29日 | ...

最近釋出的 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-amqpspring-rabbit 版本覆蓋為 2.3.12;Spring Boot 2.3.x 的使用者應將版本覆蓋為 2.2.20。

Spring for Apache Kafka 2.8 現已釋出

釋出 | 2021年11月18日 | ...

我很高興地宣佈 Spring for Apache Kafka 2.8.0 現已釋出。

顯著變化

  • 此版本使用 3.0.0 kafka-clients 版本

  • 現在支援亂序手動提交

  • 現在同一個容器工廠可同時用於批處理和記錄監聽器

  • 獨立的記錄和批處理錯誤處理程式已被通用錯誤處理程式取代

  • KafkaTemplate 現在可用於從已知分割槽/偏移量接收特定記錄

有關此版本中所有更改的資訊,請參閱新功能

專案頁面 | GitHub | 問題 | 文件 | Stack Overflow | Gitter

Spring for Apache Kafka 2.7.0 已釋出

工程 | 2021年4月14日 | ...

我很高興地宣佈 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…

Spring for Apache Kafka 2.5.0 釋出候選版本

釋出 | 2020年4月30日 | ...

2.5.0.RC1 釋出候選版本現已在 Spring 里程碑倉庫中提供。

更新:2.5.0.RELEASE 已於5月13日釋出。

亮點

  • kafka-clients 2.5.0(版本號對齊是巧合)。

  • 在使用協作式再平衡時,支援對保留分割槽重新提交可重試的偏移量提交異常。

  • 支援新的“fetch-offset-request”生產者隔離(當代理版本為 2.5 或更高時),減少了所需的生產者數量。

  • 支援靜態組員。

  • 與 Micrometer 更深入的整合。

  • 可選的交付嘗試頭部。

  • RecoveringBatchErrorHandler 可以提交部分批次並從批次中的失敗記錄重新播放(在監聽器的配合下);這現在是批處理監聽器的預設行為。

Spring for Apache Kafka 2.4 已釋出

釋出 | 2019年12月23日 | ...

為了支援上週釋出的 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…

領先一步

VMware 提供培訓和認證,助您加速進步。

瞭解更多

獲得支援

Tanzu Spring 提供 OpenJDK™、Spring 和 Apache Tomcat® 的支援和二進位制檔案,只需一份簡單的訂閱。

瞭解更多

即將舉行的活動

檢視 Spring 社群所有即將舉行的活動。

檢視所有