def send(self, request_id, payload):
log.debug("<STR_LIT>" % (len(payload), request_id))<EOL>if not self._sock:<EOL><INDENT>self.reinit()<EOL><DEDENT>try:<EOL><INDENT>self._sock.sendall(payload)<EOL><DEDENT>except socket.error:<EOL><INDENT>log.exception('<STR_LIT>')<EOL>self._raise_connection_error()<EOL><DEDENT>
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)