[KAFKA] Auto Offset Commit Behavior

Auto Offset Commit Behavior 자바 Consumer API에서는 Polling을 정규적으로 수행할 때마다 오프셋도 정규적으로 커밋 된다. 언제 Offset Commit 컨슈머에서 poll을 호출할 때마다 auto.commit.interval.ms 설정 시간이 경과된다. enable.auto.commit을 참으로 하면 설정 시간이 지나면 커밋 한다. 카프카 컨슈머를 자바에서 실행해 보면 interval는 기본으로 5000ms, enable auto commit은 true로 되어있는 걸 볼 수 있다. properties로 설정할꺼면 위와 같이 설정하면 된다. 위 코드에서 5초마다 Poll을 수행한다는 의미이다. 5초가 지난 다음에 다시 Poll을 호출하면 비동기적으로 오프셋을 커밋 한다는 의미다. 기록을 받아서 pll을 다시 호출하기 전에 오프셋 처리를 하기에 최소한 한 번으로 설정이 되어있다....

원문링크 : [KAFKA] Auto Offset Commit Behavior