docs: 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()