카프카 토픽 생성, 프로듀서, 메세지, 삭제 명령어

브로커 서버는 “server-01, server-02, server-03” 으로 지정

토픽 이름은 “test” 로 지정

 

콘솔에서 진행

 

#토픽 만들기
bin/kafka-topics.sh
\ --bootstrap-server server-01:9092, server-02:9092, server-03:9092 
\ --replication-factor 2 --partitions 3
\ --topic test --create

#프로듀서로 토픽에 메세지보내기
bin/kafka-console-producer.sh
\ --bootstrap-server server-01:9092, server-02:9092, server-03:9092
\ --topic test

#컨슈머로 보낸메세지를 확인하기
bin/kafka-console-consumer.sh
\ --bootstrap-server server-01:9092, server-02:9092, server-03:9092 
\ --topic test

#만들어진 토픽을 제거하기 
bin/kafka-topics.sh
\ --bootstrap-server server-01:9092, server-02:9092, server-03:9092
\ --topic test --delete