Hi Jia, There's currently no dedicated documentation for composing streaming connectors, but for examples, I would say that the Elasticsearch and Nifi connectors are a good place to start learning. For a more full blown example I recommend taking a look at the Kafka connector. Basically, you'll extend the RichParallelSourceFunction for sources (or RichSinkFunction for sinks) and implement the required methods that will be called during the source / sink tasks' life cycle.
I'd be happy to help you with any questions you may come into while implementing the connector. Also, I'm thinking about adding documentation for composing a new connector (filed in https://issues.apache.org/jira/browse/FLINK-3989) as its a frequently asked question, so any feedback during your learning process will be quite helpful! -- View this message in context: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Would-like-to-add-a-connector-to-DistributedLog-tp11869p11872.html Sent from the Apache Flink Mailing List archive. mailing list archive at Nabble.com.
