spring-cloud-stream kafka avro

Question

是否支持或計劃在spring-cloud-stream中從融合平臺支持avro和/或模式註冊表？我發現spring-integration-kafka（2.0）和spring-integration-kafka（2.0）中的spring-integration-kafka 1.3.0.RELEASE被從spring-cloud-stream-binder-kafka中排除，卡夫卡沒有任何我能找到的avro依賴。

Answer 1

是，

我們打算支持的Avro等格式，以及模式的註冊表和進化。這裏是一個開放的問題，您可以按照這裏：https://github.com/spring-cloud/spring-cloud-stream/issues/512

現在，這可以在一個更復雜的方式通過編解碼器和/或了MessageConverter來完成，例如在這裏：https://github.com/viniciusccarvalho/schema-evolution-samples（其作爲POC爲前者） 。該示例稍微精細一些，因爲它旨在支持模式演變，但可以註冊使用Avro（而不是Kryo默認值）的編解碼器。