# Debezium Oracle kafka connector

**URL:** <https://forum.confluent.io/t/debezium-oracle-kafka-connector/11105>\
**Category:** Kafka Connect\
**Created:** [20 July 2024 19:25 UTC](https://forum.confluent.io/t/debezium-oracle-kafka-connector/11105 "2024-07-20T19:25:41Z")\
**Posts on this page:** 5\
**Page:** 1

<div class="post-metadata">

**Author:** ![Anil](https://avatars.discourse-cdn.com/v4/letter/a/da6949/32.png) [@Anil](https://forum.confluent.io/u/Anil)\
**Post date:** [20 July 2024 19:25 UTC](https://forum.confluent.io/t/debezium-oracle-kafka-connector/11105/1 "2024-07-20T19:25:41Z")

</div>

Hi,

I am new to Kafka Debezium connector. Please help to guide me on below.

Please, help to check below, my Debezium connector, I am using in property file and executing through command line.

name=oracle-connector  
connector.class=io.debezium.connector.oracle.OracleConnector  
tasks.max=1  
database.hostname=localhost  
database.port=1521  
database.user=C##SANGULA  
database.password=admin  
[database.dbname=sangula.INFOVISIONLABS.COM](http://database.dbname=sangula.INFOVISIONLABS.COM)  
#show parameter db  
#db\_name XE add database.dbname=XE  
database.pdb.name=SANGPDB  
#database.out.server.name=kafka  
#database.server.name=kafka  
table.include.list=C##SANGULA.T  
database.pdb.name= SANGPDB  
snapshot.mode=always  
include.schema.changes= true  
database.connection.adapter= LogMiner  
database.history.kafka.topic=history  
topic.prefix=checkdata-  
database.schema=C##SANGULA  
database.server.name=test  
database.history.kafka.bootstrap.servers=kafka:9092  
schema.history.internal.kafka.bootstrap.servers=localhost:9092  
schema.history.internal.kafka.topic=schema-changes.inventory  
internal.key.converter=org.apache.kafka.connect.storage.StringConverter  
internal.value.converter=org.springframework.kafka.support.serializer.JsonSerializer  
internal.key.converter.schemas.enable=false  
internal.value.converter.schemas.enable=false

1). in my logs, I can see, these tables, but I didnt created any table. how these tables are creating automatically.

[SANGPDB.HR.COUNTRIES, SANGPDB.HR.DEPARTMENTS, SANGPDB.HR.EMPLOYEES, SANGPDB.HR.JOBS, SANGPDB.HR.JOB\_HISTORY, SANGPDB.HR.LOCATIONS, SANGPDB.HR.REGIONS] (io.debezium.connector.oracle.OracleSnapshotChangeEventSource:151)

2). I have created a table, name as T, and inserting data, but these data not populating immediately.  
taking time and I cant see, these data or table created and coming in my topic.

3). Please help to create a producer of debezium kafka with oracle, how can we create.

4). I have taken archived debezium connector libs, can you please help to provide lib path for debezium kafka connector.

Thanks, please help to understand more on this.

---

<div class="post-metadata">

**Author:** ![mmuehlbeyer](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.confluent.io/mmuehlbeyer/32/1088_2.png) [@mmuehlbeyer](https://forum.confluent.io/u/mmuehlbeyer)\
**Post date:** [21 July 2024 11:15 UTC](https://forum.confluent.io/t/debezium-oracle-kafka-connector/11105/2 "2024-07-21T11:15:22Z")

</div>

> [@Anil](#):
>
> table.include.list=C##SANGULA.T

mmh the parameter above looks wrong

---

<div class="post-metadata">

**Author:** ![Anil](https://avatars.discourse-cdn.com/v4/letter/a/da6949/32.png) [@Anil](https://forum.confluent.io/u/Anil)\
**Post date:** [24 July 2024 02:06 UTC](https://forum.confluent.io/t/debezium-oracle-kafka-connector/11105/3 "2024-07-24T02:06:53Z")

</div>

Thanj you mmuehlbeyer.

Nowmy debezium connector working fine.

name=oracle\_cdc  
connector.class=io.debezium.connector.oracle.OracleConnector  
tasks.max=1  
confluent.topic.bootstrap.servers=localhost:9092  
database.hostname=localhost  
database.port=1521  
database.user=C##OKAFKA  
database.password=admin  
[database.dbname=okcheck.INFOVISIONLABS.COM](http://database.dbname=okcheck.INFOVISIONLABS.COM)  
start.from=snapshot  
[table.inclusion.regex=okcheck.INFOVISIONLABS.COM](http://table.inclusion.regex=okcheck.INFOVISIONLABS.COM)\.C##OKAFKA\.VJNR\_MES\_SO\_HEADER  
table.exclusion.regex=  
table.topic.name.template= ${fullyQualifiedTableName}  
connection.pool.max.size= 20  
topic.prefix=checkdata9-  
confluent.topic.replication.factor=1  
redo.log.consumer.bootstrap.servers=localhost:9092  
redo.log.corruption.topic=redo-corruption-topic  
topic.creation.groups= redo  
topic.creation.redo.include= redo-log-topic  
topic.creation.redo.replication.factor= 1  
topic.creation.redo.partitions= 1  
topic.creation.redo.cleanup.policy=delete  
topic.creation.redo.retention.ms= 1209600000  
topic.creation.default.replication.factor= 1  
topic.creation.default.partitions= 1  
topic.creation.default.cleanup.policy= delete  
schema.history.internal.kafka.bootstrap.servers=localhost:9092  
schema.history.internal.kafka.topic=schema-changes.inventory  
internal.key.converter=org.apache.kafka.connect.storage.StringConverter  
internal.value.converter=org.springframework.kafka.support.serializer.JsonSerializer  
internal.key.converter.schemas.enable=false  
internal.value.converter.schemas.enable=false  
database.history.kafka.topic=history  
database.history.kafka.bootstrap.servers=kafka:9092

---

<div class="post-metadata">

**Author:** ![Anil](https://avatars.discourse-cdn.com/v4/letter/a/da6949/32.png) [@Anil](https://forum.confluent.io/u/Anil)\
**Post date:** [25 July 2024 03:30 UTC](https://forum.confluent.io/t/debezium-oracle-kafka-connector/11105/4 "2024-07-25T03:30:28Z")

</div>

Hi,

using debezium, can we do Validations like, string should start with ‘s’, string should be not more than 25 characters like this, please on this.

Thanks and Regards,  
Anil. Sangula

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/flex019/uploads/confluentcommunity/original/1X/c49438c90c9df282e9996fdf6971be890c71b65a.svg) [@system](https://forum.confluent.io/u/system)\
**Post date:** [24 August 2024 03:31 UTC](https://forum.confluent.io/t/debezium-oracle-kafka-connector/11105/5 "2024-08-24T03:31:17Z")

</div>

This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.
