/
application.properties.example
58 lines (54 loc) · 2.57 KB
/
application.properties.example
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
debezium.sink.type=databend
debezium.sink.databend.upsert=true
debezium.sink.databend.upsert-keep-deletes=false
debezium.sink.databend.database.databaseName=debezium
debezium.sink.databend.database.url=jdbc:databend://localhost:8000
debezium.sink.databend.database.username=databend
debezium.sink.databend.database.password=databend
# debezium.sink.databend.database.primaryKey=id
# debezium.sink.databend.database.tableName=products
# additional databend parameters
debezium.sink.databend.database.param.ssl=false
# enable event schemas
debezium.format.value.schemas.enable=true
debezium.format.key.schemas.enable=true
debezium.format.value=json
debezium.format.key=json
# mysql source, related docs: https://docs.confluent.io/kafka-connectors/debezium-mysql-source/current/mysql_source_connector_config.html
debezium.source.connector.class=io.debezium.connector.mysql.MySqlConnector
debezium.source.offset.storage.file.filename=data/offsets.dat
debezium.source.offset.flush.interval.ms=10
debezium.source.database.hostname=127.0.0.1
debezium.source.database.port=3306
debezium.source.database.user=mysqlUser
debezium.source.database.password=mysqlPassword
debezium.source.database.dbname=mydb
debezium.source.database.server.name=serverName
debezium.source.include.schema.changes=false
# debezium.source.table.include.list=databaseName.tableName
# debezium.source.database.ssl.mode=required
# Run without Kafka, use local file to store checkpoints
debezium.source.database.history=io.debezium.relational.history.FileDatabaseHistory
debezium.source.database.history.file.filename=data/status.dat
# do event flattening. unwrap message!
# https://debezium.io/documentation/reference/1.2/configuration/event-flattening.html#extract-new-record-state-drop-tombstones
debezium.transforms=unwrap
debezium.transforms.unwrap.type=io.debezium.transforms.ExtractNewRecordState
#debezium.transforms.unwrap.add.fields=op,table,source.ts_ms,db
# soft delete
#debezium.transforms.unwrap.delete.handling.mode=rewrite
#debezium.transforms.unwrap.drop.tombstones=false
# hard delete
debezium.transforms.unwrap.delete.handling.mode=none
debezium.transforms.unwrap.drop.tombstones=false
# ############ SET LOG LEVELS ############
quarkus.log.console.json=true
# Ignore messages below warning level from Jetty, because it's a bit verbose
quarkus.log.category."org.eclipse.jetty".level=WARN
quarkus.log.file.path=./logs/debezium.log
quarkus.log.file.rotation.max-file-size=5M
quarkus.log.file.rotation.file-suffix=.yyyy-MM-dd.gz
quarkus.log.file.rotation.max-backup-index=3
quarkus.log.level=WARN
quarkus.log.file.enable=true
quarkus.http.port=8080