重载方法构造函数 FlinkKafkaConsumer010 和替代方法答案

【问题标题】：Overloaded method constructor FlinkKafkaConsumer010 with alternatives重载方法构造函数 FlinkKafkaConsumer010 和替代方法
【发布时间】：2020-09-20 08:04:01
【问题描述】：

我有这个带有这个导入和这个代码的 scala 文件。我不知道如何解决这个重载构造函数问题：

package uimp
import org.apache.flink.streaming.api.scala._
import org.apache.flink.streaming.api.TimeCharacteristic
import org.apache.flink.streaming.util.serialization.
{SimpleStringSchema,JSONKeyValueDeserializationSchema}
import org.apache.flink.core._
import org.apache.flink.streaming.connectors.kafka.{FlinkKafkaConsumer010}
import java.util.Properties
import scala.util.parsing.json.JSONObject
import com.fasterxml.jackson.databind.node.ObjectNode

object Silocompro {
  def main(args: Array[String]): Unit = {
  // set up the execution environment
  val env = StreamExecutionEnvironment.getExecutionEnvironment
  env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)

 //...more code

 val myConsumerDemographic = new FlinkKafkaConsumer010[ObjectNode]("topic_demographic", new org.apache.flink.streaming.util.serialization.JSONKeyValueDeserializationSchema(false), propertiesTopicDemographic)

 // ...more code

我有这个 build.sbt 来解决以上所有依赖：

ThisBuild / scalaVersion := "2.12.11"

val flinkVersion = "1.9.0"

val flinkDependencies = Seq(
"org.apache.flink" %% "flink-scala" % flinkVersion  ,
"org.apache.flink" %% "flink-streaming-scala" % flinkVersion ,
"org.apache.flink" %% "flink-connector-kafka-base" % flinkVersion ,
"org.apache.flink" % "flink-core" % flinkVersion ,
"org.apache.flink" %% "flink-clients" % flinkVersion, 
"org.apache.flink" %% "flink-connector-kafka-0.10" % flinkVersion ,
"com.fasterxml.jackson.core" % "jackson-databind" % "2.10.1")

但我在组装后出现这个错误：

重载方法构造函数 FlinkKafkaConsumer010 和替代方法

对解决这个问题有什么帮助吗？

【问题讨论】：

可能会省略类型参数。请参阅此 [示例|github.com/zqhxuyuan/kafka-book/blob/master/flink/src/main/… 以获取有效的解决方案。顺便说一句，有什么理由使用 0.10 连接器而不是更新的连接器？

标签： scala apache-kafka sbt apache-flink

【解决方案1】：

我和你有同样的问题。

检查你的 FlinkKafkaConsumer010() 方法，你从包中导入了一个错误依赖 “org.apache.flink.streaming.util.serialization”，真正的依赖在flink-core.jar中。

问题可能在于没有引用 Flink 的依赖或者选择了错误的导入类。

【讨论】：