avro

Documentation

Index

• func DecodeAvro(schema string, event []byte) map[string]interface{}
• func GetSchemaIdFromPayload(msg []byte) int

Functions

func DecodeAvro

func DecodeAvro(schema string, event []byte) map[string]interface{}

decodeAvro decodes an Avro event using the provided schema and returns a nested map[string]interface{}.

Parameters: - schema: The Avro schema used for decoding the event (string). - event: The Avro event to be decoded ([]byte).

Returns: - nestedMap: The decoded event as a nested map[string]interface{}.

func GetSchemaIdFromPayload

func GetSchemaIdFromPayload(msg []byte) int

GetSchemaIdFromPayload returns the schema id from the payload