自定义flink-kafka特定结束消费位置

自定义flink-kafka-connector 背景：消费特定开始和结束位置的kafka数据，需求是执行flink任务消费完特定位置数据后，任务自行停止。但批任务并不支持消费kafka数据，而流任 ...