Kafka 컨슈머의 안전한 종료

컨슈머 애플리케이션은 안전하게 종료되어야 한다. 정상적으로 종료되지 않은 컨슈머는 세션 타임아웃이 발생할때까지 컨슈머 그룹에 남게된다.

• wakeup()
  • 컨슈머를 안전하게 종료하기 위해 Kafka 클래스는 wakeup() 함수를 지원한다.
  • wakeup() 함수가 실행된 이후 poll() 함수가 호출되면 WakeupException 예외가 발생한다. WakeupException 예외를 받은 뒤에는 데이터 처리를 위해 사용한 자원들을 해제하면 된다.