Page History

...

1. a poll loop which:
   1. calls consumer.poll (note: rebalance listener might be called during poll)
   2. start processing received records
   3. commits offsets for records that completed processing
   4. repeat
2. a rebalance listener. When partitions are revoked it:
   1. waits (blocking) until processing of all consumed records (from revoked partitions) has completed
   2. when the poll-loop commits (1.c.) were async, wait for these commits to complete
   3. synchronously commits offsets for records that completed processing

...