1

因此,我们计划使用 Avro 在基于融合的基于 kafka 的生态系统上进行通信。我目前对 Avro 的理解是每条消息都带有它的模式。如果是这种情况,我们需要模式注册表来解决版本更新吗?

我问,因为每条消息都携带模式可以防止需要像模式注册表这样的东西来将消息 id 映射到模式。或者我在这里错过了什么?

4

1 回答 1

3

当您运行 Confluent Schema Registry 时,使用 Confluent Avro Serdes 库发布的 Kafka 消息不包含 avro 模式。它们只包含一个数字 Schema id,消费者反序列化器使用它从 Confluent Schema Registry 中获取 Schema。这些模式由序列化器和反序列化器缓存,作为进一步的性能优化。

于 2017-05-31T00:40:09.997 回答