[TIL, 일일 회고] 2024.09.16 - Kafka Unrecognized token 에러원인과 해결방법

 

Error 원인

Kafka를 사용하여 상품 삭제시 해당 이벤트를 구독하고있는 메서드를 테스트하고있었습니다.

Unrecognized token 'a430475a'

 

로그를 확인해보니 위와 같이 "Unrecognized token"에러가 발생했습니다. error의 원인은 말 그대로 요청 중 JSON parse error가 난 것입니다.

 

직렬화/역직렬화 클래스를 작성하여 메시지를 보낼 때 객체를 JSON 문자열로 직렬화하고, JSON 문자열을 객체로 역직렬화하는 과정을 정상적으로 처리하고 있음에도 불구하고, 계속해서 에러가 발생했습니다. 코드를 여러 차례 확인했지만 문제가 없어 보였기에, 구글링을 통해 문제의 원인을 파악했습니다.

 

문제의 원인은 Kafka 토픽에 저장된 데이터가 JSON 형식이 아닌 경우였습니다. 이전에 테스트하는 과정에서, KafkaTemplate가 자동으로 직렬화/역직렬화를 처리하도록 설정한 적이 있었는데, 그때의 데이터가 문제를 일으켰던 것입니다.

 

즉 JSON형식 데이터가 아닌 데이터가 Kafka Topic에 저장되어 있던게 원인이었습니다.

 

해결 방법

 

해결 방법은 간단합니다. JSON형식이 아닌 데이터가 Kafka Topic에 남아있으니깐 해당 토픽을 비워주면 됩니다.

 

토픽을 비워주고 다시 서버를 실행한다면 정상적으로 서버가 실행되었습니다.