DirectDStream自定義起始偏移量讀取（基於spark-streaming-kafka-0.10 + Spark 2.3.4）

基於spark-streaming-kafka-0.10的自定義消費示例 spark版本-2.3.4java spark在2.3.0後已經不推薦使用0.8鏈接器的。0.10鏈接器也不支持receiver stream。 可是在學習的過程當中，發現新版本的寫法與老版本仍是出入很大的。如何自定義分區開始讀取的偏移量，如何將offset與zookeeper同步，查了下相關資料也比較少，官網對與這塊內容也

>>阅读原文<<