KSQL 테이블의 데이터 읽기

Question

어쩌면 이것은 초보자 용 질문 일 수도 있지만 KSQL에서 생성 된 데이터를 읽는 데 권장되는 방법은 무엇입니까?

일부 스트림 처리를 수행하고 데이터를 KSQL 테이블에 기록한다고 가정 해 보겠습니다. 이제 스프링 애플리케이션을 통해이 데이터에 액세스하려고합니다 (예 : 웹 소켓을 통해 일부 실시간 데이터 팬 아웃). 내 첫 번째 추측은 Spring Kafka를 사용하고 기본 주제를 구독하는 것이 었습니다. 아니면 카프카 시내를 사용해야합니까?

또 다른 사용 사례는 스트림 처리를 수행하고 결과를 Redis 저장소 (예 : 항상 현재 값을 반환하는 웹 서비스)에 쓸 수 있습니다. 여기서 어떤 접근 방식이 될까요?

감사합니다.

Answer 1

KSQL 쿼리가 Kafka 항목에 저장되는 경우의 결과입니다. 따라서 결과 항목에서 읽음으로써 타사 응용 프로그램의 결과에 액세스 할 수 있습니다. 쿼리 결과가 Table 인 경우 생성 된 카프카 항목은 카산드라 또는 Redis와 같은 타사 시스템의 테이블로 읽을 수있는 변경 내용 항목입니다. 이 테이블은 항상 최신 결과를 가지며 웹 서비스에서 쿼리 할 수 ​​있습니다. 시각화를 위해 Elastic으로 결과를 푸는 Clickstream 데모를 확인하십시오. 시각화 된 값은 해당 테이블의 최신 값입니다.

https://github.com/confluentinc/ksql/tree/master/ksql-clickstream-demo#clickstream-analysis