Details
-
Bug
-
Resolution: Done
-
Major
-
None
-
None
-
False
-
False
-
Undefined
Description
Hello!
I'm using the 1.5 Oracle connector using the following configuration to get one table from an Oracle 12g to Kafka using the LogMiner
{
"name": "oracle-miner-0005", "config": { "connector.class": "io.debezium.connector.oracle.OracleConnector", "tasks.max": "1", "database.server.name": "kafka-poc-miner-0005", "database.hostname": "myhost", "database.port": "1521", "database.user": "myuser", "database.password": "mypass", "database.dbname": "KAFKAPOC", "database.schema": "DEBEZIUM", "database.history.kafka.bootstrap.servers": "http://kafka-confluent-cp-kafka.kafka.svc.cluster.local:9092", "database.history.kafka.topic": "schema-logminer-0005", "key.converter": "io.confluent.connect.avro.AvroConverter", "key.converter.schema.registry.url": "http://kafka-confluent-cp-schema-registry.kafka.svc.cluster.local:8081", "value.converter": "io.confluent.connect.avro.AvroConverter", "value.converter.schema.registry.url": "http://kafka-confluent-cp-schema-registry.kafka.svc.cluster.local:8081", "errors.log.enable": "true", "database.connection.adapter": "logminer", "log.mining.archive.log.hours": 24,
"transforms": "unwrap", "transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState", "transforms.unwrap.drop.tombstones": "false", "transforms.unwrap.delete.handling.mode": "rewrite",
"schema.include.list": "DEBEZIUM", "table.include.list": "DEBEZIUM.CUSTOMERS", "column.include.list": "DEBEZIUM.CUSTOMERS.ID,DEBEZIUM.CUSTOMERS.FIRST_NAME,DEBEZIUM.CUSTOMERS.LAST_NAME,DEBEZIUM.CUSTOMERS.GENDER,DEBEZIUM.CUSTOMERS.CLUB_STATUS"
} }
There are more than one table on the DEBEZIUM schema, and the table.include.list property is working! Because I want only the CUSTOMERS table.
But the problem is that the column.include.list is not working because it returns to the topic all of the columns, not the one i'm specifying at "column.include.list"
Can you guys help me to know what i'm doing wrong?
Regards!
