李航飞 Fri, 18 Mar 2022 03:51:12 -0700
现在有一个需求是,创建一个任务,消费kafka,仅消费一个片段 即设定起始消费点和结束消费位置 我看到DataStream Connectors kafka 中有一个setBounded (setUnbounded)属性 ,可以满足需求。 问题; 我想使用 Table API 完成上面的需求,该怎么办? Table API 是否有相关属性? 有其他办法满足这个需求吗? 流处理批处理都行。