AI 助理
备案控制台
开发者社区 问答 正文

Flink消费kafka数据 写入mysql 你们怎么实现的呀?是继承RichSin #Flink

Flink消费kafka数据 写入mysql 你们怎么实现的呀?是继承RichSinkFunction 自己编写吗?#Flink

展开
收起
黄一刀 2020-06-10 23:29:32 1005 分享 版权

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

1 条回答
写回答
取消 提交回答
  • 黄二刀

    原生的呀，DDL直接搞就行

    2020-06-10 23:30:27
    赞同 展开评论
问答分类：
消息中间件 关系型数据库 MySQL Kafka 流计算 云消息队列 Kafka 版 云数据库 RDS MySQL 版 实时计算 Flink版
问答标签：
云数据库 RDS MySQL 版数据 实时计算 Flink版数据 实时计算 Flink版kafka 云消息队列 Kafka 版flink flink云数据库 RDS MySQL 版
问答地址：
开发者社区 > 数据库 > 问答
相关问答
Flink CDC里mysql cdc 正则匹配需要抽取的表 抽取任务启动后 怎么实现这个目标？
90
1
0
Flink日期减去24小时 怎么实现？需要保留时分秒
205
3
0
Flink topic分配是怎么实现的 没有自定义的吗？
120
2
0
flink怎么实时写入hbase，用hbase sink不用sql，怎么实现
329
4
0
Flink CDC里看了下mysql的日志，这种效果要怎么实现？
92
1
0
Flink sql中的GROUP_CONCAT 函数 得怎么实现？
896
3
0
Flink CDC分区表怎么实现动态订阅，分区表是动态创建的？
133
1
0
Flink CDC中我现在有个需求 不知道怎么实现?
97
3
0
flink cdc1.13不需要做完ck就能实时sink数据，这个需求怎么实现？
123
1
0
Flink CDC里请问我有个需求是我们写了一个Function要怎么实现？
71
0
0