[Kafka] Kafka Streams 사용법

개요Kafka Streams를 사용하면 특정 시간동안 Kafka에 인입되는 데이터를 집계해서 통계치를 추출할 수 있습니다.토픽에 있는 데이터를 빠른 속도로 실시간으로 변환하여 다른 토픽에 적재할 수 있는 것이 기본 동작 방식입니다.아래 예제 코드는 깃헙에 올려놨습니다.기본 코드아래는 /a라는 메소드 요청에 대해 시간 별로 요청 건 수를 통계화해서 /b로 확인하는 코드입니다.결과만 보면 /a라는 메소드는 14시에 2번, 15시에 4번 이용했다는 의미가 됩니다.@RestController@RequestMapping("/api")@RequiredArgsConstructorpublic class ApiController { private final ApiService apiService; @PostM..

→2025.01.09