mysql_jdbc_oc_sink_customers_02.json... - 인프런

카프카 완벽 가이드 - 커넥트(Connect) 편

대량 데이터로 Debezium Source와 JDBC Sink Connector 연동 실습 - 03

mysql_jdbc_oc_sink_customers_02.json 에서 오류납니다.

작성

오랜만에 강의를 전체를 다시 듣고 있습니다만,

아래와 같은 에러에서 벗어나지 못하고 있습니다.

도와 주세요.ㅠㅠ

[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:

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)

kafka 데이터-엔지니어링

답변 3

권 철민

지식공유자

안녕하십니까,

강의 실습과 다른 kafka 나 connect 버전을 사용하고 계시나요?

강의 자료대로 oc_sink.order_items_sink로 되어 있어야 합니다. 다시 강의를 들으시면서 뭔가 기존 실습 환경과 다르게 세팅이 되었거나 기존 실습 환경에서 변경이 된 부분이 제대로 반영되지 않은 것 같습니다.

일단 진행해 보시고, 혹 이후 실습이 잘 안되시면 kafka/connect 초기화 및 db 및 테이블 삭제 초기화 후에 다시 강의 실습 script로 환경 구성후 테스트 부탁드립니다.

감사합니다.

아나킨

질문자

강의 자료에는 ,

"table.name.format": "oc_sink.order_items_sink",

로 되어 있는데,

"table.name.format": "order_items_sink",

이렇게,, 스키마를 지우니깐 잘 되네요.^^

인프런 AI 인턴

안녕하세요, 인프런 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 설정으로 인해 발생할 수 있는 문제를 설명하고 있습니다.

저는 질문자님의 이해를 돕고자 지식공유자님의 기존 답변을 참고하여 유사한 답변 링크를 추천해드리고 있습니다.
현재 베타 기능으로 답변이 만족스럽지 않을 수 있는 점 양해 부탁드립니다. 🙏
추가적으로 궁금한 점이 있으시면, 이어서 질문해 주세요. 곧 지식공유자께서 답변해 주실 것입니다.

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

mysql_jdbc_oc_sink_customers_02.json 에서 오류납니다.