Struct ConfluentSchemaCache

pub struct ConfluentSchemaCache {
    writer_schemas: Cache<i32, Arc<Schema>>,
    confluent_client: Client,
}

Fetch schemas from confluent schema registry and cache them.

Background: This is mainly used for Avro writer schema (during schema evolution): When decoding an Avro message, we must get the message’s schema id, and use the exactly same schema to decode the message, and then convert it with the reader schema. (This is also why Avro has to be used with a schema registry instead of a static schema file.)

TODO: support protobuf (not sure if it’s needed)

Fields

writer_schemas: Cache<i32, Arc<Schema>>

confluent_client: Client

Implementations

impl ConfluentSchemaCache

async fn parse_and_cache_schema( &self, raw_schema: ConfluentSchema, ) -> ConnectorResult<Arc<Schema>>

pub fn new(client: Client) -> Self

Create a new ConfluentSchemaResolver

pub async fn get_by_subject( &self, subject_name: &str, ) -> ConnectorResult<Arc<Schema>>

Gets the latest schema by subject name, which is used as reader schema.

pub async fn get_by_id(&self, schema_id: i32) -> ConnectorResult<Arc<Schema>>

Gets the a specific schema by id, which is used as writer schema.

Trait Implementations

impl Debug for ConfluentSchemaCache

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.