#NEWLINE# def __init__( self , topic , partition = 0 , host = 'localhost' , port = 9092 ) : #NEWLINE# #INDENT# kafka . io . IO . __init__ ( self , host , self ) #NEWLINE# self . topic = topic #NEWLINE# self . partition = partition #NEWLINE# self . offset = 0 #NEWLINE# self . max_size = self . MAX_SIZE #NEWLINE# self . request_type = self . CONSUME_REQUEST_TYPE #NEWLINE# self . polling = self . DEFAULT_POLLING_INTERVAL #NEWLINE# self . connect ( )