当前位置: 首页 > 知识库问答 >
问题:

Spark Streaming Kafka CreateDirectStream无法解析

阙项禹
2023-03-14

请帮忙。

name := "ASUIStreaming"
version := "0.1"
scalacOptions += "-target:jvm-1.8"
scalaVersion := "2.11.11"

libraryDependencies += "org.apache.spark" %% "spark-core" % "2.1.0"
libraryDependencies += "org.apache.spark" %% "spark-streaming" % "2.1.0"
libraryDependencies += "org.apache.spark" % "spark-streaming-kafka-0-8_2.11" % "2.1.0"
libraryDependencies += "org.apache.spark" %% "spark-sql" % "2.1.0"
libraryDependencies += "org.apache.kafka" %% "kafka-clients" % "0.8.2.1"
libraryDependencies += "org.scala-lang.modules" %% "scala-parser-combinators" % "1.0.4"

共有1个答案

任元青
2023-03-14

我能够解决这个问题。在重新创建项目并再次添加所有依赖项后,我发现在Intellij中,某些代码必须在同一行,否则它将无法编译。

在这种情况下,将val kafkaParams代码放在同一行(而不是在代码块中)就解决了这个问题!

 类似资料:
  • 问题内容: 这是我在JSP文件中的Java代码。我正进入(状态 无法解析Base64Encoder。 为什么会这样呢?我必须添加与相关的内容。任何建议将不胜感激。 问题答案: 看起来您正在使用Web应用程序中包含的jar中不存在的类。您可以尝试以下吗?如有必要,请进行调整,我只是在查看通用文档,然后将其输入- 转到http://commons.apache.org/codec/index.html

  • 问题内容: 因此,我直接从Google的android网站复制了此教程示例内容,却收到一个错误,指出R.id无法解决。 这是我的Java文件 这是我的 问题答案: 您必须导入您的R类 同样,如需求发布一样,您必须为布局使用名称空间。

  • 问题内容: 之前一切正常。然后,我碰巧将一个新的xml文件添加到布局中。现在,当setContentView指向(R.layout.menu)时,我的一个类给出了错误。Eclipse告诉我R.layout.menu无法解析。我不知道为什么。我在布局文件夹中定义了一个称为菜单的布局。 有什么建议? 问题答案: 您是否执行过项目>清洁?有时,您只需要让Eclipse重新生成R文件即可。

  • 问题内容: 我是一个Java新手,因此遇到了这个问题。我尝试解码Json,为了做到这一点,我想导入这些包: “无法解决导入问题” …这些软件包是否不再可用,或者我是否需要做其他事情才能使它们起作用? 提前感谢。 问题答案: 可能您的简单json.jar文件不在您的类路径中。

  • 重命名应用程序包名称后,Android Studio显示此错误 我尝试过的事情: 清洁项目 清理Android Studio缓存 清除分级缓存 重新安装的IDE 文件->使缓存无效/重新启动 我使用了 截图

  • 我正在尝试将我的应用程序迁移到AndroidX,遵循官方文件。我运行refactor选项:migrate to androidx。 一开始,我有错误,通过重新启动和清理我的项目来解决。然后我遇到了一个问题(参见这个堆栈溢出问题),我通过将gradle构建工具降级到3.1.3来解决这个问题。 但现在我正在纠结于数据绑定。迁移工具替换了所有我的 由 但我有错误信息