Skip to content

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

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

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

Annotations

1 warning

python_test (1.20.0)  /  python_test (8)

succeeded Oct 18, 2024 in 4m 18s