Page History

...

1. a poll loop which:
   1. calls consumer.poll
   2. start starts processing received records
   3. commits offsets for records that completed processing
   4.  gets a list of to be revoked partitions, if any:
      1. validate that all records for those partitions have been processed,
      2. if some records are not completely processed yet, request revoking to be delayed
   5. gets a list of lost partitions, if any:
      1. try to abort processing of records from these partitions
      2. make sure to no longer commit anything from these partitions
   6. repeat

...