Caju

데이터 엔지니어 신영인입니다. 개발하면서 배운 점이나 해결한 문제를 공유하고 있습니다.


Spark에 연결된 Kafka의 토픽을 바꾸자 아래와 같은 오류가 발생했다.

Checkpoint에 저장된 토픽과 현재 토픽이 달라서 발생하는 문제이므로 Checkpoint 폴더를 삭제 후 재 생성하거나 위치를 변경하면 해결된다.

참고