我们计划通过 Kafka 推送数百万条消息,使用模式注册表 (SR) (Confluent),而不是一直发送完整的模式。
事实是,我们希望避免在生产者想要发送消息或消费者将收到消息时一直调用 SR。
所以我这里要讲的是AvroSerializer和AvroDeserializer管理的“本地”缓存。我认为已经实现这一点的贡献者应该很好地完成了这项工作。
但是由于牵连的调用数量,我只想确定我在上述架构中用红色写的内容
我没有找到任何功能来管理这个“本地”缓存,你知道检查它的内容、大小......
非常感谢!