[Kafka] Kafka를 편하게 Kafkactl 명령어

Github

https://github.com/deviceinsight/kafkactl

GitHub - deviceinsight/kafkactl: Command Line Tool for managing Apache Kafka

설치

homebrew:

# install tap repostory once
brew tap deviceinsight/packages

# install kafkactl
brew install deviceinsight/packages/kafkactl

# upgrade kafkactl
brew upgrade deviceinsight/packages/kafkactl

 

자주 사용하는 명령어

클러스터 조회

kafkactl config get-contexts

 

클러스터 접속

kafkactl config use-context [context명]

 

토픽(topic) 조회

kafkactl get topics
or
kafkactl list topics

>> kafkactl get topics | grep "찾을 단어"

 

토픽 생성

kafkactl create topic [topic명] --replication-factor 2 --partitions 1

 

토픽 설정 변경

kafkactl alter topic [topic명] --replication-factor 3 --verbose

 

토픽 삭제

kafkactl delete topic [topic명]

 

컨슈머 그룹 조회

kafkactl get consumer-groups

 

컨슈머 그룹 생성

kafkactl create consumer-group [GROUP]

 

컨슈머 리셋 옵션

--newest : 가장 최신의 오프셋으로 이동
--offset int : 지정한 오프셋으로 이동
--oldest : 가장 초기의 오프셋으로 이동

 

컨슈머 offset 변경 예측 결과(--execute 옵션 안주면 예측 결과만 보여줌)

kafkactl reset consumer-group-offset GROUP --[reset 옵션]

 

컨슈머 offset 변경(실행)

kafkactl reset consumer-group-offset GROUP --[reset 옵션] --execute