code: def update_consumer_offsets(self, partition_offsets):
          
          self.logger.debug("Updating consumer offsets to: %s", partition_offsets)
  
          for partition, offset in partition_offsets.items():
              self.consumer.offsets[partition] = offset
  
          # consumer keeps other offset states beyond its `offsets` dictionary,
          # a relative seek with zero delta forces the consumer to reset to the
          # current value of the `offsets` dictionary
          self.consumer.seek(0, 1)
docs: Update consumer offsets to explicit positions.