티스토리 뷰

728x90

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으로 초기화 된 것을 볼 수 있다.

 

공지사항
최근에 올라온 글
최근에 달린 댓글
Total
Today
Yesterday
링크
«   2024/11   »
1 2
3 4 5 6 7 8 9
10 11 12 13 14 15 16
17 18 19 20 21 22 23
24 25 26 27 28 29 30
글 보관함