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

[{"title":"（5个子文件7KB）一个手动管理sparkstreaming集成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}]