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();
正确连接kafka消费
http://t.csdn.cn/zYyZ3
可以尝试看下我这篇文章
已解决,是版本问题
jar包冲突了哈