現(xiàn)象一：

當(dāng)zk連接數(shù)特別大的時(shí)候，topic的partition不斷做重新選舉leader或者broker與zk連接超時(shí)，kafka0.8版本的消費(fèi)如果將offset放到zk里，就可能會(huì)不定期出現(xiàn)找不到topic-leader的情況，然后整個(gè)程序掛掉。
解決方式：升級(jí)spark-streaming-kafka的版本，將他提高到spark-streaming-kafka-0-10_2.11，官方已經(jīng)不再維護(hù)8的版本了。

現(xiàn)象二：

在用--conf spark.streaming.backpressure.initialRate=1500 和 --conf spark.streaming.backpressure.initialRate=3000 進(jìn)行限速的時(shí)候，指的是每一個(gè)partition每秒消費(fèi)的條數(shù)，如果kafka的partition不均衡，那么最好以最高的一個(gè)partition的速率來進(jìn)行限速，否則會(huì)有某些partition的數(shù)據(jù)一直延時(shí)。