질문&답변
안녕하세요. 강사님 관련하여 위 에러는 producer에서 위 형식이 아닌 다른 형식으로 메시지를 보내게 되면 db insert를 하지 못하는 에러가 발생하고, 그 후에 정상적인 메시지형태(db insert할 수 있는)로 보내더라도 기존에 잘못 보냈던 메시지가 처리되지 않아 발생하는 에러 인 것으로 보입니다. sink, source를 지우고 producer에서 정상적인 형태로만 메시지를 보내보니 디비에 정상 저장되는 것을 확인하였는데, 그렇다면 위 처럼 잘못된 메시지가 온 경우 이를 무시하거나 삭제하고 다음 메시지를 이어서 처리하는 방법이 있을까요?
질문&답변
안녕하세요. 강사님 파일 첨부가 안돼서 아래에 텍스트로 첨부하였습니다. 불편하시겠지만 확인 부탁드리겠습니다. 감사합니다. org.apache.kafka.connect.errors.ConnectException: Tolerance exceeded in error handler\r\n\tat org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:178)\r\n\tat org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execute(RetryWithToleranceOperator.java:104)\r\n\tat org.apache.kafka.connect.runtime.WorkerSinkTask.convertAndTransformRecord(WorkerSinkTask.java:495)\r\n\tat org.apache.kafka.connect.runtime.WorkerSinkTask.convertMessages(WorkerSinkTask.java:472)\r\n\tat org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:328)\r\n\tat org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:232)\r\n\tat org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:204)\r\n\tat org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:185)\r\n\tat org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:235)\r\n\tat java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)\r\n\tat java.util.concurrent.FutureTask.run(FutureTask.java:266)\r\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\r\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\r\n\tat java.lang.Thread.run(Thread.java:748)\r\nCaused 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.\r\n\tat org.apache.kafka.connect.json.JsonConverter.toConnectData(JsonConverter.java:370)\r\n\tat org.apache.kafka.connect.storage.Converter.toConnectData(Converter.java:87)\r\n\tat org.apache.kafka.connect.runtime.WorkerSinkTask.lambda$convertAndTransformRecord$1(WorkerSinkTask.java:495)\r\n\tat org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndRetry(RetryWithToleranceOperator.java:128)\r\n\tat org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:162)\r\n\t... 13 more\r\n
질문&답변
안녕하세요. 강사님. case LOAD_MAXEPISODE_REQUEST : draft. loadMaxEpisodeLoading = true; draft. loadMaxEpisodeDone = false; draft. loadMaxEpisodeError = null; break; case LOAD_MAXEPISODE_SUCCESS : draft. loadMaxEpisodeLoading = false; draft. loadMaxEpisodeDone = true; // alert(action.data); draft. maxEpisode = parseInt (action. data ) ; break; case LOAD_MAXEPISODE_FAILURE : draft. loadMaxEpisodeLoading = false; draft. loadMaxEpisodeError = action. error ; break; function * watchLoadMaxEpisode () { yield takeEvery ( LOAD_MAXEPISODE_REQUEST , loadMaxEpisode ) ; } 리듀서 및 사가 부분입니다. 크롬 시크릿 모드에서 실행하니 정상으로 동작합니다. 정확한 원인은 모르겠으나, 캐시 문제 떄문에 그런것이 아닌가 싶은데.... 제가 조금 더 확인해보고 안 되면 다시 질문드리겠습니다. 감사합니다!
질문&답변
엇...감사합니다.ㅠㅠ
질문&답변
applayout.js입니다.
