springboot-kafka :: Error deserializing key/value

kafka에 Json 데이터를 producing 했다.

그러나, springboot의 kafka listener에서 그 데이터를 deserialize를 할 때 다음과 같은 에러가 발생했다. 

 

Error deserializing key/value for partition recomData-0 at offset 6. If needed, please seek past the record to continue consumption.

Error deserializing key/value for partition recomData-0 at offset 6. If needed, please seek past the record to continue consumption.

이 문제를 해결하려고 겁나 삽질했다..ㅠㅠ..

 

결론적으로는 application.yml에 spring.kafka.properties.spring.json.value.default.type 를 추가해주면 된다.

즉 deserialize할 타입을 springboot가 몰라서 발생한 문제라고 볼 수 있다.

 

나의 경우는 QueuedMessage class였는데, value값에 full package를 알려줘야 한다.

spring.
 kafka.
  properties.
   spring.
    json.
     value.default.type = kr.co.sys4u.app.dto.QueuedMessage