我正在尝试将基于Scala的KafkaStreams应用程序从0.10.0.0升级到0.10.2.1，但我无法弄清楚如何使该应用程序进行编译。我在文档用途mapValue但是它不会更改值类型。我正在使用Scala2.11与-Xexperimental根据编译器标志这个.代码classMyStream(){defstartMyStream():Unit={valkStreamBuilder=newKStreamBuildervalkStream=kStreamBuilder.stream("myTopic")kStream.mapValues(newValueMapper[AnyRef,Doub