#NEWLINE# def send( self , topic , name , * msg ) : #NEWLINE# #INDENT# partition = self . partitioner . partition ( name , None ) #NEWLINE# logger . info ( 'sending message {} at {}@{}' . format ( msg , topic , partition ) ) #NEWLINE# return self . send_messages ( topic , partition , * msg )