Debezium Connector

Örnek

Şöyle yaparız

debezium.sink.type=pubsub
debezium.sink.pubsub.project.id= <<PUT YOUR PROJECT_ID>>
debezium.source.connector.class=io.debezium.connector.sqlserver.SqlServerConnector
debezium.source.offset.storage.file.filename=/tmp/offsets.dat
debezium.source.offset.flush.interval.ms=0
debezium.source.database.hostname=<<SQL-Server HOSTNAME/IP_ADDRESS>>
debezium.source.database.port=1433
debezium.source.database.user=sa
debezium.source.database.password= <<PASSWORD>>
debezium.source.database.dbname=demodb
debezium.source.database.server.name=demodb
debezium.sink.pravega.scope=empty
debezium.source.table.whitelist=dbo.Inventory
debezium.source.database.history.file.filename=/tmp/FileDatabaseHistory.dat
debezium.source.database.history=io.debezium.relational.history.FileDatabaseHistory