Attaching to debezium-connector-1
debezium-connector-1  | Using BOOTSTRAP_SERVERS=10.2.67.197:9094,10.2.67.198:9094,10.2.67.199:9094
debezium-connector-1  | Plugins are loaded from /kafka/connect
debezium-connector-1  | Using the following environment variables:
debezium-connector-1  |       GROUP_ID=vcr-cdc
debezium-connector-1  |       CONFIG_STORAGE_TOPIC=vcr-cdc-config
debezium-connector-1  |       OFFSET_STORAGE_TOPIC=vcr-cdc-offset
debezium-connector-1  |       STATUS_STORAGE_TOPIC=vcr-cdc-status
debezium-connector-1  |       BOOTSTRAP_SERVERS=10.2.67.197:9094,10.2.67.198:9094,10.2.67.199:9094
debezium-connector-1  |       REST_HOST_NAME=172.19.0.2
debezium-connector-1  |       REST_PORT=8083
debezium-connector-1  |       ADVERTISED_HOST_NAME=172.19.0.2
debezium-connector-1  |       ADVERTISED_PORT=8083
debezium-connector-1  |       KEY_CONVERTER=org.apache.kafka.connect.json.JsonConverter
debezium-connector-1  |       VALUE_CONVERTER=org.apache.kafka.connect.json.JsonConverter
debezium-connector-1  |       OFFSET_FLUSH_INTERVAL_MS=60000
debezium-connector-1  |       OFFSET_FLUSH_TIMEOUT_MS=5000
debezium-connector-1  |       SHUTDOWN_TIMEOUT=10000
debezium-connector-1  | --- Setting property from CONNECT_REST_ADVERTISED_PORT: rest.advertised.port=8083
debezium-connector-1  | --- Setting property from CONNECT_PRODUCER_SSL_ENDPOINT_IDENTIFICATION_ALGORITHM: producer.ssl.endpoint.identification.algorithm=
debezium-connector-1  | --- Setting property from CONNECT_PRODUCER_SSL_TRUSTSTORE_PASSWORD: producer.ssl.truststore.password=[hidden]
debezium-connector-1  | --- Setting property from CONNECT_CONSUMER_SSL_TRUSTSTORE_PASSWORD: consumer.ssl.truststore.password=[hidden]
debezium-connector-1  | --- Setting property from CONNECT_OFFSET_STORAGE_TOPIC: offset.storage.topic=vcr-cdc-offset
debezium-connector-1  | --- Setting property from CONNECT_SASL_JAAS_CONFIG: sasl.jaas.config=[hidden]
debezium-connector-1  | --- Setting property from CONNECT_KEY_CONVERTER: key.converter=org.apache.kafka.connect.json.JsonConverter
debezium-connector-1  | --- Setting property from CONNECT_CONFIG_STORAGE_TOPIC: config.storage.topic=vcr-cdc-config
debezium-connector-1  | --- Setting property from CONNECT_GROUP_ID: group.id=vcr-cdc
debezium-connector-1  | --- Setting property from CONNECT_REST_ADVERTISED_HOST_NAME: rest.advertised.host.name=172.19.0.2
debezium-connector-1  | --- Setting property from CONNECT_SSL_TRUSTSTORE_TYPE: ssl.truststore.type=JKS
debezium-connector-1  | --- Setting property from CONNECT_REST_HOST_NAME: rest.host.name=172.19.0.2
debezium-connector-1  | --- Setting property from CONNECT_PRODUCER_SASL_MECHANISM: producer.sasl.mechanism=SCRAM-SHA-512
debezium-connector-1  | --- Setting property from CONNECT_SSL_TRUSTSTORE_LOCATION: ssl.truststore.location=/etc/kafka/server.truststore
debezium-connector-1  | --- Setting property from CONNECT_PRODUCER_SECURITY_PROTOCOL: producer.security.protocol=SASL_SSL
debezium-connector-1  | --- Setting property from CONNECT_PRODUCER_SASL_JAAS_CONFIG: producer.sasl.jaas.config=[hidden]
debezium-connector-1  | --- Setting property from CONNECT_VALUE_CONVERTER: value.converter=org.apache.kafka.connect.json.JsonConverter
debezium-connector-1  | --- Setting property from CONNECT_CONSUMER_SASL_JAAS_CONFIG: consumer.sasl.jaas.config=[hidden]
debezium-connector-1  | --- Setting property from CONNECT_CONFIG_PROVIDERS_FILE_CLASS: config.providers.file.class=org.apache.kafka.common.config.provider.FileConfigProvider
debezium-connector-1  | --- Setting property from CONNECT_SECURITY_PROTOCOL: security.protocol=SASL_SSL
debezium-connector-1  | --- Setting property from CONNECT_CONSUMER_SSL_ENDPOINT_IDENTIFICATION_ALGORITHM: consumer.ssl.endpoint.identification.algorithm=
debezium-connector-1  | --- Setting property from CONNECT_SSL_TRUSTSTORE_PASSWORD: ssl.truststore.password=[hidden]
debezium-connector-1  | --- Setting property from CONNECT_REST_PORT: rest.port=8083
debezium-connector-1  | --- Setting property from CONNECT_STATUS_STORAGE_TOPIC: status.storage.topic=vcr-cdc-status
debezium-connector-1  | --- Setting property from CONNECT_CONFIG_PROVIDERS: config.providers=file
debezium-connector-1  | --- Setting property from CONNECT_OFFSET_FLUSH_TIMEOUT_MS: offset.flush.timeout.ms=5000
debezium-connector-1  | --- Setting property from CONNECT_CONSUMER_SASL_MECHANISM: consumer.sasl.mechanism=SCRAM-SHA-512
debezium-connector-1  | --- Setting property from CONNECT_PRODUCER_SSL_TRUSTSTORE_LOCATION: producer.ssl.truststore.location=/etc/kafka/server.truststore
debezium-connector-1  | --- Setting property from CONNECT_SSL_ENDPOINT_IDENTIFICATION_ALGORITHM: ssl.endpoint.identification.algorithm=
debezium-connector-1  | --- Setting property from CONNECT_PLUGIN_PATH: plugin.path=/kafka/connect
debezium-connector-1  | --- Setting property from CONNECT_CONSUMER_SSL_TRUSTSTORE_LOCATION: consumer.ssl.truststore.location=/etc/kafka/server.truststore
debezium-connector-1  | --- Setting property from CONNECT_CONSUMER_SECURITY_PROTOCOL: consumer.security.protocol=SASL_SSL
debezium-connector-1  | --- Setting property from CONNECT_OFFSET_FLUSH_INTERVAL_MS: offset.flush.interval.ms=60000
debezium-connector-1  | --- Setting property from CONNECT_BOOTSTRAP_SERVERS: bootstrap.servers=10.2.67.197:9094,10.2.67.198:9094,10.2.67.199:9094
debezium-connector-1  | --- Setting property from CONNECT_TASK_SHUTDOWN_GRACEFUL_TIMEOUT_MS: task.shutdown.graceful.timeout.ms=10000
debezium-connector-1  | --- Setting property from CONNECT_SASL_MECHANISM: sasl.mechanism=SCRAM-SHA-512
debezium-connector-1  | 2024-10-28 11:29:55,300 INFO   ||  Kafka Connect worker initializing ...   [org.apache.kafka.connect.cli.AbstractConnectCli]
debezium-connector-1  | 2024-10-28 11:29:55,302 INFO   ||  WorkerInfo values: 
debezium-connector-1  | 	jvm.args = -Xms256M, -Xmx2G, -XX:+UseG1GC, -XX:MaxGCPauseMillis=20, -XX:InitiatingHeapOccupancyPercent=35, -XX:+ExplicitGCInvokesConcurrent, -XX:MaxInlineLevel=15, -Djava.awt.headless=true, -Dcom.sun.management.jmxremote, -Dcom.sun.management.jmxremote.authenticate=false, -Dcom.sun.management.jmxremote.ssl=false, -Dkafka.logs.dir=/kafka/logs, -Dlog4j.configuration=file:/kafka/config/log4j.properties
debezium-connector-1  | 	jvm.spec = Red Hat, Inc., OpenJDK 64-Bit Server VM, 21.0.4, 21.0.4+7
debezium-connector-1  | 	jvm.classpath = /kafka/libs/activation-1.1.1.jar:/kafka/libs/aopalliance-repackaged-2.6.1.jar:/kafka/libs/argparse4j-0.7.0.jar:/kafka/libs/audience-annotations-0.12.0.jar:/kafka/libs/caffeine-2.9.3.jar:/kafka/libs/checker-qual-3.19.0.jar:/kafka/libs/commons-beanutils-1.9.4.jar:/kafka/libs/commons-cli-1.4.jar:/kafka/libs/commons-collections-3.2.2.jar:/kafka/libs/commons-digester-2.1.jar:/kafka/libs/commons-io-2.11.0.jar:/kafka/libs/commons-lang3-3.8.1.jar:/kafka/libs/commons-logging-1.2.jar:/kafka/libs/commons-validator-1.7.jar:/kafka/libs/connect-api-3.7.0.jar:/kafka/libs/connect-basic-auth-extension-3.7.0.jar:/kafka/libs/connect-json-3.7.0.jar:/kafka/libs/connect-mirror-3.7.0.jar:/kafka/libs/connect-mirror-client-3.7.0.jar:/kafka/libs/connect-runtime-3.7.0.jar:/kafka/libs/connect-transforms-3.7.0.jar:/kafka/libs/error_prone_annotations-2.10.0.jar:/kafka/libs/hk2-api-2.6.1.jar:/kafka/libs/hk2-locator-2.6.1.jar:/kafka/libs/hk2-utils-2.6.1.jar:/kafka/libs/jackson-annotations-2.16.0.jar:/kafka/libs/jackson-core-2.16.0.jar:/kafka/libs/jackson-databind-2.16.0.jar:/kafka/libs/jackson-dataformat-csv-2.16.0.jar:/kafka/libs/jackson-datatype-jdk8-2.16.0.jar:/kafka/libs/jackson-jaxrs-base-2.16.0.jar:/kafka/libs/jackson-jaxrs-json-provider-2.16.0.jar:/kafka/libs/jackson-module-jaxb-annotations-2.16.0.jar:/kafka/libs/jackson-module-scala_2.13-2.16.0.jar:/kafka/libs/jakarta.activation-api-1.2.2.jar:/kafka/libs/jakarta.annotation-api-1.3.5.jar:/kafka/libs/jakarta.inject-2.6.1.jar:/kafka/libs/jakarta.validation-api-2.0.2.jar:/kafka/libs/jakarta.ws.rs-api-2.1.6.jar:/kafka/libs/jakarta.xml.bind-api-2.3.3.jar:/kafka/libs/javassist-3.29.2-GA.jar:/kafka/libs/javax.activation-api-1.2.0.jar:/kafka/libs/javax.annotation-api-1.3.2.jar:/kafka/libs/javax.servlet-api-3.1.0.jar:/kafka/libs/javax.ws.rs-api-2.1.1.jar:/kafka/libs/jaxb-api-2.3.1.jar:/kafka/libs/jersey-client-2.39.1.jar:/kafka/libs/jersey-common-2.39.1.jar:/kafka/libs/jersey-container-servlet-2.39.1.jar:/kafka/libs/jersey-container-servlet-core-2.39.1.jar:/kafka/libs/jersey-hk2-2.39.1.jar:/kafka/libs/jersey-server-2.39.1.jar:/kafka/libs/jetty-client-9.4.53.v20231009.jar:/kafka/libs/jetty-continuation-9.4.53.v20231009.jar:/kafka/libs/jetty-http-9.4.53.v20231009.jar:/kafka/libs/jetty-io-9.4.53.v20231009.jar:/kafka/libs/jetty-security-9.4.53.v20231009.jar:/kafka/libs/jetty-server-9.4.53.v20231009.jar:/kafka/libs/jetty-servlet-9.4.53.v20231009.jar:/kafka/libs/jetty-servlets-9.4.53.v20231009.jar:/kafka/libs/jetty-util-9.4.53.v20231009.jar:/kafka/libs/jetty-util-ajax-9.4.53.v20231009.jar:/kafka/libs/jline-3.22.0.jar:/kafka/libs/jolokia-jvm-1.7.2.jar:/kafka/libs/jopt-simple-5.0.4.jar:/kafka/libs/jose4j-0.9.4.jar:/kafka/libs/jsr305-3.0.2.jar:/kafka/libs/kafka-clients-3.7.0.jar:/kafka/libs/kafka-group-coordinator-3.7.0.jar:/kafka/libs/kafka-log4j-appender-3.7.0.jar:/kafka/libs/kafka-metadata-3.7.0.jar:/kafka/libs/kafka-raft-3.7.0.jar:/kafka/libs/kafka-server-3.7.0.jar:/kafka/libs/kafka-server-common-3.7.0.jar:/kafka/libs/kafka-shell-3.7.0.jar:/kafka/libs/kafka-storage-3.7.0.jar:/kafka/libs/kafka-storage-api-3.7.0.jar:/kafka/libs/kafka-streams-3.7.0.jar:/kafka/libs/kafka-streams-examples-3.7.0.jar:/kafka/libs/kafka-streams-scala_2.13-3.7.0.jar:/kafka/libs/kafka-streams-test-utils-3.7.0.jar:/kafka/libs/kafka-tools-3.7.0.jar:/kafka/libs/kafka-tools-api-3.7.0.jar:/kafka/libs/kafka_2.13-3.7.0.jar:/kafka/libs/lz4-java-1.8.0.jar:/kafka/libs/maven-artifact-3.8.8.jar:/kafka/libs/metrics-core-2.2.0.jar:/kafka/libs/metrics-core-4.1.12.1.jar:/kafka/libs/netty-buffer-4.1.100.Final.jar:/kafka/libs/netty-codec-4.1.100.Final.jar:/kafka/libs/netty-common-4.1.100.Final.jar:/kafka/libs/netty-handler-4.1.100.Final.jar:/kafka/libs/netty-resolver-4.1.100.Final.jar:/kafka/libs/netty-transport-4.1.100.Final.jar:/kafka/libs/netty-transport-classes-epoll-4.1.100.Final.jar:/kafka/libs/netty-transport-native-epoll-4.1.100.Final.jar:/kafka/libs/netty-transport-native-unix-common-4.1.100.Final.jar:/kafka/libs/opentelemetry-proto-1.0.0-alpha.jar:/kafka/libs/osgi-resource-locator-1.0.3.jar:/kafka/libs/paranamer-2.8.jar:/kafka/libs/pcollections-4.0.1.jar:/kafka/libs/plexus-utils-3.3.1.jar:/kafka/libs/protobuf-java-3.23.4.jar:/kafka/libs/reflections-0.10.2.jar:/kafka/libs/reload4j-1.2.25.jar:/kafka/libs/rocksdbjni-7.9.2.jar:/kafka/libs/scala-collection-compat_2.13-2.10.0.jar:/kafka/libs/scala-java8-compat_2.13-1.0.2.jar:/kafka/libs/scala-library-2.13.12.jar:/kafka/libs/scala-logging_2.13-3.9.4.jar:/kafka/libs/scala-reflect-2.13.12.jar:/kafka/libs/slf4j-api-1.7.36.jar:/kafka/libs/slf4j-reload4j-1.7.36.jar:/kafka/libs/snappy-java-1.1.10.5.jar:/kafka/libs/swagger-annotations-2.2.8.jar:/kafka/libs/trogdor-3.7.0.jar:/kafka/libs/zookeeper-3.8.3.jar:/kafka/libs/zookeeper-jute-3.8.3.jar:/kafka/libs/zstd-jni-1.5.5-6.jar
debezium-connector-1  | 	os.spec = Linux, amd64, 5.15.0-43-generic
debezium-connector-1  | 	os.vcpus = 4
debezium-connector-1  |    [org.apache.kafka.connect.runtime.WorkerInfo]
debezium-connector-1  | 2024-10-28 11:29:55,303 INFO   ||  Scanning for plugin classes. This might take a moment ...   [org.apache.kafka.connect.cli.AbstractConnectCli]
debezium-connector-1  | 2024-10-28 11:29:55,335 INFO   ||  Loading plugin from: /kafka/connect/debezium-connector-mongodb   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:55,374 INFO   ||  Using up-to-date JsonConverter implementation   [io.debezium.converters.CloudEventsConverter]
debezium-connector-1  | 2024-10-28 11:29:55,538 INFO   ||  Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-mongodb/}   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:55,539 INFO   ||  Loading plugin from: /kafka/connect/debezium-connector-postgres   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:55,547 INFO   ||  Using up-to-date JsonConverter implementation   [io.debezium.converters.CloudEventsConverter]
debezium-connector-1  | 2024-10-28 11:29:55,573 INFO   ||  Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-postgres/}   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:55,576 INFO   ||  Loading plugin from: /kafka/connect/debezium-connector-db2   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:55,583 INFO   ||  Using up-to-date JsonConverter implementation   [io.debezium.converters.CloudEventsConverter]
debezium-connector-1  | 2024-10-28 11:29:55,610 INFO   ||  Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-db2/}   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:55,611 INFO   ||  Loading plugin from: /kafka/connect/debezium-connector-vitess   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:55,622 INFO   ||  Using up-to-date JsonConverter implementation   [io.debezium.converters.CloudEventsConverter]
debezium-connector-1  | 2024-10-28 11:29:55,647 INFO   ||  Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-vitess/}   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:55,647 INFO   ||  Loading plugin from: /kafka/connect/debezium-connector-mariadb   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:55,659 INFO   ||  Using up-to-date JsonConverter implementation   [io.debezium.converters.CloudEventsConverter]
debezium-connector-1  | 2024-10-28 11:29:55,683 INFO   ||  Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-mariadb/}   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:55,685 INFO   ||  Loading plugin from: /kafka/connect/debezium-connector-sqlserver   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:55,694 INFO   ||  Using up-to-date JsonConverter implementation   [io.debezium.converters.CloudEventsConverter]
debezium-connector-1  | 2024-10-28 11:29:55,717 INFO   ||  Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-sqlserver/}   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:55,798 INFO   ||  Loading plugin from: /kafka/connect/debezium-connector-informix   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:55,804 INFO   ||  Using up-to-date JsonConverter implementation   [io.debezium.converters.CloudEventsConverter]
debezium-connector-1  | 2024-10-28 11:29:55,830 INFO   ||  Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-informix/}   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:55,830 INFO   ||  Loading plugin from: /kafka/connect/debezium-connector-jdbc   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:55,843 INFO   ||  Using up-to-date JsonConverter implementation   [io.debezium.converters.CloudEventsConverter]
debezium-connector-1  | 2024-10-28 11:29:55,867 INFO   ||  Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-jdbc/}   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:55,924 INFO   ||  Loading plugin from: /kafka/connect/debezium-connector-spanner   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:55,954 INFO   ||  Using up-to-date JsonConverter implementation   [io.debezium.converters.CloudEventsConverter]
debezium-connector-1  | 2024-10-28 11:29:55,977 INFO   ||  Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-spanner/}   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:55,977 INFO   ||  Loading plugin from: /kafka/connect/debezium-connector-ibmi   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:55,984 INFO   ||  Using up-to-date JsonConverter implementation   [io.debezium.converters.CloudEventsConverter]
debezium-connector-1  | 2024-10-28 11:29:56,013 INFO   ||  Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-ibmi/}   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:56,024 INFO   ||  Loading plugin from: /kafka/connect/debezium-connector-oracle   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:56,042 INFO   ||  Using up-to-date JsonConverter implementation   [io.debezium.converters.CloudEventsConverter]
debezium-connector-1  | 2024-10-28 11:29:56,064 INFO   ||  Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-oracle/}   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:56,087 INFO   ||  Loading plugin from: /kafka/connect/debezium-connector-mysql   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:56,099 INFO   ||  Using up-to-date JsonConverter implementation   [io.debezium.converters.CloudEventsConverter]
debezium-connector-1  | 2024-10-28 11:29:56,126 INFO   ||  Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-mysql/}   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:56,129 INFO   ||  Loading plugin from: classpath   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:56,132 INFO   ||  Registered loader: jdk.internal.loader.ClassLoaders$AppClassLoader@c387f44   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:56,133 INFO   ||  Scanning plugins with ServiceLoaderScanner took 799 ms   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:56,134 INFO   ||  Loading plugin from: /kafka/connect/debezium-connector-mongodb   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:56,419 INFO   ||  Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-mongodb/}   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:56,419 INFO   ||  Loading plugin from: /kafka/connect/debezium-connector-postgres   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:56,576 INFO   ||  Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-postgres/}   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:56,577 INFO   ||  Loading plugin from: /kafka/connect/debezium-connector-db2   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:56,642 INFO   ||  Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-db2/}   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:56,643 INFO   ||  Loading plugin from: /kafka/connect/debezium-connector-vitess   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:57,158 INFO   ||  Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-vitess/}   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:57,159 INFO   ||  Loading plugin from: /kafka/connect/debezium-connector-mariadb   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:57,446 INFO   ||  Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-mariadb/}   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:57,447 INFO   ||  Loading plugin from: /kafka/connect/debezium-connector-sqlserver   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:57,541 INFO   ||  Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-sqlserver/}   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:57,546 INFO   ||  Loading plugin from: /kafka/connect/debezium-connector-informix   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:57,598 INFO   ||  Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-informix/}   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:57,598 INFO   ||  Loading plugin from: /kafka/connect/debezium-connector-jdbc   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:58,271 INFO   ||  Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-jdbc/}   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:58,276 INFO   ||  Loading plugin from: /kafka/connect/debezium-connector-spanner   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:59,025 INFO   ||  Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-spanner/}   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:59,025 INFO   ||  Loading plugin from: /kafka/connect/debezium-connector-ibmi   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:59,149 INFO   ||  Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-ibmi/}   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:59,150 INFO   ||  Loading plugin from: /kafka/connect/debezium-connector-oracle   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:59,673 INFO   ||  Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-oracle/}   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:29:59,673 INFO   ||  Loading plugin from: /kafka/connect/debezium-connector-mysql   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:30:00,002 INFO   ||  Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-mysql/}   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:30:00,003 INFO   ||  Loading plugin from: classpath   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:30:00,710 INFO   ||  Registered loader: jdk.internal.loader.ClassLoaders$AppClassLoader@c387f44   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:30:00,710 INFO   ||  Scanning plugins with ReflectionScanner took 4576 ms   [org.apache.kafka.connect.runtime.isolation.PluginScanner]
debezium-connector-1  | 2024-10-28 11:30:00,714 WARN   ||  One or more plugins are missing ServiceLoader manifests may not be usable with plugin.discovery=service_load: [
debezium-connector-1  | file:/kafka/connect/debezium-connector-vitess/	io.debezium.connector.vitess.transforms.FilterTransactionTopicRecords	transformation	2.7.3.Final
debezium-connector-1  | file:/kafka/connect/debezium-connector-vitess/	io.debezium.connector.vitess.transforms.RemoveField	transformation	2.7.3.Final
debezium-connector-1  | file:/kafka/connect/debezium-connector-vitess/	io.debezium.connector.vitess.transforms.UseLocalVgtid	transformation	2.7.3.Final
debezium-connector-1  | ]
debezium-connector-1  | Read the documentation at https://kafka.apache.org/documentation.html#connect_plugindiscovery for instructions on migrating your plugins to take advantage of the performance improvements of service_load mode. To silence this warning, set plugin.discovery=only_scan in the worker config.   [org.apache.kafka.connect.runtime.isolation.Plugins]
debezium-connector-1  | 2024-10-28 11:30:00,715 INFO   ||  Added plugin 'org.apache.kafka.connect.transforms.Filter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,715 INFO   ||  Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,715 INFO   ||  Added plugin 'io.debezium.connector.vitess.transforms.FilterTransactionTopicRecords'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,715 INFO   ||  Added plugin 'org.apache.kafka.connect.converters.DoubleConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,715 INFO   ||  Added plugin 'org.apache.kafka.connect.transforms.DropHeaders'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,715 INFO   ||  Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,716 INFO   ||  Added plugin 'org.apache.kafka.connect.transforms.InsertHeader'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,716 INFO   ||  Added plugin 'io.debezium.connector.mariadb.MariaDbConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,716 INFO   ||  Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,716 INFO   ||  Added plugin 'io.debezium.connector.postgresql.transforms.timescaledb.TimescaleDb'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,716 INFO   ||  Added plugin 'org.apache.kafka.connect.transforms.HeaderFrom$Value'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,716 INFO   ||  Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,716 INFO   ||  Added plugin 'io.debezium.transforms.ExtractNewRecordState'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,716 INFO   ||  Added plugin 'io.debezium.converters.ByteArrayConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,717 INFO   ||  Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,717 INFO   ||  Added plugin 'io.debezium.transforms.outbox.EventRouter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,717 INFO   ||  Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,717 INFO   ||  Added plugin 'io.debezium.connector.mongodb.transforms.outbox.MongoEventRouter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,717 INFO   ||  Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,717 INFO   ||  Added plugin 'org.apache.kafka.connect.transforms.Cast$Value'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,717 INFO   ||  Added plugin 'io.debezium.connector.db2as400.smt.RepackageJavaFriendlySchemaRenamer'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,717 INFO   ||  Added plugin 'io.debezium.connector.vitess.transforms.UseLocalVgtid'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,717 INFO   ||  Added plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,718 INFO   ||  Added plugin 'io.debezium.connector.postgresql.rest.DebeziumPostgresConnectRestExtension'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,718 INFO   ||  Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,718 INFO   ||  Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,718 INFO   ||  Added plugin 'io.debezium.transforms.HeaderToValue'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,718 INFO   ||  Added plugin 'org.apache.kafka.connect.transforms.RegexRouter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,718 INFO   ||  Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,718 INFO   ||  Added plugin 'io.debezium.connector.jdbc.transforms.ConvertCloudEventToSaveableForm'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,718 INFO   ||  Added plugin 'org.apache.kafka.connect.json.JsonConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,718 INFO   ||  Added plugin 'io.debezium.connector.informix.InformixConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,718 INFO   ||  Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,718 INFO   ||  Added plugin 'org.apache.kafka.common.config.provider.EnvVarConfigProvider'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,719 INFO   ||  Added plugin 'io.debezium.transforms.ExtractChangedRecordState'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,719 INFO   ||  Added plugin 'io.debezium.connector.mongodb.transforms.ExtractNewDocumentState'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,719 INFO   ||  Added plugin 'org.apache.kafka.connect.storage.StringConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,719 INFO   ||  Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,719 INFO   ||  Added plugin 'io.debezium.connector.mysql.transforms.ReadToInsertEvent'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,719 INFO   ||  Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,719 INFO   ||  Added plugin 'org.apache.kafka.connect.converters.BooleanConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,719 INFO   ||  Added plugin 'io.debezium.connector.postgresql.PostgresConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,719 INFO   ||  Added plugin 'io.debezium.connector.sqlserver.rest.DebeziumSqlServerConnectRestExtension'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,719 INFO   ||  Added plugin 'org.apache.kafka.connect.converters.ShortConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,719 INFO   ||  Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,720 INFO   ||  Added plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,720 INFO   ||  Added plugin 'io.debezium.connector.spanner.SpannerConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,720 INFO   ||  Added plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,720 INFO   ||  Added plugin 'io.debezium.connector.sqlserver.SqlServerConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,720 INFO   ||  Added plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,720 INFO   ||  Added plugin 'io.debezium.connector.mariadb.rest.DebeziumMariaDbConnectRestExtension'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,720 INFO   ||  Added plugin 'org.apache.kafka.connect.transforms.Cast$Key'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,720 INFO   ||  Added plugin 'io.debezium.converters.BinaryDataConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,720 INFO   ||  Added plugin 'org.apache.kafka.common.config.provider.DirectoryConfigProvider'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,720 INFO   ||  Added plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,721 INFO   ||  Added plugin 'io.debezium.connector.mongodb.MongoDbConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,721 INFO   ||  Added plugin 'io.debezium.transforms.partitions.PartitionRouting'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,721 INFO   ||  Added plugin 'io.debezium.connector.jdbc.JdbcSinkConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,721 INFO   ||  Added plugin 'org.apache.kafka.connect.transforms.predicates.TopicNameMatches'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,721 INFO   ||  Added plugin 'io.debezium.connector.vitess.VitessConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,721 INFO   ||  Added plugin 'org.apache.kafka.connect.converters.IntegerConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,721 INFO   ||  Added plugin 'org.apache.kafka.connect.transforms.predicates.RecordIsTombstone'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,722 INFO   ||  Added plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,722 INFO   ||  Added plugin 'io.debezium.connector.mysql.MySqlConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,722 INFO   ||  Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,722 INFO   ||  Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,722 INFO   ||  Added plugin 'org.apache.kafka.connect.converters.FloatConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,722 INFO   ||  Added plugin 'io.debezium.connector.oracle.OracleConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,722 INFO   ||  Added plugin 'io.debezium.transforms.SchemaChangeEventFilter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,722 INFO   ||  Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,722 INFO   ||  Added plugin 'io.debezium.transforms.ExtractSchemaToNewRecord'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,722 INFO   ||  Added plugin 'io.debezium.connector.db2.Db2Connector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,722 INFO   ||  Added plugin 'io.debezium.transforms.ByLogicalTableRouter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,723 INFO   ||  Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,723 INFO   ||  Added plugin 'org.apache.kafka.connect.transforms.ValueToKey'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,723 INFO   ||  Added plugin 'org.apache.kafka.connect.converters.LongConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,723 INFO   ||  Added plugin 'io.debezium.connector.db2as400.As400RpcConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,723 INFO   ||  Added plugin 'io.debezium.connector.mongodb.rest.DebeziumMongoDbConnectRestExtension'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,723 INFO   ||  Added plugin 'io.debezium.transforms.TimezoneConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,723 INFO   ||  Added plugin 'org.apache.kafka.connect.transforms.HeaderFrom$Key'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,723 INFO   ||  Added plugin 'org.apache.kafka.connect.transforms.predicates.HasHeaderKey'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,723 INFO   ||  Added plugin 'io.debezium.transforms.tracing.ActivateTracingSpan'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,723 INFO   ||  Added plugin 'io.debezium.connector.mysql.rest.DebeziumMySqlConnectRestExtension'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,723 INFO   ||  Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,723 INFO   ||  Added plugin 'io.debezium.connector.vitess.transforms.RemoveField'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,723 INFO   ||  Added plugin 'io.debezium.connector.oracle.rest.DebeziumOracleConnectRestExtension'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,724 INFO   ||  Added plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,724 INFO   ||  Added plugin 'io.debezium.converters.CloudEventsConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,724 INFO   ||  Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,726 INFO   ||  Added alias 'VitessConnector' to plugin 'io.debezium.connector.vitess.VitessConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,726 INFO   ||  Added alias 'As400RpcConnector' to plugin 'io.debezium.connector.db2as400.As400RpcConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,726 INFO   ||  Added alias 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,726 INFO   ||  Added alias 'MySql' to plugin 'io.debezium.connector.mysql.MySqlConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,726 INFO   ||  Added alias 'MirrorCheckpointConnector' to plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,726 INFO   ||  Added alias 'HeaderToValue' to plugin 'io.debezium.transforms.HeaderToValue'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,726 INFO   ||  Added alias 'RepackageJavaFriendlySchemaRenamer' to plugin 'io.debezium.connector.db2as400.smt.RepackageJavaFriendlySchemaRenamer'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,726 INFO   ||  Added alias 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,726 INFO   ||  Added alias 'RemoveField' to plugin 'io.debezium.connector.vitess.transforms.RemoveField'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,726 INFO   ||  Added alias 'SimpleHeaderConverter' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,726 INFO   ||  Added alias 'SqlServerConnector' to plugin 'io.debezium.connector.sqlserver.SqlServerConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,726 INFO   ||  Added alias 'DirectoryConfigProvider' to plugin 'org.apache.kafka.common.config.provider.DirectoryConfigProvider'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,726 INFO   ||  Added alias 'TimezoneConverter' to plugin 'io.debezium.transforms.TimezoneConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,726 INFO   ||  Added alias 'BasicAuthSecurityRestExtension' to plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,726 INFO   ||  Added alias 'Simple' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,726 INFO   ||  Added alias 'DebeziumPostgres' to plugin 'io.debezium.connector.postgresql.rest.DebeziumPostgresConnectRestExtension'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,727 INFO   ||  Added alias 'AllConnectorClientConfigOverridePolicy' to plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,727 INFO   ||  Added alias 'MirrorSource' to plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,727 INFO   ||  Added alias 'Directory' to plugin 'org.apache.kafka.common.config.provider.DirectoryConfigProvider'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,727 INFO   ||  Added alias 'DebeziumMariaDb' to plugin 'io.debezium.connector.mariadb.rest.DebeziumMariaDbConnectRestExtension'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,727 INFO   ||  Added alias 'MirrorHeartbeat' to plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,727 INFO   ||  Added alias 'BooleanConverter' to plugin 'org.apache.kafka.connect.converters.BooleanConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,727 INFO   ||  Added alias 'JsonConverter' to plugin 'org.apache.kafka.connect.json.JsonConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,727 INFO   ||  Added alias 'DebeziumMySql' to plugin 'io.debezium.connector.mysql.rest.DebeziumMySqlConnectRestExtension'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,727 INFO   ||  Added alias 'FilterTransactionTopicRecords' to plugin 'io.debezium.connector.vitess.transforms.FilterTransactionTopicRecords'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,727 INFO   ||  Added alias 'JdbcSinkConnector' to plugin 'io.debezium.connector.jdbc.JdbcSinkConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,728 INFO   ||  Added alias 'DebeziumPostgresConnectRestExtension' to plugin 'io.debezium.connector.postgresql.rest.DebeziumPostgresConnectRestExtension'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,728 INFO   ||  Added alias 'SpannerConnector' to plugin 'io.debezium.connector.spanner.SpannerConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,728 INFO   ||  Added alias 'MongoDb' to plugin 'io.debezium.connector.mongodb.MongoDbConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,728 INFO   ||  Added alias 'Postgres' to plugin 'io.debezium.connector.postgresql.PostgresConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,728 INFO   ||  Added alias 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,728 INFO   ||  Added alias 'ByLogicalTableRouter' to plugin 'io.debezium.transforms.ByLogicalTableRouter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,728 INFO   ||  Added alias 'FileConfigProvider' to plugin 'org.apache.kafka.common.config.provider.FileConfigProvider'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,728 INFO   ||  Added alias 'SchemaChangeEventFilter' to plugin 'io.debezium.transforms.SchemaChangeEventFilter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,729 INFO   ||  Added alias 'ConvertCloudEventToSaveableForm' to plugin 'io.debezium.connector.jdbc.transforms.ConvertCloudEventToSaveableForm'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,729 INFO   ||  Added alias 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,729 INFO   ||  Added alias 'FloatConverter' to plugin 'org.apache.kafka.connect.converters.FloatConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,729 INFO   ||  Added alias 'Spanner' to plugin 'io.debezium.connector.spanner.SpannerConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,729 INFO   ||  Added alias 'MariaDb' to plugin 'io.debezium.connector.mariadb.MariaDbConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,729 INFO   ||  Added alias 'ActivateTracingSpan' to plugin 'io.debezium.transforms.tracing.ActivateTracingSpan'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,729 INFO   ||  Added alias 'DebeziumSqlServerConnectRestExtension' to plugin 'io.debezium.connector.sqlserver.rest.DebeziumSqlServerConnectRestExtension'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,729 INFO   ||  Added alias 'UseLocalVgtid' to plugin 'io.debezium.connector.vitess.transforms.UseLocalVgtid'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,730 INFO   ||  Added alias 'MirrorHeartbeatConnector' to plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,730 INFO   ||  Added alias 'Oracle' to plugin 'io.debezium.connector.oracle.OracleConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,730 INFO   ||  Added alias 'PrincipalConnectorClientConfigOverridePolicy' to plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,730 INFO   ||  Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,730 INFO   ||  Added alias 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,730 INFO   ||  Added alias 'Filter' to plugin 'org.apache.kafka.connect.transforms.Filter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,730 INFO   ||  Added alias 'Informix' to plugin 'io.debezium.connector.informix.InformixConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,730 INFO   ||  Added alias 'DebeziumMariaDbConnectRestExtension' to plugin 'io.debezium.connector.mariadb.rest.DebeziumMariaDbConnectRestExtension'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,730 INFO   ||  Added alias 'ExtractNewDocumentState' to plugin 'io.debezium.connector.mongodb.transforms.ExtractNewDocumentState'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,730 INFO   ||  Added alias 'RecordIsTombstone' to plugin 'org.apache.kafka.connect.transforms.predicates.RecordIsTombstone'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,731 INFO   ||  Added alias 'CloudEventsConverter' to plugin 'io.debezium.converters.CloudEventsConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,731 INFO   ||  Added alias 'DebeziumOracle' to plugin 'io.debezium.connector.oracle.rest.DebeziumOracleConnectRestExtension'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,731 INFO   ||  Added alias 'EnvVar' to plugin 'org.apache.kafka.common.config.provider.EnvVarConfigProvider'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,731 INFO   ||  Added alias 'EnvVarConfigProvider' to plugin 'org.apache.kafka.common.config.provider.EnvVarConfigProvider'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,731 INFO   ||  Added alias 'Boolean' to plugin 'org.apache.kafka.connect.converters.BooleanConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,731 INFO   ||  Added alias 'MySqlConnector' to plugin 'io.debezium.connector.mysql.MySqlConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,731 INFO   ||  Added alias 'MariaDbConnector' to plugin 'io.debezium.connector.mariadb.MariaDbConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,731 INFO   ||  Added alias 'DebeziumSqlServer' to plugin 'io.debezium.connector.sqlserver.rest.DebeziumSqlServerConnectRestExtension'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,732 INFO   ||  Added alias 'PartitionRouting' to plugin 'io.debezium.transforms.partitions.PartitionRouting'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,732 INFO   ||  Added alias 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,732 INFO   ||  Added alias 'StringConverter' to plugin 'org.apache.kafka.connect.storage.StringConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,732 INFO   ||  Added alias 'MongoDbConnector' to plugin 'io.debezium.connector.mongodb.MongoDbConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,732 INFO   ||  Added alias 'IntegerConverter' to plugin 'org.apache.kafka.connect.converters.IntegerConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,732 INFO   ||  Added alias 'LongConverter' to plugin 'org.apache.kafka.connect.converters.LongConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,732 INFO   ||  Added alias 'DropHeaders' to plugin 'org.apache.kafka.connect.transforms.DropHeaders'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,732 INFO   ||  Added alias 'ExtractSchemaToNewRecord' to plugin 'io.debezium.transforms.ExtractSchemaToNewRecord'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,733 INFO   ||  Added alias 'BinaryData' to plugin 'io.debezium.converters.BinaryDataConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,733 INFO   ||  Added alias 'ReadToInsertEvent' to plugin 'io.debezium.connector.mysql.transforms.ReadToInsertEvent'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,733 INFO   ||  Added alias 'ShortConverter' to plugin 'org.apache.kafka.connect.converters.ShortConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,733 INFO   ||  Added alias 'CloudEvents' to plugin 'io.debezium.converters.CloudEventsConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,733 INFO   ||  Added alias 'DebeziumOracleConnectRestExtension' to plugin 'io.debezium.connector.oracle.rest.DebeziumOracleConnectRestExtension'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,733 INFO   ||  Added alias 'ExtractNewRecordState' to plugin 'io.debezium.transforms.ExtractNewRecordState'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,733 INFO   ||  Added alias 'DebeziumMongoDb' to plugin 'io.debezium.connector.mongodb.rest.DebeziumMongoDbConnectRestExtension'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,733 INFO   ||  Added alias 'Db2' to plugin 'io.debezium.connector.db2.Db2Connector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,734 INFO   ||  Added alias 'Db2Connector' to plugin 'io.debezium.connector.db2.Db2Connector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,734 INFO   ||  Added alias 'Vitess' to plugin 'io.debezium.connector.vitess.VitessConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,734 INFO   ||  Added alias 'InformixConnector' to plugin 'io.debezium.connector.informix.InformixConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,734 INFO   ||  Added alias 'DebeziumMongoDbConnectRestExtension' to plugin 'io.debezium.connector.mongodb.rest.DebeziumMongoDbConnectRestExtension'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,734 INFO   ||  Added alias 'HasHeaderKey' to plugin 'org.apache.kafka.connect.transforms.predicates.HasHeaderKey'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,734 INFO   ||  Added alias 'MirrorCheckpoint' to plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,734 INFO   ||  Added alias 'ExtractChangedRecordState' to plugin 'io.debezium.transforms.ExtractChangedRecordState'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,734 INFO   ||  Added alias 'OracleConnector' to plugin 'io.debezium.connector.oracle.OracleConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,735 INFO   ||  Added alias 'None' to plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,735 INFO   ||  Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,735 INFO   ||  Added alias 'Principal' to plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,735 INFO   ||  Added alias 'All' to plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,735 INFO   ||  Added alias 'SqlServer' to plugin 'io.debezium.connector.sqlserver.SqlServerConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,735 INFO   ||  Added alias 'DebeziumMySqlConnectRestExtension' to plugin 'io.debezium.connector.mysql.rest.DebeziumMySqlConnectRestExtension'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,735 INFO   ||  Added alias 'JdbcSink' to plugin 'io.debezium.connector.jdbc.JdbcSinkConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,735 INFO   ||  Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,736 INFO   ||  Added alias 'NoneConnectorClientConfigOverridePolicy' to plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,736 INFO   ||  Added alias 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,736 INFO   ||  Added alias 'EventRouter' to plugin 'io.debezium.transforms.outbox.EventRouter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,736 INFO   ||  Added alias 'File' to plugin 'org.apache.kafka.common.config.provider.FileConfigProvider'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,736 INFO   ||  Added alias 'DoubleConverter' to plugin 'org.apache.kafka.connect.converters.DoubleConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,736 INFO   ||  Added alias 'BinaryDataConverter' to plugin 'io.debezium.converters.BinaryDataConverter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,736 INFO   ||  Added alias 'TimescaleDb' to plugin 'io.debezium.connector.postgresql.transforms.timescaledb.TimescaleDb'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,736 INFO   ||  Added alias 'TopicNameMatches' to plugin 'org.apache.kafka.connect.transforms.predicates.TopicNameMatches'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,737 INFO   ||  Added alias 'InsertHeader' to plugin 'org.apache.kafka.connect.transforms.InsertHeader'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,737 INFO   ||  Added alias 'MirrorSourceConnector' to plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,737 INFO   ||  Added alias 'PostgresConnector' to plugin 'io.debezium.connector.postgresql.PostgresConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,737 INFO   ||  Added alias 'MongoEventRouter' to plugin 'io.debezium.connector.mongodb.transforms.outbox.MongoEventRouter'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,737 INFO   ||  Added alias 'As400Rpc' to plugin 'io.debezium.connector.db2as400.As400RpcConnector'   [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader]
debezium-connector-1  | 2024-10-28 11:30:00,761 INFO   ||  DistributedConfig values: 
debezium-connector-1  | 	access.control.allow.methods = 
debezium-connector-1  | 	access.control.allow.origin = 
debezium-connector-1  | 	admin.listeners = null
debezium-connector-1  | 	auto.include.jmx.reporter = true
debezium-connector-1  | 	bootstrap.servers = [10.2.67.197:9094, 10.2.67.198:9094, 10.2.67.199:9094]
debezium-connector-1  | 	client.dns.lookup = use_all_dns_ips
debezium-connector-1  | 	client.id = 
debezium-connector-1  | 	config.providers = [file]
debezium-connector-1  | 	config.storage.replication.factor = 1
debezium-connector-1  | 	config.storage.topic = vcr-cdc-config
debezium-connector-1  | 	connect.protocol = sessioned
debezium-connector-1  | 	connections.max.idle.ms = 540000
debezium-connector-1  | 	connector.client.config.override.policy = All
debezium-connector-1  | 	exactly.once.source.support = disabled
debezium-connector-1  | 	group.id = vcr-cdc
debezium-connector-1  | 	header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter
debezium-connector-1  | 	heartbeat.interval.ms = 3000
debezium-connector-1  | 	inter.worker.key.generation.algorithm = HmacSHA256
debezium-connector-1  | 	inter.worker.key.size = null
debezium-connector-1  | 	inter.worker.key.ttl.ms = 3600000
debezium-connector-1  | 	inter.worker.signature.algorithm = HmacSHA256
debezium-connector-1  | 	inter.worker.verification.algorithms = [HmacSHA256]
debezium-connector-1  | 	key.converter = class org.apache.kafka.connect.json.JsonConverter
debezium-connector-1  | 	listeners = [http://:8083]
debezium-connector-1  | 	metadata.max.age.ms = 300000
debezium-connector-1  | 	metric.reporters = []
debezium-connector-1  | 	metrics.num.samples = 2
debezium-connector-1  | 	metrics.recording.level = INFO
debezium-connector-1  | 	metrics.sample.window.ms = 30000
debezium-connector-1  | 	offset.flush.interval.ms = 60000
debezium-connector-1  | 	offset.flush.timeout.ms = 5000
debezium-connector-1  | 	offset.storage.partitions = 25
debezium-connector-1  | 	offset.storage.replication.factor = 1
debezium-connector-1  | 	offset.storage.topic = vcr-cdc-offset
debezium-connector-1  | 	plugin.discovery = hybrid_warn
debezium-connector-1  | 	plugin.path = [/kafka/connect]
debezium-connector-1  | 	rebalance.timeout.ms = 60000
debezium-connector-1  | 	receive.buffer.bytes = 32768
debezium-connector-1  | 	reconnect.backoff.max.ms = 1000
debezium-connector-1  | 	reconnect.backoff.ms = 50
debezium-connector-1  | 	request.timeout.ms = 40000
debezium-connector-1  | 	response.http.headers.config = 
debezium-connector-1  | 	rest.advertised.host.name = 172.19.0.2
debezium-connector-1  | 	rest.advertised.listener = null
debezium-connector-1  | 	rest.advertised.port = 8083
debezium-connector-1  | 	rest.extension.classes = []
debezium-connector-1  | 	retry.backoff.max.ms = 1000
debezium-connector-1  | 	retry.backoff.ms = 100
debezium-connector-1  | 	sasl.client.callback.handler.class = null
debezium-connector-1  | 	sasl.jaas.config = [hidden]
debezium-connector-1  | 	sasl.kerberos.kinit.cmd = /usr/bin/kinit
debezium-connector-1  | 	sasl.kerberos.min.time.before.relogin = 60000
debezium-connector-1  | 	sasl.kerberos.service.name = null
debezium-connector-1  | 	sasl.kerberos.ticket.renew.jitter = 0.05
debezium-connector-1  | 	sasl.kerberos.ticket.renew.window.factor = 0.8
debezium-connector-1  | 	sasl.login.callback.handler.class = null
debezium-connector-1  | 	sasl.login.class = null
debezium-connector-1  | 	sasl.login.connect.timeout.ms = null
debezium-connector-1  | 	sasl.login.read.timeout.ms = null
debezium-connector-1  | 	sasl.login.refresh.buffer.seconds = 300
debezium-connector-1  | 	sasl.login.refresh.min.period.seconds = 60
debezium-connector-1  | 	sasl.login.refresh.window.factor = 0.8
debezium-connector-1  | 	sasl.login.refresh.window.jitter = 0.05
debezium-connector-1  | 	sasl.login.retry.backoff.max.ms = 10000
debezium-connector-1  | 	sasl.login.retry.backoff.ms = 100
debezium-connector-1  | 	sasl.mechanism = SCRAM-SHA-512
debezium-connector-1  | 	sasl.oauthbearer.clock.skew.seconds = 30
debezium-connector-1  | 	sasl.oauthbearer.expected.audience = null
debezium-connector-1  | 	sasl.oauthbearer.expected.issuer = null
debezium-connector-1  | 	sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
debezium-connector-1  | 	sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
debezium-connector-1  | 	sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
debezium-connector-1  | 	sasl.oauthbearer.jwks.endpoint.url = null
debezium-connector-1  | 	sasl.oauthbearer.scope.claim.name = scope
debezium-connector-1  | 	sasl.oauthbearer.sub.claim.name = sub
debezium-connector-1  | 	sasl.oauthbearer.token.endpoint.url = null
debezium-connector-1  | 	scheduled.rebalance.max.delay.ms = 300000
debezium-connector-1  | 	security.protocol = SASL_SSL
debezium-connector-1  | 	send.buffer.bytes = 131072
debezium-connector-1  | 	session.timeout.ms = 10000
debezium-connector-1  | 	socket.connection.setup.timeout.max.ms = 30000
debezium-connector-1  | 	socket.connection.setup.timeout.ms = 10000
debezium-connector-1  | 	ssl.cipher.suites = null
debezium-connector-1  | 	ssl.client.auth = none
debezium-connector-1  | 	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
debezium-connector-1  | 	ssl.endpoint.identification.algorithm = 
debezium-connector-1  | 	ssl.engine.factory.class = null
debezium-connector-1  | 	ssl.key.password = null
debezium-connector-1  | 	ssl.keymanager.algorithm = SunX509
debezium-connector-1  | 	ssl.keystore.certificate.chain = null
debezium-connector-1  | 	ssl.keystore.key = null
debezium-connector-1  | 	ssl.keystore.location = null
debezium-connector-1  | 	ssl.keystore.password = null
debezium-connector-1  | 	ssl.keystore.type = JKS
debezium-connector-1  | 	ssl.protocol = TLSv1.3
debezium-connector-1  | 	ssl.provider = null
debezium-connector-1  | 	ssl.secure.random.implementation = null
debezium-connector-1  | 	ssl.trustmanager.algorithm = PKIX
debezium-connector-1  | 	ssl.truststore.certificates = null
debezium-connector-1  | 	ssl.truststore.location = /etc/kafka/server.truststore
debezium-connector-1  | 	ssl.truststore.password = [hidden]
debezium-connector-1  | 	ssl.truststore.type = JKS
debezium-connector-1  | 	status.storage.partitions = 5
debezium-connector-1  | 	status.storage.replication.factor = 1
debezium-connector-1  | 	status.storage.topic = vcr-cdc-status
debezium-connector-1  | 	task.shutdown.graceful.timeout.ms = 10000
debezium-connector-1  | 	topic.creation.enable = true
debezium-connector-1  | 	topic.tracking.allow.reset = true
debezium-connector-1  | 	topic.tracking.enable = true
debezium-connector-1  | 	value.converter = class org.apache.kafka.connect.json.JsonConverter
debezium-connector-1  | 	worker.sync.timeout.ms = 3000
debezium-connector-1  | 	worker.unsync.backoff.ms = 300000
debezium-connector-1  |    [org.apache.kafka.connect.runtime.distributed.DistributedConfig]
debezium-connector-1  | 2024-10-28 11:30:00,763 INFO   ||  Creating Kafka admin client   [org.apache.kafka.connect.runtime.WorkerConfig]
debezium-connector-1  | 2024-10-28 11:30:00,765 INFO   ||  AdminClientConfig values: 
debezium-connector-1  | 	auto.include.jmx.reporter = true
debezium-connector-1  | 	bootstrap.controllers = []
debezium-connector-1  | 	bootstrap.servers = [10.2.67.197:9094, 10.2.67.198:9094, 10.2.67.199:9094]
debezium-connector-1  | 	client.dns.lookup = use_all_dns_ips
debezium-connector-1  | 	client.id = 
debezium-connector-1  | 	connections.max.idle.ms = 300000
debezium-connector-1  | 	default.api.timeout.ms = 60000
debezium-connector-1  | 	enable.metrics.push = true
debezium-connector-1  | 	metadata.max.age.ms = 300000
debezium-connector-1  | 	metric.reporters = []
debezium-connector-1  | 	metrics.num.samples = 2
debezium-connector-1  | 	metrics.recording.level = INFO
debezium-connector-1  | 	metrics.sample.window.ms = 30000
debezium-connector-1  | 	receive.buffer.bytes = 65536
debezium-connector-1  | 	reconnect.backoff.max.ms = 1000
debezium-connector-1  | 	reconnect.backoff.ms = 50
debezium-connector-1  | 	request.timeout.ms = 30000
debezium-connector-1  | 	retries = 2147483647
debezium-connector-1  | 	retry.backoff.max.ms = 1000
debezium-connector-1  | 	retry.backoff.ms = 100
debezium-connector-1  | 	sasl.client.callback.handler.class = null
debezium-connector-1  | 	sasl.jaas.config = [hidden]
debezium-connector-1  | 	sasl.kerberos.kinit.cmd = /usr/bin/kinit
debezium-connector-1  | 	sasl.kerberos.min.time.before.relogin = 60000
debezium-connector-1  | 	sasl.kerberos.service.name = null
debezium-connector-1  | 	sasl.kerberos.ticket.renew.jitter = 0.05
debezium-connector-1  | 	sasl.kerberos.ticket.renew.window.factor = 0.8
debezium-connector-1  | 	sasl.login.callback.handler.class = null
debezium-connector-1  | 	sasl.login.class = null
debezium-connector-1  | 	sasl.login.connect.timeout.ms = null
debezium-connector-1  | 	sasl.login.read.timeout.ms = null
debezium-connector-1  | 	sasl.login.refresh.buffer.seconds = 300
debezium-connector-1  | 	sasl.login.refresh.min.period.seconds = 60
debezium-connector-1  | 	sasl.login.refresh.window.factor = 0.8
debezium-connector-1  | 	sasl.login.refresh.window.jitter = 0.05
debezium-connector-1  | 	sasl.login.retry.backoff.max.ms = 10000
debezium-connector-1  | 	sasl.login.retry.backoff.ms = 100
debezium-connector-1  | 	sasl.mechanism = SCRAM-SHA-512
debezium-connector-1  | 	sasl.oauthbearer.clock.skew.seconds = 30
debezium-connector-1  | 	sasl.oauthbearer.expected.audience = null
debezium-connector-1  | 	sasl.oauthbearer.expected.issuer = null
debezium-connector-1  | 	sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
debezium-connector-1  | 	sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
debezium-connector-1  | 	sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
debezium-connector-1  | 	sasl.oauthbearer.jwks.endpoint.url = null
debezium-connector-1  | 	sasl.oauthbearer.scope.claim.name = scope
debezium-connector-1  | 	sasl.oauthbearer.sub.claim.name = sub
debezium-connector-1  | 	sasl.oauthbearer.token.endpoint.url = null
debezium-connector-1  | 	security.protocol = SASL_SSL
debezium-connector-1  | 	security.providers = null
debezium-connector-1  | 	send.buffer.bytes = 131072
debezium-connector-1  | 	socket.connection.setup.timeout.max.ms = 30000
debezium-connector-1  | 	socket.connection.setup.timeout.ms = 10000
debezium-connector-1  | 	ssl.cipher.suites = null
debezium-connector-1  | 	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
debezium-connector-1  | 	ssl.endpoint.identification.algorithm = 
debezium-connector-1  | 	ssl.engine.factory.class = null
debezium-connector-1  | 	ssl.key.password = null
debezium-connector-1  | 	ssl.keymanager.algorithm = SunX509
debezium-connector-1  | 	ssl.keystore.certificate.chain = null
debezium-connector-1  | 	ssl.keystore.key = null
debezium-connector-1  | 	ssl.keystore.location = null
debezium-connector-1  | 	ssl.keystore.password = null
debezium-connector-1  | 	ssl.keystore.type = JKS
debezium-connector-1  | 	ssl.protocol = TLSv1.3
debezium-connector-1  | 	ssl.provider = null
debezium-connector-1  | 	ssl.secure.random.implementation = null
debezium-connector-1  | 	ssl.trustmanager.algorithm = PKIX
debezium-connector-1  | 	ssl.truststore.certificates = null
debezium-connector-1  | 	ssl.truststore.location = /etc/kafka/server.truststore
debezium-connector-1  | 	ssl.truststore.password = [hidden]
debezium-connector-1  | 	ssl.truststore.type = JKS
debezium-connector-1  |    [org.apache.kafka.clients.admin.AdminClientConfig]
debezium-connector-1  | 2024-10-28 11:30:00,801 INFO   ||  Successfully logged in.   [org.apache.kafka.common.security.authenticator.AbstractLogin]
debezium-connector-1  | 2024-10-28 11:30:00,843 INFO   ||  These configurations '[producer.sasl.jaas.config, consumer.ssl.endpoint.identification.algorithm, producer.ssl.truststore.password, group.id, rest.advertised.port, task.shutdown.graceful.timeout.ms, plugin.path, config.providers, consumer.sasl.mechanism, consumer.ssl.truststore.location, producer.ssl.truststore.location, status.storage.replication.factor, config.providers.file.class, offset.storage.topic, consumer.security.protocol, value.converter, key.converter, consumer.ssl.truststore.password, consumer.sasl.jaas.config, config.storage.topic, producer.security.protocol, rest.advertised.host.name, status.storage.topic, rest.host.name, offset.flush.timeout.ms, producer.sasl.mechanism, config.storage.replication.factor, offset.flush.interval.ms, rest.port, key.converter.schemas.enable, value.converter.schemas.enable, offset.storage.replication.factor, producer.ssl.endpoint.identification.algorithm]' were supplied but are not used yet.   [org.apache.kafka.clients.admin.AdminClientConfig]
debezium-connector-1  | 2024-10-28 11:30:00,843 INFO   ||  Kafka version: 3.7.0   [org.apache.kafka.common.utils.AppInfoParser]
debezium-connector-1  | 2024-10-28 11:30:00,843 INFO   ||  Kafka commitId: 2ae524ed625438c5   [org.apache.kafka.common.utils.AppInfoParser]
debezium-connector-1  | 2024-10-28 11:30:00,844 INFO   ||  Kafka startTimeMs: 1730115000843   [org.apache.kafka.common.utils.AppInfoParser]
debezium-connector-1  | 2024-10-28 11:30:01,125 INFO   ||  [AdminClient clientId=adminclient-1] Failed authentication with 10.2.67.199/10.2.67.199 (channelId=-3) (SSL handshake failed)   [org.apache.kafka.common.network.Selector]
debezium-connector-1  | 2024-10-28 11:30:01,126 INFO   ||  [AdminClient clientId=adminclient-1] Node -3 disconnected.   [org.apache.kafka.clients.NetworkClient]
debezium-connector-1  | 2024-10-28 11:30:01,127 ERROR  ||  [AdminClient clientId=adminclient-1] Connection to node -3 (10.2.67.199/10.2.67.199:9094) failed authentication due to: SSL handshake failed   [org.apache.kafka.clients.NetworkClient]
debezium-connector-1  | 2024-10-28 11:30:01,128 WARN   ||  [AdminClient clientId=adminclient-1] Metadata update failed due to authentication error   [org.apache.kafka.clients.admin.internals.AdminMetadataManager]
debezium-connector-1  | org.apache.kafka.common.errors.SslAuthenticationException: SSL handshake failed
debezium-connector-1  | Caused by: javax.net.ssl.SSLHandshakeException: PKIX path validation failed: java.security.cert.CertPathValidatorException: signature check failed
debezium-connector-1  | 	at java.base/sun.security.ssl.Alert.createSSLException(Alert.java:130)
debezium-connector-1  | 	at java.base/sun.security.ssl.TransportContext.fatal(TransportContext.java:378)
debezium-connector-1  | 	at java.base/sun.security.ssl.TransportContext.fatal(TransportContext.java:321)
debezium-connector-1  | 	at java.base/sun.security.ssl.TransportContext.fatal(TransportContext.java:316)
debezium-connector-1  | 	at java.base/sun.security.ssl.CertificateMessage$T13CertificateConsumer.checkServerCerts(CertificateMessage.java:1318)
debezium-connector-1  | 	at java.base/sun.security.ssl.CertificateMessage$T13CertificateConsumer.onConsumeCertificate(CertificateMessage.java:1195)
debezium-connector-1  | 	at java.base/sun.security.ssl.CertificateMessage$T13CertificateConsumer.consume(CertificateMessage.java:1138)
debezium-connector-1  | 	at java.base/sun.security.ssl.SSLHandshake.consume(SSLHandshake.java:393)
debezium-connector-1  | 	at java.base/sun.security.ssl.HandshakeContext.dispatch(HandshakeContext.java:476)
debezium-connector-1  | 	at java.base/sun.security.ssl.SSLEngineImpl$DelegatedTask$DelegatedAction.run(SSLEngineImpl.java:1273)
debezium-connector-1  | 	at java.base/sun.security.ssl.SSLEngineImpl$DelegatedTask$DelegatedAction.run(SSLEngineImpl.java:1260)
debezium-connector-1  | 	at java.base/java.security.AccessController.doPrivileged(AccessController.java:714)
debezium-connector-1  | 	at java.base/sun.security.ssl.SSLEngineImpl$DelegatedTask.run(SSLEngineImpl.java:1205)
debezium-connector-1  | 	at org.apache.kafka.common.network.SslTransportLayer.runDelegatedTasks(SslTransportLayer.java:435)
debezium-connector-1  | 	at org.apache.kafka.common.network.SslTransportLayer.handshakeUnwrap(SslTransportLayer.java:523)
debezium-connector-1  | 	at org.apache.kafka.common.network.SslTransportLayer.doHandshake(SslTransportLayer.java:373)
debezium-connector-1  | 	at org.apache.kafka.common.network.SslTransportLayer.handshake(SslTransportLayer.java:293)
debezium-connector-1  | 	at org.apache.kafka.common.network.KafkaChannel.prepare(KafkaChannel.java:178)
debezium-connector-1  | 	at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:543)
debezium-connector-1  | 	at org.apache.kafka.common.network.Selector.poll(Selector.java:481)
debezium-connector-1  | 	at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:585)
debezium-connector-1  | 	at org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.processRequests(KafkaAdminClient.java:1504)
debezium-connector-1  | 	at org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.run(KafkaAdminClient.java:1435)
debezium-connector-1  | 	at java.base/java.lang.Thread.run(Thread.java:1583)
debezium-connector-1  | Caused by: sun.security.validator.ValidatorException: PKIX path validation failed: java.security.cert.CertPathValidatorException: signature check failed
debezium-connector-1  | 	at java.base/sun.security.validator.PKIXValidator.doValidate(PKIXValidator.java:318)
debezium-connector-1  | 	at java.base/sun.security.validator.PKIXValidator.engineValidate(PKIXValidator.java:267)
debezium-connector-1  | 	at java.base/sun.security.validator.Validator.validate(Validator.java:256)
debezium-connector-1  | 	at java.base/sun.security.ssl.X509TrustManagerImpl.checkTrusted(X509TrustManagerImpl.java:284)
debezium-connector-1  | 	at java.base/sun.security.ssl.X509TrustManagerImpl.checkServerTrusted(X509TrustManagerImpl.java:144)
debezium-connector-1  | 	at java.base/sun.security.ssl.CertificateMessage$T13CertificateConsumer.checkServerCerts(CertificateMessage.java:1296)
debezium-connector-1  | 	... 19 more
debezium-connector-1  | Caused by: java.security.cert.CertPathValidatorException: signature check failed
debezium-connector-1  | 	at java.base/sun.security.provider.certpath.PKIXMasterCertPathValidator.validate(PKIXMasterCertPathValidator.java:135)
debezium-connector-1  | 	at java.base/sun.security.provider.certpath.PKIXCertPathValidator.validate(PKIXCertPathValidator.java:224)
debezium-connector-1  | 	at java.base/sun.security.provider.certpath.PKIXCertPathValidator.validate(PKIXCertPathValidator.java:144)
debezium-connector-1  | 	at java.base/sun.security.provider.certpath.PKIXCertPathValidator.engineValidate(PKIXCertPathValidator.java:83)
debezium-connector-1  | 	at java.base/java.security.cert.CertPathValidator.validate(CertPathValidator.java:309)
debezium-connector-1  | 	at java.base/sun.security.validator.PKIXValidator.doValidate(PKIXValidator.java:313)
debezium-connector-1  | 	... 24 more
debezium-connector-1  | Caused by: java.security.SignatureException: Signature does not match.
debezium-connector-1  | 	at java.base/sun.security.x509.X509CertImpl.verify(X509CertImpl.java:371)
debezium-connector-1  | 	at java.base/sun.security.provider.certpath.BasicChecker.verifySignature(BasicChecker.java:166)
debezium-connector-1  | 	at java.base/sun.security.provider.certpath.BasicChecker.check(BasicChecker.java:147)
debezium-connector-1  | 	at java.base/sun.security.provider.certpath.PKIXMasterCertPathValidator.validate(PKIXMasterCertPathValidator.java:125)
debezium-connector-1  | 	... 29 more
debezium-connector-1  | 2024-10-28 11:30:01,137 INFO   ||  App info kafka.admin.client for adminclient-1 unregistered   [org.apache.kafka.common.utils.AppInfoParser]
debezium-connector-1  | 2024-10-28 11:30:01,138 INFO   ||  [AdminClient clientId=adminclient-1] Metadata update failed   [org.apache.kafka.clients.admin.internals.AdminMetadataManager]
debezium-connector-1  | org.apache.kafka.common.errors.TimeoutException: Timed out waiting to send the call. Call: fetchMetadata
debezium-connector-1  | 2024-10-28 11:30:01,138 INFO   ||  [AdminClient clientId=adminclient-1] Metadata update failed   [org.apache.kafka.clients.admin.internals.AdminMetadataManager]
debezium-connector-1  | org.apache.kafka.common.errors.TimeoutException: Timed out waiting to send the call. Call: fetchMetadata
debezium-connector-1  | 2024-10-28 11:30:01,138 INFO   ||  [AdminClient clientId=adminclient-1] Timed out 2 remaining operation(s) during close.   [org.apache.kafka.clients.admin.KafkaAdminClient]
debezium-connector-1  | 2024-10-28 11:30:01,141 INFO   ||  Metrics scheduler closed   [org.apache.kafka.common.metrics.Metrics]
debezium-connector-1  | 2024-10-28 11:30:01,142 INFO   ||  Closing reporter org.apache.kafka.common.metrics.JmxReporter   [org.apache.kafka.common.metrics.Metrics]
debezium-connector-1  | 2024-10-28 11:30:01,142 INFO   ||  Metrics reporters closed   [org.apache.kafka.common.metrics.Metrics]
debezium-connector-1  | 2024-10-28 11:30:01,142 ERROR  ||  Stopping due to error   [org.apache.kafka.connect.cli.AbstractConnectCli]
debezium-connector-1  | org.apache.kafka.connect.errors.ConnectException: Failed to connect to and describe Kafka cluster. Check worker's broker connection and security properties.
debezium-connector-1  | 	at org.apache.kafka.connect.runtime.WorkerConfig.lookupKafkaClusterId(WorkerConfig.java:305)
debezium-connector-1  | 	at org.apache.kafka.connect.runtime.WorkerConfig.lookupKafkaClusterId(WorkerConfig.java:285)
debezium-connector-1  | 	at org.apache.kafka.connect.runtime.WorkerConfig.kafkaClusterId(WorkerConfig.java:415)
debezium-connector-1  | 	at org.apache.kafka.connect.cli.AbstractConnectCli.startConnect(AbstractConnectCli.java:124)
debezium-connector-1  | 	at org.apache.kafka.connect.cli.AbstractConnectCli.run(AbstractConnectCli.java:94)
debezium-connector-1  | 	at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:116)
debezium-connector-1  | Caused by: java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.SslAuthenticationException: SSL handshake failed
debezium-connector-1  | 	at java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396)
debezium-connector-1  | 	at java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073)
debezium-connector-1  | 	at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:165)
debezium-connector-1  | 	at org.apache.kafka.connect.runtime.WorkerConfig.lookupKafkaClusterId(WorkerConfig.java:299)
debezium-connector-1  | 	... 5 more
debezium-connector-1  | Caused by: org.apache.kafka.common.errors.SslAuthenticationException: SSL handshake failed
debezium-connector-1  | Caused by: javax.net.ssl.SSLHandshakeException: PKIX path validation failed: java.security.cert.CertPathValidatorException: signature check failed
debezium-connector-1  | 	at java.base/sun.security.ssl.Alert.createSSLException(Alert.java:130)
debezium-connector-1  | 	at java.base/sun.security.ssl.TransportContext.fatal(TransportContext.java:378)
debezium-connector-1  | 	at java.base/sun.security.ssl.TransportContext.fatal(TransportContext.java:321)
debezium-connector-1  | 	at java.base/sun.security.ssl.TransportContext.fatal(TransportContext.java:316)
debezium-connector-1  | 	at java.base/sun.security.ssl.CertificateMessage$T13CertificateConsumer.checkServerCerts(CertificateMessage.java:1318)
debezium-connector-1  | 	at java.base/sun.security.ssl.CertificateMessage$T13CertificateConsumer.onConsumeCertificate(CertificateMessage.java:1195)
debezium-connector-1  | 	at java.base/sun.security.ssl.CertificateMessage$T13CertificateConsumer.consume(CertificateMessage.java:1138)
debezium-connector-1  | 	at java.base/sun.security.ssl.SSLHandshake.consume(SSLHandshake.java:393)
debezium-connector-1  | 	at java.base/sun.security.ssl.HandshakeContext.dispatch(HandshakeContext.java:476)
debezium-connector-1  | 	at java.base/sun.security.ssl.SSLEngineImpl$DelegatedTask$DelegatedAction.run(SSLEngineImpl.java:1273)
debezium-connector-1  | 	at java.base/sun.security.ssl.SSLEngineImpl$DelegatedTask$DelegatedAction.run(SSLEngineImpl.java:1260)
debezium-connector-1  | 	at java.base/java.security.AccessController.doPrivileged(AccessController.java:714)
debezium-connector-1  | 	at java.base/sun.security.ssl.SSLEngineImpl$DelegatedTask.run(SSLEngineImpl.java:1205)
debezium-connector-1  | 	at org.apache.kafka.common.network.SslTransportLayer.runDelegatedTasks(SslTransportLayer.java:435)
debezium-connector-1  | 	at org.apache.kafka.common.network.SslTransportLayer.handshakeUnwrap(SslTransportLayer.java:523)
debezium-connector-1  | 	at org.apache.kafka.common.network.SslTransportLayer.doHandshake(SslTransportLayer.java:373)
debezium-connector-1  | 	at org.apache.kafka.common.network.SslTransportLayer.handshake(SslTransportLayer.java:293)
debezium-connector-1  | 	at org.apache.kafka.common.network.KafkaChannel.prepare(KafkaChannel.java:178)
debezium-connector-1  | 	at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:543)
debezium-connector-1  | 	at org.apache.kafka.common.network.Selector.poll(Selector.java:481)
debezium-connector-1  | 	at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:585)
debezium-connector-1  | 	at org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.processRequests(KafkaAdminClient.java:1504)
debezium-connector-1  | 	at org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.run(KafkaAdminClient.java:1435)
debezium-connector-1  | 	at java.base/java.lang.Thread.run(Thread.java:1583)
debezium-connector-1  | Caused by: sun.security.validator.ValidatorException: PKIX path validation failed: java.security.cert.CertPathValidatorException: signature check failed
debezium-connector-1  | 	at java.base/sun.security.validator.PKIXValidator.doValidate(PKIXValidator.java:318)
debezium-connector-1  | 	at java.base/sun.security.validator.PKIXValidator.engineValidate(PKIXValidator.java:267)
debezium-connector-1  | 	at java.base/sun.security.validator.Validator.validate(Validator.java:256)
debezium-connector-1  | 	at java.base/sun.security.ssl.X509TrustManagerImpl.checkTrusted(X509TrustManagerImpl.java:284)
debezium-connector-1  | 	at java.base/sun.security.ssl.X509TrustManagerImpl.checkServerTrusted(X509TrustManagerImpl.java:144)
debezium-connector-1  | 	at java.base/sun.security.ssl.CertificateMessage$T13CertificateConsumer.checkServerCerts(CertificateMessage.java:1296)
debezium-connector-1  | 	... 19 more
debezium-connector-1  | Caused by: java.security.cert.CertPathValidatorException: signature check failed
debezium-connector-1  | 	at java.base/sun.security.provider.certpath.PKIXMasterCertPathValidator.validate(PKIXMasterCertPathValidator.java:135)
debezium-connector-1  | 	at java.base/sun.security.provider.certpath.PKIXCertPathValidator.validate(PKIXCertPathValidator.java:224)
debezium-connector-1  | 	at java.base/sun.security.provider.certpath.PKIXCertPathValidator.validate(PKIXCertPathValidator.java:144)
debezium-connector-1  | 	at java.base/sun.security.provider.certpath.PKIXCertPathValidator.engineValidate(PKIXCertPathValidator.java:83)
debezium-connector-1  | 	at java.base/java.security.cert.CertPathValidator.validate(CertPathValidator.java:309)
debezium-connector-1  | 	at java.base/sun.security.validator.PKIXValidator.doValidate(PKIXValidator.java:313)
debezium-connector-1  | 	... 24 more
debezium-connector-1  | Caused by: java.security.SignatureException: Signature does not match.
debezium-connector-1  | 	at java.base/sun.security.x509.X509CertImpl.verify(X509CertImpl.java:371)
debezium-connector-1  | 	at java.base/sun.security.provider.certpath.BasicChecker.verifySignature(BasicChecker.java:166)
debezium-connector-1  | 	at java.base/sun.security.provider.certpath.BasicChecker.check(BasicChecker.java:147)
debezium-connector-1  | 	at java.base/sun.security.provider.certpath.PKIXMasterCertPathValidator.validate(PKIXMasterCertPathValidator.java:125)
debezium-connector-1  | 	... 29 more
debezium-connector-1 exited with code 2