[kafka/카프카] consumer groups - 오프셋 리셋하기 (reset offset)

offset 을 리셋하면 데이터를 처음부터 다시 읽을 수 있다.

 

1️⃣  consumer-group 상세보기

kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group consumer-group

LOG-END-OFFSET을 보면, 마지막으로 읽은 offset을 확인 할 수 있다.

 

2️⃣ offset 리셋하기

- reset시에는 모든 consumer group이 비활성화 상태여야한다. 아니면 아래와 같은 에러가 난다.

`Assignments can only be reset if the group consumer-group is inactive, but the current state is Stable`

kafka-consumer-groups.sh 
\ --bootstrap-server localhost:9092 
\ --group consumer-group 
\ --reset-offsets --to-earliest 
\ --topic test_topic 
\ --dry-run

consumer group을 나온 뒤 다시 시도해보면 NEW-OFFSET 이 0으로 초기화 된 것을 볼 수 있다.