I would just look at an example: https://github.com/confluentinc/kafka-connect-jdbc https://github.com/confluentinc/kafka-connect-hdfs
On 7/12/17, 8:27 AM, "Debasish Ghosh" <ghosh.debas...@gmail.com> wrote: Hi - I would like to use the embedded API of Kafka Connect as per https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=58851767. But cannot find enough details regarding the APIs and implementation models. Is there any sample example that gives enough details about embedded Kafka Connect APIs ? My use case is as follows :- I have a Kafka Streams app from which I plan to use a HDFS sink connector to write to HDFS. And plan to use embedded Kafka Connect API. regards. -- Debasish Ghosh http://manning.com/ghosh2 http://manning.com/ghosh Twttr: @debasishg Blog: http://debasishg.blogspot.com Code: http://github.com/debasishg