Hi guys,

In flink1.9, we can set `connector.type` to `kafka` and `format.type` to
json to read/write json data from kafka or write json data to kafka.

In my scenario, I wish to read local json data as a souce table, since I
need to do local debug and don't consume online kafka data.

For example:

> create table source (
> first varchar,
> id int
> ) with (
> 'connector.type' = 'filesystem',
> 'connector.path' = '/path/to/json',
> 'format.type' = 'json'
> )


In addition, writing local json data is also needed.

Does anyone have similar needs?

Best regards,
Anyang

Reply via email to