我现在的场景是用mongoDB-cdc同步数据至SR里，如果我需要同步全部数据库，我该怎么写sink比较好，有没有类似的demo或者思路。
目前这种方式是建立一对一的sink，即mongodb指定table，sink指定table,如果我读全数据库的话，sink不知道怎么写了，因为table根据新增数据的table而变化，求帮助，纯萌新，十分感谢！
目前这种方式是建立一对一的sink，即mongodb指定table，sink指定table,如果我读全数据库的话，sink不知道怎么写了，因为table根据新增数据的table而变化，求帮助，纯萌新，十分感谢！