SparkStreaming consumption delay, don't have to stop the program, can increase the partition number online, to speed up the consumption

CodePudding user response:

SparkStreaming parallelism and the partition number is not necessarily linked