MAPREDUCE服务 MRS-配置Kafka后进先出:配置描述

时间:2024-06-29 16:25:02

配置描述

在Spark Driver端的“spark-defaults.conf”配置文件中进行设置。

表1 参数说明

参数

说明

默认值

spark.streaming.kafka.direct.lifo

配置是否开启Kafka后进先出功能。

false

spark.streaming.kafka010.inputstream.class

获取解耦在 FusionInsight 侧的类

org.apache.spark.streaming.kafka010.HWDirectKafkaInputDStream

support.huaweicloud.com/cmpntguide-mrs/mrs_01_1959.html