###########################################################

#https://quay.io/repository/debezium/server?tab=tags&tag=latest
# Source Database Configuration
debezium.source.connector.class=io.debezium.connector.oracle.OracleConnector
debezium.source.topic.prefix=dbz

debezium.source.database.url=jdbc:oracle:thin:@(DESCRIPTION= (ADDRESS_LIST=(ADDRESS= (PROTOCOL=tcp) (host=localhost) (Port=1521))) (CONNECT_DATA= (SID=ORCLCDB)(srvr=dedicated) (GLOBAL_NAME=ORCLCDB)))
debezium.source.database.user=dbzuser
debezium.source.database.password=dbz
debezium.source.database.dbname=ORCLCDB
debezium.source.database.connection.adapter=logminer

debezium.source.offset.storage=org.apache.kafka.connect.storage.FileOffsetBackingStore
debezium.source.offset.storage.file.filename=data/offsets.dat
debezium.source.schema.history.internal=io.debezium.storage.file.history.FileSchemaHistory
debezium.source.schema.history.internal.file.filename=data/file_database_history
debezium.source.offset.flush.interval.ms=0

debezium.source.max.batch.size=100000
debezium.source.max.queue.size=500000
debezium.source.snapshot.fetch.size=500000
debezium.source.snapshot.mode=no_data

debezium.source.incremental.snapshot.chunk.size=400000

debezium.source.value.converter=org.apache.kafka.connect.json.JsonConverter
debezium.source.value.converter.schemas.enable=false

debezium.source.schema.history.internal.skip.unparseable.ddl=true
debezium.source.schema.history.internal.store.only.captured.tables.ddl=true
debezium.source.schema.history.internal.store.only.captured.databases.ddl=true

debezium.source.log.mining.batch.size.default=100000
debezium.source.log.mining.batch.size.min=10000
debezium.source.log.mining.batch.size.max=3000000
debezium.source.log.mining.sleep.time.default.ms=200
debezium.source.log.mining.sleep.time.min.ms=0
debezium.source.log.mining.sleep.time.max.ms=1000
debezium.source.log.mining.sleep.time.increment.ms=100
debezium.source.log.mining.strategy=hybrid
debezium.source.log.mining.query.filter.mode=in



debezium.source.table.include.list=DEBEZIUM.DEBEZIUM_SIGNAL,DBZUSER.POA
debezium.source.signal.data.collection=ORCLCDB.DEBEZIUM.DEBEZIUM_SIGNAL

debezium.source.provide.transaction.metadata=true
debezium.source.transaction.topic=dbz-transaction
debezium.source.tombstones.on.delete=false

debezium.source.topic.heartbeat.prefix=debezium-heartbeat
debezium.source.heartbeat.interval.ms=300000

debezium.source.schema.history.internal.store.only.captured.tables.ddl=true
debezium.source.schema.history.internal.store.only.captured.databases.ddl=true

# Sink Configuration
debezium.sink.type=pubsub
debezium.sink.pubsub.project.id=pep-data-glo-dc-dev
debezium.sink.pubsub.ordering.enabled=false
debezium.sink.pubsub.flowcontrol.enabled=false
debezium.sink.pubsub.retry.total.timeout.ms=900000
debezium.sink.pubsub.retry.max.rpc.timeout.ms=900000
debezium.sink.pubsub.retry.initial.delay.ms=120000
debezium.sink.pubsub.retry.delay.multiplier=1.2
debezium.sink.pubsub.retry.max.delay.ms=99999999
debezium.sink.pubsub.retry.initial.rpc.timeout.ms=120000
debezium.sink.pubsub.retry.rpc.timeout.multiplier=1.2
debezium.sink.pubsub.wait.message.delivery.timeout.ms=900000

# Transformations Configuration
debezium.transforms=convertTimezone,unwrap,RerouteSchema
debezium.transforms.unwrap.type=io.debezium.transforms.ExtractNewRecordState
debezium.transforms.unwrap.drop.tombstones=true
debezium.transforms.unwrap.delete.handling.mode=rewrite
#debezium.transforms.unwrap.add.fields=op:operation,ts_ns:operation_timestamp,ts_ns:operation_nanosecond,source.ts_us:source_timestamp,source.ts_ns:source_nanosecond,source.version,source.name,source.snapshot,source.connector,source.db,source.sequence,source.schema,source.table,source.txId,source.scn,source.commit_scn,source.lcr_position,source.rs_id,source.ssn.source.redo_thread,source.user_name,source.redo_sql,transaction.id,transaction.total_order,transaction.data_collection_order,source.row_id

debezium.transforms.convertTimezone.type=io.debezium.transforms.TimezoneConverter
debezium.transforms.convertTimezone.converted.timezone=Africa/Johannesburg

debezium.transforms.RerouteSchema.type=io.debezium.transforms.ByLogicalTableRouter
debezium.transforms.RerouteSchema.topic.regex=dbz
debezium.transforms.RerouteSchema.topic.replacement=dbz-schema

# Format Configuration
debezium.format.key=json
debezium.format.value=json
debezium.source.decimal.handling.mode=double

# Quarkus Configuration
quarkus.http.port=8080
quarkus.log.level=DEBUG
quarkus.log.console.json=true