Hi Ram, On 24 Sep 2016, at 16:08, ram kumar <ramkumar09...@gmail.com> wrote: > I am wondering is that possible to add JDBC connection or url as a source or > target in Flink using Scala. > Could you kindly some one help me on this? if you have any sample code please > share it here.
What’s your intended use case? Getting changes from a database or REST API into a data stream for processing in Flink? If so, you could use a data capture tool to write your changes to Kafka and then let Flink receive them from there. There are e.g. Bottled Water [1] for Postgres and Maxwell [2] and Debezium [3] for MySQL. For REST, I suppose you’d have to periodically query the API and determine changes yourself. I don’t know if there are any tools to help you with that. Regards, Felix [1] https://github.com/confluentinc/bottledwater-pg [2] http://maxwells-daemon.io/ [3] http://debezium.io/
