예니ㅣ 2024. 1. 25. 13:31

강의

ksqlDB

"ksqlDB"는 REST API 혹은 ksql 클라이언트 툴을 이용하여 Topic을 테이블처러 SQL로 조작할 수 있는 방법 입니다.

docker ps
docker exec -it ContainerID sh

ksql
    CREATE STREAM my_stream (id STRING, name STRING, title STRING) with (kafka_topic='fake_peaple', value_format='JSON');
    SELECT * FROM my_stream;