Flink upset-kaka connector not working with Avro confluent

2021-02-06 Thread shamit jain
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

Need help on Upsert-kafka connector with confluent schema registry

2021-02-06 Thread 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/