scala重载方法构造函数flinkkafkaconsumer010及其替代方法

mbjcgjjk  于 2021-06-05  发布在  Kafka
关注(0)|答案(1)|浏览(451)

我有一个scala文件,里面有导入和代码。我不知道如何解决这个问题:

  1. package uimp
  2. import org.apache.flink.streaming.api.scala._
  3. import org.apache.flink.streaming.api.TimeCharacteristic
  4. import org.apache.flink.streaming.util.serialization.
  5. {SimpleStringSchema,JSONKeyValueDeserializationSchema}
  6. import org.apache.flink.core._
  7. import org.apache.flink.streaming.connectors.kafka.{FlinkKafkaConsumer010}
  8. import java.util.Properties
  9. import scala.util.parsing.json.JSONObject
  10. import com.fasterxml.jackson.databind.node.ObjectNode
  11. object Silocompro {
  12. def main(args: Array[String]): Unit = {
  13. // set up the execution environment
  14. val env = StreamExecutionEnvironment.getExecutionEnvironment
  15. env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)
  16. //...more code
  17. val myConsumerDemographic = new FlinkKafkaConsumer010[ObjectNode]("topic_demographic", new org.apache.flink.streaming.util.serialization.JSONKeyValueDeserializationSchema(false), propertiesTopicDemographic)
  18. // ...more code

我有这个build.sbt来解决所有的依赖关系:

  1. ThisBuild / scalaVersion := "2.12.11"
  2. val flinkVersion = "1.9.0"
  3. val flinkDependencies = Seq(
  4. "org.apache.flink" %% "flink-scala" % flinkVersion ,
  5. "org.apache.flink" %% "flink-streaming-scala" % flinkVersion ,
  6. "org.apache.flink" %% "flink-connector-kafka-base" % flinkVersion ,
  7. "org.apache.flink" % "flink-core" % flinkVersion ,
  8. "org.apache.flink" %% "flink-clients" % flinkVersion,
  9. "org.apache.flink" %% "flink-connector-kafka-0.10" % flinkVersion ,
  10. "com.fasterxml.jackson.core" % "jackson-databind" % "2.10.1")

但我在装配后有一个错误:
重载方法构造函数flinkkafkaconsumer010及其替代项
有什么办法解决这个问题吗?

uqjltbpv

uqjltbpv1#

我和你有同样的问题。
检查你的flinkkafcaumer010()方法,你从包“org.apache.flink.streaming.util.serialization”中导入了一个错误依赖,它的真正依赖在flink-core.jar中。
问题可能在于没有引用flink的依赖项或选择了错误的导入类。

相关问题