Regarding Connector Options - value.deserializer

[Ronak Beejawat (rbeejawa)]

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"
             + "   ,globalcallid_callmanagerid STRING\r\n"
             + "   ,globalcallid_callid INT\r\n"
             + "   ,callidentifier INT\r\n"
             + "    ,varvqmetrics STRING\r\n"
             + "    ,duration INT\r\n"
             + "   )\r\n"
             + "   WITH (\r\n"
             + "   'connector' = 'kafka'\r\n"
             + "   ,'topic' = 'cmr'\r\n"
             + "   ,'properties.bootstrap.servers' = 
'b-1.telemetry-msk-cluster.h1qn4w.c1.kafka.us-east-1.amazonaws.com:9092'\r\n"
             + "   ,'scan.startup.mode' = 'earliest-offset'\r\n"
             + "   ,'properties.value.deserializer' = 'json'\r\n"
             + "   ,'value.format' = 'json'\r\n"
             + "   )");


Thanks
Ronak Beejawat