Hi Ralf, Have you tried _only_ adding flink-sql-connector-kafka-1.17.1.jar to the lib directory of your Flink deployment? It is a fat JAR, with all the dependencies shaded into it, so when you add them separately again, they will clash.
Best Am Mi., 11. Okt. 2023 um 04:26 Uhr schrieb Ralph Matthias Debusmann < matthias.debusm...@gmail.com>: > Hi, > > I am trying to run FlinkSQL (through sql-client.sh) and read messages from > Kafka topics. > > I downloaded 1.17.1 and extracted it. For the Kafka connectivity, I've > added flink-sql-connector-kafka-1.1.7.jar, flink-connector-kafka-1.1.7.jar > and kafka-clients-2.8.1.jar and now start the sql-client-.sh script adding > these three libs with the "-l" parameter. > > Now I'd like to create a table based on a Kafka topic like this: > CREATE TABLE bla ( > id BIGINT, > from_account INT, > to_account INT, > amount DOUBLE, > ts TIMESTAMP(3), > WATERMARK FOR ts AS ts - INTERVAL '5' SECOND > ) WITH ( > 'connector' = 'kafka', > 'topic' = 'bla', > 'properties.bootstrap.servers' = 'localhost:9092', > 'properties.group.id' = 'bla', > 'scan.startup.mode' = 'earliest-offset', > 'format' = 'json', > 'json.fail-on-missing-field' = 'true', > 'json.ignore-parse-errors' = 'false' > ); > > > Now when I select * from bla, I get the following error message: > > [ERROR] Could not execute SQL statement. Reason: > java.lang.ClassCastException: cannot assign instance of > org.apache.kafka.clients.consumer.OffsetResetStrategy to field > org.apache.flink.connector.kafka.source.enumerator.initializer.ReaderHandledOffsetsInitializer.offsetResetStrategy > of type > org.apache.flink.kafka.shaded.org.apache.kafka.clients.consumer.OffsetResetStrategy > in instance of > org.apache.flink.connector.kafka.source.enumerator.initializer.ReaderHandledOffsetsInitializer > > I tried different Kafka client lib versions and also multiple > flink(-sql)-connector-kafka versions with no avail :( > > Best, Ralph M. Debusmann > > >
