当 Schema Registry 与 Kafka 和 Avro 一起使用时,每个主题有一个或多个模式......?

Mic*_*luk 3 avro apache-kafka confluent-schema-registry

我正在尝试了解 Kafka 和 Schema Registry 如何处理 Avro 序列化消息 - 从这篇文章中我了解到架构 ID 存储在每条消息的可预测位置,因此似乎我们可以拥有消息同一主题中的各种模式,并能够找到正确的模式并基于此成功地反序列化它们。另一方面,我看到很多人似乎在使用“附加到主题的模式”这一表达方式,但这意味着每个主题有一个模式。

那么哪个是对的?我可以利用模式注册表(如 KSql)并在同一主题中拥有各种类型(或模式)的消息吗?

Rob*_*att 8

通常,您有 1:1 的主题/模式关系,但在某些情况下,每个主题可能(并且有效)有多个模式。有关更多信息,请参阅https://www.confluent.io/blog/put-several-event-types-kafka-topic/