Hi Tarush, Indeed, we do not have support for Kafka yet. It would be great to add it!
For the reading part of the code itself, the best place to look into is other projects that use Kafka, e.g., Flink. Or even Kafka's examples. For the adaptation to SAMOA, the best place to start from is the code for the HSDF and local files (HDFSFileStreamSource and LocalFileStreamSource). One tough design point is how to reuse the readers available in each platform while keeping the API towards SAMOA unified, without needing to rewrite all the code. Hope it helps! -- Gianmarco On 19 January 2016 at 21:05, tarush grover <[email protected]> wrote: > Hi All, > > Needed guidelines for starting on this issue. I am not seeing any code for > Kafka in the master branch. > > Regards, > Tarush >
