[Kafka] produer와 consumer

전부 [root@localhost bin] 위치에서 실행, kafka/bin

 

./kafka-topics.sh --bootstrap-server localhost:9092 --create --topic test

=> test라는 이름을 가진 topic을 생성 

 

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

=> test가 제대로 생성되었는지 확인

 

./kafka-topics.sh --bootstrap-server localhost:9092 --describe --topic test

=> test의 정보 확인(토픽 아이디, 파티션갯수 등등)

 

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

=>consumer생성 

 

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

=>producer 생성

 

cd /tmp/kafka-logs

ll

=> 로그파일 볼 수 있음

ls

cd test-0

ls

=> 뭐라고 적혔는지 자세히 볼 수 있음