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

时间:2024-11-16 13:21:44

功能描述

Maxwell是一个CDC(Changelog Data Capture)工具,可以将MySql中的更改实时流式写入到Kafka等流式connector。Maxwell为changelog提供了统一的格式,而且支持使用JSON对消息进行序列化。

Flink 支持将 Maxwell JSON 消息解释为 INSERT/UPDATE/DELETE 消息到 Flink SQL 系统中。在许多情况下,这对于利用此功能很有用。

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