我最近遇到了一个和你描述的类似的问题。由于ksqlDB的限制，目前使用流或表是不可能的。尽管如此，我们还是找到了一种方法来达到同样的结果。
我们的解决方案是使用连接器创建一个自定义查询，该连接器创建一个3向连接表并组合这3个表中更新的字段。

CREATE SOURCE CONNECTOR xyz_change WITH (
    'connector.class'          = '${v_connector_class}',
    'connection.url'           = '${v_connection_url}',
    'connection.user'          = '${v_connection_user}',
    'connection.password'      = '${v_connection_pass}',
    'topic.prefix'             = 'jdbc_abc_change',
    'mode'                     = 'timestamp+incrementing',
    'numeric.mapping'          = 'best_fit',
    'incrementing.column.name' = 'id',
    'timestamp.column.name'    = 'last_modified',
    'key'                      = 'id',
    'key.converter'            = '${v_converter_long}',
    'query'                    = 'select id, last_modified from(select a.id as id, GREATEST(a.last_modified, COALESCE(b.last_modified,from_unixtime(0)), COALESCE(c.last_modified,from_unixtime(0))) as last_modified  from aaa a  LEFT JOIN bbb b on a.fk_id = b.id  LEFT JOIN ccc c on a.fk_id = c.id ) sub'
);

有了它，你就可以创建任何你需要的流/表了。