1
하나의 항목을 입력으로 가져와 출력으로 여러 항목을 생성해야하는 Kafka 스트림 프로세서가 있습니다. 코드를 작성하는 올바른 방법은 무엇입니까? this.context().forward(key, item)에 대한 여러 번의 호출이 올바른 방법입니까 아니면 다른 속임수입니까?Apache Kafka : 프로세서가 입력마다 다중 출력을 생성합니다.
감사합니다.
A
답변
2
프로세서 API의 경우 context.forward(key, item)이 정확합니다.
DSL의 경우 KStream#flatMapValues() 또는 KStream()flatMap()을 사용할 수도 있습니다.