#NEWLINE# def update_consumer_offsets( self , partition_offsets ) : #NEWLINE# #INDENT# '\n        Update consumer offsets to explicit positions.\n        ' #NEWLINE# self . logger . debug ( 'Updating consumer offsets to: %s' , partition_offsets ) #NEWLINE# for ( partition , offset ) in partition_offsets . items ( ) : #NEWLINE# #INDENT# self . consumer . offsets [ partition ] = offset #NEWLINE# #UNINDENT# self . consumer . seek ( 0 , 1 )