我們很高興宣布以下版本現已推出。

建議所有使用者升級到這些版本

• 2.3.0.RELEASE (全新)

• 2.2.9.RELEASE (維護)

2.3.0 版本是此專案最新系列的第一個版本。

請參閱新功能章節以獲取更多資訊，以下是一些重點

生產

• 選擇每個執行緒使用一個 producer，以避免在清除時封鎖其他執行緒。

• 提供 AggregatingReplyingKafkaTemplate 擴充至 ReplyingKafkaTemplate，以聚合來自多個 consumer 的回覆。

消費

• 現在可以新增 RecordInterceptor 來修改 record，然後再呼叫 listener。

• ConsumerSeekAware 現在支援相對搜尋。

• 現在您可以指定在處理前一個 poll() 的結果和發出下一個 poll() 之間的時間延遲。

• 使用手動 AckMode 時，您現在可以對 record 進行負面確認，並且容器將執行必要的搜尋以重播該 record。

• 現在支援 Micrometer Timer 來監控 listener 效能。

• 可以將 SeekToCurrentErrorHandler 配置為將某些例外狀況視為嚴重錯誤，從而停用重試；您現在還可以在失敗傳遞的重試嘗試之間新增 BackOff。

• 提供 RetryingDeserializer，以便在發生例如網路故障存取 schema registry 的情況下重試序列化。

Kafka Streams

• 現在提供 RecoveringDeserializationExceptionHandler 來處理還原序列化例外。

• 提供 HeaderEnricherTransformer 以在 stream topology 定義中新增 header。

• 提供 MessagingTransformer 以允許從 stream 定義中呼叫 Spring Integration flow。

雜項

• 提供委派序列化器和還原序列化器實作，以允許傳送/接收包含不同類型的 record。

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