[FLINK-20480] Methods from CheckpointedFunction interface in FlinkKafkaConsumerBase are set to final

• Type: Improvement
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Component/s: Connectors / Kafka
• Labels: auto-deprioritized-major auto-deprioritized-minor

Environment

Flink 1.11

• Assignee: Unassigned
• Reporter: lidesheng
• Created: 04/Dec/20 07:22
• Updated: 05/Dec/21 10:38

Description

 I created a subclass from FlinkKafkaConsumerBase and wanna add some logic in checkpoint snapshot. I failed to do it because methods from CheckpointedFunction interface in FlinkKafkaConsumerBase are set to final. understand that these methods are set to final because offsets are required to hold and commit, so they do not want to be overridden by subclasses. Can we provide an additional abstract method to provide subclasses for their own state related operations? Call it in then end of final method default logic is emtpy.