How to change minimum rate per kafka partition

Question

There is a property in Spark named spark.stream.kafka.minRatePerParition and I want to change it. How can I do this dynamically? I want to increase the minimum read rate from kafka partition. 

Answer 1

Open spark shell using this command:

$ spark-shell

Then run the following command:

val sc = new SparkContext(new SparkConf())

./bin/spark-submit <all your existing options> --spark.streaming.kafka.minRatePerPartition= <min rate>