You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2018/02/22 15:30:00 UTC

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

    [ https://issues.apache.org/jira/browse/FLINK-8537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16372948#comment-16372948 ] 

Xingcan Cui commented on FLINK-8537:
------------------------------------

Hi [~twalthr], I've implemented this Avro table source factory. During the implementation, I also do some refactorings to the JSON format factory since they share lots of codes. Considering that the PR for FLINK-8538 is still pending, should I apply the changes to it?

> 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 &amp; SQL
>            Reporter: Timo Walther
>            Assignee: Xingcan Cui
>            Priority: Major
>
> 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)