[KSQL]

KSQLDB 개요

ksqlDB is a database purpose-built to help developers create stream processing applications on top of Apache Kafka®.

스트리밍처리에 최적화된 DB 라 생각하면 될것같다.

설치법은 그리 어렵지 않고  kafka 설치된 인프라에 ksql server 와 유틸리티 설치를 진행하면 된다.

설치관련 가이드 : https://docs.confluent.io/platform/current/ksqldb/installing.html

Installing ksqlDB | Confluent Documentation

 

kafka 의 topic 을 베이스로 크게 Stream, table 의 두 개념으로 사용이 가능하다.

차이점은

stream 은 말그래도 stream

table 은 마지막값

table 의 emit change 는 변화한 값 모두

 

ksql cli 로 sql 로 kafka topic 의 내용을 조회 가능하다.

stream , table 을 만들면 kafka 내에 topic 이 만들어지니 그 topic 을 consume 하면 됨(이걸 몰라서 connector 쪽을 봤)

예전에 kafka topic-> topic 으로 데이터 전송할때 logstash 쓰거나 application 을 만들거나 했는데 그럴필요없이 깔끔