[kafka] kafka consumer group 명령어

※ kafka 설치된 것에 따라 명령어의 위치가 다를 수 있음(/opt/bitnami/kafka/bin/kafka-topics.sh 여기에 있을 수도 있고 /bin에 있을 수도 있고...)

※ 쉘에 .sh이 붙고 안붙고 차이가 있을 수 있음

 

Group 리스트 : 

kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list

Group 정보 조회 :

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

Group Consumer 정보 조회 : 

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

Group 삭제 : 

kafka-consumer-groups.sh --bootstrap-server localhost:9092 \
    --delete --group $group

Group to earliest: 

kafka-consumer-groups.sh --bootstrap-server localhost:9092 \
    --group $group --reset-offsets --to-earliest \
    --execute --topic $topic

Group to latest: 

kafka-consumer-groups.sh --bootstrap-server localhost:9092 \
    --group $group --reset-offsets --to-latest \
    --execute --topic $topic

Group to specific offset : 

kafka-consumer-groups.sh --bootstrap-server localhost:9092 \
    --group $group --topic $topic --reset-offsets \
    --to-offset 0 --execute

Group to specific time : 

kafka-consumer-groups.sh --bootstrap-server localhost:9092 \
    --group $group --topic $topic --reset-offsets \
    --to-datetime 2023-11-01T00:00:00.000 --execute

 

---

Troble shooting

• kafka shell 명령어 응답 없음