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

ruanhang1993 wants to merge 1 commit intoapache:mainapache/flink-connector-kafka:mainfrom

ruanhang1993:FLINK-25509ruanhang1993/flink-connector-kafka:FLINK-25509Copy head branch name to clipboard