def commit_partition_offsets(self, partition_offsets):
self.logger.debug("<STR_LIT>", partition_offsets)<EOL>commit_requests = [<EOL>OffsetCommitRequest(self.consumer.topic, partition, offset, None)<EOL>for partition, offset in partition_offsets.items()<EOL>]<EOL>commit_responses = self.consumer.client.send_offset_commit_request(<EOL>self.consumer.group,<EOL>commit_requests,<EOL>)<EOL>for commit_response in commit_responses:<EOL><INDENT>check_error(commit_response)<EOL><DEDENT>
Commit explicit partition/offset pairs.