[FLINK-4727] Kafka 0.9 Consumer should also checkpoint auto retrieved offsets even when no data is read

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Resolved
• Fix Version/s: 1.1.4, 1.2.0
• Component/s: Connectors / Kafka
• Assignee: Tzu-Li (Gordon) Tai
• Reporter: Tzu-Li (Gordon) Tai
• Created: 03/Oct/16 08:47
• Updated: 16/Nov/16 06:31
• Resolved: 16/Nov/16 06:31

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.

Issue Links

• is blocked by: FLINK-4723 Unify behaviour of committed offsets to Kafka / ZK for Kafka 0.8 and 0.9 consumer
• links to: GitHub Pull Request #2585