flink 消费kafka启动报错

用代码块功能插入代码,请勿粘贴截图
    Properties properties = kafkaConfig.setKafkaConfig("localhost:9092", "test");

    StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
    FlinkKafkaConsumer011 comsumer = new FlinkKafkaConsumer011<>("TEMP", new SimpleStringSchema(), properties);
    comsumer.setStartFromEarliest();

    env.addSource(comsumer).print();

    env.execute();
运行结果及报错内容

img

我想要达到的结果

正确连接kafka消费

http://t.csdn.cn/zYyZ3
可以尝试看下我这篇文章

已解决,是版本问题

jar包冲突了哈