Kafka Streams 윈도우 도입기

Kafka Streams 시간 단위로 이벤트를 묶어 집계하는 윈도우 기능을 제공한다 시간 단위로 이벤트를 묶어 집계하는 윈도우 기능을 제공함.

텀블링 윈도우 겹치지 않는 고정 시간 간격으로 데이터를 묶는다 겹치지 않는 고정 시간 간격(예: 5분)으로 데이터를 묶음.

유예 시간 윈도우가 닫히기 전 늦게 도착한 이벤트를 허용하는 시간을 정의한다 윈도우가 닫히기 전 늦게 도착한 이벤트를 허용하는 시간 범위.

스트림 시간 파티션 전체에서 관찰된 최신 이벤트 시간(스트림 시간)이 윈도우 결과 발행에 영향을 준다 파티션 전체에서 관찰된 최신 이벤트 시간이 윈도우 발행 시점에 영향을 줌.

TimestampExtractor 레코드 타임스탬프를 데이터 생성 시간으로 재정의하기 위해 TimestampExtractor를 사용한다 레코드의 타임스탬프를 데이터 생성 시간으로 재정의할 수 있음.