自定義flink-kafka特定結束消費位置

自定義flink-kafka-connector 背景：消費特定開始和結束位置的kafka數據，需求是執行flink任務消費完特定位置數據后，任務自行停止。但批任務並不支持消費kafka數據，而流任 ...