我理解应该只需要flink-sql-connector-kafka_2.11-1.10.0.jar这个包就可以了， flink-connector-kafka_2.11-1.10.0.jar这个包不需要放进去的。
潘明文 <[email protected]> 于2020年2月14日周五 下午5:50写道： > > > select * from mykafka1 > > 错误信息: > [ERROR] Could not execute SQL statement. Reason: > java.lang.NoSuchMethodError: > org.apache.flink.streaming.connectors.kafka.internals.metrics.KafkaMetricWrapper.<init>(Lorg/apache/kafka/common/Metric;)V > > > > > > > > > > 在 2020-02-14 17:43:16，"Benchao Li" <[email protected]> 写道： > >明文， > > > >你的图片没有在邮件中显示出来。 > >你可以用第三方的图床来上传图片，或者直接以text的方式发送你的异常信息。 > > > > > >潘明文 <[email protected]> 于2020年2月14日周五 下午5:31写道： > > > >> > >> > >> 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 > >> > >> > >> > >> > >> > > > > > >-- > > > >Benchao Li > >School of Electronics Engineering and Computer Science, Peking University > >Tel:+86-15650713730 > >Email: [email protected]; [email protected] > -- Benchao Li School of Electronics Engineering and Computer Science, Peking University Tel:+86-15650713730 Email: [email protected]; [email protected]
