spark.streaming.kafka.maxRatePerPartition的理解

spark.streaming.kafka.maxRatePerPartition設定對目標topic每個partition每秒鍾拉取的數據條數。 假設此項設為1，批次間隔為10s，目標topic只 ...