Hi, 是否可以将这个”配置维表“换成流表,利用flink cdc,改动这个配置表的时候,监听字段cdc变化,同时下游上流join呢?
-- Best! Xuyang 在 2023-11-20 19:24:47,"casel.chen" <casel_c...@126.com> 写道: >我有一个flink >sql作业过滤条件customer_id是需要根据用户配置来定的,类似于Apollo配置中心,是否可以通过定义一张配置维表来实现呢?设置TTL定期去获取最新配置。 > > >create table customer_conf_tbl ( > customer_id STRING >) with ( > 'connector' = 'apollo', > '其他属性' .... >); >select * from biz_table where customer_id in (select string_split(customer_id, >',') from customer_conf_tbl) > > >如果要做成配置实时更新作用于sql作业的话又该如何实现呢?