spring-cloud-stream kafka avro

spring-cloud-stream kafka avro

是否支持或计划支持 spring-cloud-stream 中融合平台的 avro and/or 架构注册表?我看到 spring-integration-kafka 1.3.0.RELEASE 中存在对 avro 的依赖,它被排除在 spring-cloud-stream-binder-kafka 之外,但是[的主分支=15=]-integration-kafka (2.0) 和 spring-kafka 没有我能找到的任何 avro 依赖项。

是的,

我们确实打算支持 Avro 和其他格式,以及架构注册和演变。您可以在此处关注一个未解决的问题:https://github.com/spring-cloud/spring-cloud-stream/issues/512

目前,这可以通过使用编解码器 and/or MessageConverters 以更复杂的方式完成,例如此处:https://github.com/viniciusccarvalho/schema-evolution-samples(用作前者的 POC)。该示例稍微复杂一些,因为它旨在支持模式演变,但可以注册使用 Avro(而不是 Kryo 默认值)的编解码器。