[jira] [Created] (FLINK-18858) Kinesis SQL Connector

[Shang Yuanchun (Jira)]

Waldemar Hummer created FLINK-18858:
---------------------------------------

             Summary: Kinesis SQL Connector
                 Key: FLINK-18858
                 URL: https://issues.apache.org/jira/browse/FLINK-18858
             Project: Flink
          Issue Type: Improvement
            Reporter: Waldemar Hummer


Hi all,

as far as I can see in the [list of connectors|https://github.com/apache/flink/tree/master/flink-connectors], we have a {{[flink-connector-kinesis|https://github.com/apache/flink/tree/master/flink-connectors/flink-connector-kinesis]}} for *programmatic access* to Kinesis streams, but there does not yet seem to exist a *Kinesis SQL connector* (something like {{flink-sql-connector-kinesis}}, analogous to {{flink-sql-connector-kafka}}).

Our use case would be to enable SQL queries with direct access to Kinesis sources (and potentially sinks), to enable something like the following Flink SQL queries:
{code:java}
 $ bin/sql-client.sh embedded
...
Flink SQL> CREATE TABLE Orders(`user` string, amount int, rowtime TIME) WITH ('connector' = 'kinesis', ...);
...
Flink SQL> SELECT * FROM Orders ...;
...{code}
 

 

I was wondering if this is something that has been considered, or is already actively being worked on? If one of you can provide some guidance, we may be able to work on a PoC implementation to add this functionality.

Thanks!



--
This message was sent by Atlassian Jira
(v8.3.4#803005)