Skip to main content

Module avro

laminar_connectors::kafka

Module avro 

Source
Expand description

Avro deserialization using arrow-avro with Confluent Schema Registry.

AvroDeserializer implements RecordDeserializer by wrapping the arrow-avro push-based Decoder, which natively supports the Confluent wire format (0x00 + 4-byte BE schema ID

  • Avro payload).

Structsยง

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