'Update consumer offsets to explicit positions.'

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
    self.consumer.seek(0, 1)
