1. Version

💬

• Kafka : 2.6.0

2. auto.offset.reset

consumer가 kafka에서 해당 topic의 메세지를 어디까지 구독했는지 저장하는게 offset 이다.
하지만 consumer가 topic의 데이터를 처음부터 읽어야 하는 경우가 생긴다.
이럴 때 auto.offset.reset 옵션을 이용하면 된다.

💬 auto.offset.reset Option

server.properties의 옵션 log.retention.hours 설정된 시간만큼 topic 메세지를 저장해 둠.

• latest : 마지막으로 구독한 다음 메세지 부터 구독한다. (가장 최신)
• earliest : 처음부터 메세지를 구독한다. (가장 오래된)
• none : 구독하고자 하는 topic의 offset 정보가 없으면 exception을 발생한다.

📚 참고

https://kafka.apache.org/documentation/