diff --git a/external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/PerPartitionConfig.scala b/external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/PerPartitionConfig.scala index 4dc4a1ced5b26..3c5d63876d4d3 100644 --- a/external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/PerPartitionConfig.scala +++ b/external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/PerPartitionConfig.scala @@ -44,7 +44,7 @@ private class DefaultPerPartitionConfig(conf: SparkConf) extends PerPartitionConfig { val maxRate = conf.getLong("spark.streaming.kafka.maxRatePerPartition", 0) val minRate = conf.getLong("spark.streaming.kafka.minRatePerPartition", 1) - + def maxRatePerPartition(topicPartition: TopicPartition): Long = maxRate def minRatePerPartition(topicPartition: TopicPartition): Long = minRate }