def recv(self, request_id):
log.debug("<STR_LIT>" % request_id)<EOL>if not self._sock:<EOL><INDENT>self.reinit()<EOL><DEDENT>resp = self._read_bytes(<NUM_LIT:4>)<EOL>(size,) = struct.unpack('<STR_LIT>', resp)<EOL>resp = self._read_bytes(size)<EOL>return resp<EOL>
Get a response packet from Kafka

Arguments:
    request_id: can be any int (only used for debug logging...)

Returns:
    str: Encoded kafka packet response from server