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同步，查了下相关资料也比较少，官网对与这块内容也

>>阅读原文<<