def update_consumer_offsets(self, partition_offsets):
self.logger.debug("<STR_LIT>", partition_offsets)<EOL>for partition, offset in partition_offsets.items():<EOL><INDENT>self.consumer.offsets[partition] = offset<EOL><DEDENT>self.consumer.seek(<NUM_LIT:0>, <NUM_LIT:1>)<EOL>
Update consumer offsets to explicit positions.