KSQL을 사용하여 스트리밍 데이터를 처리하는 것을 알아보겠습니다. 예를 들어, 실시간으로 들어오는 거래 데이터를 다루고 분석하는 과정을 살펴보겠습니다. 1. 데이터 스트림 생성 먼저, KSQL을 사용하여 데이터를 스트리밍하는 토픽을 생성합니다. 예를 들어, 거래 데이터를 다루는 토픽을 생성할 수 있습니다. -- 거래 데이터를 다루는 토픽 생성 CREATE STREAM transaction_data (id INT, amount DOUBLE, timestamp BIGINT) WITH (KAFKA_TOPIC='raw_transactions', VALUE_FORMAT='JSON'); 위 코드는 raw_transactions라는 카프카 토픽으로부터 JSON 형식의 거래 데이터를 읽어와 transaction_da..