Would you like to create a JIRA to move the JSON parsing out of the Flink
Kafka connector module into a dedicated module?
2017-12-07 10:18 GMT+01:00 Sendoh :
> exactly! I initially thought this class is in table API. I was building a
> custom table source and found I have to add Kafka connector d
exactly! I initially thought this class is in table API. I was building a
custom table source and found I have to add Kafka connector dependency for
reading JSON encoded data, although my table source doesn't need it.
Cheers,
Hung
--
Sent from: http://apache-flink-user-mailing-list-archive.23
The schema is used in Flink's KafkaJsonTableSources.
Looking at the interface, I don't think it is very specific to Kafka. It
just converts byte[] to Row.
It would be certainly possible to move it into a separate module to make it
reusable without adding a Kafka dependency.
I think this will happe
