목록RocksDB (1)

Nellie's Blog

[Kafka] 스프링 부트에 Kafka Streams 적용하기

카프카 스트림즈(Kafka Streams)란?  카프카 스트림즈란 연속적인 이벤트 스트림이 들어올때마다 그때그때 처리하고 분석하여 의미있는 정보를 추출하고 실시간으로 작업을 처리하는 자바 라이브러리 기능이다.  이전에는 카프카 컨슈머 및 프로듀서 조합으로 필터링하여 다시 토픽에 넘겨주는 작업을 해주었지만 카프카 스트림즈는 매우 간단한 스트림즈 DSL 이란 기능으로 강력한 필터링 기능을 제공한다.  아래 그림으로 비교를 해보자.   기존의 필터링 방식  카프카 스트림즈를 이용한 필터링 방식또한 내장 DB 인 Rocks DB를 이용하여 key-value Store 기능도 제공한다.   2. 카프카 스트림즈 예제 코드  간단한 스프링부트 코드로 스트림즈 예제를 실습해보았다.  1. 스트림즈 DSL 라이브러리 ..
Infra/Kafka, MQTT 2024. 6. 7. 15:03
이전 Prev 1 Next 다음