kafka流：无法解析重载方法

h6my8fg2 于 2021-06-04 发布在 Kafka

关注(0)|答案(1)|浏览(779)

我正在用scala编写一个kafka流应用程序。每当我尝试使用任何方法，如'groupby'或'flatmapvalues'时，我都会收到一条编译器消息：cannot resolve overloaded method
kafkastreams是用java编写的&从scala调用它的方法似乎有些问题。有办法解决这个问题吗？

val builder: StreamsBuilder = new StreamsBuilder
builder.stream("streams-plaintext-input", Consumed.`with`(Serdes.String, Serdes.String))
       .groupBy((_, word) => word)

scala apache-kafka apache-kafka-streams

来源：https://stackoverflow.com/questions/64884829/kafka-streams-cannot-resolve-overloaded-method

1条答案

按热度按时间

osh3o9ms1#

当我开始使用这些导入时，它起了作用。

import org.apache.kafka.streams.scala.ImplicitConversions._
import org.apache.kafka.streams.scala.Serdes._
import org.apache.kafka.streams.scala.StreamsBuilder
import org.apache.kafka.streams.scala.kstream._

赞(0）回复(0）举报 2021-06-04

我来回答

kafka流：无法解析重载方法

1条答案

相关问题

热门标签

最新问答