Kafka 카프카 스트림즈 DSL 중요 옵션

less than 1 minute read

필수 옵션

bootstrap.server : 프로듀서가 데이터를 전송할 대상 카프카 클러스터에 속한 브로커의 호스트 이름:포트 를 1개 이상 작성한다. 2개 이상 브로커 정보를 입력하여 일부 브로커에 이슈가 발생하더라도 접속하는 데헤 이슈가 없도록 설정 가능하다.
application.id : 스트림즈 애플리케이션을 구분하기 위한 고유한 아이디를 설정한다. 다른 로직을 가진 스트림즈 애플리케이션들은 서로 다른 application.id 값을 가져야 한다.

default.key.serde : 레코드의 메세지 키를 직렬화, 역직렬화하는 클래스를 지정한다. (기본값 : 바이트 직렬화, 역직렬화 클래스인 Serdes.ByteArray().getClass().getName())
- 스트림 별로 별도로 직렬화, 역직렬화를 기본값이 아닌 커스텀하게 지정해서 사용할 수 있다.
default.value.serde : 레코드의 메세지 값을 직렬화, 역직렬화하는 클래스를 지정한다. (기본값 : 바이트 직렬화, 역직렬화 클래스인 Serdes.ByteArray().getClass().getName())
num.stream.threads : 스트림 프로세싱 실행 시 실행될 스레드 갯수를 지정한다. (기본값 : 1)
state.dir : 상태기반 데이터를 처리를 할 때 데이터를 저장할 디렉토리를 지정한다. (기본값 : /tmp/kafka-streams)
- 스트림 데이터들은 디스크(파일 시스템)에 저장되어 활용된다. (RocksDB 사용)