About KafkaConsumerBase

Posted by aitozi on Aug 01, 2017; 11:20am
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/About-KafkaConsumerBase-tp14601.html

Hello:

    i am new to Flink, ijust read the source code . i am doubt that , why in FlinkKafkaConsumerBase.java (version1.2),  like method : notifyCheckpointComplete  may change the pendingOffsetsToCommit in parallel , why dont need to be surrouned with "synchronized"  

thanks