debezium 으로 데이터베이스 동기화하는데, 스키마를 읽지 못하는 오류가 생겼습니다..!!

Question

선배님들 ! 무료한 금요일 오후에 질문하나 드립니다 !!debezium 으로 데이터베이스 동기화를 하고 있는데, 처음에 source, sink connector 를 생성하면 복제 데이터베이스에 잘 들어갑니다.그런데 수정을 하면 io.debezium.DebeziumException: Encountered change event for table db.tb whose schema isn't known to this connector 이 오류가 나는데 해결이 안됩니다..!토픽에 수정 데이터는 없는데 스키마를 못찾으니까 없는 문제는 당연한 것 같고 schema.history.internal.file.filename 여기에서 ddl 문은 확인했는데 해당 테이블이 존재하여 문제 없어 보이며, mysql 권한 문제인지 SHOW GRANTS 를 보아도 해당 db user 로 접속하여 SHOW BINLOG EVENTS IN 을 보아도 정상적인 것 같고, [mysqld] server-id &#61; 1 log_bin &#61; /path/mysql-bin binlog_format&#61;ROW 설정을 확인했습니다. 리더 설정이 문제인가 싶어 브로커 3개로도 설정해봤습니다..나름 이것 저것 해봤는데 뭐가 문제인지 어떤걸 더 확인해봐야하는지 감이 안잡힙니다.. 시간 괜찮으시다면 한번 도와주십쇼 !!아래는 source 설정 입니다 !{ &#34;name&#34;: &#34;mysql-debezium-connector_oauth_login&#34;, &#34;config&#34;: { &#34;connector.class&#34;: &#34;io.debezium.connector.mysql.MySqlConnector&#34;, &#34;database.hostname&#34;: &#34;localhost&#34;, &#34;database.port&#34;: &#34;3306&#34;, &#34;database.user&#34;: &#34;user&#34;, &#34;database.password&#34;: &#34;pw&#34;, &#34;database.server.id&#34;: &#34;184054&#34;, &#34;database.server.name&#34;: &#34;server_name&#34;, &#34;database.include.list&#34;: &#34;db&#34;, &#34;table.include.list&#34;: &#34;db.tb&#34;, &#34;database.history.kafka.bootstrap.servers&#34;: &#34;localhost:9092&#34;, &#34;database.history.kafka.topic&#34;: &#34;history&#34;, &#34;schema.history.internal&#34;: &#34;io.debezium.storage.file.history.FileSchemaHistory&#34;, &#34;schema.history.internal.file.filename&#34;: &#34;/path/schemahistory.dat&#34;, &#34;topic.prefix&#34;: &#34;test&#34;, &#34;include.schema.changes&#34;: &#34;true&#34;, &#34;primary.key.mode&#34;: &#34;record_key&#34;, &#34;primary.key.fields&#34;: &#34;member_id&#34;, &#34;auto.leader.rebalance.enable&#34;: &#34;true&#34;, &#34;transforms&#34;: &#34;unwrap&#34;, &#34;transforms.unwrap.type&#34;: &#34;io.debezium.transforms.ExtractNewRecordState&#34;, &#34;topic.creation.default.replication.factor&#34;: 1, &#34;topic.creation.default.partitions&#34;: 1, &#34;snapshot.mode&#34;: &#34;initial&#34;, &#34;key.converter&#34;: &#34;io.confluent.connect.avro.AvroConverter&#34;, &#34;key.converter.schema.registry.url&#34;: &#34;http://localhost:8081&#34;, &#34;value.converter&#34;: &#34;io.confluent.connect.avro.AvroConverter&#34;, &#34;value.converter.schema.registry.url&#34;: &#34;http://localhost:8081&#34;, &#34;key.converter.schemas.enable&#34;: &#34;true&#34;, &#34;value.converter.schemas.enable&#34;: &#34;true&#34; } }

debezium 으로 데이터베이스 동기화하는데, 스키마를 읽지 못하는 오류가 생겼습니다..!!

0개의 답변

#kafka 목록