오랜만에 강의를 전체를 다시 듣고 있습니다만, 아래와 같은 에러에서 벗어나지 못하고 있습니다. 도와 주세요.ㅠㅠ [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)
안녕하세요. Airflow 3.0 에서 EmailOperator 사용시 conn_id 를 세팅하지 않으면 smtp_default 를 기본적으로 사용하고 있어보입니다. smtp_default 세팅은 config 파일에 보니 email_conn_id(AIRFLOW__EMAIL__EMAIL__CONN__ID) 에 세팅되어 있어 EmailOperator 와 fail났을때 smtp_default를 세팅해놓으면 동시에 사용 가능한것은 아닐까요?
snapshot mode에 궁금한 점이 있습니다. MySqlConnector 중간에 에러가 발생하면 커넥터 기동이 멈추는데, ( snapshot.mode = initial 일 때) delete했다가 다시 create를 진행하면 중복된 snapshot 데이터를 또 토픽에 적재하는지 궁금합니다. 중복 저장된다면, 모두 삭제한 뒤 (토픽/히스토리토픽/커넥터) 다시 재생성해서 진행을 해야할까요?
안녕하세요, 좋은 강의 감사드리며 단원 정리 문제 (ch1, part2) 중 일부 선지에 대한 이해를 위해 질문드립니다. 6번 'relation'의 참여도에 관한 설명으로 옳지 않은 것을 고르는 문제에서, 1번 선지 '관계는 최소 한 개 이상의 엔터티와 연결된다.'라는 표현이 불명확하게 느껴졌습니다. 관계는 최소 두 개 이상의 엔터티들간의 관계로 이해하였기 때문입니다. 해당 선지는 한 엔터티에서 그것과 다른 엔터티를 가정했을 때의 경우일까요? 혹은, 제가 선지를 다르게 이해했어야 한 부분이 있을까요? 7번 1:m의 관계를 고르는 문제에서, 정답에 의하면 학생-강의, 강사-과목, 주문-주문 상세가 모두 1:m의 관계였습니다. 그러나 학생과 강의를 생각하면 현실 세계에서 한 강의에서도 학생이 여러 명일 수 있고 한 과목을 가르치는 강사가 여러 명일 가능성으로 m:n 관계로 볼 순 없을까요? 기출문제 등지에서 유사한 문제가 자주 출제되던데, 이렇게 현실의 예외를 하나하나 생각하면서 접근하는 것이 맞는 방법일까요? 8번의 Join의 목적과 관련하여, 테이블 간의 관계를 명확히 정의하는 것과 Join이 어떻게 연결되는지 이해가 잘 가지 않습니다. (선지 2번) 12번 '본질 식별자를 사용하는 경우의 장점'으로 선지 1번은 적절한 경우에 해당했습니다만, '데이터의 의미를 쉽게 유추할 수 있다'라는 것이 보안이 중요한 상황에서는 단점으로 생각되었습니다. 식별자의 보안을 고려하기보다는 그 명료성에 초점을 맞춰야 하겠지요? 12번의 2번 선지, '데이터의 일관성을 높일 수 있다.'의 이유를 본질식별자를 사용할 경우 본질식별자 자체의 데이터가 변경될 확률이 낮기 때문으로 이해하면 될까요? 다소 결과적으로 느껴졌습니다. 감사합니다!
안녕하세요. 현재 카프카 도입을 고려하고 있는데, 데브원영님의 강의로 공부를 시작하고 있습니다. 강의가 정말 많은 도움이 됩니다. 감사합니다. 수강 중 MSA 환경에서 카프카 공통 설정을 어떻게 처리하는지 의문이 들어 여쭙는 질문입니다. MSA 환경에서 카프카를 사용한다면, 카프카 관련 설정 내용들을 각 서버에 넣어야 할 텐데요. 카프카 관련 설정들을 공통 모듈로 만들고 주입받는 형태로 진행한다면, 그 범위를 어디까지 해야 할지 궁금합니다. consumer/producer factory나 kafka template를 먼저 넣을 수 있을 것 같고, 다른 (dlq, retry 혹은 공통 사용하는 dto라든지) 설정들을 어디까지 공통화하면 좋을지 고민이 많습니다. 혹시 유사한 구조를 경헌하신 적이 있다면 어떻게 구성하셨는지 궁금합니다.
먼저 유사한 질문이 있었는지 검색해보세요. 서로 예의를 지키며 존중하는 문화를 만들어가요. 잠깐! 인프런 서비스 운영 관련 문의는 1:1 문의하기를 이용해주세요. 안녕하십니까 강사님 ㅠ 2가지 문제가 발생하여 다시 질문드립니다. 다시 전체 삭제 후 docker 설치 -> 디비버 실행 완료 연습 데이터 잘 실행되는 것을 확인 문제1) MS SQL을 설치를 안했습니다. 그래서 문제? 없이 잘 되는거같습니다 MS SQL을 설치를 해야할까요 ? 또 안될까봐 무섭습니다 문제2) 노트북도 도커설치 -> 디비버 실행완료 연습데이터 잘 실행됨. 마찬가지로 MS SQL 설치 안함. 그런데 여기서, 컴퓨터 재부팅하고 도커 실행하니 사진과 같은 에러가 발생했습니다. GPT 검색하니 노트북도 같은 1522 포트 썻다고 그러던데. 노트북 완전 종료하고 실행해도 아래와 같이 에러가 뜹니다. 왜그런걸까요 ㅠㅠ 앗 10분뒤 컴퓨터 껏다키니 다시 실행되요 노트북과의 충돌이 있엇던걸까요 ? 추가 질문으로) docker 앱 닫앗다가 실행시키면 아에 안켜지고 관리자 권한으로 실행해도 안켜지는 경우가 있어서 컴퓨터 껐다키는데 왜그런건지도 아시나용 ㅠ
먼저 유사한 질문이 있었는지 검색해보세요. 서로 예의를 지키며 존중하는 문화를 만들어가요. 잠깐! 인프런 서비스 운영 관련 문의는 1:1 문의하기를 이용해주세요. 안녕하세요 강의에서 다음화면이 보이는데 제가 설치하고 나서 docker 확인 시 이렇게 떠요 그래서 액션 누르고 디비버 누르면 에러가 뜨는데 어떻게 해결하죠 ?? 강사님 화면이랑 제꺼랑 많이 달라요 설치영상부터.. powershell에 하면 다 성공적으로 설치됫다고ㅓ 뜨긴하던데 ㅠㅠ 그냥 무시? 하고 디비버 실행 후 강사님꺼 복사해서 엔터치니 다음과 같이 에러뜹니다 ㅠㅠ docker 화면 창 차근차근 천천히 알려주세요 ㅠ ㅠ 아 강의내용중 도커허브에 이런건 없어서 챗gpt로 powershell을 이용해서 다운??받은거같아요
wsl에서 docker설치하고, airflow를 설치해서, localhost:8080으로 들어갔는데 화면에 아래와 같은 애러가 뜨면서, Dag화면이 안뜨는 상태입니다. 해결방법에 대해 말씀해주시면 감사하겠습니다. 화면 에러내용 에러내용 /home/airflow/.local/lib/python3.12/site-packages/airflow/example_dags/standard/example_external_task_parent_deferrable.py Timestamp: 2025-07-13, 06:22:35 Traceback (most recent call last): File "<frozen importlib._bootstrap>", line 488, in _call_with_frames_removed File "/home/airflow/.local/lib/python3.12/site-packages/airflow/example_dags/standard/example_external_task_parent_deferrable.py", line 60, in <module> from tests_common.test_utils.watcher import watcher ModuleNotFoundError: No module named 'tests_common'
안녕하세요 강의 수강중인데 어떤 버전으로 진행하면되는지 문의드리고자. 현재 '섹션 2. Airflow 설치' 부분에 '5. 도커&에어플로우 설치'를 강의를 듣고 있습니다. 강의 도입부에 airflow 설치시 2.10.5 버전으로 설치 부탁하셨는데, 강의 중반부에 Airflow 3대 버전으로 영상이 업데이트 완료되어 최신 버전 docker-compose.yaml 로 설치하라고 안내해주셔서요. 어떤 버전으로 강의를 진행하면될까요?
안녕하세요. 먼저 좋은 강의 제공해주셔서 감사합니다 정말 잘 듣고 있습니다 🙂 다름이 아니라, 해당 강의(MCP 서버 Cursor에 등록하여 개발 연동)를 보면서 여러 방법을 시도해보고 있긴 하지만, smithery에서 json형식으로 값을 뽑아도 디렉토리 관련 등록 정보는 담겨있지 않는데 선생님께서는 어떤 부분을 수정하셨는지 알려주시면 감사하겠습니다 😀
안녕하세요 Debezium source connector 부분을 공부하다가 궁금한 부분이 생겨서 질문드립니다! DB의 binlog 변경 사항을 감지해서 이벤트 메시지를 발행하는 부분에서, 여러가지 원인에 의해 에러가 발생하여 메시지가 유실되는 경우도 있을 것 같은데요. 커넥트에 에러로그는 남겠지만, 재처리를 위해 SourceDB 또는 별도 로그성 테이블에 메시지발행에 대한 상태를 기록하고 싶을 경우, 커넥터로부터 메시지발행 성공에 대한 응답을 받을 수 있을까요?
