@classmethod<EOL><INDENT>def encode_consumer_metadata_request(cls, client_id, correlation_id, payloads):<DEDENT>
message = []<EOL>message.append(cls._encode_message_header(client_id, correlation_id,<EOL>KafkaProtocol.CONSUMER_METADATA_KEY))<EOL>message.append(struct.pack('<STR_LIT>' % len(payloads), len(payloads), payloads))<EOL>msg = b'<STR_LIT>'.join(message)<EOL>return write_int_string(msg)<EOL>
Encode a ConsumerMetadataRequest

Arguments:
    client_id: string
    correlation_id: int
    payloads: string (consumer group)