데이터 엔지니어링/Apache

[Kafka] Topic이 delete 되지 않을 때 - 기본 다루기

seojeon9 2024. 3. 10. 19:39

* 구글링을 하다보면 --zookeeper가 있고 --bootstrap-server가 있는데,
   kafka의 최신 버전에서는 --zookeeper옵션이 사용되지 않으므로
   --bootstrap-server 옵션을 사용하여 kafka브로커에 직접 연결해야 한다.

1. 토픽 조회

kakfa-topic --bootstrap-server localhost:9092 --list

2. 토픽 삭제

kafka-topics --delete --bootstrap-server localhost:9092 --topic <토픽이름>

 

--delete명령어 이후 다시 조회를 해보면 정상적으로 삭제가 되어야 하지만?
왜 그대로 있는거지...
심지어 아무런 에러메세지도 보여주지 않았다.

많은 구글링을 통해서 server.properties 파일을 변경하라는 글 발견

vi /etc/kafka/server.properties
delete.topic.enable=true

하지만 나는 true 되어 있었다.

다른 조치도 여러개 해보았지만 안되었다.
자.. 이제 생각을 해보자.
뭐가 문제일까?

순간 topic을 바라보고 있는 connector들이 있어서 그렇지 않을까? 생각이 들었고
source/sink connector를 먼저 지우고 다시 --delete해보니?

정상적으로 삭제가 되었다. (처음부터 그렇다고 에러메세지 보내주면 얼마나 좋으니..)

결론은 설정에서 잘못된게 없는거 같은데도 안지워진다면?
해당 토픽을 바라보고 있는 브로커들이 있지는 않은지 확인해보자~

728x90