flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-8537) Add a Kafka table source factory with Avro format support
Date Thu, 01 Mar 2018 16:14:00 GMT

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

ASF GitHub Bot commented on FLINK-8537:
---------------------------------------

Github user xccui commented on the issue:

    https://github.com/apache/flink/pull/5610
  
    Hi @twalthr @fhueske, I wonder if you could help review this PR when you are convenient.
    
    Thanks, Xingcan 


> 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)

Mime
View raw message