image

[潘明文]

CREATE TABLE mykafka1(name String) WITH (
   'connector.type' = 'kafka',
   'connector.version' = 'universal',
   'connector.topic' = 'mysql_binlog',
   'connector.properties.zookeeper.connect' = 'masternode1:2181',
   'connector.properties.bootstrap.servers' = 'masternode1:9092',
   'format.type' = 'csv',
   'update-mode' = 'append'
);



出现下面错误，没有方法，是版本不对吗？我用的是flink-sql-connector-kafka_2.11-1.10.0.jar 
flink-connector-kafka_2.11-1.10.0.jar