kafka spout 에러 질문드립니다

Question

kafka spout 에러가 발생합니다 주키퍼 노드가 없다는 내용인것 같은데, 해결방법을 모르겠습니다 ㅠㅠ

Big.D · Answer

안녕하세요! 빅디입니다.

카프카에 쌓여 있는 데이터를 스톰의 스파우트가 읽어들일때 발생 하는 문제 입니다.
스파우트는 어디까지 데이터를 읽어 들였는지, 그 기록(Offsets)을 주키퍼의 znode에 기록 하는데요,
그 위치가 /SmartCar-Topic/416bc567-c759-4855-8f48-308f3dc54db4 입니다.

불안전한 파일럿 환경의 특성으로 Offset 정보가 꼬이는 경우가 있습니다. 이때는..
카프카에 쌓여 있는 데이터를 삭제하거나, Znode의 오프셋 정보를 삭제 하는 방법이 있는데요,

우선 Znode의 오프셋 정보를 아래 절차에 따라 삭제해 해결 할 수 있습니다.

1. Server02에 Putty로 접속 및 주키퍼 클라이언트 실행:
$ zookeeper-client

2. Znode 삭제하는 아래 명령 연속 실행:
[zk: localhost:2181(CONNECTED 1] : delete /SmartCar-Topic/416bc567-c759-4855-8f48-308f3dc54db4/partition_0

[zk: localhost:2181(CONNECTED 1] : delete /SmartCar-Topic/416bc567-c759-4855-8f48-308f3dc54db4

위 명령후 카프카, 스톰 서버를 리스타트 합니다.

- 빅디 올림

인프런 커뮤니티 질문&답변

kafka spout 에러 질문드립니다