MAPREDUCE服务 MRS-Kafka生产者写入单条记录过长问题:解决办法

时间：2025-04-16 21:58:09

MAPREDUCE服务 MRS 使用Kafka

解决办法

在初始化Kafka生产者实例时，设置此配置项“max.request.size ”的值。

例如，参考本例，可以将此配置项设置为“5252880”：

        // 协议类型:当前支持配置为SASL_PLAINTEXT或者PLAINTEXT
        props.put(securityProtocol, kafkaProc.getValues(securityProtocol, "SASL_PLAINTEXT"));
        // 服务名
        props.put(saslKerberosServiceName, "kafka");
        props.put("max.request.size", "5252880");
        .......

上一篇：MAPREDUCE服务 MRS-Kafka生产者写入单条记录过长问题:问题背景与现象

下一篇：MAPREDUCE服务 MRS-Kafka生产者写入单条记录过长问题:问题背景与现象