[
https://issues.apache.org/jira/browse/FLINK-18858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17190366#comment-17190366
]
Danny Cranmer commented on FLINK-18858:
---------------------------------------
Thanks [~tzulitai]. Hello [~whummer], I am a member of the Kinesis team at AWS.
It is great to see interest in SQL support for Kinesis streams. I would be
happy to collaborate with you on this feature. Have you made any progress on
your PoC so far? It would be good to arrange a call to discuss the way forward,
feel free to drop me an email at cranm...@amazon.com. I look forward to hearing
back!
[~tzulitai]/[~rmetzger] would you expect a FLIP for this, or is the Jira
sufficient?
> Kinesis Flink SQL Connector
> ---------------------------
>
> Key: FLINK-18858
> URL: https://issues.apache.org/jira/browse/FLINK-18858
> Project: Flink
> Issue Type: Improvement
> Components: Connectors / Kinesis, Table SQL / Ecosystem
> Reporter: Waldemar Hummer
> Priority: Major
>
> 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.
>
> (Wasn't able to find an existing issue in the backlog - if this is a
> duplicate, then please let me know as well.)
> Thanks!
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
