connector.class = io.debezium.connector.sqlserver.SqlServerConnector
include.schema.changes = false
schema.history.internal.store.only.captured.tables.ddl = true
schema.history.internal.file.filename = /path/to/dat
tombstones.on.delete = false
topic.prefix = Northwind
offset.storage.file.filename = /path/to/dat
errors.retry.delay.initial.ms = 30000
snapshot.select.statement.overrides.[dbo].[Order Details] = SELECT * FROM [Northwind].[dbo].[Order Details] WHERE Quantity > 10
value.converter = org.apache.kafka.connect.json.JsonConverter
key.converter = org.apache.kafka.connect.json.JsonConverter
database.databaseName = Northwind
database.user = admin
database.names = Northwind
offset.storage = org.apache.kafka.connect.storage.FileOffsetBackingStore
snapshot.select.statement.overrides = [dbo].[Order Details]
time.precision.mode = connect
errors.retry.delay.max.ms = 60000
offset.flush.timeout.ms = 5000
event.processing.failure.handling.mode = fail
offset.flush.interval.ms = 0
schema.history.internal = io.debezium.storage.file.history.FileSchemaHistory
errors.max.retries = 6
database.hostname = hostname
database.password = ********
name = foobar
task.id = 0
table.include.list = ^dbo.Categories$,^dbo.CustomerDemographics$,^dbo.Customers$,^dbo.EmployeeTerritories$,^dbo.Employees$,^dbo.Northwind.Demo$,^dbo.Order Details$,^dbo.Orders$,^dbo.Products$,^dbo.Region$,^dbo.Shippers$,^dbo.Suppliers$,^dbo.Territories$
database.trustServerCertificate = true
snapshot.mode = initial_only

io.debezium.DebeziumException: java.lang.IllegalArgumentException: Unexpected input: D
    at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:103)
    at io.debezium.pipeline.ChangeEventSourceCoordinator.doSnapshot(ChangeEventSourceCoordinator.java:253)
    at io.debezium.pipeline.ChangeEventSourceCoordinator.doSnapshot(ChangeEventSourceCoordinator.java:237)
    at io.debezium.connector.sqlserver.SqlServerChangeEventSourceCoordinator.executeChangeEventSources(SqlServerChangeEventSourceCoordinator.java:84)
    at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:140)
    at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
    at java.base/java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:264)
    at java.base/java.util.concurrent.FutureTask.run(FutureTask.java)
    at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
    at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
    at java.base/java.lang.Thread.run(Thread.java:829)
Caused by: java.lang.IllegalArgumentException: Unexpected input: D
    at io.debezium.relational.TableIdParser$ParsingState$3.handleCharacter(TableIdParser.java:154)
    at io.debezium.relational.TableIdParser$TableIdTokenizer.tokenize(TableIdParser.java:71)
    at io.debezium.text.TokenStream.start(TokenStream.java:446)
    at io.debezium.relational.TableIdParser.parse(TableIdParser.java:36)
    at io.debezium.relational.TableIdParser.parse(TableIdParser.java:30)
    at io.debezium.relational.TableId.parseParts(TableId.java:80)
    at io.debezium.relational.TableId.parse(TableId.java:54)
    at io.debezium.relational.TableId.parse(TableId.java:30)
    at io.debezium.relational.RelationalSnapshotChangeEventSource.lambda$doExecute$0(RelationalSnapshotChangeEventSource.java:122)
    at java.base/java.util.stream.Collectors.lambda$uniqKeysMapAccumulator$1(Collectors.java:177)
    at java.base/java.util.stream.ReduceOps$3ReducingSink.accept(ReduceOps.java:169)
    at java.base/java.util.HashMap$EntrySpliterator.forEachRemaining(HashMap.java:1764)
    at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484)
    at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474)
    at java.base/java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913)
    at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
    at java.base/java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:578)
    at io.debezium.relational.RelationalSnapshotChangeEventSource.doExecute(RelationalSnapshotChangeEventSource.java:122)

private final Map<String, String> filterQueries; 

private final Map<DataCollectionId, String> filterQueries;