Almost every modern data warehouse project touches the topic of real-time data analytics. In many cases, the source systems use a traditional database, just like SQL Server, and they do not support e...
Updated May 05, 2021
Version 2.0
Blog Post
Hi!
debezium connect sqlserver to kafka
debezium.sink.type=kafka
debezium.sink.kafka.producer.bootstrap.servers=192.168.150.141:9092,192.168.150.135:9092,192.168.150.142:9092
debezium.sink.kafka.producer.key.serializer=org.apache.kafka.common.serialization.StringSerializer
debezium.sink.kafka.producer.value.serializer=org.apache.kafka.common.serialization.StringSerializer
debezium.source.connector.class=io.debezium.connector.sqlserver.SqlServerConnector
debezium.source.offset.storage.file.filename=data/offsets.dat
debezium.source.offset.flush.interval.ms=0
debezium.source.database.hostname=192.168.150.129
debezium.source.database.port=1433
debezium.source.database.user=sa
debezium.source.database.password=mypwd123
debezium.source.database.dbname=bidb
debezium.source.database.server.name=SQL2019
debezium.source.table.include.list=dbo.cdctest
debezium.source.snapshot.mode=schema_only
debezium.source.max.queue.size=8192
debezium.source.max.batch.size=2048
debezium.source.snapshot.fetch.size=2000
debezium.source.query.fetch.size=1000
debezium.source.poll.interval.ms=1000
debezium.source.database.history=io.debezium.relational.history.FileDatabaseHistory
debezium.source.database.history.file.filename=data/FileDatabaseHistory.dat
===============================================================
2021-07-26 16:25:12,643 ERROR [io.qua.run.Application] (main) Failed to start application (with profile prod): java.util.NoSuchElementException: SRCFG00014: The config property debezium.sink.pravega.scope is required but it could not be found in any config source
at io.smallrye.config.SmallRyeConfig.convertValue(SmallRyeConfig.java:259)
at io.smallrye.config.inject.ConfigProducerUtil.getValue(ConfigProducerUtil.java:84)
at io.quarkus.arc.runtime.ConfigRecorder.validateConfigProperties(ConfigRecorder.java:39)
at io.quarkus.deployment.steps.ConfigBuildStep$validateConfigProperties1249763973.deploy_0(ConfigBuildStep$validateConfigProperties1249763973.zig:631)
at io.quarkus.deployment.steps.ConfigBuildStep$validateConfigProperties1249763973.deploy(ConfigBuildStep$validateConfigProperties1249763973.zig:40)
at io.quarkus.runner.ApplicationImpl.doStart(ApplicationImpl.zig:568)
at io.quarkus.runtime.Application.start(Application.java:101)
at io.quarkus.runtime.ApplicationLifecycleManager.run(ApplicationLifecycleManager.java:101)
at io.quarkus.runtime.Quarkus.run(Quarkus.java:66)
at io.quarkus.runtime.Quarkus.run(Quarkus.java:42)
at io.quarkus.runtime.Quarkus.run(Quarkus.java:119)
at io.debezium.server.Main.main(Main.java:15)
Is this a bug？