你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站，请访问 https://docs.azure.cn。
KafkaConverter 类
- 继承
-
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
check_input_type_annotation(pytype) -> bool参数
| 名称 | 说明 |
|---|---|
|
pytype
必需
|
|
check_output_type_annotation
check_output_type_annotation(pytype) -> bool参数
| 名称 | 说明 |
|---|---|
|
pytype
必需
|
|
decode
decode(data: Datum, *, trigger_metadata) -> KafkaEvent | List[KafkaEvent]参数
| 名称 | 说明 |
|---|---|
|
data
必需
|
|
仅限关键字的参数
| 名称 | 说明 |
|---|---|
|
trigger_metadata
必需
|
|
decode_multiple_events
decode_multiple_events(data: Datum, trigger_metadata) -> List[KafkaEvent]参数
| 名称 | 说明 |
|---|---|
|
data
必需
|
|
|
trigger_metadata
必需
|
|
decode_single_event
decode_single_event(data: Datum, trigger_metadata) -> KafkaEvent参数
| 名称 | 说明 |
|---|---|
|
data
必需
|
|
|
trigger_metadata
必需
|
|
encode
encode(obj: Any, *, expected_type: type | None) -> Datum参数
| 名称 | 说明 |
|---|---|
|
obj
必需
|
|
仅限关键字的参数
| 名称 | 说明 |
|---|---|
|
expected_type
必需
|
|
has_implicit_output
abstract classmethod has_implicit_output() -> bool