Hi，
thanks，you explained clearly!
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/About-KafkaConsumerBase-tp14601p14621.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
Hi,
it maintain itself a individual instance of
FlinkKafkaConsumerBase, and it contains a individual pendingOffsetsToCommit
, am right ?
That is correct! The FlinkKafkaConsumerBase is code executed for each parallel
subtask instance, and therefore have their own pendingOffsetsToCommit which
w
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
--
View this message in context:
Hi,
pendingOffsetsToCommit is a private field which is not accessed from outside of
the FlinkKafkaConsumerBase class. It is only used in state manipulation
methods, which are not executed in parallel.
Thanks, Piotrek
> On Aug 1, 2017, at 1:20 PM, aitozi wrote:
>
> Hello:
>
>i am new to
