# 전체 토픽 조회하기 $ bin/kafka-topics.sh \ --bootstrap-server localhost:9092 \ --list
email.send 토픽이 조회되는 걸 확인할 수 있다. email.send 토픽을 삭제하자. # 토픽 삭제 $ bin/kafka-topics.sh \ --bootstrap-server localhost:9092 \ --delete --topic email.send # 잘 삭제됐는 지 확인하기 $ bin/kafka-topics.sh \ --bootstrap-server localhost:9092 \ --list
# 전체 컨슈머 그룹 조회하기 $ bin/kafka-consumer-groups.sh \ --bootstrap-server localhost:9092 \ --list
email-send-group이라는 컨슈머 그룹을 삭제하자. # 컨슈머 그룹 삭제 $ bin/kafka-consumer-groups.sh \ --bootstrap-server localhost:9092 \ --delete \ --group email-send-group # 잘 삭제됐는 지 확인하기 $ bin/kafka-consumer-groups.sh \ --bootstrap-server localhost:9092 \ --list
email.send 토픽에 메시지를 넣어서 테스트를 해봐야하기 때문에 email.send 토픽을 다시 생성해주자. # 토픽 생성 $ bin/kafka-topics.sh \ --bootstrap-server localhost:9092 \ --create --topic email.send # 토픽 잘 생성됐는 지 확인하기 $ bin/kafka-topics.sh \ --bootstrap-server localhost:9092 \ --list
email.send 토픽에 메시지가 잘 들어갔는 지 확인하기$ bin/kafka-console-consumer.sh \ --bootstrap-server localhost:9092 \ --topic email.send \ --from-beginning
email.send 토픽에 메시지가 잘 들어갔다는 걸 알 수 있다.
email.send 토픽으로 전달했다. 그러고 Kakfa에 메시지가 잘 전달되었는 지 CLI로 확인해봤더니 메시지가 잘 전달된 걸 확인할 수 있었다.