Apache Flink

hei team!
we are facing an issue when using flink sql client and using kafka connector. this is my statement:


CREATE TEMPORARY TABLE IF NOT EXISTS payments (
    userId STRING,
    paymentId STRING,
    paymentStatus STRING,
    direction STRING,
    amount BIGINT,
    eventTime TIMESTAMP
) WITH (
  'connector.type' = 'kafka',
  'connector.version' = 'universal',
  'connector.topic' = 'payments',
  'format.type' = 'json',
  'connector.properties.bootstrap.servers' = 'kafka-rt:9093',
  'connector.properties.group.id' = 'ethanol-test'
);

and I made sure I have the flink-sql-connector-kafka in the sql client docker. However when running the command I face the following issue:

[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.table.factories.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory' in
the classpath.
The following factories have been considered:
org.apache.flink.table.sources.CsvBatchTableSourceFactory
org.apache.flink.table.sources.CsvAppendTableSourceFactory

What could be the issue when the connector kafka lib is in the classpath? Regards, Oscar