Details
-
Bug
-
Status: Closed
-
Blocker
-
Resolution: Resolved
-
None
-
None
Description
This is basically the 0.9 version counterpart for FLINK-3440.
When the 0.9 consumer fetches initial offsets from Kafka on startup, but does not have any data to read, it should also checkpoint & commit these initial offsets.
Attachments
Issue Links
- is blocked by
-
FLINK-4723 Unify behaviour of committed offsets to Kafka / ZK for Kafka 0.8 and 0.9 consumer
- Resolved
- links to