오픈소스/kafka
Ksql 사용해보기
pastime
2023. 10. 29. 16:57
728x90
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`;
추가적으로 소문자의 경우 ``로 감싸줘야한다.
728x90