Реестр схем - Confluent AvroSerializer / AvroDeserializer

На основании моего понимания

Производитель: при первом вызове локальный кеш реестра схемы пуст. Затем загружается схема, связанная с определением объекта для сериализации. затем производит поиск в локальном кэше, чтобы проверить, существует ли схема, соответствующая определению объекта для сериализации, в кэше, если нет, он запрашивает реестр схемы.

Потребитель: реестр схемы будет вызывать каждый раз, когда идентификатор схемы еще не находится в локальном кэше AvroDeserlzier.

Два вопроса:

Теперь вопрос: если предположить, что схема не сохраняется в локальном кеше, сколько раз реестр схемы будет пытаться сохранить ее локально во время процесса сериализации у производителя?

На стороне потребителя реестр схемы будет вызывать каждый раз, когда идентификатор схемы еще не находится в локальном кеше AvroDeserlzier для всех записей?

Построение конвейеров данных в реальном времени с Apache Kafka: Руководство по Python
Построение конвейеров данных в реальном времени с Apache Kafka: Руководство по Python
Apache Kafka - популярная платформа распределенной потоковой передачи данных, которую можно использовать для построения конвейеров данных в реальном...
0
0
212
1

Ответы 1

Если у вас есть бесконечный промах кеша, я считаю, что HTTP-вызов будет продолжать вызываться для поиска / отправки идентификатора снова и снова, да, однако шансы, что схема не кэшируется между первым запросом / ответом и (де) сериализацией, кажутся маловероятно, потому что они встречаются в коде очень близко друг к другу. (обратите внимание, это открытый исходный код, так что вы тоже можете это проверить)

Другие вопросы по теме