인프런 커뮤니티 질문&답변

안티푸라민

작성한 질문수

[아파치 카프카 애플리케이션 프로그래밍] 개념부터 컨슈머, 프로듀서, 커넥트, 스트림즈까지!

카프카 스트림즈 에러 핸들링 질문 드립니다

작성

·

385

0

카프카 스트림즈에서 에러 발생 시 commit이 어떻게 진행되는지 궁금합니다
(카프카 스트림즈는 auto.commit 설정을 변경할 수 없는걸로 이해하고 있습니다
혹시 잘못 이해하고 있다면 말씀 부탁드립니다~)

에러 핸들링 클래스 리턴 타입이 각각 FAIL, CONTIUNE 일 때
FAIL이면 커밋 X, CONTINUE이면 커밋 O
맞을까요?

Kafka 데이터 엔지니어링

답변 1

1

데브원영 DVWY

지식공유자

카프카 스트림즈에서는 수동 커밋으로 변경이 불가하며 자동 커밋(일정 시간 간격)으로 커밋을 수행합니다. FAIL이라면 마지막 처리 레코드까지 커밋을 수행하고 그 외에는 지속적으로 데이터 처리&커밋 수행합니다.

안티푸라민

질문자

답변 감사합니다!!

한가지 더 궁금한 점이 있습니다~

카프카 스트림즈의 경우 graceful shutdown을 어떤식으로 구현하는지 궁금합니다
(스프링에 올려서 사용 예정입니다)

데브원영 DVWY

지식공유자

kafka streams 라이브러리 사용할 경우 셧다운훅을 받아서 close()메서드를 사용하시면 됩니다.

https://kafka.apache.org/22/javadoc/org/apache/kafka/streams/KafkaStreams.html#close--

안티푸라민

작성한 질문수