单流的一条数据,需要先sink 至mysql,再sink至kafka,并保证两sink的原子性以及s-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

单流的一条数据,需要先sink 至mysql,再sink至kafka,并保证两sink的原子性以及s

2021-12-07 16:06:16 360 1

请问下,有没有大佬做过类似的事情?

另外,flink side out功能,可以将单流分成多流,但是不是分成多流后,但两条流sink的时候,是不是没法保证sink时候的时序? *来自志愿者整理的flink邮件归档

取消 提交回答
全部回答(1)
  • moonlightdisco
    2021-12-07 16:11:03

    你可以先用 map 再用 addSink,这样他们的调用被 chain 在一起,可以达到先写入 mysql ,再写入 kafka 的目的。

    datastream.map(new MySQLSinkMapFunction()).addSink(new

    FlinkKafkaProducer()).

    也就是将 mysql sink 伪装成了一个 MapFunction,里面先做了 写 mysql 的动作,写成功后再将数据输出到下游。

    另外,如果要在 SQL 中解决这个需求的话,会比较麻烦,因为标准语法中没有这么个语法支持这个功能。*来自志愿者整理的flink邮件归档

    0 0
相关问答

1

回答

【RDS】RDS MySQL如何终止会话?

2022-01-12 16:17:02 445浏览量 回答数 1

1

回答

RDS MySQL如何终止会话?

2022-01-07 14:15:23 872浏览量 回答数 1

1

回答

程序使用RDS MySQL执行查询SQL时,报如下错误,如何进行排查?

2022-01-07 21:08:09 1073浏览量 回答数 1

1

回答

RDS MySQL如何使用Percona Toolkit?

2022-01-07 16:54:04 1182浏览量 回答数 1

1

回答

RDS MySQL引擎表索引方式更改为Hash无效的原因?

2022-01-07 16:53:24 1336浏览量 回答数 1

1

回答

RDS MySQL如何保证数据库字符编码正确?

2022-01-07 16:52:52 1173浏览量 回答数 1

1

回答

RDS MySQL实例执行“show slave hosts”的结果,说明了什么?

2022-01-07 16:52:00 1177浏览量 回答数 1

1

回答

RDS MySQL如何查看时区?

2022-01-07 16:51:24 1170浏览量 回答数 1

1

回答

云数据库 RDS MySQL 版如何为无主键表添加主键?

2022-01-07 16:50:51 4415浏览量 回答数 1

1

回答

RDS MySQL同步至DataHub中支持的同步架构是什么?

2021-12-12 23:29:06 88浏览量 回答数 1
0
文章
330
问答
问答排行榜
最热
最新
相关电子书
更多
低代码开发师(初级)实战教程
立即下载
阿里巴巴DevOps 最佳实践手册
立即下载
冬季实战营第三期:MySQL数据库进阶实战
立即下载