Add hadoop dependency

val hadoopConf = new Configuration()

this is not acceptable. The config need to be passed in by user, and passed to spout. Default config won't work for most of cases.