Hi all,
对于广播状态[1]文档中提到的事件流和规则流匹配问题,想问问大家有什么好的办法保证规则流应该加载完成后再处理事件流。 我想通过mysql cdc加载规则,在快照消费完之前,已经有事件消费了而且没有匹配到相应的规则,有没有办法能够在快照处理结束后再开始消费kafka里面的事件 [1] https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/datastream/fault-tolerance/broadcast_state/