Streamsets code behind...

Logstash Origin connector for StreamSets...

Connecting Spark streaming to streamsets input...