avro_decoder

avro_decoder

View source

avro_decoder(
    raw_msg, cls
)

Decoder to decode avro encoded messages to pydantic model instance

Parameters:

Name	Type	Description	Default
raw_msg	bytes	Avro encoded bytes message received from Kafka topic	required
cls	Type[pydantic.main.BaseModel]	Pydantic class; This pydantic class will be used to construct instance of same class	required

Returns:

Type	Description
Any	An instance of given pydantic class