错误消息列出了
org.apache.kafka.streams.kstream.Printed[String,?0(in value x$1)]
从错误消息中，您可以看到您提供
Printed.toSysOut了以下类型：
org.apache.kafka.streams.kstream.Printed[Nothing,Nothing]
根据Kafka 1
javadoc（
Printed在Kafka
1.1中不存在），
toSysOut定义为：
public static <K,V> Printed<K,V> toSysOut()
因此，答案是Scala进行推断
K并
V具有类型
Nothing。您需要显式提供类型。
以下可能会起作用：
source .mapValues[String](value -> value + " Stream it!!!") .print(Printed.toSysOut[String,String])
