[ https://issues.apache.org/jira/browse/FLINK-8537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448306#comment-16448306 ]
ASF GitHub Bot commented on FLINK-8537: --------------------------------------- Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5610 Thank you for the PR @xccui. The code very looks good to me. I will fix some minor things during merge. > 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 > 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)