DevelopKafka

카프카 사용하기

카프카 명령어

주키퍼 실행

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

카프카 실행

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

카프카 토픽관리

토픽을 새로 생성하고 싶으면 kafka-topics 명령어에 --create 옵셩을 통해 새로운 토픽을 생성할 수 있습니다.

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

카프카에 저장된 모든 토픽 정보를 보고 싶을 경우 --list 옵셩을 통해 확인할 수 있습니다.

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

토픽에 대한 상세 정보를 보고 싶을 경우 --describe 옵션을 통해 정보를 확인할 수 있습니다.

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

카프카 메시지 생성

카프카 토픽에 새로운 메시지를 보내고 싶을 경우 kafka-console-producer 명령어를 사용하면 됩니다.

  • --broker-list
    • 메시지를 보내기 위한 카프카 브로커 주소
  • --topic
    • 메시지가 저장될 토픽
./bin/kafka-console-producer.sh \
    --broker-list localhost:9092 \
    --topic quickstart-events

카프카 메시지 소비

카프카 토픽에 메시지를 사용하고 싶을 경우 kafka-console-consumer 명령어를 사용하면 됩니다.

  • --bootstrap-server
    • 메시지를 구독하기 위한 카프카 주소
  • --topic
    • 구독할 토픽 정보
./bin/kafka-console-consumer.sh \
    --bootstrap-server localhost:9092 \
    --topic quickstart-events \
    --from-beginning
Share