KafkaConverter Class
- Inheritance
-
KafkaConverterKafkaConverter
KafkaConverter()
check_input_type_annotation | |
check_output_type_annotation | |
decode | |
decode_multiple_events | |
decode_single_event | |
encode | |
has_implicit_output |
check_input_type_annotation(pytype) -> bool
Parameters
Name | Description |
---|---|
pytype
Required
|
|
check_output_type_annotation(pytype) -> bool
Parameters
Name | Description |
---|---|
pytype
Required
|
|
decode(data: Datum, *, trigger_metadata) -> KafkaEvent | List[KafkaEvent]
Parameters
Name | Description |
---|---|
data
Required
|
|
Keyword-Only Parameters
Name | Description |
---|---|
trigger_metadata
Required
|
|
decode_multiple_events(data: Datum, trigger_metadata) -> List[KafkaEvent]
Parameters
Name | Description |
---|---|
data
Required
|
|
trigger_metadata
Required
|
|
decode_single_event(data: Datum, trigger_metadata) -> KafkaEvent
Parameters
Name | Description |
---|---|
data
Required
|
|
trigger_metadata
Required
|
|
encode(obj: Any, *, expected_type: type | None) -> Datum
Parameters
Name | Description |
---|---|
obj
Required
|
|
Keyword-Only Parameters
Name | Description |
---|---|
expected_type
Required
|
|
abstract classmethod has_implicit_output() -> bool
Collaborate with us on GitHub
The source for this content can be found on GitHub, where you can also create and review issues and pull requests. For more information, see our contributor guide.
Azure SDK for Python feedback
Azure SDK for Python is an open source project. Select a link to provide feedback: