会员
众包
新闻
博问
闪存
云市场
所有博客
当前博客
a56爆大奖在线娱乐的博客
a56爆大奖在线娱乐的园子
账号设置
简洁模式
...
退出登录
注册
登录
jia-tong
博客园
首页
新随笔
联系
订阅
管理
2023年4月19日
SchemaRegestry组件原生的类和方法无法实现flink消费kafka的数据动态调整schema的情况--未彻底解决
摘要: 0、前提知识储备 Conflurent公司的SchemaRegestry组件的基本了解和使用 一、背景: 0.组件版本 flink:1.14 1.链路调整情况 原先链路:oracle-->OGG-->kafka-->flink-->数据库\湖\仓 实现链路:oracle-->OGG-->kafka(
阅读全文
posted @ 2023-04-19 14:49 贾彤
阅读(50)
评论(0)
推荐(0)
编辑
公告