springcloudstream中的合流平台是否支持或计划支持avro和/或schema注册表?我看到SpringIntegrationKafka 1.3.0.release中存在对avro的依赖,它被排除在SpringCloudStreamBinder kafka之外,但是SpringIntegrationKafka(2.0)的主分支和SpringKafka没有我能找到的任何avro依赖。
springcloudstream中的合流平台是否支持或计划支持avro和/或schema注册表?我看到SpringIntegrationKafka 1.3.0.release中存在对avro的依赖,它被排除在SpringCloudStreamBinder kafka之外,但是SpringIntegrationKafka(2.0)的主分支和SpringKafka没有我能找到的任何avro依赖。
1条答案
按热度按时间watbbzwu1#
对,
我们确实打算支持avro和其他格式,以及schema registry和evolution。你可以关注一个悬而未决的问题here:httpshttp://github.com/spring-cloud/spring-cloud-stream/issues/512
目前,这可以通过使用编解码器和/或消息转换器以更复杂的方式完成,例如:https://github.com/viniciusccarvalho/schema-evolution-samples (作为前者的poc)。这个例子稍微复杂一点,因为它旨在支持模式演化,但是可以注册一个使用avro(而不是kryo默认值)的编解码器。