卡夫卡与斯卡拉

Question

我试图用卡夫卡与斯卡拉 下面是我在Java代码中，其工作完全正常流流scala代码会引发编译错误。类型不匹配预期：ForEachAction [>字符串，>字符串]，实际（（任意，任意），单位） 未发现：价值关键 未发现：值值

有谁知道如何使用流API中scala

Answer 1

你的语法错了:)。 ->是建立对刚刚运营商，所以表达

(key,value)-> { 
    println(key) 
} 

有一个类型（（任意，任意），单位），因为编译器不能推断出任何类型的信息（和key和value缺失）

如果你是使用Scala的2.12更换->与=>应该解决的问题，但如果你使用Scala的旧版本，你将必须实现明确的java双功能：

textLines.foreach(new BiFunction[T1, T2] { ... }) 

Answer 2

您可以使用打印方法直接打印kafkastream。

textlines.print

它将打印卡夫卡流。您甚至可以通过将参数传递给打印函数来打印键或值。