[Kafka] Kafka CLI

kafka-topics.sh

// 토픽 목록 조회
kafka-topics.sh --bootstrap-server <broker-address> --list

// 토픽 생성 (생성 시 파티션 사이즈 및 레플리카 개수 지정)
kafka-topics.sh --bootstrap-server <broker-address> --create --topic <topic-name> --partitions <size> --replication-factor <size>

// 토픽 정보 조회
kafka-topics.sh --bootstrap-server <broker-address> --describe --topic <topic-name>

// 토픽 삭제
kafka-topics.sh --bootstrap-server <broker-address> --delete --topic <topic-name>

 

kafka-console-producer.sh

// 메시지 발행
kafka-console-producer.sh --bootstrap-server <broker-address> --topic <topic-name>

 

kafka-console-consumer.sh

// 메시지 소비 (--from-beginning는 메시지를 처음부터 읽음, 없으면 최신 메시지 부터 읽음)
kafka-console-consumer.sh --bootstrap-server <broker-address> --topic <topic-name> --from-beginning

 

kafka-consumer-groups.sh

// 컨슈머 그룹 목록 조회
kafka-consumer-groups.sh --bootstrap-server <broker-address> --list

// 특정 그룹 상태 확인
kafka-consumer-groups.sh --bootstrap-server <broker-address> --describe --group <group-name>

// 컨슈머 그룹이 구독하는 모든 토픽에 대해 오프셋 리셋(처음부터 다시 읽기)
kafka-consumer-groups.sh --bootstrap-server <broker-address> --gruop <group-name> --reset-offsets --to-earliest --all-topics --execute