Flink CDC写入数据到kafka几种格式

Flink CDC写入kafka几种常见的数据格式,其中包括upsert-kafka写入后正常的json格式,debezium-json格式以及changelog-json格式。 upsert-kafka 正常json数据格式 -- insert 操作:{"name":"魏夜游","remark":
posted @ 2024-01-03 16:13  业余砖家  阅读(310)  评论(0编辑  收藏  举报