FlinkKafkaConsumer 1.11的clientId什么的看不到这个怎么解决吗?_问答-...
FlinkKafkaConsumer String kafkaConsumer = new FlinkKafkaConsumer ( my-topic , new SimpleStringSchema(), properties); kafkaConsumer.setStartFromLatest(); // 从最新数据读取 kafkaCons...developer.aliyun.com