一个手动管理spark streaming集成kafka时的偏移量到zookeeper中的小项目

[{"title":"（ 5 个子文件 7KB ） 一个手动管理spark streaming集成kafka时的偏移量到zookeeper中的小项目","children":[{"title":"940.streaming-offset-to-zk__qindongliang","children":[{"title":"pom.xml <span style='color:#111;'> 5.79KB </span>","children":null,"spread":false},{"title":"LICENSE <span style='color:#111;'> 1.06KB </span>","children":null,"spread":false},{"title":"src","children":[{"title":"main","children":[{"title":"scala","children":[{"title":"SparkDirectStreaming.scala <span style='color:#111;'> 7.46KB </span>","children":null,"spread":false},{"title":"KafkaOffsetManager.scala <span style='color:#111;'> 3.38KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true},{"title":"README.md <span style='color:#111;'> 2.50KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}]