-
Type:
Sub-task
-
Status: Resolved
-
Priority:
Major
-
Resolution: Implemented
-
Affects Version/s: None
-
Component/s: Connectors / Kinesis
-
Labels:
Shard consumer threads currently emit records directly. In order to align shards by event time, decouple shard consumer threads and emitter with a queue, as described in [1].
- is blocked by
-
FLINK-5697 Add per-shard watermarks for FlinkKinesisConsumer
-
- Resolved
-
- links to