【发布时间】:2019-06-14 19:37:21
【问题描述】:
我想了解一些关于 Kafka 和模式注册表如何处理 Avro 序列化消息的问题 - 从this post 我了解到模式 ID 存储在每条消息的可预测位置,所以看起来我们可以在同一个主题中拥有各种模式的消息,并且能够找到正确的模式并基于此成功地反序列化它们。另一方面,我看到很多人似乎在使用“附加到主题的架构”的表达方式,但这意味着每个主题都有一个架构..
那么哪个是正确的?我可以利用架构注册表(例如 KSql)并在同一主题中拥有各种类型(或架构)的消息吗?
【问题讨论】:
标签: apache-kafka avro confluent-schema-registry