为什么我会得到这个编译错误：“不能找到kstream.consulted的隐式值”，我如何修复它？
我们有以下依赖关系：
libraryDependencies += "org.apache.kafka" %% "kafka-streams-scala" % kafkaVersion
libraryDependencies += "io.confluent" % "kafka-streams-avro-serde" % confluentVersion
libraryDependencies += "io.confluent" % "kafka-schema-registry-client" % confluentVersion
libraryDependencies += "ch.qos.logback" % "logback-classic" % "1.2.3"
libraryDependencies += "com.typesafe" % "config" % "1.4.0"
libraryDependencies += "com.sksamuel.avro4s" %% "avro4s-core" % "3.0.4"
我们使用代码生成器从AVRO模式文件生成Scala case类。一个这样生成的case类的字段之一是一个任一值。在AVRO模式中，这是用type=[t1,t2]表示的，因此生成似乎是体面的，即是一个和类型：可以是t1类型或t2类型。
could not find implicit value for parameter consumed: org.apache.kafka.streams.scala.kstream.Consumed[String, custom.UserEvent]
[error] .stream[String, UserEvent]("schma.avsc")
import org.apache.kafka.common.serialization.Serde
import org.apache.kafka.streams.Topology
import org.apache.kafka.streams.scala.ImplicitConversions._
import org.apache.kafka.streams.scala.Serdes
import org.apache.kafka.streams.scala.Serdes._
import org.apache.kafka.streams.scala.kstream.Consumed
共有1个答案
实际上缺少一个导入。现在它可以编译。以下是进口：
import org.apache.kafka.streams.Topology
import org.apache.kafka.streams.scala.ImplicitConversions._
import org.apache.kafka.streams.scala.Serdes._
-
我们有这些依赖性： 我们使用代码生成器从AVRO模式文件生成Scala案例类。一个这样生成的case类有一个值，作为其字段之一。在AVRO模式中，这是用type=[t1，t2]表示的，因此生成似乎是合理的，即sum类型：可以是t1类型，也可以是t2类型。 问题在于，从主题到案例类（二进制）的反序列化路径缺少什么- 基本上我得到这个错误目前： 第一个想法是kafka-stream-avro-serd
-
我需要将12小时的时间转换为24小时的格式。 我现在已经把12小时的时间硬编码了，以使事情更简单。 我的逻辑：输入sting 07:05:45PM提取最后2个字符。如果AM check为前两个字符，则为12。。如果是，则将其设置为00，否则按原样输出，如果PM检查前两位数字是否为12。。如果是，请保持原样，如果不是，则在前2位加上12 总线错误：10是我运行代码得到的
-
错误（25,1）：PLS-00103：遇到符号“EXEC” 放下桌上的学生；提交；
-
{“error”：“invalid_scope”，“error_description”：“AADSTS70011：为输入参数”scope“提供的值无效。作用域 https://graph.microsoft.com/User.Read https://graph.microsoft.com/User.ReadWrite https://graph.microsoft.com/User.ReadB
-
我试图解决这个问题：第三个最大数量 但我犯了这个错误 第4行：Char 37:运行时错误：有符号整数溢出：-9223372036854775808-10不能在类型“long long”（solution.cpp）摘要中表示：UndefinedBehaviorSanitizer:undefined behavior prog_joined。cpp:13:37 这是我的代码 有人能告诉我这个错误到底意
-
很抱歉，我对Java知之甚少。我得到了这个代码来接管。基本上，我在 当我运行代码时。 下面是解析XML的块 这是Improts，不确定是否需要这样做 这是XML文件