티스토리 뷰
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으로 초기화 된 것을 볼 수 있다.
'백엔드 > kafka' 카테고리의 다른 글
[kafka] comsumer-group / 컨슈머그룹생성 / 동일 그룹 내에서 여러 컨슈머 생성하기 (0) | 2023.05.29 |
---|---|
[kafka] 데이터 쓰고 읽기/ 프로듀서 관련 명령어 / producer CLI / 컨슈머 관련 명렁어 / consumer CLI (0) | 2023.05.29 |
[Kafka] topic 관련 명령어/ topic CLI (0) | 2023.05.29 |
공지사항
최근에 올라온 글
최근에 달린 댓글
- Total
- Today
- Yesterday
링크
TAG
- Linux
- Kubernetes
- 톰캣
- java 코테
- 코딩테스트
- tomcat
- 코테
- 리액트
- 스프링
- java
- springboot
- 현대코테
- 전자정부프레임워크
- Spring
- centos
- 현대
- 도커
- 자바코테
- react
- 자바스크립트
- softeer java
- Docker
- javascript
- 현대오토에버
- 오토에버코테
- softeer
- 아파치카프카
- 쿠버네티스
- 자바
- mysql
일 | 월 | 화 | 수 | 목 | 금 | 토 |
---|---|---|---|---|---|---|
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 |
글 보관함