Spark--06 SparkStreaming kafka消息堆積

問題：併發 當應用因爲各類其它因素須要暫停消費時，下一次再次啓動後就會有大量積壓消息須要進行處理，此時爲了保證應用可以正常處理積壓數據，須要進行相關調優。oop 另外對於某個時刻，某個topic寫入量突增時，會致使整個kafka集羣進行topic分區的leader切換，而此時Streaming程序也會受到影響。spa 因此針對以上問題咱們進行了以下調優：線程 spark.streaming.con

>>阅读原文<<