Hi Avi, Using the low-level streams API you can definitely read or write to arbitrary locations inside the process() method.
However, back to your original question: even with the low-level streams API the sources and sinks can only be Kafka topics for now. So, as Gwen mentioned, Connect would be the way to go to bring the data to a Kafka Topic first. Thanks Eno > On 2 Jun 2016, at 00:07, Avi Flax <avi.f...@parkassist.com> wrote: > > On 6/1/16, 18:59, "Gwen Shapira" <g...@confluent.io> wrote: > >> This would be Michael and Guozhang job to answer > > I look forward to hearing from them ;) > >> but I'd look at two options if I were you: >> >> 1) If the connector you need exists ( >> http://www.confluent.io/product/connectors), then you just need to run it. >> It is just a simple REST API (submit job, job status, etc), so I wouldn't >> count it as "learning a framework". > > Ah, I see. That’s good to know! Unfortunately in my case we have a > proprietary WebSockets API on one side and a proprietary database schema on > the other, so I’m doubtful this avenue would be applicable. :( > >> 2) I believe I've seen people implement "writes to database" in >> KafkaProcessor. Maybe try to google / search the mailing list? Guozhang and >> Michael can probably add details. > > Ah, very cool. I will do some searching. Thank you so much! > > Avi > > Software Architect @ Park Assist » We’re hiring! >
