我们计划通过kafka推送数百万条消息，使用schema registry（sr）（confluent）不总是发送完整的schema。
架构与此图相关：
事实上，我们希望避免在生产商希望发送消息或消费者将收到消息的所有时间都给sr打一个电话。
所以我想在这里讨论由avroserializer和avrodeserializer管理的“本地”缓存。我认为实现了这一点的贡献者应该做好这项工作。
但是由于牵连调用的数量，我只想确定在上面的模式中我用红色写了什么
我没有找到任何函数来管理这个“本地”缓存，你知道什么可以检查它的内容，大小。。。
谢谢！
1条答案
按热度按时间gk7wooem1#
好的，最后我自己测试了一下，找到了这个架构：在ubuntu下有两个vmbox，一个用于producer/broker/consumer，另一个用于schema registry（confluent）。
我还在bot-vm中设置了wireshark tcp包分析器。
当我为一条消息或数千条消息启动producer时，释放的数据包数相同：
设置一些sleep（在java中）我可以看到，只有在必须发送第一条消息时才调用schema注册表，而不是在创建生产者时。
希望这能帮上忙。。。