[jira] [Created] (FLINK-21841) Can not find kafka-connect with sql-kafka-connector

["JieFang.He (Jira)" <ji...@apache.org>]

JieFang.He created FLINK-21841:
----------------------------------

             Summary: Can not find kafka-connect with sql-kafka-connector
                 Key: FLINK-21841
                 URL: https://issues.apache.org/jira/browse/FLINK-21841
             Project: Flink
          Issue Type: Bug
            Reporter: JieFang.He


 

When use sql-kafka with fat-jar（make flink-sql-connector-kafka_2.11 in user jar） with flink 1.11.1  like

 
{code:java}
CREATE TABLE user_behavior (
 user_id INT,
 action STRING,
 province INT,
 ts TIMESTAMP(3)
) WITH (
 'connector' = 'kafka',
 'topic' = 'intopic',
 'properties.bootstrap.servers' = 'kafkaserver:9092',
 'properties.group.id' = 'testGroup',
 'format' = 'csv',
 'scan.startup.mode' = 'earliest-offset'
)
{code}
 

I get a exception

 
{code:java}
Caused by: org.apache.flink.table.api.ValidationException: Cannot discover a connector using option ''connector'='kafka''.
        at org.apache.flink.table.factories.FactoryUtil.getDynamicTableFactory(FactoryUtil.java:329)
        at org.apache.flink.table.factories.FactoryUtil.createTableSource(FactoryUtil.java:118)
        ... 35 more
Caused by: org.apache.flink.table.api.ValidationException: Could not find any factory for identifier 'kafka' that implements 'org.apache.flink.table.factories.DynamicTableSourceFactory' in the classpath.Available factory identifiers are:datagen

{code}
It looks like the issue [FLINK-18076|http://example.com/] is not deal with all exceptions

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)