Kafka :Confluent Schema Registry - Consumer process

As per my understanding, Avro schema will be cached in local and consumer will be using from the local cache for deserlization process. In this process if exception scenario occur like avro schema is not cached in local . What will happen ?
Will it be keep try to read from schema server ? if so , how many times it will be tried ? or any other scenario ?

Upvotes: 0

Views: 649

Answers (1)

Gery
Gery

Reputation: 649

Messages are written with schema id instead of whole schema. When consumer first reads data, it gets schema id and ask for corresponding schema to schema registry. Consumer will cache schema and do mapping for other messages.

See schema-ids-in-messages

Upvotes: 3

Related Questions