mysql_jdbc_oc_sink_customers_02.json 에서 오류납니다.

Question

오랜만에 강의를 전체를 다시 듣고 있습니다만, 아래와 같은 에러에서 벗어나지 못하고 있습니다. 도와 주세요.ㅠㅠ   [2025-07-31 18:21:32,067] ERROR [mysql_jdbc_oc_sink_customers_02|task-0] Failing task after exhausting retries; encountered 2 exceptions on last write attempt. For complete details on each exception, please enable DEBUG logging. (io.confluent.connect.jdbc.sink.JdbcSinkTask:124) [2025-07-31 18:21:32,067] ERROR [mysql_jdbc_oc_sink_customers_02|task-0] WorkerSinkTask{id=mysql_jdbc_oc_sink_customers_02-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted. Error: java.sql.SQLException: Exception chain: java.sql.BatchUpdateException: You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near ' customers_sinkcustomer_idemail_addressfull_name ) values(1,'testuser_' at line 1 java.sql.SQLSyntaxErrorException: You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near ' customers_sinkcustomer_idemail_addressfull_name ) values(1,'testuser_' at line 1 (org.apache.kafka.connect.runtime.WorkerSinkTask:616) org.apache.kafka.connect.errors.ConnectException: java.sql.SQLException: Exception chain: java.sql.BatchUpdateException: You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near ' customers_sinkcustomer_idemail_addressfull_name ) values(1,'testuser_' at line 1 java.sql.SQLSyntaxErrorException: You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near ' customers_sinkcustomer_idemail_addressfull_name ) values(1,'testuser_' at line 1 at io.confluent.connect.jdbc.sink.JdbcSinkTask.put(JdbcSinkTask.java:133) at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:584) at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:334) at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:235) at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:204) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:200) at org.apache.kafka.connect.runtime.WorkerTask.run (WorkerTask.java:255) at java.base/java.util.concurrent.Executors$ RunnableAdapter.call (Executors.java:515) at java.base/ java.util.concurrent.FutureTask.run (FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$ Worker.run (ThreadPoolExecutor.java:628) at java.base/ java.lang.Thread.run (Thread.java:829)

anakin · Answer

강의 자료에는 , "table.name.format": "oc_sink.order_items_sink", 로 되어 있는데, "table.name.format": "order_items_sink", 이렇게,, 스키마를 지우니깐 잘 되네요.^^

dooleyz3525 · Answer

안녕하십니까, 강의 실습과 다른 kafka 나 connect 버전을 사용하고 계시나요? 강의 자료대로 oc_sink.order_items_sink로 되어 있어야 합니다. 다시 강의를 들으시면서 뭔가 기존 실습 환경과 다르게 세팅이 되었거나 기존 실습 환경에서 변경이 된 부분이 제대로 반영되지 않은 것 같습니다. 일단 진행해 보시고, 혹 이후 실습이 잘 안되시면 kafka/connect 초기화 및 db 및 테이블 삭제 초기화 후에 다시 강의 실습 script로 환경 구성후 테스트 부탁드립니다. 감사합니다.

communityai8509 · Answer

안녕하세요, 인프런 AI 인턴입니다. 아나킨님이 겪고 계신 문제는 주로 SQL 쿼리 문법 오류로 인해 발생하는 것 같습니다. 오류 메시지를 살펴보면 You have an error in your SQL syntax 라는 메시지가 반복적으로 나타나고 있으며, 이는 주어진 SQL 문이 잘못 구성되었음을 의미합니다. 특히, near ' \ customers_sinkcustomer_idemail_addressfull_name`` 위치에서 오류가 발생한 것으로 보여, 테이블 또는 열 이름이 잘못 지정되었거나, 쿼리 내 일부 구문이 잘못된 것으로 보입니다. 문제를 해결하기 위해 다음 사항을 확인해 보세요: 테이블 및 컬럼 이름 확인 : SQL 쿼리에서 사용된 테이블과 컬럼 이름이 실제 데이터베이스에 존재하는지 확인하세요. 쿼리에 지정된 이름이 정확한지 확인하시기 바랍니다. 쿼리 구문 확인 : SQL 문법에서 INSERT INTO table_name (column1, column2, ...) VALUES (value1, value2, ...) 형식이 정확한지, 특히 작은 따옴표, 쉼표, 괄호 등의 구문이 올바르게 사용되었는지 점검하세요. 콘솔 로그 상세 확인 : 콘솔 로그에서 DEBUG 모드를 활성화하여 보다 상세한 로그를 확인해 보세요. 이렇게 하면 좀 더 구체적인 오류 원인을 파악하는 데 도움이 될 것입니다. JDBC Sink Connector 설정 검토 : 커넥터 설정에서 table.name.format 에 잘못된 형식이 있는지 또는 불필요한 스키마 이름이 포함되어 있는지 확인하세요. 문제가 지속된다면, 유사한 문제의 해결을 다룬 URL을 참고하시기 바랍니다: JDBC Sink Connector에서 발생할 수 있는 SQL 구문 오류 해결 위 질문에서는 JDBC Sink Connector의 설정과 관련하여 발생할 수 있는 유사한 SQL 오류 문제를 다루고 있으며, 잘못된 table.name.format 설정으로 인해 발생할 수 있는 문제를 설명하고 있습니다. 저는 질문자님의 이해를 돕고자 지식공유자님의 기존 답변을 참고하여 유사한 답변 링크를 추천해드리고 있습니다. 현재 베타 기능으로 답변이 만족스럽지 않을 수 있는 점 양해 부탁드립니다. 🙏 추가적으로 궁금한 점이 있으시면, 이어서 질문해 주세요. 곧 지식공유자께서 답변해 주실 것입니다.