#NEWLINE# def __init__( self , client , async = False , req_acks = Producer . ACK_AFTER_LOCAL_WRITE , ack_timeout = Producer . DEFAULT_ACK_TIMEOUT , codec = None , batch_send = False , batch_send_every_n = BATCH_SEND_MSG_COUNT , batch_send_every_t = BATCH_SEND_DEFAULT_INTERVAL ) : #NEWLINE# #INDENT# self . partitioner = UserPartitioner ( None ) #NEWLINE# super ( UserProducer , self ) . __init__ ( client , async , req_acks , ack_timeout , codec , batch_send , batch_send_every_n , batch_send_every_t )