Preparing truststore Preparing truststore is complete Starting Kafka Connect with configuration: # Bootstrap servers bootstrap.servers=pkc-41973.westus2.azure.confluent.cloud:9092 # REST Listeners rest.port=8083 rest.advertised.host.name=debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc rest.advertised.port=8083 # Plugins plugin.path=/opt/kafka/plugins # Provided configuration offset.storage.topic=debezium_test_offsets_v3 value.converter=org.apache.kafka.connect.json.JsonConverter config.storage.topic=debezium_test_configs_v3 key.converter=org.apache.kafka.connect.json.JsonConverter group.id=debezium-test-mongo status.storage.topic=debezium_test_status_v3 config.providers=file config.providers.file.class=org.apache.kafka.common.config.provider.FileConfigProvider config.storage.partitions=1 config.storage.replication.factor=-1 offset.storage.partitions=1 offset.storage.replication.factor=-1 replication.factor=-1 status.storage.partitions=1 status.storage.replication.factor=-1 security.protocol=SASL_SSL producer.security.protocol=SASL_SSL consumer.security.protocol=SASL_SSL admin.security.protocol=SASL_SSL sasl.mechanism=PLAIN sasl.jaas.config=[hidden] producer.sasl.mechanism=PLAIN producer.sasl.jaas.config=[hidden] consumer.sasl.mechanism=PLAIN consumer.sasl.jaas.config=[hidden] admin.sasl.mechanism=PLAIN admin.sasl.jaas.config=[hidden] # Additional configuration consumer.client.rack= + exec /usr/bin/tini -w -e 143 -- /opt/kafka/bin/connect-distributed.sh /tmp/strimzi-connect.properties 2024-07-17 13:13:35,086 INFO Kafka Connect worker initializing ... (org.apache.kafka.connect.cli.AbstractConnectCli) [main] 2024-07-17 13:13:35,090 INFO WorkerInfo values: jvm.args = -Xms128M, -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=/opt/kafka, -Dlog4j.configuration=file:/opt/kafka/custom-config/log4j.properties jvm.spec = Red Hat, Inc., OpenJDK 64-Bit Server VM, 17.0.10, 17.0.10+7-LTS jvm.classpath = /opt/kafka/bin/../libs/accessors-smart-2.4.9.jar:/opt/kafka/bin/../libs/activation-1.1.1.jar:/opt/kafka/bin/../libs/animal-sniffer-annotations-1.23.jar:/opt/kafka/bin/../libs/annotations-4.1.1.4.jar:/opt/kafka/bin/../libs/aopalliance-repackaged-2.6.1.jar:/opt/kafka/bin/../libs/argparse4j-0.7.0.jar:/opt/kafka/bin/../libs/audience-annotations-0.12.0.jar:/opt/kafka/bin/../libs/caffeine-2.9.3.jar:/opt/kafka/bin/../libs/checker-qual-3.19.0.jar:/opt/kafka/bin/../libs/commons-beanutils-1.9.4.jar:/opt/kafka/bin/../libs/commons-cli-1.4.jar:/opt/kafka/bin/../libs/commons-collections-3.2.2.jar:/opt/kafka/bin/../libs/commons-digester-2.1.jar:/opt/kafka/bin/../libs/commons-io-2.11.0.jar:/opt/kafka/bin/../libs/commons-lang-2.6.jar:/opt/kafka/bin/../libs/commons-lang3-3.8.1.jar:/opt/kafka/bin/../libs/commons-logging-1.2.jar:/opt/kafka/bin/../libs/commons-validator-1.7.jar:/opt/kafka/bin/../libs/connect-api-3.7.0.jar:/opt/kafka/bin/../libs/connect-basic-auth-extension-3.7.0.jar:/opt/kafka/bin/../libs/connect-json-3.7.0.jar:/opt/kafka/bin/../libs/connect-mirror-3.7.0.jar:/opt/kafka/bin/../libs/connect-mirror-client-3.7.0.jar:/opt/kafka/bin/../libs/connect-runtime-3.7.0.jar:/opt/kafka/bin/../libs/connect-transforms-3.7.0.jar:/opt/kafka/bin/../libs/cruise-control-metrics-reporter-2.5.137.jar:/opt/kafka/bin/../libs/error_prone_annotations-2.10.0.jar:/opt/kafka/bin/../libs/failureaccess-1.0.1.jar:/opt/kafka/bin/../libs/grpc-api-1.61.0.jar:/opt/kafka/bin/../libs/grpc-context-1.61.0.jar:/opt/kafka/bin/../libs/grpc-core-1.61.0.jar:/opt/kafka/bin/../libs/grpc-netty-shaded-1.61.0.jar:/opt/kafka/bin/../libs/grpc-stub-1.60.1.jar:/opt/kafka/bin/../libs/grpc-util-1.61.0.jar:/opt/kafka/bin/../libs/gson-2.10.1.jar:/opt/kafka/bin/../libs/guava-32.1.3-jre.jar:/opt/kafka/bin/../libs/hk2-api-2.6.1.jar:/opt/kafka/bin/../libs/hk2-locator-2.6.1.jar:/opt/kafka/bin/../libs/hk2-utils-2.6.1.jar:/opt/kafka/bin/../libs/j2objc-annotations-2.8.jar:/opt/kafka/bin/../libs/jackson-annotations-2.16.0.jar:/opt/kafka/bin/../libs/jackson-core-2.16.0.jar:/opt/kafka/bin/../libs/jackson-databind-2.16.0.jar:/opt/kafka/bin/../libs/jackson-dataformat-csv-2.16.0.jar:/opt/kafka/bin/../libs/jackson-dataformat-yaml-2.16.0.jar:/opt/kafka/bin/../libs/jackson-datatype-jdk8-2.16.0.jar:/opt/kafka/bin/../libs/jackson-datatype-jsr310-2.16.0.jar:/opt/kafka/bin/../libs/jackson-jaxrs-base-2.16.0.jar:/opt/kafka/bin/../libs/jackson-jaxrs-json-provider-2.16.0.jar:/opt/kafka/bin/../libs/jackson-module-jaxb-annotations-2.16.0.jar:/opt/kafka/bin/../libs/jackson-module-scala_2.13-2.16.0.jar:/opt/kafka/bin/../libs/jakarta.activation-api-1.2.2.jar:/opt/kafka/bin/../libs/jakarta.annotation-api-1.3.5.jar:/opt/kafka/bin/../libs/jakarta.inject-2.6.1.jar:/opt/kafka/bin/../libs/jakarta.validation-api-2.0.2.jar:/opt/kafka/bin/../libs/jakarta.ws.rs-api-2.1.6.jar:/opt/kafka/bin/../libs/jakarta.xml.bind-api-2.3.3.jar:/opt/kafka/bin/../libs/javassist-3.29.2-GA.jar:/opt/kafka/bin/../libs/javax.activation-api-1.2.0.jar:/opt/kafka/bin/../libs/javax.annotation-api-1.3.2.jar:/opt/kafka/bin/../libs/javax.servlet-api-3.1.0.jar:/opt/kafka/bin/../libs/javax.ws.rs-api-2.1.1.jar:/opt/kafka/bin/../libs/jaxb-api-2.3.1.jar:/opt/kafka/bin/../libs/jersey-client-2.39.1.jar:/opt/kafka/bin/../libs/jersey-common-2.39.1.jar:/opt/kafka/bin/../libs/jersey-container-servlet-2.39.1.jar:/opt/kafka/bin/../libs/jersey-container-servlet-core-2.39.1.jar:/opt/kafka/bin/../libs/jersey-hk2-2.39.1.jar:/opt/kafka/bin/../libs/jersey-server-2.39.1.jar:/opt/kafka/bin/../libs/jetty-client-9.4.53.v20231009.jar:/opt/kafka/bin/../libs/jetty-continuation-9.4.53.v20231009.jar:/opt/kafka/bin/../libs/jetty-http-9.4.53.v20231009.jar:/opt/kafka/bin/../libs/jetty-io-9.4.53.v20231009.jar:/opt/kafka/bin/../libs/jetty-security-9.4.53.v20231009.jar:/opt/kafka/bin/../libs/jetty-server-9.4.53.v20231009.jar:/opt/kafka/bin/../libs/jetty-servlet-9.4.53.v20231009.jar:/opt/kafka/bin/../libs/jetty-servlets-9.4.53.v20231009.jar:/opt/kafka/bin/../libs/jetty-util-9.4.53.v20231009.jar:/opt/kafka/bin/../libs/jetty-util-ajax-9.4.53.v20231009.jar:/opt/kafka/bin/../libs/jline-3.22.0.jar:/opt/kafka/bin/../libs/jmx_prometheus_javaagent-0.20.0.jar:/opt/kafka/bin/../libs/jopt-simple-5.0.4.jar:/opt/kafka/bin/../libs/jose4j-0.9.4.jar:/opt/kafka/bin/../libs/json-path-2.9.0.jar:/opt/kafka/bin/../libs/json-smart-2.4.9.jar:/opt/kafka/bin/../libs/jsonevent-layout-1.7.jar:/opt/kafka/bin/../libs/jsr305-3.0.2.jar:/opt/kafka/bin/../libs/kafka-agent-0.40.0.jar:/opt/kafka/bin/../libs/kafka-clients-3.7.0.jar:/opt/kafka/bin/../libs/kafka-env-var-config-provider-1.1.0.jar:/opt/kafka/bin/../libs/kafka-group-coordinator-3.7.0.jar:/opt/kafka/bin/../libs/kafka-kubernetes-config-provider-1.1.2.jar:/opt/kafka/bin/../libs/kafka-log4j-appender-3.7.0.jar:/opt/kafka/bin/../libs/kafka-metadata-3.7.0.jar:/opt/kafka/bin/../libs/kafka-oauth-client-0.15.0.jar:/opt/kafka/bin/../libs/kafka-oauth-common-0.15.0.jar:/opt/kafka/bin/../libs/kafka-oauth-keycloak-authorizer-0.15.0.jar:/opt/kafka/bin/../libs/kafka-oauth-server-0.15.0.jar:/opt/kafka/bin/../libs/kafka-oauth-server-plain-0.15.0.jar:/opt/kafka/bin/../libs/kafka-quotas-plugin-0.2.0.jar:/opt/kafka/bin/../libs/kafka-raft-3.7.0.jar:/opt/kafka/bin/../libs/kafka-server-3.7.0.jar:/opt/kafka/bin/../libs/kafka-server-common-3.7.0.jar:/opt/kafka/bin/../libs/kafka-shell-3.7.0.jar:/opt/kafka/bin/../libs/kafka-storage-3.7.0.jar:/opt/kafka/bin/../libs/kafka-storage-api-3.7.0.jar:/opt/kafka/bin/../libs/kafka-streams-3.7.0.jar:/opt/kafka/bin/../libs/kafka-streams-examples-3.7.0.jar:/opt/kafka/bin/../libs/kafka-streams-scala_2.13-3.7.0.jar:/opt/kafka/bin/../libs/kafka-streams-test-utils-3.7.0.jar:/opt/kafka/bin/../libs/kafka-tools-3.7.0.jar:/opt/kafka/bin/../libs/kafka-tools-api-3.7.0.jar:/opt/kafka/bin/../libs/kafka_2.13-3.7.0.jar:/opt/kafka/bin/../libs/kubernetes-client-6.8.1.jar:/opt/kafka/bin/../libs/kubernetes-client-api-6.8.1.jar:/opt/kafka/bin/../libs/kubernetes-httpclient-jdk-6.8.1.jar:/opt/kafka/bin/../libs/kubernetes-model-apps-6.8.1.jar:/opt/kafka/bin/../libs/kubernetes-model-batch-6.8.1.jar:/opt/kafka/bin/../libs/kubernetes-model-certificates-6.8.1.jar:/opt/kafka/bin/../libs/kubernetes-model-common-6.8.1.jar:/opt/kafka/bin/../libs/kubernetes-model-core-6.8.1.jar:/opt/kafka/bin/../libs/kubernetes-model-extensions-6.8.1.jar:/opt/kafka/bin/../libs/listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar:/opt/kafka/bin/../libs/lz4-java-1.8.0.jar:/opt/kafka/bin/../libs/maven-artifact-3.8.8.jar:/opt/kafka/bin/../libs/metrics-core-2.2.0.jar:/opt/kafka/bin/../libs/metrics-core-4.1.12.1.jar:/opt/kafka/bin/../libs/mirror-maker-2-extensions-1.2.0.jar:/opt/kafka/bin/../libs/mirror-maker-agent-0.40.0.jar:/opt/kafka/bin/../libs/netty-buffer-4.1.100.Final.jar:/opt/kafka/bin/../libs/netty-codec-4.1.100.Final.jar:/opt/kafka/bin/../libs/netty-common-4.1.100.Final.jar:/opt/kafka/bin/../libs/netty-handler-4.1.100.Final.jar:/opt/kafka/bin/../libs/netty-resolver-4.1.100.Final.jar:/opt/kafka/bin/../libs/netty-transport-4.1.100.Final.jar:/opt/kafka/bin/../libs/netty-transport-classes-epoll-4.1.100.Final.jar:/opt/kafka/bin/../libs/netty-transport-native-epoll-4.1.100.Final.jar:/opt/kafka/bin/../libs/netty-transport-native-unix-common-4.1.100.Final.jar:/opt/kafka/bin/../libs/nimbus-jose-jwt-9.37.2.jar:/opt/kafka/bin/../libs/opa-authorizer-1.5.1.jar:/opt/kafka/bin/../libs/opentelemetry-api-1.32.0.jar:/opt/kafka/bin/../libs/opentelemetry-api-events-1.34.1-alpha.jar:/opt/kafka/bin/../libs/opentelemetry-context-1.32.0.jar:/opt/kafka/bin/../libs/opentelemetry-exporter-common-1.34.1.jar:/opt/kafka/bin/../libs/opentelemetry-exporter-otlp-1.34.1.jar:/opt/kafka/bin/../libs/opentelemetry-exporter-otlp-common-1.34.1.jar:/opt/kafka/bin/../libs/opentelemetry-exporter-sender-grpc-managed-channel-1.34.1.jar:/opt/kafka/bin/../libs/opentelemetry-exporter-sender-jdk-1.34.1-alpha.jar:/opt/kafka/bin/../libs/opentelemetry-extension-incubator-1.32.0-alpha.jar:/opt/kafka/bin/../libs/opentelemetry-instrumentation-api-1.32.0.jar:/opt/kafka/bin/../libs/opentelemetry-instrumentation-api-semconv-1.32.0-alpha.jar:/opt/kafka/bin/../libs/opentelemetry-kafka-clients-2.6-1.32.0-alpha.jar:/opt/kafka/bin/../libs/opentelemetry-kafka-clients-common-1.32.0-alpha.jar:/opt/kafka/bin/../libs/opentelemetry-proto-1.0.0-alpha.jar:/opt/kafka/bin/../libs/opentelemetry-sdk-1.34.1.jar:/opt/kafka/bin/../libs/opentelemetry-sdk-common-1.34.1.jar:/opt/kafka/bin/../libs/opentelemetry-sdk-extension-autoconfigure-1.34.1.jar:/opt/kafka/bin/../libs/opentelemetry-sdk-extension-autoconfigure-spi-1.34.1.jar:/opt/kafka/bin/../libs/opentelemetry-sdk-logs-1.34.1.jar:/opt/kafka/bin/../libs/opentelemetry-sdk-metrics-1.34.1.jar:/opt/kafka/bin/../libs/opentelemetry-sdk-trace-1.34.1.jar:/opt/kafka/bin/../libs/opentelemetry-semconv-1.21.0-alpha.jar:/opt/kafka/bin/../libs/osgi-resource-locator-1.0.3.jar:/opt/kafka/bin/../libs/paranamer-2.8.jar:/opt/kafka/bin/../libs/pcollections-4.0.1.jar:/opt/kafka/bin/../libs/perfmark-api-0.26.0.jar:/opt/kafka/bin/../libs/plexus-utils-3.3.1.jar:/opt/kafka/bin/../libs/protobuf-java-3.23.4.jar:/opt/kafka/bin/../libs/reflections-0.10.2.jar:/opt/kafka/bin/../libs/reload4j-1.2.25.jar:/opt/kafka/bin/../libs/rocksdbjni-7.9.2.jar:/opt/kafka/bin/../libs/scala-collection-compat_2.13-2.10.0.jar:/opt/kafka/bin/../libs/scala-java8-compat_2.13-1.0.2.jar:/opt/kafka/bin/../libs/scala-library-2.13.12.jar:/opt/kafka/bin/../libs/scala-logging_2.13-3.9.4.jar:/opt/kafka/bin/../libs/scala-reflect-2.13.12.jar:/opt/kafka/bin/../libs/slf4j-api-1.7.36.jar:/opt/kafka/bin/../libs/slf4j-reload4j-1.7.36.jar:/opt/kafka/bin/../libs/snakeyaml-2.0.jar:/opt/kafka/bin/../libs/snakeyaml-engine-2.6.jar:/opt/kafka/bin/../libs/snappy-java-1.1.10.5.jar:/opt/kafka/bin/../libs/swagger-annotations-2.2.8.jar:/opt/kafka/bin/../libs/tracing-agent-0.40.0.jar:/opt/kafka/bin/../libs/trogdor-3.7.0.jar:/opt/kafka/bin/../libs/zjsonpatch-0.3.0.jar:/opt/kafka/bin/../libs/zookeeper-3.8.3.jar:/opt/kafka/bin/../libs/zookeeper-jute-3.8.3.jar:/opt/kafka/bin/../libs/zstd-jni-1.5.5-6.jar os.spec = Linux, amd64, 5.15.0-1060-azure os.vcpus = 64 (org.apache.kafka.connect.runtime.WorkerInfo) [main] 2024-07-17 13:13:35,090 INFO Scanning for plugin classes. This might take a moment ... (org.apache.kafka.connect.cli.AbstractConnectCli) [main] 2024-07-17 13:13:35,111 INFO Loading plugin from: /opt/kafka/plugins/debezium-connector-mongo (org.apache.kafka.connect.runtime.isolation.PluginScanner) [main] 2024-07-17 13:13:35,152 INFO Using up-to-date JsonConverter implementation (io.debezium.converters.CloudEventsConverter) [main] Jul 17, 2024 1:13:35 PM io.opentelemetry.api.GlobalOpenTelemetry maybeAutoConfigureAndSetGlobal INFO: AutoConfiguredOpenTelemetrySdk found on classpath but automatic configuration is disabled. To enable, run your JVM with -Dotel.java.global-autoconfigure.enabled=true 2024-07-17 13:13:35,332 INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/plugins/debezium-connector-mongo/} (org.apache.kafka.connect.runtime.isolation.PluginScanner) [main] 2024-07-17 13:13:35,333 INFO Loading plugin from: classpath (org.apache.kafka.connect.runtime.isolation.PluginScanner) [main] 2024-07-17 13:13:35,342 INFO Registered loader: jdk.internal.loader.ClassLoaders$AppClassLoader@2b2fa4f7 (org.apache.kafka.connect.runtime.isolation.PluginScanner) [main] 2024-07-17 13:13:35,342 INFO Scanning plugins with ServiceLoaderScanner took 232 ms (org.apache.kafka.connect.runtime.isolation.PluginScanner) [main] 2024-07-17 13:13:35,344 INFO Loading plugin from: /opt/kafka/plugins/debezium-connector-mongo (org.apache.kafka.connect.runtime.isolation.PluginScanner) [main] 2024-07-17 13:13:35,593 INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/plugins/debezium-connector-mongo/} (org.apache.kafka.connect.runtime.isolation.PluginScanner) [main] 2024-07-17 13:13:35,594 INFO Loading plugin from: classpath (org.apache.kafka.connect.runtime.isolation.PluginScanner) [main] 2024-07-17 13:13:36,414 INFO Registered loader: jdk.internal.loader.ClassLoaders$AppClassLoader@2b2fa4f7 (org.apache.kafka.connect.runtime.isolation.PluginScanner) [main] 2024-07-17 13:13:36,414 INFO Scanning plugins with ReflectionScanner took 1070 ms (org.apache.kafka.connect.runtime.isolation.PluginScanner) [main] 2024-07-17 13:13:36,416 WARN All plugins have ServiceLoader manifests, consider reconfiguring plugin.discovery=service_load (org.apache.kafka.connect.runtime.isolation.Plugins) [main] 2024-07-17 13:13:36,418 INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,418 INFO Added plugin 'org.apache.kafka.connect.transforms.Filter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,418 INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,418 INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,418 INFO Added plugin 'io.strimzi.kafka.EnvVarConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,418 INFO Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,418 INFO Added plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,418 INFO Added plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,418 INFO Added plugin 'org.apache.kafka.connect.transforms.DropHeaders' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,418 INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,418 INFO Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,418 INFO Added plugin 'org.apache.kafka.connect.transforms.InsertHeader' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,418 INFO Added plugin 'io.debezium.converters.BinaryDataConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,418 INFO Added plugin 'org.apache.kafka.common.config.provider.DirectoryConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,418 INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,418 INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,418 INFO Added plugin 'org.apache.kafka.connect.transforms.HeaderFrom$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,418 INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,418 INFO Added plugin 'io.debezium.transforms.ExtractNewRecordState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,418 INFO Added plugin 'io.debezium.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,418 INFO Added plugin 'io.debezium.connector.mongodb.MongoDbConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,419 INFO Added plugin 'io.debezium.transforms.partitions.PartitionRouting' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,419 INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.TopicNameMatches' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,419 INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,419 INFO Added plugin 'io.debezium.transforms.outbox.EventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,419 INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,419 INFO Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,419 INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.RecordIsTombstone' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,419 INFO Added plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,419 INFO Added plugin 'io.debezium.connector.mongodb.transforms.outbox.MongoEventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,419 INFO Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,419 INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,419 INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,419 INFO Added plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,419 INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,419 INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,419 INFO Added plugin 'io.strimzi.kafka.KubernetesConfigMapConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,419 INFO Added plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,419 INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,419 INFO Added plugin 'io.debezium.transforms.HeaderToValue' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,419 INFO Added plugin 'io.debezium.transforms.SchemaChangeEventFilter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,419 INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,419 INFO Added plugin 'io.debezium.transforms.ExtractSchemaToNewRecord' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,419 INFO Added plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,420 INFO Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,420 INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,420 INFO Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,420 INFO Added plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,420 INFO Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,420 INFO Added plugin 'io.debezium.connector.mongodb.rest.DebeziumMongoDbConnectRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,420 INFO Added plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,420 INFO Added plugin 'io.debezium.transforms.TimezoneConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,420 INFO Added plugin 'org.apache.kafka.connect.transforms.HeaderFrom$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,420 INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.HasHeaderKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,420 INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,420 INFO Added plugin 'org.apache.kafka.common.config.provider.EnvVarConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,420 INFO Added plugin 'io.debezium.transforms.ExtractChangedRecordState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,420 INFO Added plugin 'io.debezium.connector.mongodb.transforms.ExtractNewDocumentState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,420 INFO Added plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,420 INFO Added plugin 'io.debezium.transforms.tracing.ActivateTracingSpan' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,420 INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,420 INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,420 INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,420 INFO Added plugin 'org.apache.kafka.connect.converters.BooleanConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,420 INFO Added plugin 'io.strimzi.kafka.KubernetesSecretConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,420 INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,420 INFO Added plugin 'io.debezium.converters.CloudEventsConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,420 INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,420 INFO Added plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,422 INFO Added alias 'ExtractNewDocumentState' to plugin 'io.debezium.connector.mongodb.transforms.ExtractNewDocumentState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,422 INFO Added alias 'RecordIsTombstone' to plugin 'org.apache.kafka.connect.transforms.predicates.RecordIsTombstone' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,422 INFO Added alias 'CloudEventsConverter' to plugin 'io.debezium.converters.CloudEventsConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,422 INFO Added alias 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,422 INFO Added alias 'MirrorCheckpointConnector' to plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,422 INFO Added alias 'Boolean' to plugin 'org.apache.kafka.connect.converters.BooleanConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,422 INFO Added alias 'HeaderToValue' to plugin 'io.debezium.transforms.HeaderToValue' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,422 INFO Added alias 'PartitionRouting' to plugin 'io.debezium.transforms.partitions.PartitionRouting' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,422 INFO Added alias 'KubernetesSecret' to plugin 'io.strimzi.kafka.KubernetesSecretConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,422 INFO Added alias 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,422 INFO Added alias 'StringConverter' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,423 INFO Added alias 'MongoDbConnector' to plugin 'io.debezium.connector.mongodb.MongoDbConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,423 INFO Added alias 'IntegerConverter' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,423 INFO Added alias 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,423 INFO Added alias 'LongConverter' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,423 INFO Added alias 'DropHeaders' to plugin 'org.apache.kafka.connect.transforms.DropHeaders' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,423 INFO Added alias 'SimpleHeaderConverter' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,423 INFO Added alias 'ExtractSchemaToNewRecord' to plugin 'io.debezium.transforms.ExtractSchemaToNewRecord' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,423 INFO Added alias 'BinaryData' to plugin 'io.debezium.converters.BinaryDataConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,423 INFO Added alias 'DirectoryConfigProvider' to plugin 'org.apache.kafka.common.config.provider.DirectoryConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,423 INFO Added alias 'ShortConverter' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,423 INFO Added alias 'CloudEvents' to plugin 'io.debezium.converters.CloudEventsConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,423 INFO Added alias 'KubernetesSecretConfigProvider' to plugin 'io.strimzi.kafka.KubernetesSecretConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,423 INFO Added alias 'TimezoneConverter' to plugin 'io.debezium.transforms.TimezoneConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,423 INFO Added alias 'BasicAuthSecurityRestExtension' to plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,423 INFO Added alias 'KubernetesConfigMapConfigProvider' to plugin 'io.strimzi.kafka.KubernetesConfigMapConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,423 INFO Added alias 'Simple' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,423 INFO Added alias 'AllConnectorClientConfigOverridePolicy' to plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,423 INFO Added alias 'ExtractNewRecordState' to plugin 'io.debezium.transforms.ExtractNewRecordState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,423 INFO Added alias 'MirrorSource' to plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,424 INFO Added alias 'DebeziumMongoDb' to plugin 'io.debezium.connector.mongodb.rest.DebeziumMongoDbConnectRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,424 INFO Added alias 'Directory' to plugin 'org.apache.kafka.common.config.provider.DirectoryConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,424 INFO Added alias 'MirrorHeartbeat' to plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,424 INFO Added alias 'DebeziumMongoDbConnectRestExtension' to plugin 'io.debezium.connector.mongodb.rest.DebeziumMongoDbConnectRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,424 INFO Added alias 'BooleanConverter' to plugin 'org.apache.kafka.connect.converters.BooleanConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,424 INFO Added alias 'HasHeaderKey' to plugin 'org.apache.kafka.connect.transforms.predicates.HasHeaderKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,424 INFO Added alias 'MirrorCheckpoint' to plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,424 INFO Added alias 'ExtractChangedRecordState' to plugin 'io.debezium.transforms.ExtractChangedRecordState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,424 INFO Added alias 'None' to plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,424 INFO Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,424 INFO Added alias 'Principal' to plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,424 INFO Added alias 'All' to plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,424 INFO Added alias 'JsonConverter' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,424 INFO Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,424 INFO Added alias 'MongoDb' to plugin 'io.debezium.connector.mongodb.MongoDbConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,424 INFO Added alias 'NoneConnectorClientConfigOverridePolicy' to plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,424 INFO Added alias 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,424 INFO Added alias 'ByLogicalTableRouter' to plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,424 INFO Added alias 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,425 INFO Added alias 'FileConfigProvider' to plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,425 INFO Added alias 'EventRouter' to plugin 'io.debezium.transforms.outbox.EventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,425 INFO Added alias 'SchemaChangeEventFilter' to plugin 'io.debezium.transforms.SchemaChangeEventFilter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,425 INFO Added alias 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,425 INFO Added alias 'File' to plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,425 INFO Added alias 'FloatConverter' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,425 INFO Added alias 'ActivateTracingSpan' to plugin 'io.debezium.transforms.tracing.ActivateTracingSpan' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,425 INFO Added alias 'DoubleConverter' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,425 INFO Added alias 'BinaryDataConverter' to plugin 'io.debezium.converters.BinaryDataConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,425 INFO Added alias 'TopicNameMatches' to plugin 'org.apache.kafka.connect.transforms.predicates.TopicNameMatches' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,425 INFO Added alias 'MirrorHeartbeatConnector' to plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,425 INFO Added alias 'InsertHeader' to plugin 'org.apache.kafka.connect.transforms.InsertHeader' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,425 INFO Added alias 'KubernetesConfigMap' to plugin 'io.strimzi.kafka.KubernetesConfigMapConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,425 INFO Added alias 'MirrorSourceConnector' to plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,425 INFO Added alias 'PrincipalConnectorClientConfigOverridePolicy' to plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,425 INFO Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,425 INFO Added alias 'MongoEventRouter' to plugin 'io.debezium.connector.mongodb.transforms.outbox.MongoEventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,425 INFO Added alias 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,425 INFO Added alias 'Filter' to plugin 'org.apache.kafka.connect.transforms.Filter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2024-07-17 13:13:36,456 INFO DistributedConfig values: access.control.allow.methods = access.control.allow.origin = admin.listeners = null auto.include.jmx.reporter = true bootstrap.servers = [pkc-41973.westus2.azure.confluent.cloud:9092] client.dns.lookup = use_all_dns_ips client.id = config.providers = [file] config.storage.replication.factor = -1 config.storage.topic = debezium_test_configs_v3 connect.protocol = sessioned connections.max.idle.ms = 540000 connector.client.config.override.policy = All exactly.once.source.support = disabled group.id = debezium-test-mongo header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter heartbeat.interval.ms = 3000 inter.worker.key.generation.algorithm = HmacSHA256 inter.worker.key.size = null inter.worker.key.ttl.ms = 3600000 inter.worker.signature.algorithm = HmacSHA256 inter.worker.verification.algorithms = [HmacSHA256] key.converter = class org.apache.kafka.connect.json.JsonConverter listeners = [http://:8083] metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 offset.flush.interval.ms = 60000 offset.flush.timeout.ms = 5000 offset.storage.partitions = 1 offset.storage.replication.factor = -1 offset.storage.topic = debezium_test_offsets_v3 plugin.discovery = hybrid_warn plugin.path = [/opt/kafka/plugins] rebalance.timeout.ms = 60000 receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 40000 response.http.headers.config = rest.advertised.host.name = debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc rest.advertised.listener = null rest.advertised.port = 8083 rest.extension.classes = [] retry.backoff.max.ms = 1000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = [hidden] sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = PLAIN sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null scheduled.rebalance.max.delay.ms = 300000 security.protocol = SASL_SSL send.buffer.bytes = 131072 session.timeout.ms = 10000 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.client.auth = none ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS status.storage.partitions = 1 status.storage.replication.factor = -1 status.storage.topic = debezium_test_status_v3 task.shutdown.graceful.timeout.ms = 5000 topic.creation.enable = true topic.tracking.allow.reset = true topic.tracking.enable = true value.converter = class org.apache.kafka.connect.json.JsonConverter worker.sync.timeout.ms = 3000 worker.unsync.backoff.ms = 300000 (org.apache.kafka.connect.runtime.distributed.DistributedConfig) [main] 2024-07-17 13:13:36,457 INFO Creating Kafka admin client (org.apache.kafka.connect.runtime.WorkerConfig) [main] 2024-07-17 13:13:36,459 INFO AdminClientConfig values: auto.include.jmx.reporter = true bootstrap.controllers = [] bootstrap.servers = [pkc-41973.westus2.azure.confluent.cloud:9092] client.dns.lookup = use_all_dns_ips client.id = connections.max.idle.ms = 300000 default.api.timeout.ms = 60000 enable.metrics.push = true metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 retry.backoff.max.ms = 1000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = [hidden] sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = PLAIN sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = SASL_SSL security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2024-07-17 13:13:36,511 INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin) [main] 2024-07-17 13:13:36,609 INFO These configurations '[producer.sasl.jaas.config, replication.factor, group.id, rest.advertised.port, plugin.path, config.providers, status.storage.partitions, consumer.sasl.mechanism, admin.security.protocol, offset.storage.partitions, status.storage.replication.factor, config.providers.file.class, offset.storage.topic, consumer.security.protocol, admin.sasl.mechanism, value.converter, key.converter, consumer.client.rack, consumer.sasl.jaas.config, config.storage.topic, producer.security.protocol, rest.advertised.host.name, status.storage.topic, producer.sasl.mechanism, rest.port, config.storage.partitions, config.storage.replication.factor, offset.storage.replication.factor, admin.sasl.jaas.config]' were supplied but are not used yet. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2024-07-17 13:13:36,610 INFO Kafka version: 3.7.0 (org.apache.kafka.common.utils.AppInfoParser) [main] 2024-07-17 13:13:36,610 INFO Kafka commitId: 2ae524ed625438c5 (org.apache.kafka.common.utils.AppInfoParser) [main] 2024-07-17 13:13:36,610 INFO Kafka startTimeMs: 1721222016609 (org.apache.kafka.common.utils.AppInfoParser) [main] 2024-07-17 13:13:37,131 INFO Kafka cluster ID: lkc-dggxr7 (org.apache.kafka.connect.runtime.WorkerConfig) [main] 2024-07-17 13:13:37,131 INFO App info kafka.admin.client for adminclient-1 unregistered (org.apache.kafka.common.utils.AppInfoParser) [kafka-admin-client-thread | adminclient-1] 2024-07-17 13:13:37,139 INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-1] 2024-07-17 13:13:37,139 INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-1] 2024-07-17 13:13:37,139 INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-1] 2024-07-17 13:13:37,148 INFO PublicConfig values: access.control.allow.methods = access.control.allow.origin = admin.listeners = null listeners = [http://:8083] response.http.headers.config = rest.advertised.host.name = debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc rest.advertised.listener = null rest.advertised.port = 8083 rest.extension.classes = [] ssl.cipher.suites = null ssl.client.auth = none ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS topic.tracking.allow.reset = true topic.tracking.enable = true (org.apache.kafka.connect.runtime.rest.RestServerConfig$PublicConfig) [main] 2024-07-17 13:13:37,155 INFO Logging initialized @2418ms to org.eclipse.jetty.util.log.Slf4jLog (org.eclipse.jetty.util.log) [main] 2024-07-17 13:13:37,202 INFO Added connector for http://:8083 (org.apache.kafka.connect.runtime.rest.RestServer) [main] 2024-07-17 13:13:37,202 INFO Initializing REST server (org.apache.kafka.connect.runtime.rest.RestServer) [main] 2024-07-17 13:13:37,221 INFO jetty-9.4.53.v20231009; built: 2023-10-09T12:29:09.265Z; git: 27bde00a0b95a1d5bbee0eae7984f891d2d0f8c9; jvm 17.0.10+7-LTS (org.eclipse.jetty.server.Server) [main] 2024-07-17 13:13:37,239 INFO Started http_8083@1a2e563e{HTTP/1.1, (http/1.1)}{0.0.0.0:8083} (org.eclipse.jetty.server.AbstractConnector) [main] 2024-07-17 13:13:37,240 INFO Started @2503ms (org.eclipse.jetty.server.Server) [main] 2024-07-17 13:13:37,256 INFO Advertised URI: http://debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083/ (org.apache.kafka.connect.runtime.rest.RestServer) [main] 2024-07-17 13:13:37,256 INFO REST server listening at http://10.36.42.194:8083/, advertising URL http://debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083/ (org.apache.kafka.connect.runtime.rest.RestServer) [main] 2024-07-17 13:13:37,257 INFO Advertised URI: http://debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083/ (org.apache.kafka.connect.runtime.rest.RestServer) [main] 2024-07-17 13:13:37,257 INFO REST admin endpoints at http://debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083/ (org.apache.kafka.connect.runtime.rest.RestServer) [main] 2024-07-17 13:13:37,257 INFO Advertised URI: http://debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083/ (org.apache.kafka.connect.runtime.rest.RestServer) [main] 2024-07-17 13:13:37,257 INFO Setting up All Policy for ConnectorClientConfigOverride. This will allow all client configurations to be overridden (org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy) [main] 2024-07-17 13:13:37,262 INFO JsonConverterConfig values: converter.type = key decimal.format = BASE64 replace.null.with.default = true schemas.cache.size = 1000 schemas.enable = false (org.apache.kafka.connect.json.JsonConverterConfig) [main] 2024-07-17 13:13:37,274 INFO Kafka version: 3.7.0 (org.apache.kafka.common.utils.AppInfoParser) [main] 2024-07-17 13:13:37,274 INFO Kafka commitId: 2ae524ed625438c5 (org.apache.kafka.common.utils.AppInfoParser) [main] 2024-07-17 13:13:37,274 INFO Kafka startTimeMs: 1721222017274 (org.apache.kafka.common.utils.AppInfoParser) [main] 2024-07-17 13:13:37,278 INFO JsonConverterConfig values: converter.type = key decimal.format = BASE64 replace.null.with.default = true schemas.cache.size = 1000 schemas.enable = false (org.apache.kafka.connect.json.JsonConverterConfig) [main] 2024-07-17 13:13:37,278 INFO JsonConverterConfig values: converter.type = value decimal.format = BASE64 replace.null.with.default = true schemas.cache.size = 1000 schemas.enable = false (org.apache.kafka.connect.json.JsonConverterConfig) [main] 2024-07-17 13:13:37,284 WARN Ignoring 'config.storage.partitions=1' setting, since config topic partitions is always 1 (org.apache.kafka.connect.runtime.distributed.DistributedConfig) [main] 2024-07-17 13:13:37,291 INFO Advertised URI: http://debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083/ (org.apache.kafka.connect.runtime.rest.RestServer) [main] 2024-07-17 13:13:37,298 INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin) [main] 2024-07-17 13:13:37,315 INFO Kafka version: 3.7.0 (org.apache.kafka.common.utils.AppInfoParser) [main] 2024-07-17 13:13:37,315 INFO Kafka commitId: 2ae524ed625438c5 (org.apache.kafka.common.utils.AppInfoParser) [main] 2024-07-17 13:13:37,315 INFO Kafka startTimeMs: 1721222017315 (org.apache.kafka.common.utils.AppInfoParser) [main] 2024-07-17 13:13:37,317 INFO Kafka Connect worker initialization took 2230ms (org.apache.kafka.connect.cli.AbstractConnectCli) [main] 2024-07-17 13:13:37,317 INFO Kafka Connect starting (org.apache.kafka.connect.runtime.Connect) [main] 2024-07-17 13:13:37,319 INFO Initializing REST resources (org.apache.kafka.connect.runtime.rest.RestServer) [main] 2024-07-17 13:13:37,319 INFO [Worker clientId=connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083, groupId=debezium-test-mongo] Herder starting (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,321 INFO Worker starting (org.apache.kafka.connect.runtime.Worker) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,321 INFO Starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,321 INFO Starting KafkaBasedLog with topic debezium_test_offsets_v3 (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,322 INFO AdminClientConfig values: auto.include.jmx.reporter = true bootstrap.controllers = [] bootstrap.servers = [pkc-41973.westus2.azure.confluent.cloud:9092] client.dns.lookup = use_all_dns_ips client.id = debezium-test-mongo-shared-admin connections.max.idle.ms = 300000 default.api.timeout.ms = 60000 enable.metrics.push = true metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 retry.backoff.max.ms = 1000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = [hidden] sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = PLAIN sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = SASL_SSL security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,327 INFO These configurations '[producer.sasl.jaas.config, replication.factor, group.id, rest.advertised.port, plugin.path, config.providers, status.storage.partitions, consumer.sasl.mechanism, admin.security.protocol, metrics.context.connect.kafka.cluster.id, offset.storage.partitions, status.storage.replication.factor, config.providers.file.class, offset.storage.topic, consumer.security.protocol, admin.sasl.mechanism, value.converter, key.converter, consumer.client.rack, consumer.sasl.jaas.config, config.storage.topic, producer.security.protocol, metrics.context.connect.group.id, rest.advertised.host.name, status.storage.topic, producer.sasl.mechanism, rest.port, config.storage.partitions, config.storage.replication.factor, offset.storage.replication.factor, admin.sasl.jaas.config]' were supplied but are not used yet. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,327 INFO Kafka version: 3.7.0 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,327 INFO Kafka commitId: 2ae524ed625438c5 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,327 INFO Kafka startTimeMs: 1721222017327 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,347 INFO Adding admin resources to main listener (org.apache.kafka.connect.runtime.rest.RestServer) [main] 2024-07-17 13:13:37,376 INFO DefaultSessionIdManager workerName=node0 (org.eclipse.jetty.server.session) [main] 2024-07-17 13:13:37,377 INFO No SessionScavenger set, using defaults (org.eclipse.jetty.server.session) [main] 2024-07-17 13:13:37,377 INFO node0 Scavenging every 600000ms (org.eclipse.jetty.server.session) [main] 2024-07-17 13:13:37,585 INFO ProducerConfig values: acks = -1 auto.include.jmx.reporter = true batch.size = 16384 bootstrap.servers = [pkc-41973.westus2.azure.confluent.cloud:9092] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = debezium-test-mongo-offsets compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 2147483647 enable.idempotence = false enable.metrics.push = true interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer linger.ms = 0 max.block.ms = 60000 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metadata.max.idle.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.adaptive.partitioning.enable = true partitioner.availability.timeout.ms = 0 partitioner.class = null partitioner.ignore.keys = false receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 retry.backoff.max.ms = 1000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = [hidden] sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = PLAIN sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = SASL_SSL security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,605 INFO initializing Kafka metrics collector (org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] Jul 17, 2024 1:13:37 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.RootResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.RootResource will be ignored. Jul 17, 2024 1:13:37 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource will be ignored. Jul 17, 2024 1:13:37 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.InternalConnectResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.InternalConnectResource will be ignored. Jul 17, 2024 1:13:37 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource will be ignored. Jul 17, 2024 1:13:37 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.LoggingResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.LoggingResource will be ignored. 2024-07-17 13:13:37,623 INFO These configurations '[producer.sasl.jaas.config, replication.factor, group.id, rest.advertised.port, plugin.path, config.providers, status.storage.partitions, consumer.sasl.mechanism, admin.security.protocol, metrics.context.connect.kafka.cluster.id, offset.storage.partitions, status.storage.replication.factor, config.providers.file.class, offset.storage.topic, consumer.security.protocol, admin.sasl.mechanism, value.converter, key.converter, consumer.client.rack, consumer.sasl.jaas.config, config.storage.topic, producer.security.protocol, metrics.context.connect.group.id, rest.advertised.host.name, status.storage.topic, producer.sasl.mechanism, rest.port, config.storage.partitions, config.storage.replication.factor, offset.storage.replication.factor, admin.sasl.jaas.config]' were supplied but are not used yet. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,623 INFO Kafka version: 3.7.0 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,623 INFO Kafka commitId: 2ae524ed625438c5 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,623 INFO Kafka startTimeMs: 1721222017623 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,629 INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.include.jmx.reporter = true auto.offset.reset = earliest bootstrap.servers = [pkc-41973.westus2.azure.confluent.cloud:9092] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = debezium-test-mongo-offsets client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false enable.metrics.push = true exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = debezium-test-mongo group.instance.id = null group.protocol = classic group.remote.assignor = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true internal.throw.on.fetch.stable.offset.unsupported = false isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.max.ms = 1000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = [hidden] sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = PLAIN sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = SASL_SSL security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 45000 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,637 INFO initializing Kafka metrics collector (org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,659 INFO [Producer clientId=debezium-test-mongo-offsets] Cluster ID: lkc-dggxr7 (org.apache.kafka.clients.Metadata) [kafka-producer-network-thread | debezium-test-mongo-offsets] 2024-07-17 13:13:37,664 INFO These configurations '[producer.sasl.jaas.config, replication.factor, rest.advertised.port, plugin.path, config.providers, status.storage.partitions, consumer.sasl.mechanism, admin.security.protocol, metrics.context.connect.kafka.cluster.id, offset.storage.partitions, status.storage.replication.factor, config.providers.file.class, offset.storage.topic, consumer.security.protocol, admin.sasl.mechanism, value.converter, key.converter, consumer.client.rack, consumer.sasl.jaas.config, config.storage.topic, producer.security.protocol, metrics.context.connect.group.id, rest.advertised.host.name, status.storage.topic, producer.sasl.mechanism, rest.port, config.storage.partitions, config.storage.replication.factor, offset.storage.replication.factor, admin.sasl.jaas.config]' were supplied but are not used yet. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,664 INFO Kafka version: 3.7.0 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,664 INFO Kafka commitId: 2ae524ed625438c5 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,664 INFO Kafka startTimeMs: 1721222017664 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,694 INFO [Consumer clientId=debezium-test-mongo-offsets, groupId=debezium-test-mongo] Cluster ID: lkc-dggxr7 (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,697 INFO [Consumer clientId=debezium-test-mongo-offsets, groupId=debezium-test-mongo] Assigned to partition(s): debezium_test_offsets_v3-0 (org.apache.kafka.clients.consumer.internals.LegacyKafkaConsumer) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,699 INFO [Consumer clientId=debezium-test-mongo-offsets, groupId=debezium-test-mongo] Seeking to earliest offset of partition debezium_test_offsets_v3-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] Jul 17, 2024 1:13:37 PM org.glassfish.jersey.internal.Errors logErrors WARNING: The following warnings have been detected: WARNING: The (sub)resource method listLoggers in org.apache.kafka.connect.runtime.rest.resources.LoggingResource contains empty path annotation. WARNING: The (sub)resource method createConnector in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation. WARNING: The (sub)resource method listConnectors in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation. WARNING: The (sub)resource method listConnectorPlugins in org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource contains empty path annotation. WARNING: The (sub)resource method serverInfo in org.apache.kafka.connect.runtime.rest.resources.RootResource contains empty path annotation. 2024-07-17 13:13:37,721 INFO Started o.e.j.s.ServletContextHandler@22b82ddf{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler) [main] 2024-07-17 13:13:37,721 INFO REST resources initialized; server is started and ready to handle requests (org.apache.kafka.connect.runtime.rest.RestServer) [main] 2024-07-17 13:13:37,721 INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect) [main] 2024-07-17 13:13:37,865 INFO [Consumer clientId=debezium-test-mongo-offsets, groupId=debezium-test-mongo] Resetting offset for partition debezium_test_offsets_v3-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b8-pkc-41973.westus2.azure.confluent.cloud:9092 (id: 8 rack: 2)], epoch=2}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,907 INFO Finished reading KafkaBasedLog for topic debezium_test_offsets_v3 (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,907 INFO Started KafkaBasedLog for topic debezium_test_offsets_v3 (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,907 INFO Finished reading offsets topic and starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,908 INFO Worker started (org.apache.kafka.connect.runtime.Worker) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,908 INFO Starting KafkaBasedLog with topic debezium_test_status_v3 (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,915 INFO ProducerConfig values: acks = -1 auto.include.jmx.reporter = true batch.size = 16384 bootstrap.servers = [pkc-41973.westus2.azure.confluent.cloud:9092] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = debezium-test-mongo-statuses compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 120000 enable.idempotence = false enable.metrics.push = true interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.StringSerializer linger.ms = 0 max.block.ms = 60000 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metadata.max.idle.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.adaptive.partitioning.enable = true partitioner.availability.timeout.ms = 0 partitioner.class = null partitioner.ignore.keys = false receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 0 retry.backoff.max.ms = 1000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = [hidden] sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = PLAIN sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = SASL_SSL security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,915 INFO initializing Kafka metrics collector (org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,920 INFO These configurations '[producer.sasl.jaas.config, replication.factor, group.id, rest.advertised.port, plugin.path, config.providers, status.storage.partitions, consumer.sasl.mechanism, admin.security.protocol, metrics.context.connect.kafka.cluster.id, offset.storage.partitions, status.storage.replication.factor, config.providers.file.class, offset.storage.topic, consumer.security.protocol, admin.sasl.mechanism, value.converter, key.converter, consumer.client.rack, consumer.sasl.jaas.config, config.storage.topic, producer.security.protocol, metrics.context.connect.group.id, rest.advertised.host.name, status.storage.topic, producer.sasl.mechanism, rest.port, config.storage.partitions, config.storage.replication.factor, offset.storage.replication.factor, admin.sasl.jaas.config]' were supplied but are not used yet. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,920 INFO Kafka version: 3.7.0 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,920 INFO Kafka commitId: 2ae524ed625438c5 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,920 INFO Kafka startTimeMs: 1721222017920 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,921 INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.include.jmx.reporter = true auto.offset.reset = earliest bootstrap.servers = [pkc-41973.westus2.azure.confluent.cloud:9092] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = debezium-test-mongo-statuses client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false enable.metrics.push = true exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = debezium-test-mongo group.instance.id = null group.protocol = classic group.remote.assignor = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true internal.throw.on.fetch.stable.offset.unsupported = false isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.max.ms = 1000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = [hidden] sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = PLAIN sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = SASL_SSL security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 45000 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,922 INFO initializing Kafka metrics collector (org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,926 INFO These configurations '[producer.sasl.jaas.config, replication.factor, rest.advertised.port, plugin.path, config.providers, status.storage.partitions, consumer.sasl.mechanism, admin.security.protocol, metrics.context.connect.kafka.cluster.id, offset.storage.partitions, status.storage.replication.factor, config.providers.file.class, offset.storage.topic, consumer.security.protocol, admin.sasl.mechanism, value.converter, key.converter, consumer.client.rack, consumer.sasl.jaas.config, config.storage.topic, producer.security.protocol, metrics.context.connect.group.id, rest.advertised.host.name, status.storage.topic, producer.sasl.mechanism, rest.port, config.storage.partitions, config.storage.replication.factor, offset.storage.replication.factor, admin.sasl.jaas.config]' were supplied but are not used yet. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,926 INFO Kafka version: 3.7.0 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,926 INFO Kafka commitId: 2ae524ed625438c5 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:37,926 INFO Kafka startTimeMs: 1721222017926 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,010 INFO [Producer clientId=debezium-test-mongo-statuses] Cluster ID: lkc-dggxr7 (org.apache.kafka.clients.Metadata) [kafka-producer-network-thread | debezium-test-mongo-statuses] 2024-07-17 13:13:38,032 INFO [Consumer clientId=debezium-test-mongo-statuses, groupId=debezium-test-mongo] Cluster ID: lkc-dggxr7 (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,032 INFO [Consumer clientId=debezium-test-mongo-statuses, groupId=debezium-test-mongo] Assigned to partition(s): debezium_test_status_v3-0 (org.apache.kafka.clients.consumer.internals.LegacyKafkaConsumer) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,033 INFO [Consumer clientId=debezium-test-mongo-statuses, groupId=debezium-test-mongo] Seeking to earliest offset of partition debezium_test_status_v3-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,101 INFO [Consumer clientId=debezium-test-mongo-statuses, groupId=debezium-test-mongo] Resetting offset for partition debezium_test_status_v3-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b11-pkc-41973.westus2.azure.confluent.cloud:9092 (id: 11 rack: 2)], epoch=2}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,119 INFO Finished reading KafkaBasedLog for topic debezium_test_status_v3 (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,119 INFO Started KafkaBasedLog for topic debezium_test_status_v3 (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,121 INFO Starting KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,121 INFO Starting KafkaBasedLog with topic debezium_test_configs_v3 (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,128 INFO ProducerConfig values: acks = -1 auto.include.jmx.reporter = true batch.size = 16384 bootstrap.servers = [pkc-41973.westus2.azure.confluent.cloud:9092] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = debezium-test-mongo-configs compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 2147483647 enable.idempotence = false enable.metrics.push = true interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.StringSerializer linger.ms = 0 max.block.ms = 60000 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metadata.max.idle.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.adaptive.partitioning.enable = true partitioner.availability.timeout.ms = 0 partitioner.class = null partitioner.ignore.keys = false receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 retry.backoff.max.ms = 1000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = [hidden] sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = PLAIN sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = SASL_SSL security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,128 INFO initializing Kafka metrics collector (org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,131 INFO These configurations '[producer.sasl.jaas.config, replication.factor, group.id, rest.advertised.port, plugin.path, config.providers, status.storage.partitions, consumer.sasl.mechanism, admin.security.protocol, metrics.context.connect.kafka.cluster.id, offset.storage.partitions, status.storage.replication.factor, config.providers.file.class, offset.storage.topic, consumer.security.protocol, admin.sasl.mechanism, value.converter, key.converter, consumer.client.rack, consumer.sasl.jaas.config, config.storage.topic, producer.security.protocol, metrics.context.connect.group.id, rest.advertised.host.name, status.storage.topic, producer.sasl.mechanism, rest.port, config.storage.partitions, config.storage.replication.factor, offset.storage.replication.factor, admin.sasl.jaas.config]' were supplied but are not used yet. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,131 INFO Kafka version: 3.7.0 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,131 INFO Kafka commitId: 2ae524ed625438c5 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,131 INFO Kafka startTimeMs: 1721222018131 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,132 INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.include.jmx.reporter = true auto.offset.reset = earliest bootstrap.servers = [pkc-41973.westus2.azure.confluent.cloud:9092] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = debezium-test-mongo-configs client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false enable.metrics.push = true exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = debezium-test-mongo group.instance.id = null group.protocol = classic group.remote.assignor = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true internal.throw.on.fetch.stable.offset.unsupported = false isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.max.ms = 1000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = [hidden] sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = PLAIN sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = SASL_SSL security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 45000 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,132 INFO initializing Kafka metrics collector (org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,135 INFO These configurations '[producer.sasl.jaas.config, replication.factor, rest.advertised.port, plugin.path, config.providers, status.storage.partitions, consumer.sasl.mechanism, admin.security.protocol, metrics.context.connect.kafka.cluster.id, offset.storage.partitions, status.storage.replication.factor, config.providers.file.class, offset.storage.topic, consumer.security.protocol, admin.sasl.mechanism, value.converter, key.converter, consumer.client.rack, consumer.sasl.jaas.config, config.storage.topic, producer.security.protocol, metrics.context.connect.group.id, rest.advertised.host.name, status.storage.topic, producer.sasl.mechanism, rest.port, config.storage.partitions, config.storage.replication.factor, offset.storage.replication.factor, admin.sasl.jaas.config]' were supplied but are not used yet. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,135 INFO Kafka version: 3.7.0 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,135 INFO Kafka commitId: 2ae524ed625438c5 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,135 INFO Kafka startTimeMs: 1721222018135 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,150 INFO [Consumer clientId=debezium-test-mongo-configs, groupId=debezium-test-mongo] Cluster ID: lkc-dggxr7 (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,151 INFO [Consumer clientId=debezium-test-mongo-configs, groupId=debezium-test-mongo] Assigned to partition(s): debezium_test_configs_v3-0 (org.apache.kafka.clients.consumer.internals.LegacyKafkaConsumer) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,151 INFO [Consumer clientId=debezium-test-mongo-configs, groupId=debezium-test-mongo] Seeking to earliest offset of partition debezium_test_configs_v3-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,221 INFO [Producer clientId=debezium-test-mongo-configs] Cluster ID: lkc-dggxr7 (org.apache.kafka.clients.Metadata) [kafka-producer-network-thread | debezium-test-mongo-configs] 2024-07-17 13:13:38,275 INFO [Consumer clientId=debezium-test-mongo-configs, groupId=debezium-test-mongo] Resetting offset for partition debezium_test_configs_v3-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[b7-pkc-41973.westus2.azure.confluent.cloud:9092 (id: 7 rack: 1)], epoch=2}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,289 INFO Finished reading KafkaBasedLog for topic debezium_test_configs_v3 (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,289 INFO Started KafkaBasedLog for topic debezium_test_configs_v3 (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,289 INFO Started KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,289 INFO [Worker clientId=connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083, groupId=debezium-test-mongo] Herder started (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,396 INFO [Worker clientId=connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083, groupId=debezium-test-mongo] Cluster ID: lkc-dggxr7 (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,396 INFO [Worker clientId=connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083, groupId=debezium-test-mongo] Discovered group coordinator b5-pkc-41973.westus2.azure.confluent.cloud:9092 (id: 2147483642 rack: null) (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,412 INFO [Worker clientId=connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083, groupId=debezium-test-mongo] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,412 INFO [Worker clientId=connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083, groupId=debezium-test-mongo] (Re-)joining group (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,428 INFO [Worker clientId=connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083, groupId=debezium-test-mongo] (Re-)joining group (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,429 INFO [Worker clientId=connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083, groupId=debezium-test-mongo] Successfully joined group with generation Generation{generationId=3, memberId='connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-aa87640c-1602-4b7a-8221-c5fe65a86a91', protocol='sessioned'} (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,443 INFO [Worker clientId=connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083, groupId=debezium-test-mongo] Successfully synced group in generation Generation{generationId=3, memberId='connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-aa87640c-1602-4b7a-8221-c5fe65a86a91', protocol='sessioned'} (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,443 INFO [Worker clientId=connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083, groupId=debezium-test-mongo] Joined group at generation 3 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-aa87640c-1602-4b7a-8221-c5fe65a86a91', leaderUrl='http://debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083/', offset=93, connectorIds=[debezium-connector-fleet-mongo], taskIds=[debezium-connector-fleet-mongo-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,444 WARN [Worker clientId=connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083, groupId=debezium-test-mongo] Catching up to assignment's config offset. (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,444 INFO [Worker clientId=connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083, groupId=debezium-test-mongo] Current config state offset -1 is behind group assignment 93, reading to end of config log (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,452 INFO [Worker clientId=connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083, groupId=debezium-test-mongo] Finished reading to end of log and updated config snapshot, new config log offset: 93 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,452 INFO [Worker clientId=connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083, groupId=debezium-test-mongo] Starting connectors and tasks using config offset 93 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,453 INFO [Worker clientId=connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083, groupId=debezium-test-mongo] Starting task debezium-connector-fleet-mongo-0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [StartAndStopExecutor-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-2] 2024-07-17 13:13:38,454 INFO [Worker clientId=connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083, groupId=debezium-test-mongo] Starting connector debezium-connector-fleet-mongo (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [StartAndStopExecutor-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,458 INFO [debezium-connector-fleet-mongo|worker] Creating connector debezium-connector-fleet-mongo of type io.debezium.connector.mongodb.MongoDbConnector (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,459 INFO [debezium-connector-fleet-mongo|task-0] Creating task debezium-connector-fleet-mongo-0 (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-2] 2024-07-17 13:13:38,461 INFO [debezium-connector-fleet-mongo|worker] SourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.mongodb.MongoDbConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = class org.apache.kafka.connect.storage.StringConverter name = debezium-connector-fleet-mongo offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [RegexReroute] value.converter = class org.apache.kafka.connect.json.JsonConverter (org.apache.kafka.connect.runtime.SourceConnectorConfig) [StartAndStopExecutor-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,461 INFO [debezium-connector-fleet-mongo|task-0] ConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.mongodb.MongoDbConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class org.apache.kafka.connect.storage.StringConverter name = debezium-connector-fleet-mongo predicates = [] tasks.max = 1 transforms = [RegexReroute] value.converter = class org.apache.kafka.connect.json.JsonConverter (org.apache.kafka.connect.runtime.ConnectorConfig) [StartAndStopExecutor-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-2] 2024-07-17 13:13:38,463 INFO [debezium-connector-fleet-mongo|task-0] EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.mongodb.MongoDbConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class org.apache.kafka.connect.storage.StringConverter name = debezium-connector-fleet-mongo predicates = [] tasks.max = 1 transforms = [RegexReroute] transforms.RegexReroute.negate = false transforms.RegexReroute.predicate = null transforms.RegexReroute.regex = .* transforms.RegexReroute.replacement = debezium_test_fleet_mongo transforms.RegexReroute.type = class org.apache.kafka.connect.transforms.RegexRouter value.converter = class org.apache.kafka.connect.json.JsonConverter (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig) [StartAndStopExecutor-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-2] 2024-07-17 13:13:38,463 INFO [debezium-connector-fleet-mongo|worker] EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.mongodb.MongoDbConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = class org.apache.kafka.connect.storage.StringConverter name = debezium-connector-fleet-mongo offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [RegexReroute] transforms.RegexReroute.negate = false transforms.RegexReroute.predicate = null transforms.RegexReroute.regex = .* transforms.RegexReroute.replacement = debezium_test_fleet_mongo transforms.RegexReroute.type = class org.apache.kafka.connect.transforms.RegexRouter value.converter = class org.apache.kafka.connect.json.JsonConverter (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig) [StartAndStopExecutor-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,467 INFO [debezium-connector-fleet-mongo|task-0] TaskConfig values: task.class = class io.debezium.connector.mongodb.MongoDbConnectorTask (org.apache.kafka.connect.runtime.TaskConfig) [StartAndStopExecutor-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-2] 2024-07-17 13:13:38,467 INFO [debezium-connector-fleet-mongo|worker] Instantiated connector debezium-connector-fleet-mongo with version 2.7.0.Final of type class io.debezium.connector.mongodb.MongoDbConnector (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,468 INFO [debezium-connector-fleet-mongo|worker] Finished creating connector debezium-connector-fleet-mongo (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,469 INFO [debezium-connector-fleet-mongo|task-0] Instantiated task debezium-connector-fleet-mongo-0 with version 2.7.0.Final of type io.debezium.connector.mongodb.MongoDbConnectorTask (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-2] 2024-07-17 13:13:38,469 INFO [debezium-connector-fleet-mongo|task-0] StringConverterConfig values: converter.encoding = UTF-8 converter.type = key (org.apache.kafka.connect.storage.StringConverterConfig) [StartAndStopExecutor-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-2] 2024-07-17 13:13:38,469 INFO [debezium-connector-fleet-mongo|task-0] JsonConverterConfig values: converter.type = value decimal.format = BASE64 replace.null.with.default = true schemas.cache.size = 1000 schemas.enable = false (org.apache.kafka.connect.json.JsonConverterConfig) [StartAndStopExecutor-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-2] 2024-07-17 13:13:38,469 INFO [debezium-connector-fleet-mongo|task-0] Set up the key converter class org.apache.kafka.connect.storage.StringConverter for task debezium-connector-fleet-mongo-0 using the connector config (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-2] 2024-07-17 13:13:38,469 INFO [debezium-connector-fleet-mongo|task-0] Set up the value converter class org.apache.kafka.connect.json.JsonConverter for task debezium-connector-fleet-mongo-0 using the connector config (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-2] 2024-07-17 13:13:38,469 INFO [debezium-connector-fleet-mongo|task-0] Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task debezium-connector-fleet-mongo-0 using the worker config (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-2] 2024-07-17 13:13:38,472 INFO [debezium-connector-fleet-mongo|task-0] SourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.mongodb.MongoDbConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = class org.apache.kafka.connect.storage.StringConverter name = debezium-connector-fleet-mongo offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [RegexReroute] value.converter = class org.apache.kafka.connect.json.JsonConverter (org.apache.kafka.connect.runtime.SourceConnectorConfig) [StartAndStopExecutor-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-2] 2024-07-17 13:13:38,472 INFO [debezium-connector-fleet-mongo|task-0] EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.mongodb.MongoDbConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = class org.apache.kafka.connect.storage.StringConverter name = debezium-connector-fleet-mongo offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [RegexReroute] transforms.RegexReroute.negate = false transforms.RegexReroute.predicate = null transforms.RegexReroute.regex = .* transforms.RegexReroute.replacement = debezium_test_fleet_mongo transforms.RegexReroute.type = class org.apache.kafka.connect.transforms.RegexRouter value.converter = class org.apache.kafka.connect.json.JsonConverter (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig) [StartAndStopExecutor-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-2] 2024-07-17 13:13:38,473 INFO [debezium-connector-fleet-mongo|task-0] Initializing: org.apache.kafka.connect.runtime.TransformationChain{org.apache.kafka.connect.transforms.RegexRouter} (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-2] 2024-07-17 13:13:38,473 INFO [debezium-connector-fleet-mongo|task-0] ProducerConfig values: acks = -1 auto.include.jmx.reporter = true batch.size = 16384 bootstrap.servers = [pkc-41973.westus2.azure.confluent.cloud:9092] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = connector-producer-debezium-connector-fleet-mongo-0 compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 2147483647 enable.idempotence = false enable.metrics.push = true interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer linger.ms = 0 max.block.ms = 9223372036854775807 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metadata.max.idle.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.adaptive.partitioning.enable = true partitioner.availability.timeout.ms = 0 partitioner.class = null partitioner.ignore.keys = false receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 retry.backoff.max.ms = 1000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = [hidden] sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = PLAIN sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = SASL_SSL security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer (org.apache.kafka.clients.producer.ProducerConfig) [StartAndStopExecutor-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-2] 2024-07-17 13:13:38,474 INFO [debezium-connector-fleet-mongo|task-0] initializing Kafka metrics collector (org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector) [StartAndStopExecutor-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-2] 2024-07-17 13:13:38,477 INFO [debezium-connector-fleet-mongo|task-0] These configurations '[metrics.context.connect.group.id, metrics.context.connect.kafka.cluster.id]' were supplied but are not used yet. (org.apache.kafka.clients.producer.ProducerConfig) [StartAndStopExecutor-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-2] 2024-07-17 13:13:38,477 INFO [debezium-connector-fleet-mongo|task-0] Kafka version: 3.7.0 (org.apache.kafka.common.utils.AppInfoParser) [StartAndStopExecutor-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-2] 2024-07-17 13:13:38,477 INFO [debezium-connector-fleet-mongo|task-0] Kafka commitId: 2ae524ed625438c5 (org.apache.kafka.common.utils.AppInfoParser) [StartAndStopExecutor-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-2] 2024-07-17 13:13:38,477 INFO [debezium-connector-fleet-mongo|task-0] Kafka startTimeMs: 1721222018477 (org.apache.kafka.common.utils.AppInfoParser) [StartAndStopExecutor-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-2] 2024-07-17 13:13:38,483 INFO [Worker clientId=connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083, groupId=debezium-test-mongo] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,507 INFO [debezium-connector-fleet-mongo|task-0] [Producer clientId=connector-producer-debezium-connector-fleet-mongo-0] Cluster ID: lkc-dggxr7 (org.apache.kafka.clients.Metadata) [kafka-producer-network-thread | connector-producer-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,516 INFO [debezium-connector-fleet-mongo|task-0] Starting MongoDbConnectorTask with configuration: (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,517 INFO [debezium-connector-fleet-mongo|task-0] connector.class = io.debezium.connector.mongodb.MongoDbConnector (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,517 INFO [debezium-connector-fleet-mongo|task-0] collection.include.list = dev_fleetprodb.addressdata,dev_fleetprodb.eventdata,dev_fleetprodb.filterrecalculationstate,dev_fleetprodb.gpsdata,groupfilter,dev_fleetprodb.latest_gps,dev_fleetprodb.testcol,dev_fleetprodb.trackedresourcefilter (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,517 INFO [debezium-connector-fleet-mongo|task-0] mongodb.connection.string = ******** (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,517 INFO [debezium-connector-fleet-mongo|task-0] tasks.max = 1 (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,517 INFO [debezium-connector-fleet-mongo|task-0] capture.mode = change_streams_update_full (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,517 INFO [debezium-connector-fleet-mongo|task-0] transforms = RegexReroute (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,517 INFO [debezium-connector-fleet-mongo|task-0] transforms.RegexReroute.regex = .* (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,517 INFO [debezium-connector-fleet-mongo|task-0] transforms.RegexReroute.type = org.apache.kafka.connect.transforms.RegexRouter (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,517 INFO [debezium-connector-fleet-mongo|task-0] key.converter.schemas.enable = false (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,518 INFO [debezium-connector-fleet-mongo|task-0] topic.prefix = fleet-mongo (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,518 INFO [debezium-connector-fleet-mongo|task-0] task.class = io.debezium.connector.mongodb.MongoDbConnectorTask (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,518 INFO [debezium-connector-fleet-mongo|task-0] transforms.RegexReroute.replacement = debezium_test_fleet_mongo (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,518 INFO [debezium-connector-fleet-mongo|task-0] value.converter.schemas.enable = false (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,518 INFO [debezium-connector-fleet-mongo|task-0] name = debezium-connector-fleet-mongo (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,518 INFO [debezium-connector-fleet-mongo|task-0] skipped.operations = none (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,518 INFO [debezium-connector-fleet-mongo|task-0] value.converter = org.apache.kafka.connect.json.JsonConverter (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,518 INFO [debezium-connector-fleet-mongo|task-0] key.converter = org.apache.kafka.connect.storage.StringConverter (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,518 INFO [debezium-connector-fleet-mongo|task-0] database.include.list = dev_fleetprodb (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,520 INFO [debezium-connector-fleet-mongo|task-0] Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker (io.debezium.config.CommonConnectorConfig) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,528 INFO [debezium-connector-fleet-mongo|worker] Successfully started MongoDB connector (io.debezium.connector.mongodb.MongoDbConnector) [connector-thread-debezium-connector-fleet-mongo] 2024-07-17 13:13:38,545 INFO SourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.mongodb.MongoDbConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = class org.apache.kafka.connect.storage.StringConverter name = debezium-connector-fleet-mongo offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [RegexReroute] value.converter = class org.apache.kafka.connect.json.JsonConverter (org.apache.kafka.connect.runtime.SourceConnectorConfig) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,546 INFO EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.mongodb.MongoDbConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = class org.apache.kafka.connect.storage.StringConverter name = debezium-connector-fleet-mongo offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [RegexReroute] transforms.RegexReroute.negate = false transforms.RegexReroute.predicate = null transforms.RegexReroute.regex = .* transforms.RegexReroute.replacement = debezium_test_fleet_mongo transforms.RegexReroute.type = class org.apache.kafka.connect.transforms.RegexRouter value.converter = class org.apache.kafka.connect.json.JsonConverter (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig) [DistributedHerder-connect-debezium-connect-mongo-connect-0.debezium-connect-mongo-connect.debezium-poc.svc:8083-1] 2024-07-17 13:13:38,549 INFO [debezium-connector-fleet-mongo|task-0] Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker (io.debezium.config.CommonConnectorConfig) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,559 INFO [debezium-connector-fleet-mongo|task-0] Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker (io.debezium.config.CommonConnectorConfig) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,566 INFO [debezium-connector-fleet-mongo|task-0] Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker (io.debezium.config.CommonConnectorConfig) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,569 INFO [debezium-connector-fleet-mongo|task-0] Loading the custom topic naming strategy plugin: io.debezium.schema.DefaultTopicNamingStrategy (io.debezium.config.CommonConnectorConfig) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,570 INFO [debezium-connector-fleet-mongo|task-0] Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker (io.debezium.config.CommonConnectorConfig) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,572 INFO [debezium-connector-fleet-mongo|task-0] Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker (io.debezium.config.CommonConnectorConfig) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,580 INFO [debezium-connector-fleet-mongo|task-0] Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker (io.debezium.config.CommonConnectorConfig) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,625 INFO [debezium-connector-fleet-mongo|task-0] Found previous partition offset MongoDbPartition [sourcePartition={server_id=fleet-mongo}]: {sec=1721219402, ord=1, incremental_snapshot_correlation_id=6697b7b7d470bc6750689664, resume_token=gQAAAAJfZGF0YQBxAAAAODI2Njk3Qjk0QTAwMDAwMDAxMkIwMjJDMDEwMDI5NkU1QTEwMDQ4MTUzMDFBOEJBNjI0NThDQjc1MUZCRTMwMDBBNzY4MzQ2NjQ1RjY5NjQwMDY0NjY5N0I3QjdENDcwQkM2NzUwNjg5NjY0MDAwNAAA, incremental_snapshot_maximum_key=aced000570, incremental_snapshot_collections=[{"incremental_snapshot_collections_id":"dev_fleetprodb.eventdata","incremental_snapshot_collections_additional_condition":null}], incremental_snapshot_primary_key=aced000570} (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,631 INFO [debezium-connector-fleet-mongo|task-0] Requested thread factory for component MongoDbConnector, id = fleet-mongo named = SignalProcessor (io.debezium.util.Threads) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,640 WARN [debezium-connector-fleet-mongo|task-0] Found a not connector specific implementation io.debezium.snapshot.lock.NoLockingSupport for lock mode no_locking_support (io.debezium.snapshot.SnapshotLockProvider) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,646 INFO [debezium-connector-fleet-mongo|task-0] Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker (io.debezium.config.CommonConnectorConfig) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,648 INFO [debezium-connector-fleet-mongo|task-0] Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker (io.debezium.config.CommonConnectorConfig) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,650 INFO [debezium-connector-fleet-mongo|task-0] Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker (io.debezium.config.CommonConnectorConfig) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,652 INFO [debezium-connector-fleet-mongo|task-0] Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker (io.debezium.config.CommonConnectorConfig) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,655 INFO [debezium-connector-fleet-mongo|task-0] Found existing offset for at {sec=1721219402, ord=1, incremental_snapshot_correlation_id=6697b7b7d470bc6750689664, resume_token=gQAAAAJfZGF0YQBxAAAAODI2Njk3Qjk0QTAwMDAwMDAxMkIwMjJDMDEwMDI5NkU1QTEwMDQ4MTUzMDFBOEJBNjI0NThDQjc1MUZCRTMwMDBBNzY4MzQ2NjQ1RjY5NjQwMDY0NjY5N0I3QjdENDcwQkM2NzUwNjg5NjY0MDAwNAAA, incremental_snapshot_maximum_key=aced000570, incremental_snapshot_collections=[{"incremental_snapshot_collections_id":"dev_fleetprodb.eventdata","incremental_snapshot_collections_additional_condition":null}], incremental_snapshot_primary_key=aced000570} (io.debezium.connector.mongodb.connection.MongoDbConnection) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,680 INFO [debezium-connector-fleet-mongo|task-0] MongoClient with metadata {"driver": {"name": "mongo-java-driver|sync", "version": "4.11.0"}, "os": {"type": "Linux", "name": "Linux", "architecture": "amd64", "version": "5.15.0-1060-azure"}, "platform": "Java/Red Hat, Inc./17.0.10+7-LTS"} created with settings MongoClientSettings{readPreference=primary, writeConcern=WriteConcern{w=majority, wTimeout=null ms, journal=null}, retryWrites=true, retryReads=true, readConcern=ReadConcern{level=null}, credential=MongoCredential{mechanism=null, userName='debezium_test', source='admin', password=, mechanismProperties=}, transportSettings=null, streamFactoryFactory=null, commandListeners=[], codecRegistry=ProvidersCodecRegistry{codecProviders=[ValueCodecProvider{}, BsonValueCodecProvider{}, DBRefCodecProvider{}, DBObjectCodecProvider{}, DocumentCodecProvider{}, CollectionCodecProvider{}, IterableCodecProvider{}, MapCodecProvider{}, GeoJsonCodecProvider{}, GridFSFileCodecProvider{}, Jsr310CodecProvider{}, JsonObjectCodecProvider{}, BsonCodecProvider{}, EnumCodecProvider{}, com.mongodb.client.model.mql.ExpressionCodecProvider@25d005fd, com.mongodb.Jep395RecordCodecProvider@2c88a01b, com.mongodb.KotlinCodecProvider@690acadb]}, loggerSettings=LoggerSettings{maxDocumentLength=1000}, clusterSettings={hosts=[127.0.0.1:27017], srvHost=dev.rha9i.mongodb.net, srvServiceName=mongodb, mode=MULTIPLE, requiredClusterType=REPLICA_SET, requiredReplicaSetName='atlas-5g1vd8-shard-0', serverSelector='null', clusterListeners='[]', serverSelectionTimeout='30000 ms', localThreshold='15 ms'}, socketSettings=SocketSettings{connectTimeoutMS=10000, readTimeoutMS=0, receiveBufferSize=0, proxySettings=ProxySettings{host=null, port=null, username=null, password=null}}, heartbeatSocketSettings=SocketSettings{connectTimeoutMS=10000, readTimeoutMS=10000, receiveBufferSize=0, proxySettings=ProxySettings{host=null, port=null, username=null, password=null}}, connectionPoolSettings=ConnectionPoolSettings{maxSize=100, minSize=0, maxWaitTimeMS=120000, maxConnectionLifeTimeMS=0, maxConnectionIdleTimeMS=0, maintenanceInitialDelayMS=0, maintenanceFrequencyMS=60000, connectionPoolListeners=[], maxConnecting=2}, serverSettings=ServerSettings{heartbeatFrequencyMS=10000, minHeartbeatFrequencyMS=500, serverListeners='[]', serverMonitorListeners='[]'}, sslSettings=SslSettings{enabled=true, invalidHostNameAllowed=false, context=javax.net.ssl.SSLContext@1b5ff3c9}, applicationName='null', compressorList=[], uuidRepresentation=STANDARD, serverApi=null, autoEncryptionSettings=null, dnsClient=null, inetAddressResolver=null, contextProvider=null} (org.mongodb.driver.client) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,693 INFO [debezium-connector-fleet-mongo|task-0] Effective change stream pipeline: [{"$replaceRoot": {"newRoot": {"namespace": {"$concat": ["$ns.db", ".", "$ns.coll"]}, "event": "$$ROOT"}}}, {"$match": {"$and": [{"$and": [{"event.ns.db": {"$regularExpression": {"pattern": "dev_fleetprodb", "options": "i"}}}, {"namespace": {"$regularExpression": {"pattern": "dev_fleetprodb.addressdata|dev_fleetprodb.eventdata|dev_fleetprodb.filterrecalculationstate|dev_fleetprodb.gpsdata|groupfilter|dev_fleetprodb.latest_gps|dev_fleetprodb.testcol|dev_fleetprodb.trackedresourcefilter", "options": "i"}}}]}, {"event.operationType": {"$in": ["insert", "update", "replace", "delete"]}}]}}, {"$replaceRoot": {"newRoot": "$event"}}] (io.debezium.connector.mongodb.ChangeStreamPipelineFactory) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,700 INFO [debezium-connector-fleet-mongo|task-0] Adding discovered server dev-shard-00-01.rha9i.mongodb.net:27017 to client view of cluster (org.mongodb.driver.cluster) [cluster-ClusterId{value='6697c3824e86ca33fad4527c', description='null'}-srv-dev.rha9i.mongodb.net] 2024-07-17 13:13:38,717 INFO [debezium-connector-fleet-mongo|task-0] Adding discovered server dev-shard-00-02.rha9i.mongodb.net:27017 to client view of cluster (org.mongodb.driver.cluster) [cluster-ClusterId{value='6697c3824e86ca33fad4527c', description='null'}-srv-dev.rha9i.mongodb.net] 2024-07-17 13:13:38,720 INFO [debezium-connector-fleet-mongo|task-0] Adding discovered server dev-shard-00-00.rha9i.mongodb.net:27017 to client view of cluster (org.mongodb.driver.cluster) [cluster-ClusterId{value='6697c3824e86ca33fad4527c', description='null'}-srv-dev.rha9i.mongodb.net] 2024-07-17 13:13:38,724 INFO [debezium-connector-fleet-mongo|task-0] No server chosen by ReadPreferenceServerSelector{readPreference=primary} from cluster description ClusterDescription{type=REPLICA_SET, connectionMode=MULTIPLE, serverDescriptions=[ServerDescription{address=dev-shard-00-01.rha9i.mongodb.net:27017, type=UNKNOWN, state=CONNECTING}, ServerDescription{address=dev-shard-00-00.rha9i.mongodb.net:27017, type=UNKNOWN, state=CONNECTING}, ServerDescription{address=dev-shard-00-02.rha9i.mongodb.net:27017, type=UNKNOWN, state=CONNECTING}]}. Waiting for 30000 ms before timing out (org.mongodb.driver.cluster) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,826 INFO [debezium-connector-fleet-mongo|task-0] Monitor thread successfully connected to server with description ServerDescription{address=dev-shard-00-02.rha9i.mongodb.net:27017, type=REPLICA_SET_PRIMARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=13, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=38431707, setName='atlas-5g1vd8-shard-0', canonicalAddress=dev-shard-00-02.rha9i.mongodb.net:27017, hosts=[dev-shard-00-01.rha9i.mongodb.net:27017, dev-shard-00-02.rha9i.mongodb.net:27017, dev-shard-00-00.rha9i.mongodb.net:27017], passives=[], arbiters=[], primary='dev-shard-00-02.rha9i.mongodb.net:27017', tagSet=TagSet{[Tag{name='availabilityZone', value='3'}, Tag{name='diskState', value='READY'}, Tag{name='nodeType', value='ELECTABLE'}, Tag{name='provider', value='AZURE'}, Tag{name='region', value='US_WEST_2'}, Tag{name='workloadType', value='OPERATIONAL'}]}, electionId=7fffffff000000000000003b, setVersion=11, topologyVersion=TopologyVersion{processId=667ef976f534ccc609d74826, counter=6}, lastWriteDate=Wed Jul 17 13:13:34 UTC 2024, lastUpdateTimeNanos=2223771682385057} (org.mongodb.driver.cluster) [cluster-ClusterId{value='6697c3824e86ca33fad4527c', description='null'}-dev-shard-00-02.rha9i.mongodb.net:27017] 2024-07-17 13:13:38,826 INFO [debezium-connector-fleet-mongo|task-0] Monitor thread successfully connected to server with description ServerDescription{address=dev-shard-00-01.rha9i.mongodb.net:27017, type=REPLICA_SET_SECONDARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=13, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=38444171, setName='atlas-5g1vd8-shard-0', canonicalAddress=dev-shard-00-01.rha9i.mongodb.net:27017, hosts=[dev-shard-00-01.rha9i.mongodb.net:27017, dev-shard-00-02.rha9i.mongodb.net:27017, dev-shard-00-00.rha9i.mongodb.net:27017], passives=[], arbiters=[], primary='dev-shard-00-02.rha9i.mongodb.net:27017', tagSet=TagSet{[Tag{name='availabilityZone', value='2'}, Tag{name='diskState', value='READY'}, Tag{name='nodeType', value='ELECTABLE'}, Tag{name='provider', value='AZURE'}, Tag{name='region', value='US_WEST_2'}, Tag{name='workloadType', value='OPERATIONAL'}]}, electionId=null, setVersion=11, topologyVersion=TopologyVersion{processId=667efa786da2d52cfdf9ad5a, counter=3}, lastWriteDate=Wed Jul 17 13:13:34 UTC 2024, lastUpdateTimeNanos=2223771682269857} (org.mongodb.driver.cluster) [cluster-ClusterId{value='6697c3824e86ca33fad4527c', description='null'}-dev-shard-00-01.rha9i.mongodb.net:27017] 2024-07-17 13:13:38,826 INFO [debezium-connector-fleet-mongo|task-0] Monitor thread successfully connected to server with description ServerDescription{address=dev-shard-00-00.rha9i.mongodb.net:27017, type=REPLICA_SET_SECONDARY, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=13, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=38943684, setName='atlas-5g1vd8-shard-0', canonicalAddress=dev-shard-00-00.rha9i.mongodb.net:27017, hosts=[dev-shard-00-01.rha9i.mongodb.net:27017, dev-shard-00-02.rha9i.mongodb.net:27017, dev-shard-00-00.rha9i.mongodb.net:27017], passives=[], arbiters=[], primary='dev-shard-00-02.rha9i.mongodb.net:27017', tagSet=TagSet{[Tag{name='availabilityZone', value='1'}, Tag{name='diskState', value='READY'}, Tag{name='nodeType', value='ELECTABLE'}, Tag{name='provider', value='AZURE'}, Tag{name='region', value='US_WEST_2'}, Tag{name='workloadType', value='OPERATIONAL'}]}, electionId=null, setVersion=11, topologyVersion=TopologyVersion{processId=667ef89a2b27dc7f636250da, counter=4}, lastWriteDate=Wed Jul 17 13:13:34 UTC 2024, lastUpdateTimeNanos=2223771682267863} (org.mongodb.driver.cluster) [cluster-ClusterId{value='6697c3824e86ca33fad4527c', description='null'}-dev-shard-00-00.rha9i.mongodb.net:27017] 2024-07-17 13:13:38,827 INFO [debezium-connector-fleet-mongo|task-0] Discovered replica set primary dev-shard-00-02.rha9i.mongodb.net:27017 with max election id 7fffffff000000000000003b and max set version 11 (org.mongodb.driver.cluster) [cluster-ClusterId{value='6697c3824e86ca33fad4527c', description='null'}-dev-shard-00-02.rha9i.mongodb.net:27017] 2024-07-17 13:13:38,892 INFO [debezium-connector-fleet-mongo|task-0] Valid resume token present, so no snapshot will be performed' (io.debezium.connector.mongodb.connection.MongoDbConnection) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,906 INFO [debezium-connector-fleet-mongo|task-0] Requested thread factory for component MongoDbConnector, id = fleet-mongo named = change-event-source-coordinator (io.debezium.util.Threads) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,906 INFO [debezium-connector-fleet-mongo|task-0] Requested thread factory for component MongoDbConnector, id = fleet-mongo named = blocking-snapshot (io.debezium.util.Threads) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,907 INFO [debezium-connector-fleet-mongo|task-0] Creating thread debezium-mongodbconnector-fleet-mongo-change-event-source-coordinator (io.debezium.util.Threads) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,908 INFO [debezium-connector-fleet-mongo|task-0] WorkerSourceTask{id=debezium-connector-fleet-mongo-0} Source task finished initialization and start (org.apache.kafka.connect.runtime.AbstractWorkerSourceTask) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:38,909 INFO [debezium-connector-fleet-mongo|task-0] Metrics registered (io.debezium.pipeline.ChangeEventSourceCoordinator) [debezium-mongodbconnector-fleet-mongo-change-event-source-coordinator] 2024-07-17 13:13:38,909 INFO [debezium-connector-fleet-mongo|task-0] Context created (io.debezium.pipeline.ChangeEventSourceCoordinator) [debezium-mongodbconnector-fleet-mongo-change-event-source-coordinator] 2024-07-17 13:13:38,912 INFO [debezium-connector-fleet-mongo|task-0] A previous offset indicating a completed snapshot has been found. (io.debezium.connector.mongodb.MongoDbSnapshotChangeEventSource) [debezium-mongodbconnector-fleet-mongo-change-event-source-coordinator] 2024-07-17 13:13:38,912 INFO [debezium-connector-fleet-mongo|task-0] According to the connector configuration, no snapshot will occur. (io.debezium.connector.mongodb.MongoDbSnapshotChangeEventSource) [debezium-mongodbconnector-fleet-mongo-change-event-source-coordinator] 2024-07-17 13:13:38,915 INFO [debezium-connector-fleet-mongo|task-0] Snapshot ended with SnapshotResult [status=SKIPPED, offset=MongoDbOffsetContext [sourceInfo=SourceInfo [initialSync=false, collectionId=null, position=Position [ts=Timestamp{value=7392581040830676993, seconds=1721219402, inc=1}, changeStreamSessionTxnId=null, resumeToken=gQAAAAJfZGF0YQBxAAAAODI2Njk3Qjk0QTAwMDAwMDAxMkIwMjJDMDEwMDI5NkU1QTEwMDQ4MTUzMDFBOEJBNjI0NThDQjc1MUZCRTMwMDBBNzY4MzQ2NjQ1RjY5NjQwMDY0NjY5N0I3QjdENDcwQkM2NzUwNjg5NjY0MDAwNAAA]]]] (io.debezium.pipeline.ChangeEventSourceCoordinator) [debezium-mongodbconnector-fleet-mongo-change-event-source-coordinator] 2024-07-17 13:13:38,916 INFO [debezium-connector-fleet-mongo|task-0] Connected metrics set to 'true' (io.debezium.pipeline.ChangeEventSourceCoordinator) [debezium-mongodbconnector-fleet-mongo-change-event-source-coordinator] 2024-07-17 13:13:38,918 INFO [debezium-connector-fleet-mongo|task-0] Requested thread factory for component MongoDbConnector, id = mongodb named = incremental-snapshot (io.debezium.util.Threads) [debezium-mongodbconnector-fleet-mongo-change-event-source-coordinator] 2024-07-17 13:13:38,918 INFO [debezium-connector-fleet-mongo|task-0] Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker (io.debezium.config.CommonConnectorConfig) [debezium-mongodbconnector-fleet-mongo-change-event-source-coordinator] 2024-07-17 13:13:38,920 INFO [debezium-connector-fleet-mongo|task-0] Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker (io.debezium.config.CommonConnectorConfig) [debezium-mongodbconnector-fleet-mongo-change-event-source-coordinator] 2024-07-17 13:13:38,922 INFO [debezium-connector-fleet-mongo|task-0] Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker (io.debezium.config.CommonConnectorConfig) [debezium-mongodbconnector-fleet-mongo-change-event-source-coordinator] 2024-07-17 13:13:38,924 INFO [debezium-connector-fleet-mongo|task-0] Loading the custom source info struct maker plugin: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker (io.debezium.config.CommonConnectorConfig) [debezium-mongodbconnector-fleet-mongo-change-event-source-coordinator] 2024-07-17 13:13:38,925 INFO [debezium-connector-fleet-mongo|task-0] Incremental snapshot in progress, need to read new chunk on start (io.debezium.connector.mongodb.snapshot.MongoDbIncrementalSnapshotChangeEventSource) [debezium-mongodbconnector-fleet-mongo-change-event-source-coordinator] 2024-07-17 13:13:38,928 INFO [debezium-connector-fleet-mongo|task-0] MongoClient with metadata {"driver": {"name": "mongo-java-driver|sync", "version": "4.11.0"}, "os": {"type": "Linux", "name": "Linux", "architecture": "amd64", "version": "5.15.0-1060-azure"}, "platform": "Java/Red Hat, Inc./17.0.10+7-LTS"} created with settings MongoClientSettings{readPreference=primary, writeConcern=WriteConcern{w=majority, wTimeout=null ms, journal=null}, retryWrites=true, retryReads=true, readConcern=ReadConcern{level=null}, credential=MongoCredential{mechanism=null, userName='debezium_test', source='admin', password=, mechanismProperties=}, transportSettings=null, streamFactoryFactory=null, commandListeners=[], codecRegistry=ProvidersCodecRegistry{codecProviders=[ValueCodecProvider{}, BsonValueCodecProvider{}, DBRefCodecProvider{}, DBObjectCodecProvider{}, DocumentCodecProvider{}, CollectionCodecProvider{}, IterableCodecProvider{}, MapCodecProvider{}, GeoJsonCodecProvider{}, GridFSFileCodecProvider{}, Jsr310CodecProvider{}, JsonObjectCodecProvider{}, BsonCodecProvider{}, EnumCodecProvider{}, com.mongodb.client.model.mql.ExpressionCodecProvider@25d005fd, com.mongodb.Jep395RecordCodecProvider@2c88a01b, com.mongodb.KotlinCodecProvider@690acadb]}, loggerSettings=LoggerSettings{maxDocumentLength=1000}, clusterSettings={hosts=[127.0.0.1:27017], srvHost=dev.rha9i.mongodb.net, srvServiceName=mongodb, mode=MULTIPLE, requiredClusterType=REPLICA_SET, requiredReplicaSetName='atlas-5g1vd8-shard-0', serverSelector='null', clusterListeners='[]', serverSelectionTimeout='30000 ms', localThreshold='15 ms'}, socketSettings=SocketSettings{connectTimeoutMS=10000, readTimeoutMS=0, receiveBufferSize=0, proxySettings=ProxySettings{host=null, port=null, username=null, password=null}}, heartbeatSocketSettings=SocketSettings{connectTimeoutMS=10000, readTimeoutMS=10000, receiveBufferSize=0, proxySettings=ProxySettings{host=null, port=null, username=null, password=null}}, connectionPoolSettings=ConnectionPoolSettings{maxSize=100, minSize=0, maxWaitTimeMS=120000, maxConnectionLifeTimeMS=0, maxConnectionIdleTimeMS=0, maintenanceInitialDelayMS=0, maintenanceFrequencyMS=60000, connectionPoolListeners=[], maxConnecting=2}, serverSettings=ServerSettings{heartbeatFrequencyMS=10000, minHeartbeatFrequencyMS=500, serverListeners='[]', serverMonitorListeners='[]'}, sslSettings=SslSettings{enabled=true, invalidHostNameAllowed=false, context=javax.net.ssl.SSLContext@3cd51dc5}, applicationName='null', compressorList=[], uuidRepresentation=STANDARD, serverApi=null, autoEncryptionSettings=null, dnsClient=null, inetAddressResolver=null, contextProvider=null} (org.mongodb.driver.client) [debezium-mongodbconnector-fleet-mongo-change-event-source-coordinator] 2024-07-17 13:13:38,928 ERROR [debezium-connector-fleet-mongo|task-0] Error while attempting to emit window open for chunk 'c3492866-47cd-4ebf-99fc-e7a6b3c02d80': Cannot invoke "io.debezium.connector.mongodb.CollectionId.dbName()" because "collectionId" is null (io.debezium.connector.mongodb.connection.MongoDbConnections) [debezium-mongodbconnector-fleet-mongo-change-event-source-coordinator] java.lang.NullPointerException: Cannot invoke "io.debezium.connector.mongodb.CollectionId.dbName()" because "collectionId" is null at io.debezium.connector.mongodb.snapshot.MongoDbIncrementalSnapshotChangeEventSource.lambda$emitWindowOpen$0(MongoDbIncrementalSnapshotChangeEventSource.java:219) at io.debezium.connector.mongodb.connection.MongoDbConnection.lambda$execute$0(MongoDbConnection.java:89) at io.debezium.connector.mongodb.connection.MongoDbConnection.execute(MongoDbConnection.java:105) at io.debezium.connector.mongodb.connection.MongoDbConnection.execute(MongoDbConnection.java:88) at io.debezium.connector.mongodb.snapshot.MongoDbIncrementalSnapshotChangeEventSource.emitWindowOpen(MongoDbIncrementalSnapshotChangeEventSource.java:216) at io.debezium.connector.mongodb.snapshot.MongoDbIncrementalSnapshotChangeEventSource.readChunk(MongoDbIncrementalSnapshotChangeEventSource.java:290) at io.debezium.connector.mongodb.snapshot.MongoDbIncrementalSnapshotChangeEventSource.init(MongoDbIncrementalSnapshotChangeEventSource.java:269) at io.debezium.connector.mongodb.snapshot.MongoDbIncrementalSnapshotChangeEventSource.init(MongoDbIncrementalSnapshotChangeEventSource.java:76) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$initStreamEvents$7(ChangeEventSourceCoordinator.java:328) at java.base/java.util.Optional.ifPresent(Optional.java:178) at io.debezium.pipeline.ChangeEventSourceCoordinator.initStreamEvents(ChangeEventSourceCoordinator.java:328) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:302) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:203) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:143) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at java.base/java.lang.Thread.run(Thread.java:840) 2024-07-17 13:13:38,931 ERROR [debezium-connector-fleet-mongo|task-0] Producer failure (io.debezium.pipeline.ErrorHandler) [debezium-mongodbconnector-fleet-mongo-change-event-source-coordinator] io.debezium.DebeziumException: Database error while executing incremental snapshot for table 'DataCollection{id=dev_fleetprodb.eventdata, additionalCondition=, surrogateKey=}' at io.debezium.connector.mongodb.snapshot.MongoDbIncrementalSnapshotChangeEventSource.readChunk(MongoDbIncrementalSnapshotChangeEventSource.java:343) at io.debezium.connector.mongodb.snapshot.MongoDbIncrementalSnapshotChangeEventSource.init(MongoDbIncrementalSnapshotChangeEventSource.java:269) at io.debezium.connector.mongodb.snapshot.MongoDbIncrementalSnapshotChangeEventSource.init(MongoDbIncrementalSnapshotChangeEventSource.java:76) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$initStreamEvents$7(ChangeEventSourceCoordinator.java:328) at java.base/java.util.Optional.ifPresent(Optional.java:178) at io.debezium.pipeline.ChangeEventSourceCoordinator.initStreamEvents(ChangeEventSourceCoordinator.java:328) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:302) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:203) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:143) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at java.base/java.lang.Thread.run(Thread.java:840) Caused by: io.debezium.DebeziumException: Error while attempting to emit window open for chunk 'c3492866-47cd-4ebf-99fc-e7a6b3c02d80' at io.debezium.connector.mongodb.connection.MongoDbConnections.lambda$eventSourcingErrorHandler$1(MongoDbConnections.java:53) at io.debezium.connector.mongodb.connection.MongoDbConnection.execute(MongoDbConnection.java:111) at io.debezium.connector.mongodb.connection.MongoDbConnection.execute(MongoDbConnection.java:88) at io.debezium.connector.mongodb.snapshot.MongoDbIncrementalSnapshotChangeEventSource.emitWindowOpen(MongoDbIncrementalSnapshotChangeEventSource.java:216) at io.debezium.connector.mongodb.snapshot.MongoDbIncrementalSnapshotChangeEventSource.readChunk(MongoDbIncrementalSnapshotChangeEventSource.java:290) ... 13 more Caused by: java.lang.NullPointerException: Cannot invoke "io.debezium.connector.mongodb.CollectionId.dbName()" because "collectionId" is null at io.debezium.connector.mongodb.snapshot.MongoDbIncrementalSnapshotChangeEventSource.lambda$emitWindowOpen$0(MongoDbIncrementalSnapshotChangeEventSource.java:219) at io.debezium.connector.mongodb.connection.MongoDbConnection.lambda$execute$0(MongoDbConnection.java:89) at io.debezium.connector.mongodb.connection.MongoDbConnection.execute(MongoDbConnection.java:105) ... 16 more 2024-07-17 13:13:38,931 INFO [debezium-connector-fleet-mongo|task-0] Connected metrics set to 'false' (io.debezium.pipeline.ChangeEventSourceCoordinator) [debezium-mongodbconnector-fleet-mongo-change-event-source-coordinator] 2024-07-17 13:13:39,409 ERROR [debezium-connector-fleet-mongo|task-0] WorkerSourceTask{id=debezium-connector-fleet-mongo-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask) [task-thread-debezium-connector-fleet-mongo-0] org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped. at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:67) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:150) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at java.base/java.lang.Thread.run(Thread.java:840) Caused by: io.debezium.DebeziumException: Database error while executing incremental snapshot for table 'DataCollection{id=dev_fleetprodb.eventdata, additionalCondition=, surrogateKey=}' at io.debezium.connector.mongodb.snapshot.MongoDbIncrementalSnapshotChangeEventSource.readChunk(MongoDbIncrementalSnapshotChangeEventSource.java:343) at io.debezium.connector.mongodb.snapshot.MongoDbIncrementalSnapshotChangeEventSource.init(MongoDbIncrementalSnapshotChangeEventSource.java:269) at io.debezium.connector.mongodb.snapshot.MongoDbIncrementalSnapshotChangeEventSource.init(MongoDbIncrementalSnapshotChangeEventSource.java:76) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$initStreamEvents$7(ChangeEventSourceCoordinator.java:328) at java.base/java.util.Optional.ifPresent(Optional.java:178) at io.debezium.pipeline.ChangeEventSourceCoordinator.initStreamEvents(ChangeEventSourceCoordinator.java:328) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:302) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:203) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:143) ... 5 more Caused by: io.debezium.DebeziumException: Error while attempting to emit window open for chunk 'c3492866-47cd-4ebf-99fc-e7a6b3c02d80' at io.debezium.connector.mongodb.connection.MongoDbConnections.lambda$eventSourcingErrorHandler$1(MongoDbConnections.java:53) at io.debezium.connector.mongodb.connection.MongoDbConnection.execute(MongoDbConnection.java:111) at io.debezium.connector.mongodb.connection.MongoDbConnection.execute(MongoDbConnection.java:88) at io.debezium.connector.mongodb.snapshot.MongoDbIncrementalSnapshotChangeEventSource.emitWindowOpen(MongoDbIncrementalSnapshotChangeEventSource.java:216) at io.debezium.connector.mongodb.snapshot.MongoDbIncrementalSnapshotChangeEventSource.readChunk(MongoDbIncrementalSnapshotChangeEventSource.java:290) ... 13 more Caused by: java.lang.NullPointerException: Cannot invoke "io.debezium.connector.mongodb.CollectionId.dbName()" because "collectionId" is null at io.debezium.connector.mongodb.snapshot.MongoDbIncrementalSnapshotChangeEventSource.lambda$emitWindowOpen$0(MongoDbIncrementalSnapshotChangeEventSource.java:219) at io.debezium.connector.mongodb.connection.MongoDbConnection.lambda$execute$0(MongoDbConnection.java:89) at io.debezium.connector.mongodb.connection.MongoDbConnection.execute(MongoDbConnection.java:105) ... 16 more 2024-07-17 13:13:39,409 INFO [debezium-connector-fleet-mongo|task-0] Stopping down connector (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:39,410 INFO [debezium-connector-fleet-mongo|task-0] Creating thread debezium-mongodbconnector-fleet-mongo-SignalProcessor (io.debezium.util.Threads) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:39,411 INFO [debezium-connector-fleet-mongo|task-0] SignalProcessor stopped (io.debezium.pipeline.signal.SignalProcessor) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:39,411 INFO [debezium-connector-fleet-mongo|task-0] Debezium ServiceRegistry stopped. (io.debezium.service.DefaultServiceRegistry) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:39,411 INFO [debezium-connector-fleet-mongo|task-0] [Producer clientId=connector-producer-debezium-connector-fleet-mongo-0] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:39,416 INFO [debezium-connector-fleet-mongo|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:39,416 INFO [debezium-connector-fleet-mongo|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:39,416 INFO [debezium-connector-fleet-mongo|task-0] Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter (org.apache.kafka.common.metrics.Metrics) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:39,416 INFO [debezium-connector-fleet-mongo|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [task-thread-debezium-connector-fleet-mongo-0] 2024-07-17 13:13:39,416 INFO [debezium-connector-fleet-mongo|task-0] App info kafka.producer for connector-producer-debezium-connector-fleet-mongo-0 unregistered (org.apache.kafka.common.utils.AppInfoParser) [task-thread-debezium-connector-fleet-mongo-0]