def send(self, request_id, payload):
        """
        Send a request to Kafka

        Arguments::
            request_id (int): can be any int (used only for debug logging...)
            payload: an encoded kafka packet (see KafkaProtocol)
        """

        log.debug("About to send %d bytes to Kafka, request %d" % (len(payload), request_id))

        # Make sure we have a connection
        if not self._sock:
            self.reinit()

        try:
            self._sock.sendall(payload)
        except socket.error:
            log.exception('Unable to send payload to Kafka')
            self._raise_connection_error()
def send ( self , request_id , payload ) : log . debug ( "About to send %d bytes to Kafka, request %d" % ( len ( payload ) , request_id ) ) if not self . _sock : self . reinit ( ) try : self . _sock . sendall ( payload ) except socket . error : log . exception ( 'Unable to send payload to Kafka' ) self . _raise_connection_error ( )
Send a request to Kafka

        Arguments::
            request_id (int): can be any int (used only for debug logging...)
            payload: an encoded kafka packet (see KafkaProtocol)