Details
-
Sub-task
-
Status: Closed
-
Major
-
Resolution: Done
-
None
-
None
-
None
Description
What
Use the Flink Configuration object to standardise the method of specifying configurations for the KDS source.
Also include validations:
Check that region in config matches ARN. ARN should take priority.
Why
We want to standardise error messages + source serialization methods implemented by Flink on the Flink Configuration objects.
Attachments
Issue Links
- is blocked by
-
FLINK-31813 Initial implementation of Kinesis Source using FLIP-27
- Resolved
- links to