[jira] [Created] (FLINK-19283) Allow subclasses to override/extend FlinkKafkaConsumerBase checkpoint methods

["Adrian Kreuziger (Jira)" <ji...@apache.org>]

Adrian Kreuziger created FLINK-19283:
----------------------------------------

             Summary: Allow subclasses to override/extend FlinkKafkaConsumerBase checkpoint methods
                 Key: FLINK-19283
                 URL: https://issues.apache.org/jira/browse/FLINK-19283
             Project: Flink
          Issue Type: Improvement
          Components: Connectors / Kafka
    Affects Versions: 1.11.1, 1.11.0
            Reporter: Adrian Kreuziger


I'm working on a class that extends the FlinkKafkaConsumer to add some additional functionality the first time the consumer runs. I'd like to be able to store some additional state, but am unable to do so as the initializeState() and snapshotState() are marked as final. Ideally I'd like to be able to do something like
{code:java}
@Override	public final void initializeState(FunctionInitializationContext context) throws Exception {
super.initializeState(context);
// some additional initialization here

}

@Override	public final void snapshotState(FunctionSnapshotContext context) throws Exception {
super.snapshotState(context);
// set some additional state here

}{code}
I'm guessing it was marked final for a reason, is there a reason this would be problematic? The restoredState and unionOffsetStates properties are still private which would prevent subclasses from modifying the offset state.

 



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