KafkaTriggerConverter Class

Inheritance
KafkaTriggerConverter

Methods

decode
decode_multiple_events
decode_single_event
encode
get_parsed_props

decode

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

Parameters

cls
Required
data
Required

decode_multiple_events

decode_multiple_events(data: azure.functions.meta.Datum, trigger_metadata) -> typing.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: typing.Any, *, expected_type: typing.Union[type, NoneType]) -> azure.functions.meta.Datum

Parameters

cls
Required
obj
Required

get_parsed_props

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

Parameters

cls
Required
props
Required
parsed_data
Required