🗑 Kafka: topic 삭제하기

❗️ 문제점

topic을 제거했는데 아래 명령어로 조회하면 marked for deletion 메시지만 나오고 완전히 제거되지 않는 문제가 생겼습니다.

해당 글은 topic을 완전히 제거하기 위한 방법에 알아보고자 합니다.

./bin/kafka-topics.sh --list --zookeeper host:port

 

🤩  해결 방법

(1) ./config/server_properties에서 설정

delete.topic.enable = true

 

(2) Kafka 재시작

 

(3) zookeeper-shell 접근

./zookeeper-shell.sh localhost:2181

 

(4) 제거해야 할 toptic 조회

ls /brokers/topics

 

(5) 해당 topic 제거

rmr /brokers/topics/{topic 이름}

 

(6) 정상적으로 topic이 제거되었는지 확인

./bin/kafka-topics.sh --list --zookeeper host:port

 

만약에 삭제했던 topic을 같은 이름으로 만드는 경우 또 다시 marked for deletion 메시지가 나온다면 로그를 지우고 재시작해보길 바랍니다.