Closed LinMingQiang closed 7 years ago
why i cant use scala to write kafka streams scala version 2.10 kafka version 0.10.0 Cannot compile : val builder = new KStreamBuilder(); val source = builder.stream[String,String](new String("topics")); source.map(value => value.toLowerCase)
This cannot work with Scala 2.10 because it requires Scala lambdas to be converted to Java 8 lambas.
Use Scala 2.11 or Scala 2.12 instead.
why i cant use scala to write kafka streams scala version 2.10 kafka version 0.10.0 Cannot compile : val builder = new KStreamBuilder(); val source = builder.stream[String,String](new String("topics")); source.map(value => value.toLowerCase)