learningLab

답변 주셔서 감사합니다. aws aurora mysql 로 작업하고 있으며, 이 문제가 aws msk connector 에서만 발생하는 것인지는 정확하지 않습니다. 다만 처음에는 잘되었다가 hisotry 테이블 교체로 발생한 이슈입니다. 위 사항으로 진행해도 같은 오류가 발생하더라고요.. 다만, 새로운 schema.history.internal.kafka.topic 으로 지정된 topic에 로컬 환경에서 똑같이 생성한 history topic의 정보를 넣어두고 실행해도 오류가 발생하는 것을 보입니다. 그렇다면 debezium connector는 binlog에 있는 정보만을 토대로 snapshot을 찍는거 같아 보이는데 맞을까요? 그렇다면 binlog의 ddl이 남아 있지 않으면 무조건 schema에 대한 에러가 발생하는걸까요? 추가로 다른 해결방법은 없는걸까요??

learningLab

Posts