code: def encode_consumermetadata_request(cls, client_id, correlation_id,
                                          consumer_group):
          
          message = cls._encode_message_header(client_id, correlation_id,
                                               KafkaCodec.CONSUMER_METADATA_KEY)
          message += write_short_ascii(consumer_group)
          return message
docs: Encode a ConsumerMetadataRequest
  
          :param bytes client_id: string
          :param int correlation_id: int
          :param str consumer_group: string