自定义flink-kafka-connector，目前flink，DataStream API支持设定消费结束偏移位置,但Table API并不支持该功能，因此只能自定义kafka连接器，可在批任务的情况下，设定开始位置和结束位置。