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
>

回复