카프카 스트림즈

스트림즈DSL 기본 사용 - stream(), to()

Untitled

스트림즈DSL - filter()

Untitled

스트림즈DSL - KTable과 KStream join()

3개의 토픽을 우선 생성

Untitled

KTable 레코드 추가

Untitled

주문(order) 토픽 생성 - KStream

Untitled

KTable과 KStream의 조인 확인

Untitled