데이터 엔지니어 이것저것

사용에 앞서 필요한 lib pip install ksql from ksql import KSQLAPI from pprint import pprint client = KSQLAPI('http://127.0.0.1:8088', timeout=None) result = client.ksql('show topics;') pprint(result) 결과물 data = client.query("""SELECT * FROM `ksqlstudy`;""", use_http2=True) for i in data: print(i)

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`; 추가적으로 소문자의 경우 ``로 감싸줘야한다.