Timo Walther commented on FLINK-8538:

Thanks for working on this [~xccui]. I had a quick look at it. Yes, I think you 
are on the right direction. I think we don't need a new module. We can also add 
this to {{flink-kafka-base}} but the question is if we want one descriptor for 
all Kafka connectors or make them version specific. Actually I'm in favor of 
just one descriptor but since connector interfaces change from version to 
version, it might be better to have {{Kafka010}} as a descriptor. What do you 
think [~fhueske]? I started working on FLINK-8558. Are you planning to work on 
FLINK-8630? Otherwise I would assign it to me. Would be great if we can get 
this in for Flink 1.5.

> Add a Kafka table source factory with JSON format support
> ---------------------------------------------------------
>                 Key: FLINK-8538
>                 URL: https://issues.apache.org/jira/browse/FLINK-8538
>             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 for JSON should 
> be added. This issue includes improving the existing JSON descriptor with 
> validation that can be used for other connectors as well. It is up for 
> discussion if we want to split the KafkaJsonTableSource into connector and 
> format such that we can reuse the format for other table sources as well.

This message was sent by Atlassian JIRA

Reply via email to