1100. Join Basic - dkkahm/study-kafka-with-spring GitHub Wiki

제약 조건

• KStream은 제약 없으면, Data 입력될 때마다 현재 가지고 있는 모든 Data 검색이 발생하므로 Window 제약이 반드시 필요함
• 또한 Co-Partitioning (두 topic 의 partition 개수가 같음) 제약이 요구되는 경우도 있으므로 확인 필요
  • https://gunju-ko.github.io/kafka/kafka-stream/2018/05/28/Stream-DSL.html

Join Event 발생 시점

• Inner Join
  • 두 topic 모두에서 같은 Key를 가진 값이 들어온 시점
• Left Join
  • Primary topic에서만 값이 발생시 (Left, null) 발생
  • Primary topic에서 값이 발생하고, 조금 후 Secondary topic 에서 같은 Key를 가진 값이 발생 시 (Left, Right) 발생
  • Secondary topic에서 값이 발생하고, 조금 후 Primary topic에서 값이 발생시 (Left, Right)
• Outer Join
  • Primary 에서만 값이 발생 시 (Left, null)
  • Secondary 에서만 값이 발생 시 (null, Right)
  • Primary 혹은 Secondary 에서 값 발생시, 동일한 Key에 해당하는 값이 상대 topic에서 이미 발생한 경우 (Left, Right)