You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "lidesheng (Jira)" <ji...@apache.org> on 2020/12/04 07:23:00 UTC

[jira] [Created] (FLINK-20480) Methods from CheckpointedFunction interface in FlinkKafkaConsumerBase are set to final

lidesheng created FLINK-20480:
---------------------------------

             Summary: Methods from CheckpointedFunction interface in FlinkKafkaConsumerBase are set to final
                 Key: FLINK-20480
                 URL: https://issues.apache.org/jira/browse/FLINK-20480
             Project: Flink
          Issue Type: Wish
          Components: Connectors / Kafka
         Environment: Flink 1.11
            Reporter: lidesheng


 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. 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)