Re: About KafkaConsumerBase

Posted by aitozi on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/About-KafkaConsumerBase-tp14601p14619.html


Hi,Piotr Nowojski

      i think you are right, but i think it is executed in parallel, but in each parallel , it maintain itself a individual   instance of FlinkKafkaConsumerBase, and it contains a individual pendingOffsetsToCommit , am right ?

thanks, aitozi