* 구글링을 하다보면 --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
'데이터 엔지니어링 > Apache' 카테고리의 다른 글
[Kafka] Kafka Connect 날짜 변환 문제 해결 - Avro / Epoch (0) | 2024.03.07 |
---|---|
[Spark] Windows에서 Apache Spark 사용하기 (0) | 2023.02.23 |