[FLINK-8537] Add a Kafka table source factory with Avro format support

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.6.0
• Component/s: Table SQL / API
• Assignee: Xingcan Cui
• Reporter: Timo Walther
• Created: 31/Jan/18 12:06
• Updated: 24/Apr/18 08:29
• Resolved: 24/Apr/18 08:28

Description

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.

Issue Links

• links to: GitHub Pull Request #5610