카프카는 스칼라

Question

나는 카프카 스칼라 아래 완벽하게 잘 작동 자바 내 코드가 함께 스트림을 사용하려고와 스트림 스칼라 코드가 컴파일 오류를 발생시킵니다. 유형 기대 불일치 : ForEachAction [> 문자열,> 문자열], 실제 ((어떤, 어떤), 단위) 를 찾을 수 없습니다 : 값 키 를 찾을 수 없습니다 값 값

사람에 스트림 API를 사용하는 방법을 알고 있나요 scala

Answer 1

구문이 잘못되었습니다. :) ->는

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

입력 가지고 단지 쌍을 생성하는 연산자, 그렇게 표현 ((모든, 모두), 단위) 컴파일러는 모든 종류의 정보를 추론 할 수없는 (그리고 key 및 value이 누락) 때문에이 경우

입니다 =>로 교체 스칼라 2.12 ->을 사용하여 문제를 해결해야하지만 스칼라의 이전 버전을 사용하는 경우, 당신은 명시 적으로 자바 bifunction 구현해야합니다

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

Answer 2

을 인쇄 방법을 사용하여 kafkastream을 직접 인쇄 할 수 있습니다.

textlines.print

그것은 카프카 스트림을 출력합니다. print 함수에 인수를 전달하여 키 또는 값을 인쇄 할 수도 있습니다.