1. zookeeper 서버 실행

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

• kafka가 설치된 디렉터리에서 위 명령어 실행

2. kafka 서버 실행 (최소 3대 실행 권장)

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

3. kafka consumer 실행

./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test

• 마지막 인자에 '--from-beginning' 입력 시, 여기서부터 메시지를 가져온다는 것을 의미

4. ./python/pub_example.py 실행

python3 ./python/pub_example.py

해야할 일

Python을 사용하여 kafka subscribe 또는 publish 함수 생성 및 정리