[Kafka] KSQL

 

KSQL?

Apache Kafka를 위한 SQL 엔진, SQL과 비슷한 문법으로 복잡한 스트리밍 데이터를 쉽게 처리하고, 실시간 대시보드, 모니터링 시스템 및 기타 실시간 애플리케이션을 구축할 수 있음.

 

Stream, Table

Stream Object

연속적인 record의 흐름, 집계보다 데이터 자체를 담는 경우가 많음

 

Table Object

최신상태를 보여주는 데이터를 넣는경우가 많음.

재고, 계좌 잔액 등을 생각하면 좋을 듯, key-value형식으로 구성되어 있음

 

 

사용 모습

Stream 생성

 

쿼리