3
점점 더 많은 기사가 이벤트 저장소로 kafka에 대해 이야기하고 cqrs & 이벤트 소싱으로 작성된 응용 프로그램에서이를 사용합니다. 쓰기 측에서 작업을 완료하기 위해 특정 집계의 이벤트에 대해 kafka (이벤트 저장소)를 어떻게 쿼리합니까?이벤트 소스로 kafka를 사용하여 이벤트 소스를 보충하십시오.
A
답변
0
카프카 스트림 (http://docs.confluent.io/current/streams/index.html)을 사용하여 카프카에 저장된 데이터 집계를 계산할 수 있습니다. 다음 릴리스에서 (투표가 이미 진행 중입니다) Kafka Streams는 대화 형 쿼리이라는 새로운 기능을 추가하여 원하는 경우 언제든지 각 집계의 현재 값을 쿼리 할 수 있습니다.
어떻게 대화 형 쿼리 작업에 대한 설명서가 상세하게 설명 릴리스 후 https://cwiki.apache.org/confluence/display/KAFKA/KIP-67%3A+Queryable+state+for+Kafka+Streams(기능 옛 이름 "Queryable에서 주"여전히) 지금은 설계 문서를 참조하십시오. 후속 의문 사항이 있으면 바로 진행하십시오.
kafka 및 쿼리 가능한 상태를 사용하는 방법에 대한 예제가 있습니까? 모든 사건이 같은 주제에 있어야합니까? 하나의 집계에는 여러 유형의 이벤트가있을 수 있으며 각 이벤트마다 고유 한 주제가 있다고 가정합니다. – hsen
카프카와 쿼리 가능한 상태를 사용하는 방법에 대한 예제가 있습니까? 모든 사건이 같은 주제에 있어야합니까? 하나의 집계에는 여러 유형의 이벤트가있을 수 있으며 각 이벤트마다 고유 한 주제가 있다고 가정합니다. 특정 집계의 상태를 쿼리하려면 이러한 모든 이벤트의 결과를 순서대로 집계해야합니다. 카프카를 잘못 사용하고 있습니까? – hsen
다음은 두 가지 예입니다. https://github.com/confluentinc/examples/blob/master/kafka-streams/src/main/java/io/confluent/examples/streams/interactivequeries/WordCountInteractiveQueriesExample.java 및 https : // github.com/confluentinc/examples/blob/master/kafka-streams/src/main/java/io/confluent/examples/streams/interactivequeries/kafkamusic/KafkaMusicExample.java (이 레포에는 다른 카프카 스트림 예제도 포함되어 있습니다). –