Hi Shamit,
In this snippet:
Table definition with upsert-kafka is below (not working),
>
> CREATE TABLE proposalLine (PROPOSAL_LINE_ID
> bigint,LAST_MODIFIED_BY STRING ,PRIMARY KEY (PROPOSAL_LINE_ID) NOT ENFORCED
> ) "WITH ('connector' = 'upsert-kafka',
Hi Shamit,
thanks for reaching out to the community. I am pulling in Timo who might
know more about this problem.
Cheers,
Till
On Sun, Feb 7, 2021 at 6:22 AM shamit jain wrote:
> Hello Team,
>
> I am facing issue with "upsert-kafka" connector which should read the Avro
> message serialized
Hello Team,
I am facing issue with "upsert-kafka" connector which should read the Avro
message serialized using
"io.confluent.kafka.serializers.KafkaAvroDeserializer". Same is working with
"kafka" connector.
Looks like we are not able to pass the schema registry url and subject name
like the
