스트림즈 조인에 관련해서 질문드립니다.

Question

오늘 질문을 여러번 올리게되네요 ㅎ..   스트림즈 KStream과 KTable 을 join시 KStream과 KTable에 새로운값을 추가했을때 최신값에 대한 처리값이 출력되는데 강의에서 KStream에 같은 키에 대한값을 두개 넣었으니 해당키에 대한 값이 2개일텐데 왜 join시 최신값만 join되서 처리되는건가요? KStream과 GlobalKTable 을 join시 GlobalKTable에도 최신값을 기준으로 업데이트 되는건가요? 그게 아니라면 join시에 같은 키를 가진 값들이 여러개있을텐데 처리될때 최신값을 기준으로 join되는건지 아니면 모든값에 대해 join처리되는건지 궁금합니다.

dvwy · Answer

답변드립니다. KStream, KTable 조인(join메서드)을 수행할 때 순서가 중요합니다. 만약 KTable에 해당 키에 대한 데이터를 넣고 KStream을 두번 넣으면 두개의 결과값이 나올 것입니다. 만약 그렇지 않고 KTable에 매칭되는 메시지 키가 없다면 결과값이 없을 수도 있습니다. KStream, GlobalKTable 조인(Join메서드)의 경우 GlobalKTable의 가장 최신 메시지 키에 대한 레코드에 대해 매칭됩니다. 같은 키를 가진 값이 여러개 있을 경우 가장 최신값을 기준으로 처리되는 것입니다.