Details
-
New Feature
-
Status: Resolved
-
Major
-
Resolution: Implemented
-
None
Description
It would be nice to let the Kinesis consumer be on-par in functionality with the Kafka consumer, since they share very similar abstractions. Per-partition / shard watermarks is something we can add also to the Kinesis consumer.
Attachments
Issue Links
- blocks
-
FLINK-10921 Prioritize shard consumers in Kinesis Consumer by event time
- Resolved
- is blocked by
-
FLINK-6349 Enforce per-subtask record ordering on resharding for FlinkKinesisConsumer
- Open
- relates to
-
FLINK-8648 Allow for customization of emitRecordAndUpdateState in Kinesis connector
- Resolved
- links to