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

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