我想限制从Kafka获取数据时的速率。我的代码看起来像：

df = spark.read.format('kafka') \
        .option("kafka.bootstrap.servers",'...')\
        .option("subscribe",'A') \
        .option("startingOffsets",'''{"A":{"0":200,"1":200,"2":200}}''') \
        .option("endingOffsets",'''{"A":{"0":400,"1":400,"2":400}}''') \
        .option("maxOffsetsPerTrigger",20) \
        .load() \
        .cache()

但是当我打电话的时候 df.count() ，结果是600。我期望的是20岁。有人知道为什么“maxoffsetspertrigger”不起作用吗。