kafka topic 삭제시 유의사항

apache kafka 를 사용하면서 topic 을 삭제해야 할 경우가 있다.

topic 삭제는 0.8.x 부터 지원이 되는 기능인데, topic 삭제를 정상적으로 진행 하기 위해서는 

$KAFKA_HOME/config/server.properties 파일에 아래와 같은 내용을 추가 해야 한다.

delete.topic.enable = true

이 설정을 추가하지 않은 상태에서 topic 을 삭제하게 되면, 해당 topic 은 삭제 상태로 남게 되고, 해당 topic 으로 들어온 어떠한 메시지도 처리가 되지 않는 현상이 발생한다.

./kafka-topics.sh --list --zookeeper "localhost:2181"

topic1

topic2 - marked for deletion

해당 설정 값을 바꾼 후에는 반드시 kafka 를 재시작 해야 한다.

./kafka-topics.sh --list --zookeeper "localhost:2181"

topic1