본문 바로가기

KAFKA

(3)
[Solved][Connector]오류 발생 후 커넥터 실행 시 같은 오류가 발생하는 경우 상황 1. 커넥터에서 오류 발생 시, 종료 후 재시작2. 이전과 동일한 증상이 발생 원인 카프카 토픽은 이전에 전달된 메시지가 그대로 남아있어서 커넥터 실행 시 자동으로 이전 메시지 읽어옴 -> 다시 같은 오류가 발생한다 해결 방법 토픽을 지우고 처음부터 다시 시작한다 ^^
[Solved][Connector]org.apache.kafka.connect.errors.DataException: JsonConverter with schemas.enable requires "schema" and "payload" fields and may not contain additional fields. If you are trying to deserialize plain JSON data, set schemas.enable=false .. 문제 Caused by: org.apache.kafka.connect.errors.DataException: JsonConverter with schemas.enable requires "schema" and "payload" fields and may not contain additional fields. If you are trying to deserialize plain JSON data, set schemas.enable=false in your converter configuration.at org.apache.kafka.connect.json.JsonConverter.toConnectData(JsonConverter.java:370)at org.apache.kafka.connect.storag..
[Solved][Connector] ERROR WorkerSinkTask{id=gps-sink-0} Task threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:187) org.apache.kafka.connect.errors.ConnectException: Tolerance exceeded in error handler ERROR WorkerSinkTask{id=gps-sink-0} Task threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:187)org.apache.kafka.connect.errors.ConnectException: Tolerance exceeded in error handlerat org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:196)at org.apache.kafka.connect.runtime.errors.RetryWith..