我正在使用合流源连接器将postgres中的数据复制到kafka。
我想到了在每个运行周期之前运行update命令的以下技巧。我从函数结果集中创建了一个postgres视图。但是函数在返回结果集之前正在运行update命令）。
据我所知，它是有效的，但这是一个合法的伎俩，因为汇合连接器是关心？有更好的办法吗？
如果我有一个同步连接器同步5个这样的视图。我可以知道哪一个将首先运行，所以更新将与第一个，而不是由所有人完成。
我可以肯定地知道，所有5个视图看到相同的最新交易，没有一个比其他人最近。例如，view1最多可看到事务100，而上次执行的view5最多可看到事务101。
请参见下面的代码：

CREATE OR REPLACE FUNCTION get_abc()
RETURNS SETOF view1 AS $$
    UPDATE common_table SET updated = now() WHERE updated IS null;
    SELECT * FROM view1; -- view1 is taking data from common_table this is why I run the update...
$$ 
LANGUAGE SQL;

CREATE VIEW view2 AS 
SELECT * FROM get_abc();

谢谢！