我很高興地宣布 spring-kafka (Spring for Apache Kafka) 1.0 版本的第二個 Milestone 版本現已推出。

這些組件 org.springframework.kafka:spring-kafka:1.0.0.M2 和 org.springframework.kafka:spring-kafka-test:1.0.0.M2 可在 Milestone 儲存庫中找到。

自第一個里程碑以來的變更包括

• KafkaTemplate.send() 方法現在會回傳 ListenableFuture<SendResult<K, V>>

以非同步方式追蹤發布到 Kafka topic。

• MessagingMessageListenerAdapter (適用於 @KafkaListener 方法) 現在可以從方法引數推斷 payload 轉換的型別。
• StringJsonMessageConverter 可以使用型別推斷，使用 Jackson ObjectMapper 從 JSON 內容建構目標物件。
• 已從 Listener 新增 RECEIVED_ 標頭，以避免在使用 Spring Integration Adapters 等傳送時，與相同的 messageKey 重新導向到相同的 topic 發生衝突。
• 更多測試工具。

更多資訊請參閱參考手冊。

Spring Integration Kafka 支援

不要錯過基於此 Spring for Apache Kafka 基礎的 Spring Integration Kafka 2.0 的第一個里程碑。

下一步

• Spring Boot Kafka starter 和 AutoConfiguration 正在進行中。
• 針對 spring-cloud-stream 的新的 Binder 實作。
• 充實文件，設定專案頁面等。

此外，我們已經在研究 1.1 版本，以使用 Reactive Streams 和 Reactor 的 Flux 和 Mono 抽象化來實作與 Kafka 的互動。 同時，Apache Kafka 0.10.0 及其 Kafka Streams 功能也將是 Spring for Apache Kafka 1.1 的一個很好的補充。

同時，我們期待您的回饋，如果一切順利，計劃在接下來的幾週內發布 1.0.0.RELEASE！

專案頁面 | 文件 | 求助