#NEWLINE# def resume( self , * partitions ) : #NEWLINE# #INDENT# 'Resume fetching from the specified (paused) partitions.\n\n        Arguments:\n            *partitions (TopicPartition): partitions to resume\n        ' #NEWLINE# if ( not all ( [ isinstance ( p , TopicPartition ) for p in partitions ] ) ) : #NEWLINE# #INDENT# raise TypeError ( 'partitions must be TopicPartition namedtuples' ) #NEWLINE# #UNINDENT# for partition in partitions : #NEWLINE# #INDENT# log . debug ( 'Resuming partition %s' , partition ) #NEWLINE# self . _subscription . resume ( partition )