[
https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16360606#comment-16360606
]
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
(v7.6.3#76005)
