아파치 카프카에서 상태를 만들고 쿼리하기 : 카프카 스트림?

내 요구 사항에 맞는 아파치 클러스터를 구축하고 있으며 대부분은 상태 비 저장입니다. 그러나 실제로 상태가 필요한 상황이 하나 있습니다.아파치 카프카에서 상태를 만들고 쿼리하기 : 카프카 스트림?

내가 설명하는 것은 내가 열어 모든 약국 가게와 그 모든 상점에서 일어나는 거래를 말하고있다. 그래서 가게는 의약품의 숫자의 초기 상태로 열립니다. 의약품이 판매되고 더 많은 의약품이 보급되면서 국가는 지속적으로 변화하고 있습니다.

카프카는 실시간으로 실시간 거래를 유지해야 할 필요가 있지만 필자는 약국 저장소 상태와 쿼리를 작성하고 특정 시점에 상점에서 주어진 약품의 수를 알아낼 수 있어야합니다. 가능한가? 그것은 카프카 스트림이 사용 된 것입니까?

예, 당신은 카프카의 주제를 소비하며 지속적으로 예에서와 같이 유지하기 위해 업데이트되는 쿼리 가능한 저장, 현재 약물의 재고를 유지하는 응용 프로그램을 구축 할 카프카 스트림을 사용할 수 있습니다.

체크 아웃 문서는 시작하기 :

2017-01-08 05:39:27

는 카프카 스트림 ' "대화 형 쿼리"기능을 사용하여이 예제를 체크 아웃 대화식 쿼리 설명서 : http://docs.confluent.io/current/streams/developer-guide.html#interactive - 질의 –

답변