MAPREDUCE服务 MRS-Kakfa消费者读取单条记录过长问题:解决办法

时间:2024-08-27 10:23:54

解决办法

  1. 在初始化建立Kafka消费者实例时,设置此配置项“max.partition.fetch.bytes”的值。

    例如,参考本例,可以将此配置项设置为“5252880”:
    ......
    // 安全协议类型
    props.put(securityProtocol, kafkaProc.getValues(securityProtocol, "SASL_PLAINTEXT"));
    // 服务名
    props.put(saslKerberosServiceName, "kafka");
            
    props.put("max.partition.fetch.bytes","5252880");
    ......

support.huaweicloud.com/trouble-mrs/mrs_03_0201.html