[BEAM-3526] Support for checkpointMark finalize in KafkaIO

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Affects Version/s: 2.2.0
• Fix Version/s: 2.4.0
• Component/s: io-java-kafka
• Assignee: Raghu Angadi
• Reporter: Raghu Angadi
• Created: 24/Jan/18 20:55
• Updated: 23/Dec/20 16:31
• Resolved: 06/Feb/18 00:56

Description

Users have been asking for option to commit offsets back to Kafka inside CheckpointMark.finalizeCheckpoint(). This option is some what better than setting AUTO_COMMIT in Kafka consumer. 

Issue Links

• links to: GitHub Pull Request #4481