Kafka 기본 명령어

Topic 관련 명령

실행하기

bin/zookeeper-server-start.sh config/zookeeper.properties
bin/kafka-server-start.sh config/server.properties

종료하기

bin/kafka-server-stop.sh config/server.properties
bin/zookeeper-server-stop.sh config/zookeeper.properties

topic 목록 보기

bin/kafka-topics.sh \
    --bootstrap-server localhost:9092 \
    --list

topic 정보 보기

bin/kafka-topics.sh \
    --bootstrap-server localhost:9092 \
    --topic quickstart-events \
    --describe

Producer 관련 명령

특정 topic 내에 produce 하기

bin/kafka-console-producer.sh \
    –-broker-list localhost:9092 \
    –-topic my_topic

• 위 명령어 입력시, CLI에서 메시지를 스트림으로 입력할 수 있다.

Consumer 관련 명령어

Consumer group 목록보기

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

Consumer group status 확인

bin/kafka-consumer-groups.sh \
    --bootstrap-server localhost:9092 \
    --group my_group_name \
    --describe

Consumer group 제거하기

bin/kafka-consumer-groups.sh \
    --bootstrap-server localhost:9092 \
    --group my_group_name \
    --delete 

topic Consume 해보기

bin/kafka-console-consumer.sh \
    --bootstrap-server localhost:9092 \
    --from-beginning \
    --topic my_topic

특정 파티션만 Consume 하기

--partition 1 추가
bin/kafka-console-consumer.sh \
    --bootstrap-server localhost:9092 \
    --from-beginning \
    --partition 1 \
    --topic my_topic

특정 consumer group 으로 consume 하기

--group group_name 을 추가

bin/kafka-console-consumer.sh \
    --bootstrap-server localhost:9092 \
    --from-beginning \
    --group group_name \
    --topic my_topic