This repository was archived by the owner on Dec 14, 2022. It is now read-only.
This repository was archived by the owner on Dec 14, 2022. It is now read-only.
[FEATURE] 基于keyshare模式的简单使用 #612
Description
Is your feature request related to a problem? Please describe.
当前的keyshared模式使用flink消费实现key的范围消费需要自己计算相应的key值范围，期望改成传实际内容的方式
以及flinksql当前没有找到keyshared方式的过滤