Skip to content

[FLINK-25509][connector/kafka] Add RecordEvaluator to dynamically stop source based on de-serialized records#76

Open
ruanhang1993 wants to merge 1 commit intoapache:mainfrom ruanhang1993:FLINK-25509