KafkaConverter Class
Constructor
KafkaConverter()Methods
| check_input_type_annotation | |
| check_output_type_annotation | |
| decode | |
| decode_multiple_events | |
| decode_single_event | |
| encode | |
| has_implicit_output |
check_input_type_annotation
check_input_type_annotation(pytype) -> boolParameters
| Name | Description |
|---|---|
|
pytype
Required
|
|
check_output_type_annotation
check_output_type_annotation(pytype) -> boolParameters
| Name | Description |
|---|---|
|
pytype
Required
|
|
decode
decode(data: Datum, *, trigger_metadata) -> KafkaEvent | List[KafkaEvent]Parameters
| Name | Description |
|---|---|
|
data
Required
|
|
Keyword-Only Parameters
| Name | Description |
|---|---|
|
trigger_metadata
Required
|
|
decode_multiple_events
decode_multiple_events(data: Datum, trigger_metadata) -> List[KafkaEvent]Parameters
| Name | Description |
|---|---|
|
data
Required
|
|
|
trigger_metadata
Required
|
|
decode_single_event
decode_single_event(data: Datum, trigger_metadata) -> KafkaEventParameters
| Name | Description |
|---|---|
|
data
Required
|
|
|
trigger_metadata
Required
|
|
encode
encode(obj: Any, *, expected_type: type | None) -> DatumParameters
| Name | Description |
|---|---|
|
obj
Required
|
|
Keyword-Only Parameters
| Name | Description |
|---|---|
|
expected_type
Required
|
|
has_implicit_output
abstract classmethod has_implicit_output() -> bool