KSQL을 이용한 실시간 조인
코드너리 | 2022. 03. 01
CDC
실시간 스트리밍
사용된 파라오 슬롯:
Kafka Streams 혹은 KSQL을 이용한 조인
Kafka Streams 혹은 KSQL을 이용해 아래와 같은 순서로 조인을 수행합니다.
MongoDB와 MySQL의 변경 데이터를 Kafka Connect를 이용하여 각각의 CDC 토픽으로 전송합니다.
Kafka Streams 또는 KSQL을 이용하여 두 토픽을 실시간으로 조인합니다.