Kafka - consumer-groups.sh

bin/kafka-consumer-groups.sh --bootstrap-server my-kafka:9092 --list -> 그룹 리스트 확인

bin/kafka-consumer-groups.sh --bootstrap-server my-kafka:9092 --group 그룹이름 --describe -> 컨슈머 그룹 상태 확인, 레코드의 오프셋, 파티션 마지막 레코드의 오프셋, 컨슈머 랙, 컨슈머 ID, 호스트를 알 수 있다.

bin/kafka-consumer-groups.sh --bootstrap-server my-kafka:9092 --group 그룹이름 --topic 토픽이름 --reset-offsets --옵션 --execute -> 오프셋 리셋

오프셋 리셋 종류
--to-earliest -> 가장 처음 오프셋으로 리셋
--to-latest -> 가장 마지막 오프셋으로 리셋
--to-current -> 현 시점 기준 오프셋으로 리셋
--to-datetime -> 특정 일시로 오프셋 리셋(레코드 타임스탬프 기준)
--to-offset {long} -> 특정 오프셋으로 리셋
--shift-by {+/- long} -> 현재 컨슈머 오프셋에서 앞뒤로 옮겨서 리셋