Scala: не удается разрешить перегруженные методы (Flink WatermarkStrategy)

#apache-kafka #apache-flink #flink-streaming #apache-kafka #apache-flink #потоковая передача flink Вопрос: Я следую документации Flink о том, как использовать WatermarkStrategy с KafkaConsumer. Код показан ниже val kafkaSource = new FlinkKafkaConsumer[MyType]("myTopic", schema, props)…