spring-cloud-stream kafka avro

【问题标题】：spring-cloud-stream kafka avrospring-cloud-stream kafka avro
【发布时间】：2016-05-20 16:05:29
【问题描述】：

是否有任何支持或计划支持来自 spring-cloud-stream 中的融合平台的 avro 和/或模式注册表？我看到 spring-integration-kafka 1.3.0.RELEASE 中对 avro 有依赖关系，它被排除在 spring-cloud-stream-binder-kafka 之外，但是 spring-integration-kafka 的主分支（2.0）和 spring- kafka 没有我能找到的任何 avro 依赖项。

【问题讨论】：

标签： spring-integration apache-kafka spring-cloud-stream

【解决方案1】：

是的，

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

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

【讨论】：