KafkaConverter Class

Inheritance

InConverter

KafkaConverter

OutConverter

KafkaConverter

Constructor

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) -> 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