Skip to content
Flink Connector Kafka CI

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

Sign in to view logs

[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 and 1 warning

This job was cancelled