본문으로 바로가기

1. 증상

  • Topic에 데이터가 들어가지 않는다는 로그가 발생하는 에러
  • Error while fetching metadata with correlation id

 

2. 원인

  • 생성되지 않은 topic이었고 Topic의 자동 생성을 막아둔 상태라서 다음과 같은 현상 발생

[server.properties]

auto.create.topics.enable=false

 

3. 해결

  • 명령어를 이용해 Kafka Broker에 해당 Topic을 생성해줍니다.
  • auto.create.topics.enable=true는 권장하지 않습니다. Topic 관리할 때 잘못된 호출로 인해 자신도 모르는 Topic이 들어가게 되면 관리도 어려울뿐더러 디스크 용량이 꽉 찰 위험도 있습니다.
# bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic kafka-test