Hi 社区的各位
最近也是刚刚开始接触flink,现在是有这样的一个需求,主流是来自于kafka,需要关联的配置来自于mysql,由于配置会发生新增更新删除的操作,所以使用cdc
+
broadcaststate来做配置的关联,但是这会存在一个广播流的初始化问题,我看了网上和社区中其他关于broadcaststate这个问题的回复,大概有一下两种解决方案:
1.初始化通过jdbc获取,通过fromCollection处理后,union
cdc过来的配置流,这个经过测试确实可以解决,但是会有疑惑:通过fromCollection处理的内存的数据一定会比kafka,cdc过来的数
到配置
在 2021年2月1日 13:30,赵一旦 写道:
FlinkSQL ? javenjiangfsof 于2021年2月1日周一 上午11:40写道: > Hi
社区的各位 > >
最近也是刚刚开始接触flink,现在是有这样的一个需求,主流是来自于kafka,需要关联的配置来自于mysql,由于配置会发生新增更新删除的操作,所以使用cdc
> + >
broadcaststate来做配置的关联,但是这会存在一个广播流的初始化问题,我看了网上和社区中其他关于broadcaststate这个问题的回复,大概有一下两种解决方案:
>
("flinkpw")
.deserializer(new StringDebeziumDeserializationSchema()) // converts
SourceRecord to String .build();
```
在 2021年2月1日 14:07,赵一旦 写道:
我没发现官网没看到DataStream有cdc的connector貌似,你是怎么搞的呢。 javenjiangfsof
于2021年2月1日周一 下午1:40写道: > DataStream API,像下面这样 > ``` >
val l