René
08/09/2024, 9:48 AMThis is the table definition:
CREATE TABLE cvl_test (
EPOCH_ID BIGINT,
DESCRIPT VARCHAR )
WITH (
'connector' = 'kafka',
'properties.bootstrap.servers' = 'broker:9092',
'avro-confluent.schema-registry.url' = '<http://srurl:8081>',
'properties.sasl.mechanism' = 'PLAIN',
'properties.security.protocol' = 'SASL_SSL',
'properties.ssl.truststore.location' = '/etc/kafka/secrets/jks/truststore.jks',
'topic' = 'FCM1.SYST034.CVL',
'format' = 'avro-confluent',
'properties.group.id' = 'testGroup',
'scan.startup.mode' = 'earliest-offset'
);
René
08/09/2024, 9:50 AM