Closed benbenqiang closed 8 years ago
Thanks for your contribution. Could you add the copyright and parameter options for it? Or I can add it. You can take a look of file: https://github.com/huawei-noah/streamDM/blob/master/src/main/scala/org/apache/spark/streamdm/streams/TextStreamReader.scala
Is this OK? @JianfengQian
Qiang, Thanks for your contribution!
read data from kafka using direct api