본문 바로가기
개발~

자주 사용하는 카프카 명령어

by 보배곰 2021. 11. 4.

broker1.url.com:9092,broker2.url.com:9092 : 사용자가 생성한 broker url 입니다. 여기서는 2개 입니다.

my-custom-topic : 사용자가 생성한 topic 명 입니다.

my-custom-group-id : 사용자가 생성한 group id 명 입니다.


토픽 목록 조회

> ./kafka-topics.sh --bootstrap-server broker1.url.com:9092,broker2.url.com:9092 --list

토픽 생성

> ./kafka-topics.sh --create --bootstrap-server broker1.url.com:9092,broker2.url.com:9092 --replication-factor 2 --partitions 2 --topic my-custom-topic

메세지 전송

> ./kafka-console-producer.sh --broker-list broker1.url.com:9092,broker2.url.com:9092 --topic my-custom-topic
> 
> {"test":1}

명령어 입력하고 잠시 기다리면 데이터 입력할 수 있게 뜨고, 여기서 입력한 데이터는 {"test":1} 입니다.

record 조회 (데이터 조회)

> ./kafka-console-consumer.sh --bootstrap-server broker1.url.com:9092,broker2.url.com:9092 --topic my-custom-topic --from-beginning

이미 들어있는 record와 실시간 데이터가 생기는 걸 확인할 수 있습니다.

offset 조회

> ./kafka-consumer-groups.sh --bootstrap-server broker1.url.com:9092,broker2.url.com:9092 --group my-custom-group-id --describe

'개발~' 카테고리의 다른 글

Go tour  (0) 2021.08.09
IntelliJ에서 자주 쓰는 Git 명령어(feat. JIRA)  (0) 2021.05.24
vi 편집기 입력 에러  (1) 2020.05.18
Linux alias 설정하기  (0) 2020.03.20
참고 사이트  (0) 2017.03.06

댓글