Struct AvroDeserializer 

pub struct AvroDeserializer { /* private fields */ }

Avro deserializer backed by arrow-avro with optional Schema Registry.

Supports both raw Avro and the Confluent wire format. When a Schema Registry client is provided, unknown schema IDs are fetched and registered automatically.

Implementations

impl AvroDeserializer

pub fn new() -> Self

Creates a new Avro deserializer without Schema Registry integration.

The caller must register schemas manually via register_schema.

pub fn with_schema_registry(registry: Arc<SchemaRegistryClient>) -> Self

Creates a new Avro deserializer with Schema Registry integration.

Unknown schema IDs encountered in the Confluent wire format will be fetched from the registry automatically.

pub fn register_schema( &mut self, schema_id: i32, avro_schema_json: &str, ) -> Result<(), SerdeError>

Registers an Avro schema with a Confluent schema ID.

Errors

Returns SerdeError if the fingerprint cannot be set.

pub async fn ensure_schema_registered( &mut self, schema_id: i32, ) -> Result<(), SerdeError>

Ensures a schema ID is registered, fetching from SR if needed.

Called by the Kafka source connector when an unknown schema ID is encountered in the Confluent wire format during poll.

Errors

Returns SerdeError if the schema cannot be fetched or registered.

pub fn extract_confluent_id(data: &[u8]) -> Option<i32>

Extracts the Confluent schema ID from a wire-format message.

Returns None if the message is not in Confluent wire format.

Trait Implementations

impl Debug for AvroDeserializer

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

Formats the value using the given formatter.

impl Default for AvroDeserializer

fn default() -> Self

Returns the “default value” for a type.

impl RecordDeserializer for AvroDeserializer

fn deserialize( &self, data: &[u8], schema: &SchemaRef, ) -> Result<RecordBatch, SerdeError>

Deserializes a single record from raw bytes.

fn deserialize_batch( &self, records: &[&[u8]], schema: &SchemaRef, ) -> Result<RecordBatch, SerdeError>

Deserializes a batch of records from raw bytes.

fn format(&self) -> Format

Returns the format this deserializer handles.

fn as_any_mut(&mut self) -> Option<&mut dyn Any>

Downcasts to concrete type (e.g., for Avro schema resolution).