【发布时间】:2019-05-01 18:31:43
【问题描述】:
根据我的理解
Producer : 在第一次调用 Schema 注册表的本地缓存为空。然后加载与要序列化的对象定义相关的模式。然后在本地缓存中查找,以检查缓存中是否已经存在与要序列化的对象定义对应的模式,如果不存在,则向模式注册表请求。
消费者:每当架构 ID 不在 AvroDeserlzier 的本地缓存中时,架构注册表都会调用。
两个问题:
现在的问题是,如果本地缓存中没有捕获模式,那么模式注册表将在生产者的序列化过程中尝试将其本地存储多少次?
在消费者方面,每当架构 ID 尚未在 AvroDeserlzier 的本地缓存中用于所有记录时,架构注册表都会调用?
【问题讨论】:
标签: apache-kafka avro kafka-consumer-api confluent-schema-registry