KafkaTriggerConverter Class

Inheritance

KafkaConverter

KafkaTriggerConverter

Constructor

KafkaTriggerConverter()

Methods

decode
decode_multiple_events
decode_single_event
encode
get_parsed_props

decode

decode(data: azure.functions.meta.Datum, *, trigger_metadata) -> Union[azure.functions.kafka.KafkaEvent, List[azure.functions.kafka.KafkaEvent]]

Parameters

cls

Required

data

Required

decode_multiple_events

decode_multiple_events(data: azure.functions.meta.Datum, trigger_metadata) -> List[azure.functions.kafka.KafkaEvent]

Parameters

cls

Required

data

Required

trigger_metadata

Required

decode_single_event

decode_single_event(data: azure.functions.meta.Datum, trigger_metadata) -> azure.functions.kafka.KafkaEvent

Parameters

cls

Required

data

Required

trigger_metadata

Required

encode

encode(obj: Any, *, expected_type: Optional[type]) -> azure.functions.meta.Datum

Parameters

cls

Required

obj

Required

get_parsed_props

get_parsed_props(props: azure.functions.meta.Datum, parsed_data) -> List[Any]

Parameters

cls

Required

props

Required

parsed_data

Required