커넥트 에러 관련

안녕하세요. 강사님관련하여 위 에러는 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);} 리듀서 및 사가 부분입니다. 크롬 시크릿 모드에서 실행하니 정상으로 동작합니다. 정확한 원인은 모르겠으나, 캐시 문제 떄문에 그런것이 아닌가 싶은데.... 제가 조금 더 확인해보고 안 되면 다시 질문드리겠습니다. 감사합니다!

프로필 컴포넌트가 2번 생성됩니다...

엇...감사합니다.ㅠㅠ

프로필 컴포넌트가 2번 생성됩니다...

applayout.js입니다. (사진)