KafkaConverter Class

Inheritance
KafkaConverter
KafkaConverter

Methods

check_input_type_annotation
check_output_type_annotation
decode
decode_multiple_events
decode_single_event
encode

check_input_type_annotation

check_input_type_annotation(pytype) -> bool

Parameters

cls
Required
pytype
Required

check_output_type_annotation

check_output_type_annotation(pytype) -> bool

Parameters

cls
Required
pytype
Required

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