[E-commerce App] Kafka 커맨드 정리 📍

1. 서버 기동

Zookeeper Server

# 현재 위치: /Users/minju/study/msa/kafka-demo/kafka_2.13-2.7.0
$ ./bin/zookeeper-server-start.sh ./config/zookeeper.properties

Kafka Server

# 현재 위치: /Users/minju/study/msa/kafka-demo/kafka_2.13-2.7.0
$ ./bin/kafka-server-start.sh ./config/server.properties

Kafka Connect

# 현재 위치: /Users/minju/study/msa/kafka-demo/confluent-6.1.0
$ ./bin/connect-distributed ./etc/kafka/connect-distributed.properties

2. Topic 관련

Topic 생성

# 현재 위치: /Users/minju/study/msa/kafka-demo/kafka_2.13-2.7.0
$ ./bin/kafka-topics.sh --bootstrap-server localhost:9092 --create -topic quickstart-events --partitions 1

Topic 목록 확인

# 현재 위치: /Users/minju/study/msa/kafka-demo/kafka_2.13-2.7.0
$ ./bin/kafka-topics.sh --bootstrap-server localhost:9092 --list

Topic 정보 확인

# 현재 위치: /Users/minju/study/msa/kafka-demo/kafka_2.13-2.7.0
$ ./bin/kafka-topics.sh --bootstrap-server localhost:9092 --describe --topic quickstart-events

3. 메시지 생산 및 소비

Producer (Kafka console producer)

# 현재 위치: /Users/minju/study/msa/kafka-demo/kafka_2.13-2.7.0
$ ./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic quickstart-events

Consumer (Kafka console consumer)

# 현재 위치: /Users/minju/study/msa/kafka-demo/kafka_2.13-2.7.0
$ ./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic quickstart-events --from-beginning

---

💛 개인 공부 기록용 블로그입니다. 👻

맨 위로 이동하기