Ksql 사용해보기

KSQL에서 스키마 레지스트리를 연결하기 위해 옵션 추가

KSQL_KSQL_SCHEMA_REGISTRY_URL: 'http://schema-registry:8081'

토픽 리스트 출력

 

스트림 만들기 명령어

 

CREATE OR REPLACE STREAM `ksqlstudy` WITH (KAFKA_TOPIC = 'kafka.topic.test', VALUE_FORMAT = 'AVRO');

 

스트림 리스트 출력

스트림 출력

select * from `ksqlstudy`;

 

추가적으로 소문자의 경우 ``로 감싸줘야한다.