【问题标题】:Schema Registry - Confluent AvroSerializer/AvroDeserializerSchema Registry - Confluent AvroSerializer/AvroDeserializer
【发布时间】:2019-05-01 18:31:43
【问题描述】:

根据我的理解

Producer : 在第一次调用 Schema 注册表的本地缓存为空。然后加载与要序列化的对象定义相关的模式。然后在本地缓存中查找,以检查缓存中是否已经存在与要序列化的对象定义对应的模式,如果不存在,则向模式注册表请求。

消费者:每当架构 ID 不在 AvroDeserlzier 的本地缓存中时,架构注册表都会调用。

两个问题:

现在的问题是,如果本地缓存中没有捕获模式,那么模式注册表将在生产者的序列化过程中尝试将其本地存储多少次?

在消费者方面,每当架构 ID 尚未在 AvroDeserlzier 的本地缓存中用于所有记录时,架构注册表都会调用?

【问题讨论】:

    标签: apache-kafka avro kafka-consumer-api confluent-schema-registry


    【解决方案1】:

    如果您有无限的缓存未命中,我相信 HTTP 调用将不断被调用以一次又一次地查找/发送 ID,是的,但是在第一个请求/响应和(de )序列化似乎不太可能,因为它们在代码中非常接近。 (注意,它是开源的,所以你也可以验证一下)

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 2021-10-04
      • 2023-01-11
      • 1970-01-01
      • 2019-07-21
      • 2019-07-21
      • 2017-10-06
      • 2018-03-27
      • 2019-06-23
      相关资源
      最近更新 更多