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

2 errors

compile_and_test (1.20.0, 8, 11, 17, 21)  /  compile_and_test (11)

cancelled Oct 18, 2024 in 5m 7s