#NEWLINE# def acknowledge_registration( self , workerName , partition , offsetSkip , **kwargs ) : #NEWLINE# #INDENT# self . produce ( 'AcknowledgeRegistration' , workerName , partition = partition , offsetSkip = offsetSkip , ** partition )