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

回复