2024年1月3日
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) 推荐(0) 编辑
Flink-postgres-cdc实时同步报错：无法访问文件 "decoderbufs": 没有那个文件或目录
摘要： 问题描述 Caused by: org.postgresql.util.PSQLException: 错误: 无法访问文件 "decoderbufs": 没有那个文件或目录 解决办法 postgres-cdc的属性缺少如下配置： 'slot.name' = 'myslot','decoding.pl 阅读全文
posted @ 2024-01-03 10:43 业余砖家 阅读(126) 评论(0) 推荐(0) 编辑
Flink-启动后无法访问WebUI界面（Flink1.16）
摘要： 问题描述 通过./bin/start-cluster.sh启动Flink程序，正常启动后无法通过浏览器访问web UI界面，http://192.168.80.133:8081。 问题原因 Flink1.12之前启动Flink程序后，可以正常打开WebUI界面，换成新的版本后Flink1.15、Fl 阅读全文
posted @ 2024-01-03 09:14 业余砖家 阅读(1120) 评论(0) 推荐(0) 编辑