[2024-01-22 19:34:10,655] INFO [test-debezium-v25-03-source|worker] Creating connector test-debezium-v25-03-source of type io.debezium.connector.sqlserver.SqlServerConnector (org.apache.kafka.connect.runtime.Worker:293)
[2024-01-22 19:34:10,657] INFO [test-debezium-v25-03-source|worker] SourceConnectorConfig values:
        config.action.reload = restart
        connector.class = io.debezium.connector.sqlserver.SqlServerConnector
        errors.log.enable = false
        errors.log.include.messages = false
        errors.retry.delay.max.ms = 60000
        errors.retry.timeout = 0
        errors.tolerance = none
        exactly.once.support = requested
        header.converter = null
        key.converter = class org.apache.kafka.connect.storage.StringConverter
        name = test-debezium-v25-03-source
        offsets.storage.topic = null
        predicates = []
        tasks.max = 1
        topic.creation.groups = []
        transaction.boundary = poll
        transaction.boundary.interval.ms = null
        transforms = [unwrap, extractKey]
        value.converter = class io.confluent.connect.avro.AvroConverter
 (org.apache.kafka.connect.runtime.SourceConnectorConfig:376)
[2024-01-22 19:34:10,659] INFO [test-debezium-v25-03-source|worker] EnrichedConnectorConfig values:
        config.action.reload = restart
        connector.class = io.debezium.connector.sqlserver.SqlServerConnector
        errors.log.enable = false
        errors.log.include.messages = false
        errors.retry.delay.max.ms = 60000
        errors.retry.timeout = 0
        errors.tolerance = none
        exactly.once.support = requested
        header.converter = null
        key.converter = class org.apache.kafka.connect.storage.StringConverter
        name = test-debezium-v25-03-source
        offsets.storage.topic = null
        predicates = []
        tasks.max = 1
        topic.creation.groups = []
        transaction.boundary = poll
        transaction.boundary.interval.ms = null
        transforms = [unwrap, extractKey]
        transforms.extractKey.field = ID
        transforms.extractKey.negate = false
        transforms.extractKey.predicate =
        transforms.extractKey.type = class org.apache.kafka.connect.transforms.ExtractField$Key
        transforms.unwrap.add.fields = []
        transforms.unwrap.add.fields.prefix = __
        transforms.unwrap.add.headers = [op, db, table, schema]
        transforms.unwrap.add.headers.prefix = __
        transforms.unwrap.delete.handling.mode = none
        transforms.unwrap.drop.fields.from.key = false
        transforms.unwrap.drop.fields.header.name = null
        transforms.unwrap.drop.fields.keep.schema.compatible = true
        transforms.unwrap.drop.tombstones = true
        transforms.unwrap.negate = false
        transforms.unwrap.predicate =
        transforms.unwrap.route.by.field =
        transforms.unwrap.type = class io.debezium.transforms.ExtractNewRecordState
        value.converter = class io.confluent.connect.avro.AvroConverter
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:376)
[2024-01-22 19:34:10,669] INFO [test-debezium-v25-03-source|worker] Instantiated connector test-debezium-v25-03-source with version 2.5.0.Final of type class io.debezium.connector.sqlserver.SqlServerConnector (org.apache.kafka.connect.runtime.Worker:315)
[2024-01-22 19:34:10,670] INFO [test-debezium-v25-03-source|worker] Finished creating connector test-debezium-v25-03-source (org.apache.kafka.connect.runtime.Worker:336)
[2024-01-22 19:34:10,674] INFO SourceConnectorConfig values:
        config.action.reload = restart
        connector.class = io.debezium.connector.sqlserver.SqlServerConnector
        errors.log.enable = false
        errors.log.include.messages = false
        errors.retry.delay.max.ms = 60000
        errors.retry.timeout = 0
        errors.tolerance = none
        exactly.once.support = requested
        header.converter = null
        key.converter = class org.apache.kafka.connect.storage.StringConverter
        name = test-debezium-v25-03-source
        offsets.storage.topic = null
        predicates = []
        tasks.max = 1
        topic.creation.groups = []
        transaction.boundary = poll
        transaction.boundary.interval.ms = null
        transforms = [unwrap, extractKey]
        value.converter = class io.confluent.connect.avro.AvroConverter
 (org.apache.kafka.connect.runtime.SourceConnectorConfig:376)
[2024-01-22 19:34:10,676] INFO EnrichedConnectorConfig values:
        config.action.reload = restart
        connector.class = io.debezium.connector.sqlserver.SqlServerConnector
        errors.log.enable = false
        errors.log.include.messages = false
        errors.retry.delay.max.ms = 60000
        errors.retry.timeout = 0
        errors.tolerance = none
        exactly.once.support = requested
        header.converter = null
        key.converter = class org.apache.kafka.connect.storage.StringConverter
        name = test-debezium-v25-03-source
        offsets.storage.topic = null
        predicates = []
        tasks.max = 1
        topic.creation.groups = []
        transaction.boundary = poll
        transaction.boundary.interval.ms = null
        transforms = [unwrap, extractKey]
        transforms.extractKey.field = ID
        transforms.extractKey.negate = false
        transforms.extractKey.predicate =
        transforms.extractKey.type = class org.apache.kafka.connect.transforms.ExtractField$Key
        transforms.unwrap.add.fields = []
        transforms.unwrap.add.fields.prefix = __
        transforms.unwrap.add.headers = [op, db, table, schema]
        transforms.unwrap.add.headers.prefix = __
        transforms.unwrap.delete.handling.mode = none
        transforms.unwrap.drop.fields.from.key = false
        transforms.unwrap.drop.fields.header.name = null
        transforms.unwrap.drop.fields.keep.schema.compatible = true
        transforms.unwrap.drop.tombstones = true
        transforms.unwrap.negate = false
        transforms.unwrap.predicate =
        transforms.unwrap.route.by.field =
        transforms.unwrap.type = class io.debezium.transforms.ExtractNewRecordState
        value.converter = class io.confluent.connect.avro.AvroConverter
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:376)
[2024-01-22 19:34:10,680] INFO [test-debezium-v25-03-source|worker] Loading the custom source info struct maker plugin: io.debezium.connector.sqlserver.SqlServerSourceInfoStructMaker (io.debezium.config.CommonConnectorConfig:1318)
[2024-01-22 19:34:10,797] INFO [test-debezium-v25-03-source|worker] Connection gracefully closed (io.debezium.jdbc.JdbcConnection:949)
[2024-01-22 19:34:10,804] INFO [test-debezium-v25-03-source|task-0] Creating task test-debezium-v25-03-source-0 (org.apache.kafka.connect.runtime.Worker:596)
[2024-01-22 19:34:10,806] INFO [test-debezium-v25-03-source|task-0] ConnectorConfig values:
        config.action.reload = restart
        connector.class = io.debezium.connector.sqlserver.SqlServerConnector
        errors.log.enable = false
        errors.log.include.messages = false
        errors.retry.delay.max.ms = 60000
        errors.retry.timeout = 0
        errors.tolerance = none
        header.converter = null
        key.converter = class org.apache.kafka.connect.storage.StringConverter
        name = test-debezium-v25-03-source
        predicates = []
        tasks.max = 1
        transforms = [unwrap, extractKey]
        value.converter = class io.confluent.connect.avro.AvroConverter
 (org.apache.kafka.connect.runtime.ConnectorConfig:376)
[2024-01-22 19:34:10,807] INFO [test-debezium-v25-03-source|task-0] EnrichedConnectorConfig values:
        config.action.reload = restart
        connector.class = io.debezium.connector.sqlserver.SqlServerConnector
        errors.log.enable = false
        errors.log.include.messages = false
        errors.retry.delay.max.ms = 60000
        errors.retry.timeout = 0
        errors.tolerance = none
        header.converter = null
        key.converter = class org.apache.kafka.connect.storage.StringConverter
        name = test-debezium-v25-03-source
        predicates = []
        tasks.max = 1
        transforms = [unwrap, extractKey]
        transforms.extractKey.field = ID
        transforms.extractKey.negate = false
        transforms.extractKey.predicate =
        transforms.extractKey.type = class org.apache.kafka.connect.transforms.ExtractField$Key
        transforms.unwrap.add.fields = []
        transforms.unwrap.add.fields.prefix = __
        transforms.unwrap.add.headers = [op, db, table, schema]
        transforms.unwrap.add.headers.prefix = __
        transforms.unwrap.delete.handling.mode = none
        transforms.unwrap.drop.fields.from.key = false
        transforms.unwrap.drop.fields.header.name = null
        transforms.unwrap.drop.fields.keep.schema.compatible = true
        transforms.unwrap.drop.tombstones = true
        transforms.unwrap.negate = false
        transforms.unwrap.predicate =
        transforms.unwrap.route.by.field =
        transforms.unwrap.type = class io.debezium.transforms.ExtractNewRecordState
        value.converter = class io.confluent.connect.avro.AvroConverter
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:376)
[2024-01-22 19:34:10,811] INFO [test-debezium-v25-03-source|task-0] TaskConfig values:
        task.class = class io.debezium.connector.sqlserver.SqlServerConnectorTask
 (org.apache.kafka.connect.runtime.TaskConfig:376)
[2024-01-22 19:34:10,816] INFO [test-debezium-v25-03-source|task-0] Instantiated task test-debezium-v25-03-source-0 with version 2.5.0.Final of type io.debezium.connector.sqlserver.SqlServerConnectorTask (org.apache.kafka.connect.runtime.Worker:610)
[2024-01-22 19:34:10,820] INFO [test-debezium-v25-03-source|task-0] StringConverterConfig values:
        converter.encoding = UTF-8
        converter.type = key
 (org.apache.kafka.connect.storage.StringConverterConfig:376)
[2024-01-22 19:34:10,830] INFO [test-debezium-v25-03-source|task-0] AvroConverterConfig values:
        auto.register.schemas = true
        basic.auth.credentials.source = URL
        basic.auth.user.info = [hidden]
        bearer.auth.cache.expiry.buffer.seconds = 300
        bearer.auth.client.id = null
        bearer.auth.client.secret = null
        bearer.auth.credentials.source = STATIC_TOKEN
        bearer.auth.custom.provider.class = null
        bearer.auth.identity.pool.id = null
        bearer.auth.issuer.endpoint.url = null
        bearer.auth.logical.cluster = null
        bearer.auth.scope = null
        bearer.auth.scope.claim.name = scope
        bearer.auth.sub.claim.name = sub
        bearer.auth.token = [hidden]
        context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy
        http.connect.timeout.ms = 60000
        http.read.timeout.ms = 60000
        id.compatibility.strict = true
        key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy
        latest.cache.size = 1000
        latest.cache.ttl.sec = -1
        latest.compatibility.strict = true
        max.schemas.per.subject = 1000
        normalize.schemas = false
        proxy.host =
        proxy.port = -1
        rule.actions = []
        rule.executors = []
        rule.service.loader.enable = true
        schema.format = null
        schema.reflection = false
        schema.registry.basic.auth.user.info = [hidden]
        schema.registry.ssl.cipher.suites = null
        schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
        schema.registry.ssl.endpoint.identification.algorithm = https
        schema.registry.ssl.engine.factory.class = null
        schema.registry.ssl.key.password = null
        schema.registry.ssl.keymanager.algorithm = SunX509
        schema.registry.ssl.keystore.certificate.chain = null
        schema.registry.ssl.keystore.key = null
        schema.registry.ssl.keystore.location = null
        schema.registry.ssl.keystore.password = null
        schema.registry.ssl.keystore.type = JKS
        schema.registry.ssl.protocol = TLSv1.3
        schema.registry.ssl.provider = null
        schema.registry.ssl.secure.random.implementation = null
        schema.registry.ssl.trustmanager.algorithm = PKIX
        schema.registry.ssl.truststore.certificates = null
        schema.registry.ssl.truststore.location = null
        schema.registry.ssl.truststore.password = null
        schema.registry.ssl.truststore.type = JKS
        schema.registry.url = [http://kafkahost:8081]
        use.latest.version = false
        use.latest.with.metadata = null
        use.schema.id = -1
        value.subject.name.strategy = class io.confluent.kafka.serializers.subject.RecordNameStrategy
 (io.confluent.connect.avro.AvroConverterConfig:376)
[2024-01-22 19:34:10,941] INFO [test-debezium-v25-03-source|task-0] KafkaAvroSerializerConfig values:
        auto.register.schemas = true
        avro.reflection.allow.null = false
        avro.remove.java.properties = false
        avro.use.logical.type.converters = false
        basic.auth.credentials.source = URL
        basic.auth.user.info = [hidden]
        bearer.auth.cache.expiry.buffer.seconds = 300
        bearer.auth.client.id = null
        bearer.auth.client.secret = null
        bearer.auth.credentials.source = STATIC_TOKEN
        bearer.auth.custom.provider.class = null
        bearer.auth.identity.pool.id = null
        bearer.auth.issuer.endpoint.url = null
        bearer.auth.logical.cluster = null
        bearer.auth.scope = null
        bearer.auth.scope.claim.name = scope
        bearer.auth.sub.claim.name = sub
        bearer.auth.token = [hidden]
        context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy
        http.connect.timeout.ms = 60000
        http.read.timeout.ms = 60000
        id.compatibility.strict = true
        key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy
        latest.cache.size = 1000
        latest.cache.ttl.sec = -1
        latest.compatibility.strict = true
        max.schemas.per.subject = 1000
        normalize.schemas = false
        proxy.host =
        proxy.port = -1
        rule.actions = []
        rule.executors = []
        rule.service.loader.enable = true
        schema.format = null
        schema.reflection = false
        schema.registry.basic.auth.user.info = [hidden]
        schema.registry.ssl.cipher.suites = null
        schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
        schema.registry.ssl.endpoint.identification.algorithm = https
        schema.registry.ssl.engine.factory.class = null
        schema.registry.ssl.key.password = null
        schema.registry.ssl.keymanager.algorithm = SunX509
        schema.registry.ssl.keystore.certificate.chain = null
        schema.registry.ssl.keystore.key = null
        schema.registry.ssl.keystore.location = null
        schema.registry.ssl.keystore.password = null
        schema.registry.ssl.keystore.type = JKS
        schema.registry.ssl.protocol = TLSv1.3
        schema.registry.ssl.provider = null
        schema.registry.ssl.secure.random.implementation = null
        schema.registry.ssl.trustmanager.algorithm = PKIX
        schema.registry.ssl.truststore.certificates = null
        schema.registry.ssl.truststore.location = null
        schema.registry.ssl.truststore.password = null
        schema.registry.ssl.truststore.type = JKS
        schema.registry.url = [http://kafkahost:8081]
        use.latest.version = false
        use.latest.with.metadata = null
        use.schema.id = -1
        value.subject.name.strategy = class io.confluent.kafka.serializers.subject.RecordNameStrategy
 (io.confluent.kafka.serializers.KafkaAvroSerializerConfig:376)
[2024-01-22 19:34:11,468] INFO [test-debezium-v25-03-source|task-0] KafkaAvroDeserializerConfig values:
        auto.register.schemas = true
        avro.reflection.allow.null = false
        avro.use.logical.type.converters = false
        basic.auth.credentials.source = URL
        basic.auth.user.info = [hidden]
        bearer.auth.cache.expiry.buffer.seconds = 300
        bearer.auth.client.id = null
        bearer.auth.client.secret = null
        bearer.auth.credentials.source = STATIC_TOKEN
        bearer.auth.custom.provider.class = null
        bearer.auth.identity.pool.id = null
        bearer.auth.issuer.endpoint.url = null
        bearer.auth.logical.cluster = null
        bearer.auth.scope = null
        bearer.auth.scope.claim.name = scope
        bearer.auth.sub.claim.name = sub
        bearer.auth.token = [hidden]
        context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy
        http.connect.timeout.ms = 60000
        http.read.timeout.ms = 60000
        id.compatibility.strict = true
        key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy
        latest.cache.size = 1000
        latest.cache.ttl.sec = -1
        latest.compatibility.strict = true
        max.schemas.per.subject = 1000
        normalize.schemas = false
        proxy.host =
        proxy.port = -1
        rule.actions = []
        rule.executors = []
        rule.service.loader.enable = true
        schema.format = null
        schema.reflection = false
        schema.registry.basic.auth.user.info = [hidden]
        schema.registry.ssl.cipher.suites = null
        schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
        schema.registry.ssl.endpoint.identification.algorithm = https
        schema.registry.ssl.engine.factory.class = null
        schema.registry.ssl.key.password = null
        schema.registry.ssl.keymanager.algorithm = SunX509
        schema.registry.ssl.keystore.certificate.chain = null
        schema.registry.ssl.keystore.key = null
        schema.registry.ssl.keystore.location = null
        schema.registry.ssl.keystore.password = null
        schema.registry.ssl.keystore.type = JKS
        schema.registry.ssl.protocol = TLSv1.3
        schema.registry.ssl.provider = null
        schema.registry.ssl.secure.random.implementation = null
        schema.registry.ssl.trustmanager.algorithm = PKIX
        schema.registry.ssl.truststore.certificates = null
        schema.registry.ssl.truststore.location = null
        schema.registry.ssl.truststore.password = null
        schema.registry.ssl.truststore.type = JKS
        schema.registry.url = [http://kafkahost:8081]
        specific.avro.key.type = null
        specific.avro.reader = false
        specific.avro.value.type = null
        use.latest.version = false
        use.latest.with.metadata = null
        use.schema.id = -1
        value.subject.name.strategy = class io.confluent.kafka.serializers.subject.RecordNameStrategy
 (io.confluent.kafka.serializers.KafkaAvroDeserializerConfig:376)
[2024-01-22 19:34:11,539] INFO [test-debezium-v25-03-source|task-0] AvroDataConfig values:
        allow.optional.map.keys = false
        connect.meta.data = true
        discard.type.doc.default = false
        enhanced.avro.schema.support = false
        generalized.sum.type.support = false
        ignore.default.for.nullables = false
        schemas.cache.config = 1000
        scrub.invalid.names = false
 (io.confluent.connect.avro.AvroDataConfig:376)
[2024-01-22 19:34:11,540] INFO [test-debezium-v25-03-source|task-0] Set up the key converter class org.apache.kafka.connect.storage.StringConverter for task test-debezium-v25-03-source-0 using the connector config (org.apache.kafka.connect.runtime.Worker:625)
[2024-01-22 19:34:11,540] INFO [test-debezium-v25-03-source|task-0] Set up the value converter class io.confluent.connect.avro.AvroConverter for task test-debezium-v25-03-source-0 using the connector config (org.apache.kafka.connect.runtime.Worker:631)
[2024-01-22 19:34:11,541] INFO [test-debezium-v25-03-source|task-0] Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task test-debezium-v25-03-source-0 using the worker config (org.apache.kafka.connect.runtime.Worker:636)
[2024-01-22 19:34:11,547] INFO [test-debezium-v25-03-source|task-0] SourceConnectorConfig values:
        config.action.reload = restart
        connector.class = io.debezium.connector.sqlserver.SqlServerConnector
        errors.log.enable = false
        errors.log.include.messages = false
        errors.retry.delay.max.ms = 60000
        errors.retry.timeout = 0
        errors.tolerance = none
        exactly.once.support = requested
        header.converter = null
        key.converter = class org.apache.kafka.connect.storage.StringConverter
        name = test-debezium-v25-03-source
        offsets.storage.topic = null
        predicates = []
        tasks.max = 1
        topic.creation.groups = []
        transaction.boundary = poll
        transaction.boundary.interval.ms = null
        transforms = [unwrap, extractKey]
        value.converter = class io.confluent.connect.avro.AvroConverter
 (org.apache.kafka.connect.runtime.SourceConnectorConfig:376)
[2024-01-22 19:34:11,548] INFO [test-debezium-v25-03-source|task-0] EnrichedConnectorConfig values:
        config.action.reload = restart
        connector.class = io.debezium.connector.sqlserver.SqlServerConnector
        errors.log.enable = false
        errors.log.include.messages = false
        errors.retry.delay.max.ms = 60000
        errors.retry.timeout = 0
        errors.tolerance = none
        exactly.once.support = requested
        header.converter = null
        key.converter = class org.apache.kafka.connect.storage.StringConverter
        name = test-debezium-v25-03-source
        offsets.storage.topic = null
        predicates = []
        tasks.max = 1
        topic.creation.groups = []
        transaction.boundary = poll
        transaction.boundary.interval.ms = null
        transforms = [unwrap, extractKey]
        transforms.extractKey.field = ID
        transforms.extractKey.negate = false
        transforms.extractKey.predicate =
        transforms.extractKey.type = class org.apache.kafka.connect.transforms.ExtractField$Key
        transforms.unwrap.add.fields = []
        transforms.unwrap.add.fields.prefix = __
        transforms.unwrap.add.headers = [op, db, table, schema]
        transforms.unwrap.add.headers.prefix = __
        transforms.unwrap.delete.handling.mode = none
        transforms.unwrap.drop.fields.from.key = false
        transforms.unwrap.drop.fields.header.name = null
        transforms.unwrap.drop.fields.keep.schema.compatible = true
        transforms.unwrap.drop.tombstones = true
        transforms.unwrap.negate = false
        transforms.unwrap.predicate =
        transforms.unwrap.route.by.field =
        transforms.unwrap.type = class io.debezium.transforms.ExtractNewRecordState
        value.converter = class io.confluent.connect.avro.AvroConverter
 (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:376)
[2024-01-22 19:34:11,558] WARN [test-debezium-v25-03-source|task-0] The deleted record handling configs "drop.tombstones" and "delete.handling.mode" have been deprecated, please use "delete.tombstone.handling.mode" instead. (io.debezium.transforms.AbstractExtractNewRecordState:101)
[2024-01-22 19:34:11,559] INFO [test-debezium-v25-03-source|task-0] Initializing: org.apache.kafka.connect.runtime.TransformationChain{io.debezium.transforms.ExtractNewRecordState, org.apache.kafka.connect.transforms.ExtractField$Key} (org.apache.kafka.connect.runtime.Worker:1301)
[2024-01-22 19:34:11,568] INFO [test-debezium-v25-03-source|task-0] ProducerConfig values:
        acks = -1
        auto.include.jmx.reporter = true
        batch.size = 16384
        bootstrap.servers = [kafkahost:9092]
        buffer.memory = 33554432
        client.dns.lookup = use_all_dns_ips
        client.id = connector-producer-test-debezium-v25-03-source-0
        compression.type = none
        connections.max.idle.ms = 540000
        delivery.timeout.ms = 2147483647
        enable.idempotence = false
        interceptor.classes = []
        key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
        linger.ms = 0
        max.block.ms = 9223372036854775807
        max.in.flight.requests.per.connection = 1
        max.request.size = 1048576
        metadata.max.age.ms = 300000
        metadata.max.idle.ms = 300000
        metric.reporters = []
        metrics.num.samples = 2
        metrics.recording.level = INFO
        metrics.sample.window.ms = 30000
        partitioner.adaptive.partitioning.enable = true
        partitioner.availability.timeout.ms = 0
        partitioner.class = null
        partitioner.ignore.keys = false
        receive.buffer.bytes = 32768
        reconnect.backoff.max.ms = 1000
        reconnect.backoff.ms = 50
        request.timeout.ms = 30000
        retries = 2147483647
        retry.backoff.ms = 100
        sasl.client.callback.handler.class = null
        sasl.jaas.config = null
        sasl.kerberos.kinit.cmd = /usr/bin/kinit
        sasl.kerberos.min.time.before.relogin = 60000
        sasl.kerberos.service.name = null
        sasl.kerberos.ticket.renew.jitter = 0.05
        sasl.kerberos.ticket.renew.window.factor = 0.8
        sasl.login.callback.handler.class = null
        sasl.login.class = null
        sasl.login.connect.timeout.ms = null
        sasl.login.read.timeout.ms = null
        sasl.login.refresh.buffer.seconds = 300
        sasl.login.refresh.min.period.seconds = 60
        sasl.login.refresh.window.factor = 0.8
        sasl.login.refresh.window.jitter = 0.05
        sasl.login.retry.backoff.max.ms = 10000
        sasl.login.retry.backoff.ms = 100
        sasl.mechanism = GSSAPI
        sasl.oauthbearer.clock.skew.seconds = 30
        sasl.oauthbearer.expected.audience = null
        sasl.oauthbearer.expected.issuer = null
        sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
        sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
        sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
        sasl.oauthbearer.jwks.endpoint.url = null
        sasl.oauthbearer.scope.claim.name = scope
        sasl.oauthbearer.sub.claim.name = sub
        sasl.oauthbearer.token.endpoint.url = null
        security.protocol = PLAINTEXT
        security.providers = null
        send.buffer.bytes = 131072
        socket.connection.setup.timeout.max.ms = 30000
        socket.connection.setup.timeout.ms = 10000
        ssl.cipher.suites = null
        ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
        ssl.endpoint.identification.algorithm = https
        ssl.engine.factory.class = null
        ssl.key.password = null
        ssl.keymanager.algorithm = SunX509
        ssl.keystore.certificate.chain = null
        ssl.keystore.key = null
        ssl.keystore.location = null
        ssl.keystore.password = null
        ssl.keystore.type = JKS
        ssl.protocol = TLSv1.3
        ssl.provider = null
        ssl.secure.random.implementation = null
        ssl.trustmanager.algorithm = PKIX
        ssl.truststore.certificates = null
        ssl.truststore.location = null
        ssl.truststore.password = null
        ssl.truststore.type = JKS
        transaction.timeout.ms = 60000
        transactional.id = null
        value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
 (org.apache.kafka.clients.producer.ProducerConfig:376)
[2024-01-22 19:34:11,604] WARN [test-debezium-v25-03-source|task-0] These configurations '[metrics.context.connect.kafka.cluster.id]' were supplied but are not used yet. (org.apache.kafka.clients.producer.ProducerConfig:385)
[2024-01-22 19:34:11,606] INFO [test-debezium-v25-03-source|task-0] Kafka version: 7.4.1-ccs (org.apache.kafka.common.utils.AppInfoParser:119)
[2024-01-22 19:34:11,606] INFO [test-debezium-v25-03-source|task-0] Kafka commitId: fed9c006bfc7ba5bf7d2dee840e041d1a851d903 (org.apache.kafka.common.utils.AppInfoParser:120)
[2024-01-22 19:34:11,607] INFO [test-debezium-v25-03-source|task-0] Kafka startTimeMs: 1705948451605 (org.apache.kafka.common.utils.AppInfoParser:121)
[2024-01-22 19:34:11,619] INFO [test-debezium-v25-03-source|task-0] [Producer clientId=connector-producer-test-debezium-v25-03-source-0] Cluster ID: ukJbw5WeQVGTixPWGoUSog (org.apache.kafka.clients.Metadata:287)
[2024-01-22 19:34:11,628] INFO [test-debezium-v25-03-source|task-0] Starting SqlServerConnectorTask with configuration: (io.debezium.connector.common.BaseSourceTask:135)
[2024-01-22 19:34:11,628] INFO Created connector test-debezium-v25-03-source (org.apache.kafka.connect.cli.ConnectStandalone:113)
[2024-01-22 19:34:11,631] INFO [test-debezium-v25-03-source|task-0]    connector.class = io.debezium.connector.sqlserver.SqlServerConnector (io.debezium.connector.common.BaseSourceTask:137)
[2024-01-22 19:34:11,631] INFO [test-debezium-v25-03-source|task-0]    transforms.unwrap.delete.handling.mode = none (io.debezium.connector.common.BaseSourceTask:137)
[2024-01-22 19:34:11,632] INFO [test-debezium-v25-03-source|task-0]    tasks.max = 1 (io.debezium.connector.common.BaseSourceTask:137)
[2024-01-22 19:34:11,632] INFO [test-debezium-v25-03-source|task-0]    database.history.kafka.topic = _localhost.schemahistory.debezium03 (io.debezium.connector.common.BaseSourceTask:137)
[2024-01-22 19:34:11,633] INFO [test-debezium-v25-03-source|task-0]    transforms = unwrap,extractKey (io.debezium.connector.common.BaseSourceTask:137)
[2024-01-22 19:34:11,633] INFO [test-debezium-v25-03-source|task-0]    value.converter.value.subject.name.strategy = io.confluent.kafka.serializers.subject.RecordNameStrategy (io.debezium.connector.common.BaseSourceTask:137)
[2024-01-22 19:34:11,633] INFO [test-debezium-v25-03-source|task-0]    transforms.extractKey.type = org.apache.kafka.connect.transforms.ExtractField$Key (io.debezium.connector.common.BaseSourceTask:137)
[2024-01-22 19:34:11,634] INFO [test-debezium-v25-03-source|task-0]    topic.prefix = localhost.test25.TestTable03 (io.debezium.connector.common.BaseSourceTask:137)
[2024-01-22 19:34:11,634] INFO [test-debezium-v25-03-source|task-0]    schema.history.internal.kafka.topic = _localhost.schemahistory.debezium03 (io.debezium.connector.common.BaseSourceTask:137)
[2024-01-22 19:34:11,634] INFO [test-debezium-v25-03-source|task-0]    transforms.unwrap.drop.tombstones = true (io.debezium.connector.common.BaseSourceTask:137)
[2024-01-22 19:34:11,634] INFO [test-debezium-v25-03-source|task-0]    transforms.unwrap.type = io.debezium.transforms.ExtractNewRecordState (io.debezium.connector.common.BaseSourceTask:137)
[2024-01-22 19:34:11,635] INFO [test-debezium-v25-03-source|task-0]    value.converter = io.confluent.connect.avro.AvroConverter (io.debezium.connector.common.BaseSourceTask:137)
[2024-01-22 19:34:11,635] INFO [test-debezium-v25-03-source|task-0]    key.converter = org.apache.kafka.connect.storage.StringConverter (io.debezium.connector.common.BaseSourceTask:137)
[2024-01-22 19:34:11,636] INFO [test-debezium-v25-03-source|task-0]    database.encrypt = false (io.debezium.connector.common.BaseSourceTask:137)
[2024-01-22 19:34:11,636] INFO [test-debezium-v25-03-source|task-0]    database.user = devel (io.debezium.connector.common.BaseSourceTask:137)
[2024-01-22 19:34:11,636] INFO [test-debezium-v25-03-source|task-0]    transforms.extractKey.field = ID (io.debezium.connector.common.BaseSourceTask:137)
[2024-01-22 19:34:11,636] INFO [test-debezium-v25-03-source|task-0]    database.names = test (io.debezium.connector.common.BaseSourceTask:137)
[2024-01-22 19:34:11,637] INFO [test-debezium-v25-03-source|task-0]    database.history.kafka.bootstrap.servers = kafkahost:9092 (io.debezium.connector.common.BaseSourceTask:137)
[2024-01-22 19:34:11,637] INFO [test-debezium-v25-03-source|task-0]    database.server.name = localhost-test-test25-TestTable03 (io.debezium.connector.common.BaseSourceTask:137)
[2024-01-22 19:34:11,637] INFO [test-debezium-v25-03-source|task-0]    schema.history.internal.kafka.bootstrap.servers = kafkahost:9092 (io.debezium.connector.common.BaseSourceTask:137)
[2024-01-22 19:34:11,638] INFO [test-debezium-v25-03-source|task-0]    transforms.unwrap.add.headers = op,db,table,schema (io.debezium.connector.common.BaseSourceTask:137)
[2024-01-22 19:34:11,638] INFO [test-debezium-v25-03-source|task-0]    database.port = 1433 (io.debezium.connector.common.BaseSourceTask:137)
[2024-01-22 19:34:11,638] INFO [test-debezium-v25-03-source|task-0]    value.converter.schema.registry.url = http://kafkahost:8081 (io.debezium.connector.common.BaseSourceTask:137)
[2024-01-22 19:34:11,639] INFO [test-debezium-v25-03-source|task-0]    task.class = io.debezium.connector.sqlserver.SqlServerConnectorTask (io.debezium.connector.common.BaseSourceTask:137)
[2024-01-22 19:34:11,639] INFO [test-debezium-v25-03-source|task-0]    database.hostname = dbserver (io.debezium.connector.common.BaseSourceTask:137)
[2024-01-22 19:34:11,639] INFO [test-debezium-v25-03-source|task-0]    database.password = ******** (io.debezium.connector.common.BaseSourceTask:137)
[2024-01-22 19:34:11,640] INFO [test-debezium-v25-03-source|task-0]    name = test-debezium-v25-03-source (io.debezium.connector.common.BaseSourceTask:137)
[2024-01-22 19:34:11,640] INFO [test-debezium-v25-03-source|task-0]    value.converter.auto.register.schemas = true (io.debezium.connector.common.BaseSourceTask:137)
[2024-01-22 19:34:11,641] INFO [test-debezium-v25-03-source|task-0]    value.converter.connect.meta.data = true (io.debezium.connector.common.BaseSourceTask:137)
[2024-01-22 19:34:11,641] INFO [test-debezium-v25-03-source|task-0]    task.id = 0 (io.debezium.connector.common.BaseSourceTask:137)
[2024-01-22 19:34:11,641] INFO [test-debezium-v25-03-source|task-0]    table.include.list = test25.TestTable03 (io.debezium.connector.common.BaseSourceTask:137)
[2024-01-22 19:34:11,642] INFO [test-debezium-v25-03-source|task-0] Loading the custom source info struct maker plugin: io.debezium.connector.sqlserver.SqlServerSourceInfoStructMaker (io.debezium.config.CommonConnectorConfig:1318)
[2024-01-22 19:34:11,644] INFO [test-debezium-v25-03-source|task-0] Loading the custom topic naming strategy plugin: io.debezium.schema.SchemaTopicNamingStrategy (io.debezium.config.CommonConnectorConfig:1066)
[2024-01-22 19:34:11,721] INFO [test-debezium-v25-03-source|task-0] KafkaSchemaHistory Consumer config: {key.deserializer=org.apache.kafka.common.serialization.StringDeserializer, value.deserializer=org.apache.kafka.common.serialization.StringDeserializer, enable.auto.commit=false, group.id=localhost.test25.TestTable03-schemahistory, bootstrap.servers=kafkahost:9092, fetch.min.bytes=1, session.timeout.ms=10000, auto.offset.reset=earliest, client.id=localhost.test25.TestTable03-schemahistory} (io.debezium.storage.kafka.history.KafkaSchemaHistory:245)
[2024-01-22 19:34:11,721] INFO [test-debezium-v25-03-source|task-0] KafkaSchemaHistory Producer config: {retries=1, value.serializer=org.apache.kafka.common.serialization.StringSerializer, acks=1, batch.size=32768, max.block.ms=10000, bootstrap.servers=kafkahost:9092, buffer.memory=1048576, key.serializer=org.apache.kafka.common.serialization.StringSerializer, client.id=localhost.test25.TestTable03-schemahistory, linger.ms=0} (io.debezium.storage.kafka.history.KafkaSchemaHistory:246)
[2024-01-22 19:34:11,723] INFO [test-debezium-v25-03-source|task-0] Requested thread factory for connector SqlServerConnector, id = localhost.test25.TestTable03 named = db-history-config-check (io.debezium.util.Threads:271)
[2024-01-22 19:34:11,728] INFO [test-debezium-v25-03-source|task-0] Idempotence will be disabled because acks is set to 1, not set to 'all'. (org.apache.kafka.clients.producer.ProducerConfig:536)
[2024-01-22 19:34:11,729] INFO [test-debezium-v25-03-source|task-0] ProducerConfig values:
        acks = 1
        auto.include.jmx.reporter = true
        batch.size = 32768
        bootstrap.servers = [kafkahost:9092]
        buffer.memory = 1048576
        client.dns.lookup = use_all_dns_ips
        client.id = localhost.test25.TestTable03-schemahistory
        compression.type = none
        connections.max.idle.ms = 540000
        delivery.timeout.ms = 120000
        enable.idempotence = false
        interceptor.classes = []
        key.serializer = class org.apache.kafka.common.serialization.StringSerializer
        linger.ms = 0
        max.block.ms = 10000
        max.in.flight.requests.per.connection = 5
        max.request.size = 1048576
        metadata.max.age.ms = 300000
        metadata.max.idle.ms = 300000
        metric.reporters = []
        metrics.num.samples = 2
        metrics.recording.level = INFO
        metrics.sample.window.ms = 30000
        partitioner.adaptive.partitioning.enable = true
        partitioner.availability.timeout.ms = 0
        partitioner.class = null
        partitioner.ignore.keys = false
        receive.buffer.bytes = 32768
        reconnect.backoff.max.ms = 1000
        reconnect.backoff.ms = 50
        request.timeout.ms = 30000
        retries = 1
        retry.backoff.ms = 100
        sasl.client.callback.handler.class = null
        sasl.jaas.config = null
        sasl.kerberos.kinit.cmd = /usr/bin/kinit
        sasl.kerberos.min.time.before.relogin = 60000
        sasl.kerberos.service.name = null
        sasl.kerberos.ticket.renew.jitter = 0.05
        sasl.kerberos.ticket.renew.window.factor = 0.8
        sasl.login.callback.handler.class = null
        sasl.login.class = null
        sasl.login.connect.timeout.ms = null
        sasl.login.read.timeout.ms = null
        sasl.login.refresh.buffer.seconds = 300
        sasl.login.refresh.min.period.seconds = 60
        sasl.login.refresh.window.factor = 0.8
        sasl.login.refresh.window.jitter = 0.05
        sasl.login.retry.backoff.max.ms = 10000
        sasl.login.retry.backoff.ms = 100
        sasl.mechanism = GSSAPI
        sasl.oauthbearer.clock.skew.seconds = 30
        sasl.oauthbearer.expected.audience = null
        sasl.oauthbearer.expected.issuer = null
        sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
        sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
        sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
        sasl.oauthbearer.jwks.endpoint.url = null
        sasl.oauthbearer.scope.claim.name = scope
        sasl.oauthbearer.sub.claim.name = sub
        sasl.oauthbearer.token.endpoint.url = null
        security.protocol = PLAINTEXT
        security.providers = null
        send.buffer.bytes = 131072
        socket.connection.setup.timeout.max.ms = 30000
        socket.connection.setup.timeout.ms = 10000
        ssl.cipher.suites = null
        ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
        ssl.endpoint.identification.algorithm = https
        ssl.engine.factory.class = null
        ssl.key.password = null
        ssl.keymanager.algorithm = SunX509
        ssl.keystore.certificate.chain = null
        ssl.keystore.key = null
        ssl.keystore.location = null
        ssl.keystore.password = null
        ssl.keystore.type = JKS
        ssl.protocol = TLSv1.3
        ssl.provider = null
        ssl.secure.random.implementation = null
        ssl.trustmanager.algorithm = PKIX
        ssl.truststore.certificates = null
        ssl.truststore.location = null
        ssl.truststore.password = null
        ssl.truststore.type = JKS
        transaction.timeout.ms = 60000
        transactional.id = null
        value.serializer = class org.apache.kafka.common.serialization.StringSerializer
 (org.apache.kafka.clients.producer.ProducerConfig:376)
[2024-01-22 19:34:11,736] INFO [test-debezium-v25-03-source|task-0] Kafka version: 7.4.1-ccs (org.apache.kafka.common.utils.AppInfoParser:119)
[2024-01-22 19:34:11,737] INFO [test-debezium-v25-03-source|task-0] Kafka commitId: fed9c006bfc7ba5bf7d2dee840e041d1a851d903 (org.apache.kafka.common.utils.AppInfoParser:120)
[2024-01-22 19:34:11,737] INFO [test-debezium-v25-03-source|task-0] Kafka startTimeMs: 1705948451736 (org.apache.kafka.common.utils.AppInfoParser:121)
[2024-01-22 19:34:11,742] INFO [test-debezium-v25-03-source|task-0] [Producer clientId=localhost.test25.TestTable03-schemahistory] Cluster ID: ukJbw5WeQVGTixPWGoUSog (org.apache.kafka.clients.Metadata:287)
[2024-01-22 19:34:11,756] INFO [test-debezium-v25-03-source|task-0] ConsumerConfig values:
        allow.auto.create.topics = true
        auto.commit.interval.ms = 5000
        auto.include.jmx.reporter = true
        auto.offset.reset = earliest
        bootstrap.servers = [kafkahost:9092]
        check.crcs = true
        client.dns.lookup = use_all_dns_ips
        client.id = localhost.test25.TestTable03-schemahistory
        client.rack =
        connections.max.idle.ms = 540000
        default.api.timeout.ms = 60000
        enable.auto.commit = false
        exclude.internal.topics = true
        fetch.max.bytes = 52428800
        fetch.max.wait.ms = 500
        fetch.min.bytes = 1
        group.id = localhost.test25.TestTable03-schemahistory
        group.instance.id = null
        heartbeat.interval.ms = 3000
        interceptor.classes = []
        internal.leave.group.on.close = true
        internal.throw.on.fetch.stable.offset.unsupported = false
        isolation.level = read_uncommitted
        key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
        max.partition.fetch.bytes = 1048576
        max.poll.interval.ms = 300000
        max.poll.records = 500
        metadata.max.age.ms = 300000
        metric.reporters = []
        metrics.num.samples = 2
        metrics.recording.level = INFO
        metrics.sample.window.ms = 30000
        partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor]
        receive.buffer.bytes = 65536
        reconnect.backoff.max.ms = 1000
        reconnect.backoff.ms = 50
        request.timeout.ms = 30000
        retry.backoff.ms = 100
        sasl.client.callback.handler.class = null
        sasl.jaas.config = null
        sasl.kerberos.kinit.cmd = /usr/bin/kinit
        sasl.kerberos.min.time.before.relogin = 60000
        sasl.kerberos.service.name = null
        sasl.kerberos.ticket.renew.jitter = 0.05
        sasl.kerberos.ticket.renew.window.factor = 0.8
        sasl.login.callback.handler.class = null
        sasl.login.class = null
        sasl.login.connect.timeout.ms = null
        sasl.login.read.timeout.ms = null
        sasl.login.refresh.buffer.seconds = 300
        sasl.login.refresh.min.period.seconds = 60
        sasl.login.refresh.window.factor = 0.8
        sasl.login.refresh.window.jitter = 0.05
        sasl.login.retry.backoff.max.ms = 10000
        sasl.login.retry.backoff.ms = 100
        sasl.mechanism = GSSAPI
        sasl.oauthbearer.clock.skew.seconds = 30
        sasl.oauthbearer.expected.audience = null
        sasl.oauthbearer.expected.issuer = null
        sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
        sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
        sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
        sasl.oauthbearer.jwks.endpoint.url = null
        sasl.oauthbearer.scope.claim.name = scope
        sasl.oauthbearer.sub.claim.name = sub
        sasl.oauthbearer.token.endpoint.url = null
        security.protocol = PLAINTEXT
        security.providers = null
        send.buffer.bytes = 131072
        session.timeout.ms = 10000
        socket.connection.setup.timeout.max.ms = 30000
        socket.connection.setup.timeout.ms = 10000
        ssl.cipher.suites = null
        ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
        ssl.endpoint.identification.algorithm = https
        ssl.engine.factory.class = null
        ssl.key.password = null
        ssl.keymanager.algorithm = SunX509
        ssl.keystore.certificate.chain = null
        ssl.keystore.key = null
        ssl.keystore.location = null
        ssl.keystore.password = null
        ssl.keystore.type = JKS
        ssl.protocol = TLSv1.3
        ssl.provider = null
        ssl.secure.random.implementation = null
        ssl.trustmanager.algorithm = PKIX
        ssl.truststore.certificates = null
        ssl.truststore.location = null
        ssl.truststore.password = null
        ssl.truststore.type = JKS
        value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
 (org.apache.kafka.clients.consumer.ConsumerConfig:376)
[2024-01-22 19:34:11,820] INFO [test-debezium-v25-03-source|task-0] Kafka version: 7.4.1-ccs (org.apache.kafka.common.utils.AppInfoParser:119)
[2024-01-22 19:34:11,821] INFO [test-debezium-v25-03-source|task-0] Kafka commitId: fed9c006bfc7ba5bf7d2dee840e041d1a851d903 (org.apache.kafka.common.utils.AppInfoParser:120)
[2024-01-22 19:34:11,821] INFO [test-debezium-v25-03-source|task-0] Kafka startTimeMs: 1705948451820 (org.apache.kafka.common.utils.AppInfoParser:121)
[2024-01-22 19:34:11,830] INFO [test-debezium-v25-03-source|task-0] [Consumer clientId=localhost.test25.TestTable03-schemahistory, groupId=localhost.test25.TestTable03-schemahistory] Cluster ID: ukJbw5WeQVGTixPWGoUSog (org.apache.kafka.clients.Metadata:287)
[2024-01-22 19:34:11,837] INFO [test-debezium-v25-03-source|task-0] [Consumer clientId=localhost.test25.TestTable03-schemahistory, groupId=localhost.test25.TestTable03-schemahistory] Resetting generation and member id due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1015)
[2024-01-22 19:34:11,838] INFO [test-debezium-v25-03-source|task-0] [Consumer clientId=localhost.test25.TestTable03-schemahistory, groupId=localhost.test25.TestTable03-schemahistory] Request joining group due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1062)
[2024-01-22 19:34:11,839] INFO [test-debezium-v25-03-source|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:693)
[2024-01-22 19:34:11,839] INFO [test-debezium-v25-03-source|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:697)
[2024-01-22 19:34:11,840] INFO [test-debezium-v25-03-source|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:703)
[2024-01-22 19:34:11,842] INFO [test-debezium-v25-03-source|task-0] App info kafka.consumer for localhost.test25.TestTable03-schemahistory unregistered (org.apache.kafka.common.utils.AppInfoParser:83)
[2024-01-22 19:34:11,843] INFO [test-debezium-v25-03-source|task-0] AdminClientConfig values:
        auto.include.jmx.reporter = true
        bootstrap.servers = [kafkahost:9092]
        client.dns.lookup = use_all_dns_ips
        client.id = localhost.test25.TestTable03-schemahistory
        connections.max.idle.ms = 300000
        default.api.timeout.ms = 60000
        metadata.max.age.ms = 300000
        metric.reporters = []
        metrics.num.samples = 2
        metrics.recording.level = INFO
        metrics.sample.window.ms = 30000
        receive.buffer.bytes = 65536
        reconnect.backoff.max.ms = 1000
        reconnect.backoff.ms = 50
        request.timeout.ms = 30000
        retries = 1
        retry.backoff.ms = 100
        sasl.client.callback.handler.class = null
        sasl.jaas.config = null
        sasl.kerberos.kinit.cmd = /usr/bin/kinit
        sasl.kerberos.min.time.before.relogin = 60000
        sasl.kerberos.service.name = null
        sasl.kerberos.ticket.renew.jitter = 0.05
        sasl.kerberos.ticket.renew.window.factor = 0.8
        sasl.login.callback.handler.class = null
        sasl.login.class = null
        sasl.login.connect.timeout.ms = null
        sasl.login.read.timeout.ms = null
        sasl.login.refresh.buffer.seconds = 300
        sasl.login.refresh.min.period.seconds = 60
        sasl.login.refresh.window.factor = 0.8
        sasl.login.refresh.window.jitter = 0.05
        sasl.login.retry.backoff.max.ms = 10000
        sasl.login.retry.backoff.ms = 100
        sasl.mechanism = GSSAPI
        sasl.oauthbearer.clock.skew.seconds = 30
        sasl.oauthbearer.expected.audience = null
        sasl.oauthbearer.expected.issuer = null
        sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
        sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
        sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
        sasl.oauthbearer.jwks.endpoint.url = null
        sasl.oauthbearer.scope.claim.name = scope
        sasl.oauthbearer.sub.claim.name = sub
        sasl.oauthbearer.token.endpoint.url = null
        security.protocol = PLAINTEXT
        security.providers = null
        send.buffer.bytes = 131072
        socket.connection.setup.timeout.max.ms = 30000
        socket.connection.setup.timeout.ms = 10000
        ssl.cipher.suites = null
        ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
        ssl.endpoint.identification.algorithm = https
        ssl.engine.factory.class = null
        ssl.key.password = null
        ssl.keymanager.algorithm = SunX509
        ssl.keystore.certificate.chain = null
        ssl.keystore.key = null
        ssl.keystore.location = null
        ssl.keystore.password = null
        ssl.keystore.type = JKS
        ssl.protocol = TLSv1.3
        ssl.provider = null
        ssl.secure.random.implementation = null
        ssl.trustmanager.algorithm = PKIX
        ssl.truststore.certificates = null
        ssl.truststore.location = null
        ssl.truststore.password = null
        ssl.truststore.type = JKS
 (org.apache.kafka.clients.admin.AdminClientConfig:376)
[2024-01-22 19:34:11,846] WARN [test-debezium-v25-03-source|task-0] These configurations '[value.serializer, acks, batch.size, max.block.ms, buffer.memory, key.serializer, linger.ms]' were supplied but are not used yet. (org.apache.kafka.clients.admin.AdminClientConfig:385)
[2024-01-22 19:34:11,846] INFO [test-debezium-v25-03-source|task-0] Kafka version: 7.4.1-ccs (org.apache.kafka.common.utils.AppInfoParser:119)
[2024-01-22 19:34:11,846] INFO [test-debezium-v25-03-source|task-0] Kafka commitId: fed9c006bfc7ba5bf7d2dee840e041d1a851d903 (org.apache.kafka.common.utils.AppInfoParser:120)
[2024-01-22 19:34:11,847] INFO [test-debezium-v25-03-source|task-0] Kafka startTimeMs: 1705948451846 (org.apache.kafka.common.utils.AppInfoParser:121)
[2024-01-22 19:34:12,008] INFO [test-debezium-v25-03-source|task-0] Database schema history topic '(name=_localhost.schemahistory.debezium03, numPartitions=1, replicationFactor=default, replicasAssignments=null, configs={cleanup.policy=delete, retention.ms=9223372036854775807, retention.bytes=-1})' created (io.debezium.storage.kafka.history.KafkaSchemaHistory:555)
[2024-01-22 19:34:12,011] INFO [test-debezium-v25-03-source|task-0] App info kafka.admin.client for localhost.test25.TestTable03-schemahistory unregistered (org.apache.kafka.common.utils.AppInfoParser:83)
[2024-01-22 19:34:12,015] INFO [test-debezium-v25-03-source|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:693)
[2024-01-22 19:34:12,015] INFO [test-debezium-v25-03-source|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:697)
[2024-01-22 19:34:12,017] INFO [test-debezium-v25-03-source|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:703)
[2024-01-22 19:34:12,052] INFO [test-debezium-v25-03-source|task-0] No previous offsets found (io.debezium.connector.common.BaseSourceTask:378)
[2024-01-22 19:34:12,075] INFO [test-debezium-v25-03-source|task-0] Requested thread factory for connector SqlServerConnector, id = localhost.test25.TestTable03 named = SignalProcessor (io.debezium.util.Threads:271)
[2024-01-22 19:34:12,106] INFO [test-debezium-v25-03-source|task-0] Requested thread factory for connector SqlServerConnector, id = localhost.test25.TestTable03 named = change-event-source-coordinator (io.debezium.util.Threads:271)
[2024-01-22 19:34:12,106] INFO [test-debezium-v25-03-source|task-0] Requested thread factory for connector SqlServerConnector, id = localhost.test25.TestTable03 named = blocking-snapshot (io.debezium.util.Threads:271)
[2024-01-22 19:34:12,122] INFO [test-debezium-v25-03-source|task-0] Creating thread debezium-sqlserverconnector-localhost.test25.TestTable03-change-event-source-coordinator (io.debezium.util.Threads:288)
[2024-01-22 19:34:12,132] INFO [test-debezium-v25-03-source|task-0] Metrics registered (io.debezium.pipeline.ChangeEventSourceCoordinator:131)
[2024-01-22 19:34:12,133] INFO [test-debezium-v25-03-source|task-0] Context created (io.debezium.pipeline.ChangeEventSourceCoordinator:134)
[2024-01-22 19:34:12,140] INFO [test-debezium-v25-03-source|task-0] SignalProcessor started. Scheduling it every 5000ms (io.debezium.pipeline.signal.SignalProcessor:105)
[2024-01-22 19:34:12,141] INFO [test-debezium-v25-03-source|task-0] Creating thread debezium-sqlserverconnector-localhost.test25.TestTable03-SignalProcessor (io.debezium.util.Threads:288)
[2024-01-22 19:34:12,141] INFO [test-debezium-v25-03-source|task-0] WorkerSourceTask{id=test-debezium-v25-03-source-0} Source task finished initialization and start (org.apache.kafka.connect.runtime.AbstractWorkerSourceTask:275)
[2024-01-22 19:34:12,149] INFO [test-debezium-v25-03-source|task-0] No previous offset has been found (io.debezium.connector.sqlserver.SqlServerSnapshotChangeEventSource:78)
[2024-01-22 19:34:12,150] INFO [test-debezium-v25-03-source|task-0] According to the connector configuration both schema and data will be snapshotted (io.debezium.connector.sqlserver.SqlServerSnapshotChangeEventSource:80)
[2024-01-22 19:34:12,156] INFO [test-debezium-v25-03-source|task-0] Snapshot step 1 - Preparing (io.debezium.relational.RelationalSnapshotChangeEventSource:121)
[2024-01-22 19:34:12,194] INFO [test-debezium-v25-03-source|task-0] Snapshot step 2 - Determining captured tables (io.debezium.relational.RelationalSnapshotChangeEventSource:130)
[2024-01-22 19:34:12,507] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.TestTableN03 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,507] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.TestTableN04 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,508] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.TestTableN01 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,508] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.TestTableN02 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,508] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.TestTableN07 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,509] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.TestTableN08 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,509] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.TestTableN05 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,509] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.TestTableN06 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,510] INFO [test-debezium-v25-03-source|task-0] Adding table test.test23.TestTable03c to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,510] INFO [test-debezium-v25-03-source|task-0] Adding table test.test23.TestTable03b to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,510] INFO [test-debezium-v25-03-source|task-0] Adding table test.test23.TestTable03a to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,510] INFO [test-debezium-v25-03-source|task-0] Adding table test.test23.TestTable03g to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,511] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.debezium_signal to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,511] INFO [test-debezium-v25-03-source|task-0] Adding table test.test23.TestTable03f to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,511] INFO [test-debezium-v25-03-source|task-0] Adding table test.test23.TestTable03e to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,511] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.TestTableN10 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,512] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.TestTableN11 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,512] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.OutboxTest08 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,512] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.OutboxTest09 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,512] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.OutboxTest07 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,513] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.TestTable04 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,514] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.TestTable05 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,514] INFO [test-debezium-v25-03-source|task-0] Adding table test.test23.TestTable02b to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,514] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.TestTable06 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,516] INFO [test-debezium-v25-03-source|task-0] Adding table test.test24.TestTable01 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,516] INFO [test-debezium-v25-03-source|task-0] Adding table test.test23.TestTable01 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,517] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.TestTable21b to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,517] INFO [test-debezium-v25-03-source|task-0] Adding table test.test23.Signal_TestTable06 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,518] INFO [test-debezium-v25-03-source|task-0] Adding table test.test23.Signal_TestTable05 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,518] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.TestTable10 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,518] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.TestTable11 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,518] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.TestTable12 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,519] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.OutboxTest08a to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,519] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.TestTable13 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,519] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.OutboxTest08b to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,520] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.TestTable14 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,520] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.TestTable15 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,520] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.TestTable16 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,520] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.TestTable17 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,521] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.TestTable18 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,521] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.TestTable19 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,521] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.TestTable20 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,521] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.TestTable22 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,522] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.TestTable23 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,522] INFO [test-debezium-v25-03-source|task-0] Adding table test.destold.TestTable23 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,522] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.JendaBracha to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,523] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.InsertTestTable15 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,523] INFO [test-debezium-v25-03-source|task-0] Adding table test.pkquery.InsertsTestTable to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,523] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.NewTestTable01 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,523] INFO [test-debezium-v25-03-source|task-0] Adding table test.dest24.TestTable01 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,524] INFO [test-debezium-v25-03-source|task-0] Adding table test.dest24.TestTable04 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,524] INFO [test-debezium-v25-03-source|task-0] Adding table test.dest24.TestTable02 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,524] INFO [test-debezium-v25-03-source|task-0] Adding table test.dest24.TestTable03 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,525] INFO [test-debezium-v25-03-source|task-0] Adding table test.dest25.TestTable02 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,525] INFO [test-debezium-v25-03-source|task-0] Adding table test.dest25.TestTable01 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,525] INFO [test-debezium-v25-03-source|task-0] Adding table test.dest25.TestTable03 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,525] INFO [test-debezium-v25-03-source|task-0] Adding table test.test23.TestTable06 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,526] INFO [test-debezium-v25-03-source|task-0] Adding table test.test23.TestTable05 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,526] INFO [test-debezium-v25-03-source|task-0] Adding table test.test24.TestTable02 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,526] INFO [test-debezium-v25-03-source|task-0] Adding table test.test23.TestTable07 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,526] INFO [test-debezium-v25-03-source|task-0] Adding table test.test24.TestTable03 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,526] INFO [test-debezium-v25-03-source|task-0] Adding table test.test25.TestTable03 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,527] INFO [test-debezium-v25-03-source|task-0] Adding table test.test24.TestTable04 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,527] INFO [test-debezium-v25-03-source|task-0] Adding table test.test25.TestTable02 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,527] INFO [test-debezium-v25-03-source|task-0] Adding table test.test25.TestTable01 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,527] INFO [test-debezium-v25-03-source|task-0] Adding table test.dest.TestTable06 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,528] INFO [test-debezium-v25-03-source|task-0] Adding table test.dest.TestTable07 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,528] INFO [test-debezium-v25-03-source|task-0] Adding table test.dest.TestTable05 to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,528] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.TestTableN09b to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,529] INFO [test-debezium-v25-03-source|task-0] Adding table test.dbo.TestTableN09a to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,529] INFO [test-debezium-v25-03-source|task-0] Adding table test.test23.TestTable04b to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,529] INFO [test-debezium-v25-03-source|task-0] Adding table test.test23.TestTable04a to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource:289)
[2024-01-22 19:34:12,533] INFO [test-debezium-v25-03-source|task-0] Created connection pool with 1 threads (io.debezium.relational.RelationalSnapshotChangeEventSource:222)
[2024-01-22 19:34:12,534] INFO [test-debezium-v25-03-source|task-0] Snapshot step 3 - Locking captured tables [test.test25.TestTable03] (io.debezium.relational.RelationalSnapshotChangeEventSource:139)
[2024-01-22 19:34:12,535] INFO [test-debezium-v25-03-source|task-0] Setting locking timeout to 10 s (io.debezium.connector.sqlserver.SqlServerSnapshotChangeEventSource:136)
[2024-01-22 19:34:12,543] INFO [test-debezium-v25-03-source|task-0] Executing schema locking (io.debezium.connector.sqlserver.SqlServerSnapshotChangeEventSource:141)
[2024-01-22 19:34:12,544] INFO [test-debezium-v25-03-source|task-0] Locking table test.test25.TestTable03 (io.debezium.connector.sqlserver.SqlServerSnapshotChangeEventSource:148)
[2024-01-22 19:34:12,546] INFO [test-debezium-v25-03-source|task-0] Snapshot step 4 - Determining snapshot offset (io.debezium.relational.RelationalSnapshotChangeEventSource:145)
[2024-01-22 19:34:12,565] INFO [test-debezium-v25-03-source|task-0] Snapshot step 5 - Reading structure of captured tables (io.debezium.relational.RelationalSnapshotChangeEventSource:148)
[2024-01-22 19:34:12,606] INFO [test-debezium-v25-03-source|task-0] Reading structure of schema 'test' (io.debezium.connector.sqlserver.SqlServerSnapshotChangeEventSource:210)
[2024-01-22 19:34:13,027] INFO [test-debezium-v25-03-source|task-0] Snapshot step 6 - Persisting schema history (io.debezium.relational.RelationalSnapshotChangeEventSource:152)
[2024-01-22 19:34:13,028] INFO [test-debezium-v25-03-source|task-0] Capturing structure of table test.test25.TestTable03 (io.debezium.relational.RelationalSnapshotChangeEventSource:367)
[2024-01-22 19:45:53,926] INFO [test-debezium-v25-03-source|task-0] [Producer clientId=localhost.test25.TestTable03-schemahistory] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:937)
[2024-01-22 19:45:53,926] INFO [test-debezium-v25-03-source|task-0] [Producer clientId=connector-producer-test-debezium-v25-03-source-0] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:937)