[jira] [Created] (FLINK-8537) Add a Kafka table source factory with Avro format support

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-8537) Add a Kafka table source factory with Avro format support

Shang Yuanchun (Jira)
Timo Walther created FLINK-8537:
-----------------------------------

             Summary: Add a Kafka table source factory with Avro format support
                 Key: FLINK-8537
                 URL: https://issues.apache.org/jira/browse/FLINK-8537
             Project: Flink
          Issue Type: Sub-task
          Components: Table API & SQL
            Reporter: Timo Walther


Similar to {{CSVTableSourceFactory}} a Kafka table source factory should be added. This issue includes creating a {{Avro}} descriptor with validation that can be used for other connectors as well. It is up for discussion if we want to split the KafkaAvroTableSource into connector and format such that we can reuse the format for other table sources as well.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)