Hi all, I'm trying to select data from a table wit...
# troubleshooting
r
Hi all, I'm trying to select data from a table with the kafka connector on flink sql but I get this error: [ERROR] Could not execute SQL statement. Reason: java.lang.ClassNotFoundException: org.apache.avro.SchemaParseException
Copy code
This 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'
);
Can anyone give me an advice what could be the cause here?