Details
-
Sub-task
-
Status: Resolved
-
Major
-
Resolution: Done
-
None
-
None
-
None
Description
Implement a base implementation of the Kinesis source based on FLIP-27
Attachments
Issue Links
- blocks
-
FLINK-31986 Implement Integration test for FLIP-27 DataStreams API
- Resolved
-
FLINK-31987 Implement KDS Table API support
- Resolved
-
FLINK-31989 Update documentation
- Resolved
-
FLINK-32218 Implement support for parent/child shard ordering
- Resolved
-
FLINK-32229 Implement metrics and logging for Initial implementation
- Resolved
-
FLINK-31990 Use Flink Configuration to specify KDS Source configuration object
- Closed
-
FLINK-31988 Implement Python wrapper for new KDS source
- Open
-
FLINK-32097 Implement support for Kinesis deaggregation
- Open
- links to