gt;
>
> *From:* Hang Ruan
> *Sent:* Monday, January 10, 2022 3:06 PM
> *To:* dev@flink.apache.org; Ronak Beejawat (rbeejawa)
> *Cc:* commun...@flink.apache.org; u...@flink.apache.org
> *Subject:* Re: Regarding Connector Options - value.deserializer
>
>
>
>
share any link for sample example
for the same ?
Thanks
Ronak Beejawat
From: Hang Ruan
Sent: Monday, January 10, 2022 3:06 PM
To: dev@flink.apache.org; Ronak Beejawat (rbeejawa)
Cc: commun...@flink.apache.org; u...@flink.apache.org
Subject: Re: Regarding Connector Options - value.deserializer
Hi, Ronak,
I think you should implement a custom format by yourself instead of
overriding. The 'value.format' is a required table option.
Best,
Hang
Ronak Beejawat (rbeejawa) 于2022年1月10日周一
17:09写道：
> Hi Team,
>
> Is there any way we use value.deserializer in Connector Options from kafka
> via
Hi Team,
Is there any way we use value.deserializer in Connector Options from kafka via
sql api?
PFB below code snippt :
tableEnv.executeSql("CREATE TABLE cmrTable (\r\n"
+ " org_id STRING\r\n"
+ " ,cluster_id STRING\r\n"
+ "
