카프카 스트림즈(Kafka Streams) - 스트림즈DSL의 주요 옵션

스트림즈DSL 주요 옵션

스트림즈DSL 애플리케이션을 실행할 때 설정해야 하는 필수 옵션과 선택 옵션이 있는데, 선택 옵션을 설정하지 않은 경우 기본값이 적용되기 때문에 주의해야 합니다.

필수 옵션

• bootstrap.servers: 브로커의 호스트 이름과 포트를 1개 이상 설정
• application.id: 스트림즈 애플리케이션의 구분을 위한 고유한 아이디 설정

선택 옵션

• default.key.serde: 레코드의 메시지 키 직렬화, 역직렬화 클래스 설정 (default: Serdes.ByteArray().getClass().getName())
• default.value.serde: 레코드의 메시지 값 직렬화, 역직렬화 클래스 설정 (default: Serdes.ByteArray().getClass().getName())
• num.stream.threads: 스트림 프로세싱 실행 시 실행될 스레드 개수 설정 (default: 1)
• state.dir: rocksDB 저장소가 위치할 디렉토리 설정(default: /tmp/kafka-streams)

※ rocksDB란?

rocksDB란 페이스북이 개발한 고성능의 key-value DB로서 카프카 스트림즈가 상태기반 데이터 처리를 할 때 로컬 저장소로 사용됩니다.

더욱 사제한 옵션은 https://kafka.apache.org/documentation/#streamsconfigs에서 확인이 가능합니다.