Hello ,
I have kafka connect on prem, my debezium connector is running but It does not create the needed topics on confluent cloud.
I made sure to create all the needed Acls and enabled topic auto-creation is enabled by default on the kafka connect level .
My connector config.json :
{
“name”: “archi-poc-connector”,
“config”: {
“connector.class” : “io.debezium.connector.oracle.OracleConnector”,
“database.url”: “jdbc:oracle:thin:@data.groupe.com:1574/DATA”,
“database.user” : “user”,
“database.password” : “password”,
“database.connection.adapter”: “logminer”,
“database.dbname” : “SALESFORCE”,
“database.server.name” : "DATA ,
“table.include.list”: “RPA.table”,
“column.include.list”: “RPA.table.PAR_NR,RPA.table.LAS_NAM,RPA.table.FRST_NAM”,
“database.hostname”:“data.groupe.com”,
“database.port” : “1521”,
“schema.history.internal.kafka.topic” : “archi_test_poc”,
“topic.prefix” : “data”,
“tasks.max” : “1”,
“schema.history.internal.kafka.bootstrap.servers”: “pkc-095w1.europe-west1.gcp.confluent.cloud:9092”,
“schema.history.internal.consumer.security.protocol”: “SASL_SSL”,
“schema.history.internal.consumer.ssl.endpoint.identification.algorithm”: “https”,
“schema.history.internal.consumer.sasl.mechanism”: “PLAIN”,
“schema.history.internal.consumer.sasl.jaas.config”: “org.apache.kafka.common.security.plain.PlainLoginModule required username="APIKEY" password="secret";”,
“schema.history.internal.producer.security.protocol”: “SASL_SSL”,
“schema.history.internal.producer.ssl.endpoint.identification.algorithm”: “https”,
“schema.history.internal.producer.sasl.mechanism”: “PLAIN”,
“schema.history.internal.producer.sasl.jaas.config”: “org.apache.kafka.common.security.plain.PlainLoginModule required username="APIKEY" password="secret";”,
“database.oracle.version” : “12+”
}
}
I am working with oracle 19 c .
Any suggetions ?
Thank you .