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

안녕하세요 전에도 질문을 올렸었는데 답변 주신 대로 했더니 잘 해결 되었습니다.감사합니다.

전에 올린 질문 중 답변해주신 내용이 oracle connector는 하나의 source connector만 생성하면 된다고 하셨는데요.

하나의 source connector로 구성 후 테이블을 추가하려고 하는데 추가할 경우에는

connector를 다시 생성해야 할까요?

아래의 명령어로 update 후 재기동을 해봤으나 추가한 테이블에 대한 topic이 생성 되지 않습니다.

http PUT http://localhost:8083/connectors/ora_source_connector/config @ora_source_connector_test.json

http POST http://localhost:8083/connectors/ora_source_connector/restart

json 내용

{

"connector.class" : "io.debezium.connector.oracle.OracleConnector",

"db_type":"oracle",

"tasks.max" : "1",

"database.server.name" : "source_connector_01",

"database.user" : "xx",

"database.password" : "xx",

"database.url": "jdbc:oracle:thin:@xx",

"database.dbname" : "xx",

"database.out.server.name":"ora_source_out",

"schema.history.internal.kafka.bootstrap.servers" : "xx:9092",

"schema.history.internal.kafka.topic": "ora_source_history",

"schema.include.list": "xx",

"include.schema.changes": "true",

"database.connection.adapter": "logminer",

"topic.prefix": "ORA_SOURCE",

"schema.include.list": "xx",

"table.include.list":"xx.AF_CLAIM , xx.AF_CS_MGMT , xx.AF_BRAND",

"include.schema.changes": "true",

"auto.evolve": "true",

"time.precision.mode": "connect",

"key.converter": "io.confluent.connect.avro.AvroConverter",

"value.converter": "io.confluent.connect.avro.AvroConverter",

"key.converter.schema.registry.url": "http://localhost:8081",

"value.converter.schema.registry.url": "http://localhost:8081",

"snapshot.mode" : "initial",

"tombstones.on.delete": "true",

"transforms": "rename_topic",

"transforms.rename_topic.type" : "org.apache.kafka.connect.transforms.RegexRouter",

"transforms.rename_topic.regex" : "ORA_SOURCE(.*)",

"transforms.rename_topic.replacement" : "source_$1",

"transforms": "unwrap",

"transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState",

"transforms.unwrap.drop.tombstones": "false"

}