写kafka和flink代码的时候用到java的java.time.Duration时候报错。我用的jdk是java1.8。
ConsumerRecords<String, String> poll = new ConsumerRecords<>(Duration.ofSeconds(1));爆红
写kafka和flink代码的时候用到java的java.time.Duration时候报错。我用的jdk是java1.8。
ConsumerRecords<String, String> poll = new ConsumerRecords<>(Duration.ofSeconds(1));爆红
提示写的很清楚了,他需要的入参是Map类型的,你提供的是 Duration类型