Kafka: Реестр Confluent Schema - Потребительский процесс - PullRequest
0 голосов
/ 07 января 2019

Насколько я понимаю, схема Avro будет кэшироваться локально, а потребитель будет использовать локальный кеш для процесса десерлизации. В этом процессе, если возникает сценарий исключения, например, схема avro не кэшируется в локальной системе. Что будет?
Будет ли попытаться продолжить чтение с сервера схемы? если так, сколько раз это будет пробоваться? или любой другой сценарий?

1 Ответ

0 голосов
/ 07 января 2019

Сообщения пишутся с идентификатором схемы вместо всей схемы. Когда потребитель впервые читает данные, он получает идентификатор схемы и запрашивает соответствующую схему в реестре схемы. Потребитель будет кэшировать схему и выполнять сопоставление для других сообщений.

См. идентификаторы схем в сообщениях

...