[Apache Kafka] topic 삭제 후 재생성시 producer 동작 안하는 현상

이전포스팅처럼 topic을 삭제 후 동일한 이름으로 topic을 다시 생성 시 producer가 동작을 안하는 현상이 있습니다.

topic 정보를 확인해보면 topic의 고유 TopicId값을 확인할 수 있습니다.

.\kafka-topics.bat --describe --bootstrap-server=localhost:9092

topic 정보 확인

 

해당 TopicId값은 D:\tmp\kafka-logs\토픽명\partition.metadata 파일을 열어보면 topic_id값이 있는데 해당값이랑 일치해야 producer가 동작을 합니다.

partition.metadata 파일

partition.metadata 파일의 topic_id값을 topic 정보에서 확인한 값과 일치시킨후 zookeeper, kafka를 다시 시작하면 producer가 정상적으로 동작하는것을 확인할 수 있습니다.

 

topicid값이 달라지는 이유는 추가로 확인이 필요할 것 같습니다.

추가로 확인한 사항으로 topic 삭제 후 kafka-logs 테이블의 토픽명 폴더(D:\tmp\kafka-logs\토픽명)를 지우고 topic을 생성하면 토픽명 폴더가 새로 생기면서 topicid가 같아집니다.