t,LAST_MODIFIED_BY String )
WITH ('connector' = 'kafka', 'properties.bootstrap.servers' = 'localhost:9092',
'properties.auto.offset.reset' = 'earliest', 'topic' =
'lndcdcadsprpslproposalline',
'format'='avro-confluent','avro-confluent.schema-registry.url' = 'http://localhost:8081'">http://localhost:8081',
'avro-confluent.schema-registry.subject' = 'lndcdcadsprpslproposalline-value')
Regards,
Shamit
#x27;, 'properties.bootstrap.servers' =
'localhost:9092', 'properties.auto.offset.reset' = 'earliest', 'topic' =
'lndcdcadsprpslproposalline',
'format'='avro-confluent','avro-confluent.schema-registry.url' = '
<http://localhost:8081'> http://localhost:8081',
'avro-confluent.schema-registry.subject' =
'lndcdcadsprpslproposalline-value')
Regards,
Shamit <http://localhost:8081'>
--
Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/