Hi Caizhi：
这个应该是和我们业务处理模式有关，我们需要同一个Kafka 流 输出两个Sink 同时要保持顺序性， 这个对我们来说是个通用的功能，
我在想如何实现这种方式， 请问有什么方案值得推荐吗？
我想通过实现一种自定义Table 比如 在一个Jdbc Table表的属性里 填充Kafka 属性，保持相同的Schema， 做为一个Sink 这样
方便做统一管理， 然后实现自定义Table 逻辑， 这种方案如何？
---
Best,
WuKong
发件人： Caizhi Weng
发送时间： 2021-10-14 17:50
收件人： user-zh
主题： Re: Flink-1.12 sql 同一个Job 下 如何控制 多个SQL的执行顺序
Hi！
“先插入 db，然后再写下游 kafka”，是说想要保证同一条数据必须写进 db 之后，才能写入 kafka 吗？
目前暂时没有这样的功能，如果确实很需要，可以考虑写一个 udf，udf 读到数据以后先写入 db
再传给下游。可以描述一下为什么有这种需求，大概是什么样的使用场景吗？
WuKong <[email protected]> 于2021年10月14日周四 下午5:11写道：
> Hi：
> 目前遇到一个问题，我想在一个Job下 ，有两个SQL 分步都是 读取同一个Source Kafka 数据， 一个是插入Tidb 落数据，
> 另一个是写入下游Kafka， 目前想控制 先插入DB 然后再写入下游Kafka, 请问有什么方案可以实现这种方式？
>
>
>
> ---
> Best,
> WuKong
>
