数据湖探索 DLI-Kafka:功能描述

时间:2024-12-11 08:41:28

功能描述

Kafka 连接器提供从 Kafka topic 中消费和写入数据的能力。

Apache Kafka是一个快速、可扩展的、高吞吐、可容错的分布式发布订阅消息系统,具有高吞吐量、内置分区、支持数据副本和容错的特性,适合在大规模消息处理场景中使用。

表1 支持类别

类别

详情

支持表类型

源表、结果表

支持数据格式

CS V

JSON

Apache Avro

Confluent Avro

Debezium CDC

Canal CDC

Maxwell CDC

OGG CDC

Raw

support.huaweicloud.com/sqlref-flink-dli/dli_08_15058.html