D:\kafka>.\bin\windows\connect-standalone.bat .\config\connect-standalone.properties
[2024-11-19 17:19:21,594] INFO Kafka Connect worker initializing ... (org.apache.kafka.connect.cli.AbstractConnectCli:114)
[2024-11-19 17:19:21,600] INFO WorkerInfo values:
jvm.args = -Xmx256M, -XX:+UseG1GC, -XX:MaxGCPauseMillis=20, -XX:InitiatingHeapOccupancyPercent=35, -XX:+ExplicitGCInvokesConcurrent, -Djava.awt.headless=true, -Dcom.sun.management.jmxremote, -Dcom.sun.management.jmxremote.authenticate=false, -Dcom.sun.management.jmxremote.ssl=false, -Dkafka.logs.dir=D:\kafka/logs, -Dlog4j.configuration=file:D:\kafka/config/connect-log4j.properties
jvm.spec = Oracle Corporation, Java HotSpot(TM) 64-Bit Server VM, 21.0.2, 21.0.2+13-LTS-58
jvm.classpath = D:\kafka\libs\activation-1.1.1.jar;D:\kafka\libs\aopalliance-repackaged-2.6.1.jar;D:\kafka\libs\argparse4j-0.7.0.jar;D:\kafka\libs\audience-annotations-0.12.0.jar;D:\kafka\libs\avro-1.10.2.jar;D:\kafka\libs\caffeine-2.9.3.jar;D:\kafka\libs\checker-qual-3.19.0.jar;D:\kafka\libs\commons-beanutils-1.9.4.jar;D:\kafka\libs\commons-cli-1.4.jar;D:\kafka\libs\commons-collections-3.2.2.jar;D:\kafka\libs\commons-digester-2.1.jar;D:\kafka\libs\commons-io-2.11.0.jar;D:\kafka\libs\commons-lang3-3.12.0.jar;D:\kafka\libs\commons-logging-1.2.jar;D:\kafka\libs\commons-validator-1.7.jar;D:\kafka\libs\connect-api-3.8.0.jar;D:\kafka\libs\connect-basic-auth-extension-3.8.0.jar;D:\kafka\libs\connect-file-
3.8.0.jar;D:\kafka\libs\connect-json-3.8.0.jar;D:\kafka\libs\connect-mirror-3.8.0.jar;D:\kafka\libs\connect-mirror-client-3.8.0.jar;D:\kafka\libs\connect-runtime-3.8.0.jar;D:\kafka\libs\connect-transforms-3.8.0.jar;D:\kafka\libs\error_prone_annotations-2.10.0.jar;D:\kafka\libs\hk2-api-2.6.1.jar;D:\kafka\libs\hk2-locator-2.6.1.jar;D:\kafka\libs\hk2-utils-2.6.1.jar;D:\kafka\libs\jackson-annotations-2.16.2.jar;D:\kafka\libs\jackson-core-2.16.2.jar;D:\kafka\libs\jackson-databind-2.16.2.jar;D:\kafka\libs\jackson-dataformat-csv-2.16.2.jar;D:\kafka\libs\jackson-datatype-jdk8-2.16.2.jar;D:\kafka\libs\jackson-jaxrs-base-2.16.2.jar;D:\kafka\libs\jackson-jaxrs-json-provider-2.16.2.jar;D:\kafka\libs\jackson-module-afterburner-2.16.2.jar;D:\kafka\libs\jackson-module-jaxb-annotations-2.16.2.jar;D:\kafka\libs\jackson-module-scala_2.12-2.16.2.jar;D:\kafka\libs\jakarta.activation-api-1.2.2.jar;D:\kafka\libs\jakarta.annotation-api-1.3.5.jar;D:\kafka\libs\jakarta.inject-2.6.1.jar;D:\kafka\libs\jakarta.validation-api-2.0.2.jar;D:\kafka\libs\jakarta.ws.rs-api-2.1.6.jar;D:\kafka\libs\jakarta.xml.bind-api-2.3.3.jar;D:\kafka\libs\javassist-3.29.2-GA.jar;D:\kafka\libs\javax.activation-api-1.2.0.jar;D:\kafka\libs\javax.annotation-api-1.3.2.jar;D:\kafka\libs\javax.servlet-api-3.1.0.jar;D:\kafka\libs\javax.ws.rs-api-2.1.1.jar;D:\kafka\libs\jaxb-api-2.3.1.jar;D:\kafka\libs\jersey-client-2.39.1.jar;D:\kafka\libs\jersey-common-2.39.1.jar;D:\kafka\libs\jersey-container-servlet-2.39.1.jar;D:\kafka\libs\jersey-container-servlet-core-2.39.1.jar;D:\kafka\libs\jersey-hk2-2.39.1.jar;D:\kafka\libs\jersey-server-2.39.1.jar;D:\kafka\libs\jetty-client-9.4.54.v20240208.jar;D:\kafka\libs\jetty-continuation-9.4.54.v20240208.jar;D:\kafka\libs\jetty-http-9.4.54.v20240208.jar;D:\kafka\libs\jetty-io-9.4.54.v20240208.jar;D:\kafka\libs\jetty-security-9.4.54.v20240208.jar;D:\kafka\libs\jetty-server-9.4.54.v20240208.jar;D:\kafka\libs\jetty-servlet-9.4.54.v20240208.jar;D:\kafka\libs\jetty-servlets-9.4.54.v20240208.jar;D:\kafka\libs\jetty-util-9.4.54.v20240208.jar;D:\kafka\libs\jetty-util-ajax-9.4.54.v20240208.jar;D:\kafka\libs\jline-3.25.1.jar;D:\kafka\libs\jopt-simple-5.0.4.jar;D:\kafka\libs\jose4j-0.9.4.jar;D:\kafka\libs\jsr305-3.0.2.jar;D:\kafka\libs\kafka-clients-3.8.0.jar;D:\kafka\libs\kafka-group-coordinator-3.8.0.jar;D:\kafka\libs\kafka-group-coordinator-api-3.8.0.jar;D:\kafka\libs\kafka-log4j-appender-3.8.0.jar;D:\kafka\libs\kafka-metadata-3.8.0.jar;D:\kafka\libs\kafka-raft-3.8.0.jar;D:\kafka\libs\kafka-server-3.8.0.jar;D:\kafka\libs\kafka-server-common-3.8.0.jar;D:\kafka\libs\kafka-shell-3.8.0.jar;D:\kafka\libs\kafka-storage-3.8.0.jar;D:\kafka\libs\kafka-storage-api-3.8.0.jar;D:\kafka\libs\kafka-streams-3.8.0.jar;D:\kafka\libs\kafka-streams-examples-3.8.0.jar;D:\kafka\libs\kafka-streams-scala_2.12-3.8.0.jar;D:\kafka\libs\kafka-streams-test-utils-3.8.0.jar;D:\kafka\libs\kafka-tools-3.8.0.jar;D:\kafka\libs\kafka-tools-api-3.8.0.jar;D:\kafka\libs\kafka-transaction-coordinator-3.8.0.jar;D:\kafka\libs\kafka_2.12-3.8.0.jar;D:\kafka\libs\lz4-java-1.8.0.jar;D:\kafka\libs\maven-artifact-3.9.6.jar;D:\kafka\libs\metrics-core-2.2.0.jar;D:\kafka\libs\metrics-core-4.1.12.1.jar;D:\kafka\libs\netty-buffer-4.1.110.Final.jar;D:\kafka\libs\netty-codec-4.1.110.Final.jar;D:\kafka\libs\netty-common-4.1.110.Final.jar;D:\kafka\libs\netty-handler-4.1.110.Final.jar;D:\kafka\libs\netty-resolver-4.1.110.Final.jar;D:\kafka\libs\netty-transport-4.1.110.Final.jar;D:\kafka\libs\netty-transport-classes-epoll-4.1.110.Final.jar;D:\kafka\libs\netty-transport-native-epoll-4.1.110.Final.jar;D:\kafka\libs\netty-transport-native-unix-common-4.1.110.Final.jar;D:\kafka\libs\opentelemetry-proto-1.0.0-alpha.jar;D:\kafka\libs\osgi-resource-locator-1.0.3.jar;D:\kafka\libs\paranamer-2.8.jar;D:\kafka\libs\pcollections-4.0.1.jar;D:\kafka\libs\plexus-utils-3.5.1.jar;D:\kafka\libs\protobuf-java-3.23.4.jar;D:\kafka\libs\reflections-0.10.2.jar;D:\kafka\libs\reload4j-1.2.25.jar;D:\kafka\libs\rocksdbjni-7.9.2.jar;D:\kafka\libs\scala-collection-compat_2.12-2.10.0.jar;D:\kafka\libs\scala-java8-compat_2.12-1.0.2.jar;D:\kafka\libs\scala-library-2.12.19.jar;D:\kafka\libs\scala-logging_2.12-3.9.4.jar;D:\kafka\libs\scala-reflect-2.12.19.jar;D:\kafka\libs\slf4j-api-1.7.36.jar;D:\kafka\libs\slf4j-reload4j-1.7.36.jar;D:\kafka\libs\snappy-java-1.1.10.5.jar;D:\kafka\libs\swagger-annotations-2.2.8.jar;D:\kafka\libs\trogdor-3.8.0.jar;D:\kafka\libs\zookeeper-3.8.4.jar;D:\kafka\libs\zookeeper-jute-3.8.4.jar;D:\kafka\libs\zstd-jni-1.5.6-3.jar
os.spec = Windows 10, amd64, 10.0
os.vcpus = 16
(org.apache.kafka.connect.runtime.WorkerInfo:71)
[2024-11-19 17:19:21,602] INFO Scanning for plugin classes. This might take a moment ... (org.apache.kafka.connect.cli.AbstractConnectCli:120)
[2024-11-19 17:19:21,626] INFO Loading plugin from: D:\kafka\connectors\mongo-kafka-connect-1.13.0-confluent.jar (org.apache.kafka.connect.runtime.isolation.PluginScanner:75)
[2024-11-19 17:19:21,814] INFO Registered loader: PluginClassLoader{pluginLocation=file:/D:/kafka/connectors/mongo-kafka-connect-1.13.0-confluent.jar} (org.apache.kafka.connect.runtime.isolation.PluginScanner:80)
[2024-11-19 17:19:21,816] INFO Loading plugin from: D:\kafka\connectors\smt-1.0-SNAPSHOT-jar-with-dependencies.jar (org.apache.kafka.connect.runtime.isolation.PluginScanner:75)
[2024-11-19 17:19:21,863] INFO Registered loader: PluginClassLoader{pluginLocation=file:/D:/kafka/connectors/smt-1.0-SNAPSHOT-jar-with-dependencies.jar} (org.apache.kafka.connect.runtime.isolation.PluginScanner:80)
[2024-11-19 17:19:21,863] INFO Loading plugin from: classpath (org.apache.kafka.connect.runtime.isolation.PluginScanner:75)
[2024-11-19 17:19:21,876] INFO Registered loader: jdk.internal.loader.ClassLoaders$AppClassLoader@5acf9800 (org.apache.kafka.connect.runtime.isolation.PluginScanner:80)
[2024-11-19 17:19:21,877] INFO Scanning plugins with ServiceLoaderScanner took 254 ms (org.apache.kafka.connect.runtime.isolation.PluginScanner:70)
[2024-11-19 17:19:21,878] INFO Loading plugin from: D:\kafka\connectors\mongo-kafka-connect-1.13.0-confluent.jar (org.apache.kafka.connect.runtime.isolation.PluginScanner:75)
[2024-11-19 17:19:22,149] INFO Registered loader: PluginClassLoader{pluginLocation=file:/D:/kafka/connectors/mongo-kafka-connect-1.13.0-confluent.jar} (org.apache.kafka.connect.runtime.isolation.PluginScanner:80)
[2024-11-19 17:19:22,149] INFO Loading plugin from: D:\kafka\connectors\smt-1.0-SNAPSHOT-jar-with-dependencies.jar (org.apache.kafka.connect.runtime.isolation.PluginScanner:75)
[2024-11-19 17:19:22,264] INFO Registered loader: PluginClassLoader{pluginLocation=file:/D:/kafka/connectors/smt-1.0-SNAPSHOT-jar-with-dependencies.jar} (org.apache.kafka.connect.runtime.isolation.PluginScanner:80)
[2024-11-19 17:19:22,265] INFO Loading plugin from: classpath (org.apache.kafka.connect.runtime.isolation.PluginScanner:75)
[2024-11-19 17:19:23,354] INFO Registered loader: jdk.internal.loader.ClassLoaders$AppClassLoader@5acf9800 (org.apache.kafka.connect.runtime.isolation.PluginScanner:80)
[2024-11-19 17:19:23,356] INFO Scanning plugins with ReflectionScanner took 1478 ms (org.apache.kafka.connect.runtime.isolation.PluginScanner:70)
[2024-11-19 17:19:23,364] WARN One or more plugins are missing ServiceLoader manifests may not be usable with plugin.discovery=service_load: [
file:/D:/kafka/connectors/mongo-kafka-connect-1.13.0-confluent.jar com.mongodb.kafka.connect.MongoSinkConnector sink 1.13.0
file:/D:/kafka/connectors/mongo-kafka-connect-1.13.0-confluent.jar com.mongodb.kafka.connect.MongoSourceConnector source 1.13.0
file:/D:/kafka/connectors/smt-1.0-SNAPSHOT-jar-with-dependencies.jar org.example.DateTransformer transformation undefined
]
Read the documentation at https://kafka.apache.org/documentation.html#connect_plugindiscovery for instructions on migrating your plugins to take advantage of the performance improvements of service_load mode. To silence this warning, set plugin.discovery=only_scan in the worker config. (org.apache.kafka.connect.runtime.isolation.Plugins:122)
[2024-11-19 17:19:23,366] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,367] INFO Added plugin 'org.apache.kafka.connect.transforms.Filter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,368] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,369] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,370] INFO Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,370] INFO Added plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,371] INFO Added plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,371] INFO Added plugin 'org.apache.kafka.connect.transforms.DropHeaders' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,372] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,372] INFO Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,372] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertHeader' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,373] INFO Added plugin 'org.apache.kafka.common.config.provider.DirectoryConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,374] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,374] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,375] INFO Added plugin 'org.apache.kafka.connect.transforms.HeaderFrom$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,375] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,376] INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.TopicNameMatches' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,376] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,377] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,377] INFO Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,378] INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.RecordIsTombstone' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,379] INFO Added plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,379] INFO Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,380] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,380] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,381] INFO Added plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,381] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,381] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,382] INFO Added plugin 'com.mongodb.kafka.connect.MongoSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,385] INFO Added plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,386] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,386] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,387] INFO Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,387] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,387] INFO Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,388] INFO Added plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,388] INFO Added plugin 'com.mongodb.kafka.connect.MongoSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,389] INFO Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,389] INFO Added plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,390] INFO Added plugin 'org.apache.kafka.connect.transforms.HeaderFrom$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,390] INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.HasHeaderKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,391] INFO Added plugin 'org.example.DateTransformer' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,391] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,392] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,392] INFO Added plugin 'org.apache.kafka.common.config.provider.EnvVarConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,392] INFO Added plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,393] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,394] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,394] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,394] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,395] INFO Added plugin 'org.apache.kafka.connect.converters.BooleanConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,395] INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,396] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,397] INFO Added plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:105)
[2024-11-19 17:19:23,401] INFO Added alias 'RecordIsTombstone' to plugin 'org.apache.kafka.connect.transforms.predicates.RecordIsTombstone' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,402] INFO Added alias 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,403] INFO Added alias 'FileStreamSource' to plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,404] INFO Added alias 'EnvVar' to plugin 'org.apache.kafka.common.config.provider.EnvVarConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,404] INFO Added alias 'EnvVarConfigProvider' to plugin 'org.apache.kafka.common.config.provider.EnvVarConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,405] INFO Added alias 'MirrorCheckpointConnector' to plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,405] INFO Added alias 'Boolean' to plugin 'org.apache.kafka.connect.converters.BooleanConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,405] INFO Added alias 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,407] INFO Added alias 'StringConverter' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,407] INFO Added alias 'IntegerConverter' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,408] INFO Added alias 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,408] INFO Added alias 'LongConverter' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,409] INFO Added alias 'DropHeaders' to plugin 'org.apache.kafka.connect.transforms.DropHeaders' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,409] INFO Added alias 'SimpleHeaderConverter' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,410] INFO Added alias 'FileStreamSinkConnector' to plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,410] INFO Added alias 'DirectoryConfigProvider' to plugin 'org.apache.kafka.common.config.provider.DirectoryConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,410] INFO Added alias 'ShortConverter' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,411] INFO Added alias 'BasicAuthSecurityRestExtension' to plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,411] INFO Added alias 'Simple' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,411] INFO Added alias 'AllConnectorClientConfigOverridePolicy' to plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,412] INFO Added alias 'MirrorSource' to plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,412] INFO Added alias 'Directory' to plugin 'org.apache.kafka.common.config.provider.DirectoryConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,412] INFO Added alias 'MongoSource' to plugin 'com.mongodb.kafka.connect.MongoSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,413] INFO Added alias 'MongoSinkConnector' to plugin 'com.mongodb.kafka.connect.MongoSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,413] INFO Added alias 'MirrorHeartbeat' to plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,414] INFO Added alias 'DateTransformer' to plugin 'org.example.DateTransformer' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,417] INFO Added alias 'FileStreamSourceConnector' to plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,418] INFO Added alias 'BooleanConverter' to plugin 'org.apache.kafka.connect.converters.BooleanConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,418] INFO Added alias 'HasHeaderKey' to plugin 'org.apache.kafka.connect.transforms.predicates.HasHeaderKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,418] INFO Added alias 'MirrorCheckpoint' to plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,419] INFO Added alias 'None' to plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,419] INFO Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,420] INFO Added alias 'Principal' to plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,420] INFO Added alias 'All' to plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,421] INFO Added alias 'JsonConverter' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,421] INFO Added alias 'MongoSourceConnector' to plugin 'com.mongodb.kafka.connect.MongoSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,422] INFO Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,422] INFO Added alias 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,423] INFO Added alias 'NoneConnectorClientConfigOverridePolicy' to plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,423] INFO Added alias 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,423] INFO Added alias 'MongoSink' to plugin 'com.mongodb.kafka.connect.MongoSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,424] INFO Added alias 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,424] INFO Added alias 'FileConfigProvider' to plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,425] INFO Added alias 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,425] INFO Added alias 'File' to plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,426] INFO Added alias 'FloatConverter' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,426] INFO Added alias 'ByteArrayConverter' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,426] INFO Added alias 'FileStreamSink' to plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,427] INFO Added alias 'DoubleConverter' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,427] INFO Added alias 'TopicNameMatches' to plugin 'org.apache.kafka.connect.transforms.predicates.TopicNameMatches' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,428] INFO Added alias 'MirrorHeartbeatConnector' to plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,428] INFO Added alias 'InsertHeader' to plugin 'org.apache.kafka.connect.transforms.InsertHeader' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,429] INFO Added alias 'MirrorSourceConnector' to plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,430] INFO Added alias 'PrincipalConnectorClientConfigOverridePolicy' to plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,432] INFO Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,433] INFO Added alias 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,434] INFO Added alias 'Filter' to plugin 'org.apache.kafka.connect.transforms.Filter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:109)
[2024-11-19 17:19:23,449] INFO StandaloneConfig values:
access.control.allow.methods =
access.control.allow.origin =
admin.listeners = null
auto.include.jmx.reporter = true
bootstrap.servers = [localhost:9092]
client.dns.lookup = use_all_dns_ips
config.providers = []
connector.client.config.override.policy = All
header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter
key.converter = class org.apache.kafka.connect.json.JsonConverter
listeners = [http://:8083]
metric.reporters = []
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
offset.flush.interval.ms = 1000
offset.flush.timeout.ms = 5000
offset.storage.file.filename = D:/kafka/connect/connect.offsets
plugin.discovery = hybrid_warn
plugin.path = [D:/kafka/connectors]
response.http.headers.config =
rest.advertised.host.name = null
rest.advertised.listener = null
rest.advertised.port = null
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
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
(org.apache.kafka.connect.runtime.standalone.StandaloneConfig:372)
[2024-11-19 17:19:23,451] INFO Creating Kafka admin client (org.apache.kafka.connect.runtime.WorkerConfig:283)
[2024-11-19 17:19:23,456] INFO AdminClientConfig values:
auto.include.jmx.reporter = true
bootstrap.controllers = []
bootstrap.servers = [localhost: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
metadata.recovery.strategy = none
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 = null
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.min.time.before.relogin = 60000
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
sasl.kerberos.ticket.renew.window.factor = 0.8
sasl.login.callback.handler.class = null
sasl.login.class = null
sasl.login.connect.timeout.ms = null
sasl.login.read.timeout.ms = null
sasl.login.refresh.buffer.seconds = 300
sasl.login.refresh.min.period.seconds = 60
sasl.login.refresh.window.factor = 0.8
sasl.login.refresh.window.jitter = 0.05
sasl.login.retry.backoff.max.ms = 10000
sasl.login.retry.backoff.ms = 100
sasl.mechanism = GSSAPI
sasl.oauthbearer.clock.skew.seconds = 30
sasl.oauthbearer.expected.audience = null
sasl.oauthbearer.expected.issuer = null
sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
sasl.oauthbearer.jwks.endpoint.url = null
sasl.oauthbearer.scope.claim.name = scope
sasl.oauthbearer.sub.claim.name = sub
sasl.oauthbearer.token.endpoint.url = null
security.protocol = PLAINTEXT
security.providers = null
send.buffer.bytes = 131072
socket.connection.setup.timeout.max.ms = 30000
socket.connection.setup.timeout.ms = 10000
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
ssl.endpoint.identification.algorithm = https
ssl.engine.factory.class = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.certificate.chain = null
ssl.keystore.key = null
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLSv1.3
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.certificates = null
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
(org.apache.kafka.clients.admin.AdminClientConfig:372)
[2024-11-19 17:19:23,574] INFO These configurations '[offset.flush.interval.ms, key.converter.schemas.enable, offset.storage.file.filename, value.converter.schemas.enable, plugin.path, value.converter, key.converter]' were supplied but are not used yet. (org.apache.kafka.clients.admin.AdminClientConfig:381)
[2024-11-19 17:19:23,576] INFO Kafka version: 3.8.0 (org.apache.kafka.common.utils.AppInfoParser:124)
[2024-11-19 17:19:23,577] INFO Kafka commitId: 771b9576b00ecf5b (org.apache.kafka.common.utils.AppInfoParser:125)
[2024-11-19 17:19:23,577] INFO Kafka startTimeMs: 1732029563575 (org.apache.kafka.common.utils.AppInfoParser:126)
[2024-11-19 17:19:23,814] INFO Kafka cluster ID: daqwrCtFQPyzbeevhFwA1A (org.apache.kafka.connect.runtime.WorkerConfig:300)
[2024-11-19 17:19:23,816] INFO App info kafka.admin.client for adminclient-1 unregistered (org.apache.kafka.common.utils.AppInfoParser:88)
[2024-11-19 17:19:23,822] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:684)
[2024-11-19 17:19:23,823] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:688)
[2024-11-19 17:19:23,824] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:694)
[2024-11-19 17:19:23,830] 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 = null
rest.advertised.listener = null
rest.advertised.port = null
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:372)
[2024-11-19 17:19:23,841] INFO Logging initialized @2708ms to org.eclipse.jetty.util.log.Slf4jLog (org.eclipse.jetty.util.log:170)
[2024-11-19 17:19:23,873] INFO Added connector for http://:8083 (org.apache.kafka.connect.runtime.rest.RestServer:121)
[2024-11-19 17:19:23,874] INFO Initializing REST server (org.apache.kafka.connect.runtime.rest.RestServer:192)
[2024-11-19 17:19:23,900] INFO jetty-9.4.54.v20240208; built: 2024-02-08T19:42:39.027Z; git: cef3fbd6d736a21e7d541a5db490381d95a2047d; jvm 21.0.2+13-LTS-58 (org.eclipse.jetty.server.Server:375)
[2024-11-19 17:19:23,935] INFO Started http_8083@192b472d{HTTP/1.1, (http/1.1)}{0.0.0.0:8083} (org.eclipse.jetty.server.AbstractConnector:333)
[2024-11-19 17:19:23,936] INFO Started @2803ms (org.eclipse.jetty.server.Server:415)
[2024-11-19 17:19:23,953] INFO Advertised URI: http://192.168.1.3:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:412)
[2024-11-19 17:19:23,954] INFO REST server listening at http://192.168.1.3:8083/, advertising URL http://192.168.1.3:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:212)
[2024-11-19 17:19:23,955] INFO Advertised URI: http://192.168.1.3:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:412)
[2024-11-19 17:19:23,955] INFO REST admin endpoints at http://192.168.1.3:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:215)
[2024-11-19 17:19:23,956] INFO Advertised URI: http://192.168.1.3:8083/ (org.apache.kafka.connect.runtime.rest.RestServer:412)
[2024-11-19 17:19:23,957] INFO Setting up All Policy for ConnectorClientConfigOverride. This will allow all client configurations to be overridden (org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy:44)
[2024-11-19 17:19:23,958] 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:372)
[2024-11-19 17:19:23,967] INFO Kafka version: 3.8.0 (org.apache.kafka.common.utils.AppInfoParser:124)
[2024-11-19 17:19:23,967] INFO Kafka commitId: 771b9576b00ecf5b (org.apache.kafka.common.utils.AppInfoParser:125)
[2024-11-19 17:19:23,969] INFO Kafka startTimeMs: 1732029563967 (org.apache.kafka.common.utils.AppInfoParser:126)
[2024-11-19 17:19:23,975] 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:372)
[2024-11-19 17:19:23,976] 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:372)
[2024-11-19 17:19:23,983] INFO Kafka Connect worker initialization took 2386ms (org.apache.kafka.connect.cli.AbstractConnectCli:141)
[2024-11-19 17:19:23,984] INFO Kafka Connect starting (org.apache.kafka.connect.runtime.Connect:51)
[2024-11-19 17:19:23,986] INFO Herder starting (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:108)
[2024-11-19 17:19:23,986] INFO Worker starting (org.apache.kafka.connect.runtime.Worker:232)
[2024-11-19 17:19:23,988] INFO Starting FileOffsetBackingStore with file D:\kafka\connect\connect.offsets (org.apache.kafka.connect.storage.FileOffsetBackingStore:63)
[2024-11-19 17:19:24,008] INFO Worker started (org.apache.kafka.connect.runtime.Worker:242)
[2024-11-19 17:19:24,009] INFO Herder started (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:111)
[2024-11-19 17:19:24,010] INFO Initializing REST resources (org.apache.kafka.connect.runtime.rest.RestServer:219)
[2024-11-19 17:19:24,039] INFO Adding admin resources to main listener (org.apache.kafka.connect.runtime.rest.RestServer:234)
[2024-11-19 17:19:24,075] INFO DefaultSessionIdManager workerName=node0 (org.eclipse.jetty.server.session:334)
[2024-11-19 17:19:24,076] INFO No SessionScavenger set, using defaults (org.eclipse.jetty.server.session:339)
[2024-11-19 17:19:24,078] INFO node0 Scavenging every 660000ms (org.eclipse.jetty.server.session:132)
[2024-11-19 17:19:24,481] INFO Started o.e.j.s.ServletContextHandler@dd20ebc{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:921)
[2024-11-19 17:19:24,482] INFO REST resources initialized; server is started and ready to handle requests (org.apache.kafka.connect.runtime.rest.RestServer:299)
[2024-11-19 17:19:24,483] INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect:57)
[2024-11-19 17:19:26,706] INFO MongoSinkTopicConfig values:
bulk.write.ordered = true
change.data.capture.handler =
collection = movies
database = movies
delete.on.null.values = false
delete.writemodel.strategy = com.mongodb.kafka.connect.sink.writemodel.strategy.DeleteOneDefaultStrategy
document.id.strategy = com.mongodb.kafka.connect.sink.processor.id.strategy.BsonOidStrategy
document.id.strategy.overwrite.existing = false
document.id.strategy.partial.key.projection.list =
document.id.strategy.partial.key.projection.type =
document.id.strategy.partial.value.projection.list =
document.id.strategy.partial.value.projection.type =
document.id.strategy.uuid.format = string
errors.log.enable = false
errors.tolerance = none
field.renamer.mapping = []
field.renamer.regexp = []
key.projection.list =
key.projection.type = none
max.batch.size = 0
mongo.errors.log.enable = false
mongo.errors.tolerance = none
namespace.mapper = com.mongodb.kafka.connect.sink.namespace.mapping.DefaultNamespaceMapper
namespace.mapper.error.if.invalid = false
namespace.mapper.key.collection.field =
namespace.mapper.key.database.field =
namespace.mapper.value.collection.field =
namespace.mapper.value.database.field =
post.processor.chain = [com.mongodb.kafka.connect.sink.processor.DocumentIdAdder]
rate.limiting.every.n = 0
rate.limiting.timeout = 0
timeseries.expire.after.seconds = 0
timeseries.granularity =
timeseries.metafield =
timeseries.timefield =
timeseries.timefield.auto.convert = false
timeseries.timefield.auto.convert.date.format = yyyy-MM-dd[['T'][ ]][HH:mm:ss[[.][SSSSSS][SSS]][ ]VV[ ]'['VV']'][HH:mm:ss[[.][SSSSSS][SSS]][ ]X][HH:mm:ss[[.][SSSSSS][SSS]]]
timeseries.timefield.auto.convert.locale.language.tag =
topic = movies
value.projection.list =
value.projection.type = none
writemodel.strategy = com.mongodb.kafka.connect.sink.writemodel.strategy.DefaultWriteModelStrategy
(com.mongodb.kafka.connect.sink.MongoSinkTopicConfig:372)
[2024-11-19 17:19:26,729] INFO MongoSinkTopicConfig values:
bulk.write.ordered = true
change.data.capture.handler =
collection = movies
database = movies
delete.on.null.values = false
delete.writemodel.strategy = com.mongodb.kafka.connect.sink.writemodel.strategy.DeleteOneDefaultStrategy
document.id.strategy = com.mongodb.kafka.connect.sink.processor.id.strategy.BsonOidStrategy
document.id.strategy.overwrite.existing = false
document.id.strategy.partial.key.projection.list =
document.id.strategy.partial.key.projection.type =
document.id.strategy.partial.value.projection.list =
document.id.strategy.partial.value.projection.type =
document.id.strategy.uuid.format = string
errors.log.enable = false
errors.tolerance = none
field.renamer.mapping = []
field.renamer.regexp = []
key.projection.list =
key.projection.type = none
max.batch.size = 0
mongo.errors.log.enable = false
mongo.errors.tolerance = none
namespace.mapper = com.mongodb.kafka.connect.sink.namespace.mapping.DefaultNamespaceMapper
namespace.mapper.error.if.invalid = false
namespace.mapper.key.collection.field =
namespace.mapper.key.database.field =
namespace.mapper.value.collection.field =
namespace.mapper.value.database.field =
post.processor.chain = [com.mongodb.kafka.connect.sink.processor.DocumentIdAdder]
rate.limiting.every.n = 0
rate.limiting.timeout = 0
timeseries.expire.after.seconds = 0
timeseries.granularity =
timeseries.metafield =
timeseries.timefield =
timeseries.timefield.auto.convert = false
timeseries.timefield.auto.convert.date.format = yyyy-MM-dd[['T'][ ]][HH:mm:ss[[.][SSSSSS][SSS]][ ]VV[ ]'['VV']'][HH:mm:ss[[.][SSSSSS][SSS]][ ]X][HH:mm:ss[[.][SSSSSS][SSS]]]
timeseries.timefield.auto.convert.locale.language.tag =
topic = movies
value.projection.list =
value.projection.type = none
writemodel.strategy = com.mongodb.kafka.connect.sink.writemodel.strategy.DefaultWriteModelStrategy
(com.mongodb.kafka.connect.sink.MongoSinkTopicConfig:372)
[2024-11-19 17:19:26,810] INFO MongoClient with metadata {"driver": {"name": "mongo-java-driver|sync", "version": "4.7.2"}, "os": {"type": "Windows", "name": "Windows 10", "architecture": "amd64", "version": "10.0"}, "platform": "Java/Oracle Corporation/21.0.2+13-LTS-58"} created with settings MongoClientSettings{readPreference=primary, writeConcern=WriteConcern{w=null, wTimeout=null ms, journal=null}, retryWrites=true, retryReads=true, readConcern=ReadConcern{level=null}, credential=null, streamFactoryFactory=null, commandListeners=[], codecRegistry=ProvidersCodecRegistry{codecProviders=[ValueCodecProvider{}, BsonValueCodecProvider{}, DBRefCodecProvider{}, DBObjectCodecProvider{}, DocumentCodecProvider{}, IterableCodecProvider{}, MapCodecProvider{}, GeoJsonCodecProvider{}, GridFSFileCodecProvider{}, Jsr310CodecProvider{}, JsonObjectCodecProvider{}, BsonCodecProvider{}, EnumCodecProvider{}, com.mongodb.Jep395RecordCodecProvider@71d5f582]}, clusterSettings={hosts=[localhost:27017], srvServiceName=mongodb, mode=SINGLE, requiredClusterType=UNKNOWN, requiredReplicaSetName='null', serverSelector='null', clusterListeners='[com.mongodb.kafka.connect.util.ConnectionValidator$1@71c78d91]', serverSelectionTimeout='30000 ms', localThreshold='30000 ms'}, socketSettings=SocketSettings{connectTimeoutMS=10000, readTimeoutMS=0, receiveBufferSize=0, sendBufferSize=0}, heartbeatSocketSettings=SocketSettings{connectTimeoutMS=10000, readTimeoutMS=10000, receiveBufferSize=0, sendBufferSize=0}, 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=false, invalidHostNameAllowed=false, context=null}, applicationName='null', compressorList=[], uuidRepresentation=UNSPECIFIED, serverApi=null, autoEncryptionSettings=null, contextProvider=null} (org.mongodb.driver.client:71)
[2024-11-19 17:19:26,837] INFO Opened connection [connectionId{localValue:1, serverValue:899}] to localhost:27017 (org.mongodb.driver.connection:71)
[2024-11-19 17:19:26,837] INFO Opened connection [connectionId{localValue:2, serverValue:898}] to localhost:27017 (org.mongodb.driver.connection:71)
[2024-11-19 17:19:26,838] INFO Monitor thread successfully connected to server with description ServerDescription{address=localhost:27017, type=STANDALONE, state=CONNECTED, ok=true, minWireVersion=0, maxWireVersion=25, maxDocumentSize=16777216, logicalSessionTimeoutMinutes=30, roundTripTimeNanos=27288100} (org.mongodb.driver.cluster:71)
[2024-11-19 17:19:26,857] INFO AbstractConfig values:
(org.apache.kafka.common.config.AbstractConfig:372)
[2024-11-19 17:19:26,876] INFO [mongodb-sink|worker] Creating connector mongodb-sink of type com.mongodb.kafka.connect.MongoSinkConnector (org.apache.kafka.connect.runtime.Worker:312)
[2024-11-19 17:19:26,878] INFO [mongodb-sink|worker] SinkConnectorConfig values:
config.action.reload = restart
connector.class = com.mongodb.kafka.connect.MongoSinkConnector
errors.deadletterqueue.context.headers.enable = false
errors.deadletterqueue.topic.name =
errors.deadletterqueue.topic.replication.factor = 3
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 = mongodb-sink
predicates = []
tasks.max = 1
tasks.max.enforce = true
topics = [movies]
topics.regex =
transforms = [AddRecordCreatedOn, AddRecordLastUpdatedOn, FormatRecordCreatedOn, FormatRecordLastUpdatedOn, FormatReleasedToTimestamp, FormatLastUpdatedToTimestamp, CustomSmt]
value.converter = class org.apache.kafka.connect.json.JsonConverter
(org.apache.kafka.connect.runtime.SinkConnectorConfig:372)
[2024-11-19 17:19:26,882] INFO [mongodb-sink|worker] EnrichedConnectorConfig values:
config.action.reload = restart
connector.class = com.mongodb.kafka.connect.MongoSinkConnector
errors.deadletterqueue.context.headers.enable = false
errors.deadletterqueue.topic.name =
errors.deadletterqueue.topic.replication.factor = 3
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 = mongodb-sink
predicates = []
tasks.max = 1
tasks.max.enforce = true
topics = [movies]
topics.regex =
transforms = [AddRecordCreatedOn, AddRecordLastUpdatedOn, FormatRecordCreatedOn, FormatRecordLastUpdatedOn, FormatReleasedToTimestamp, FormatLastUpdatedToTimestamp, CustomSmt]
transforms.AddRecordCreatedOn.negate = false
transforms.AddRecordCreatedOn.offset.field = null
transforms.AddRecordCreatedOn.partition.field = null
transforms.AddRecordCreatedOn.predicate = null
transforms.AddRecordCreatedOn.static.field = null
transforms.AddRecordCreatedOn.static.value = null
transforms.AddRecordCreatedOn.timestamp.field = recordCreatedOn
transforms.AddRecordCreatedOn.topic.field = null
transforms.AddRecordCreatedOn.type = class org.apache.kafka.connect.transforms.InsertField$Value
transforms.AddRecordLastUpdatedOn.negate = false
transforms.AddRecordLastUpdatedOn.offset.field = null
transforms.AddRecordLastUpdatedOn.partition.field = null
transforms.AddRecordLastUpdatedOn.predicate = null
transforms.AddRecordLastUpdatedOn.static.field = null
transforms.AddRecordLastUpdatedOn.static.value = null
transforms.AddRecordLastUpdatedOn.timestamp.field = recordLastUpdatedOn
transforms.AddRecordLastUpdatedOn.topic.field = null
transforms.AddRecordLastUpdatedOn.type = class org.apache.kafka.connect.transforms.InsertField$Value
transforms.CustomSmt.negate = false
transforms.CustomSmt.predicate = null
transforms.CustomSmt.type = class org.example.DateTransformer
transforms.FormatLastUpdatedToTimestamp.field = released
transforms.FormatLastUpdatedToTimestamp.format = yyyy-MM-dd'T'HH:mm:ss.SSS'Z'
transforms.FormatLastUpdatedToTimestamp.negate = false
transforms.FormatLastUpdatedToTimestamp.predicate = null
transforms.FormatLastUpdatedToTimestamp.target.type = Timestamp
transforms.FormatLastUpdatedToTimestamp.type = class org.apache.kafka.connect.transforms.TimestampConverter$Value
transforms.FormatLastUpdatedToTimestamp.unix.precision = milliseconds
transforms.FormatRecordCreatedOn.field = recordCreatedOn
transforms.FormatRecordCreatedOn.format = yyyy-MM-dd'T'HH:mm:ss.SSS'Z'
transforms.FormatRecordCreatedOn.negate = false
transforms.FormatRecordCreatedOn.predicate = null
transforms.FormatRecordCreatedOn.target.type = Timestamp
transforms.FormatRecordCreatedOn.type = class org.apache.kafka.connect.transforms.TimestampConverter$Value
transforms.FormatRecordCreatedOn.unix.precision = milliseconds
transforms.FormatRecordLastUpdatedOn.field = recordLastUpdatedOn
transforms.FormatRecordLastUpdatedOn.format = yyyy-MM-dd'T'HH:mm:ss.SSS'Z'
transforms.FormatRecordLastUpdatedOn.negate = false
transforms.FormatRecordLastUpdatedOn.predicate = null
transforms.FormatRecordLastUpdatedOn.target.type = Timestamp
transforms.FormatRecordLastUpdatedOn.type = class org.apache.kafka.connect.transforms.TimestampConverter$Value
transforms.FormatRecordLastUpdatedOn.unix.precision = milliseconds
transforms.FormatReleasedToTimestamp.field = lastUpdated
transforms.FormatReleasedToTimestamp.format = yyyy-MM-dd'T'HH:mm:ss.SSS'Z'
transforms.FormatReleasedToTimestamp.negate = false
transforms.FormatReleasedToTimestamp.predicate = null
transforms.FormatReleasedToTimestamp.target.type = Timestamp
transforms.FormatReleasedToTimestamp.type = class org.apache.kafka.connect.transforms.TimestampConverter$Value
transforms.FormatReleasedToTimestamp.unix.precision = milliseconds
value.converter = class org.apache.kafka.connect.json.JsonConverter
(org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:372)
[2024-11-19 17:19:26,887] INFO [mongodb-sink|worker] Instantiated connector mongodb-sink with version 1.13.0 of type class com.mongodb.kafka.connect.MongoSinkConnector (org.apache.kafka.connect.runtime.Worker:334)
[2024-11-19 17:19:26,889] INFO [mongodb-sink|worker] Finished creating connector mongodb-sink (org.apache.kafka.connect.runtime.Worker:355)
[2024-11-19 17:19:26,894] INFO SinkConnectorConfig values:
config.action.reload = restart
connector.class = com.mongodb.kafka.connect.MongoSinkConnector
errors.deadletterqueue.context.headers.enable = false
errors.deadletterqueue.topic.name =
errors.deadletterqueue.topic.replication.factor = 3
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 = mongodb-sink
predicates = []
tasks.max = 1
tasks.max.enforce = true
topics = [movies]
topics.regex =
transforms = [AddRecordCreatedOn, AddRecordLastUpdatedOn, FormatRecordCreatedOn, FormatRecordLastUpdatedOn, FormatReleasedToTimestamp, FormatLastUpdatedToTimestamp, CustomSmt]
value.converter = class org.apache.kafka.connect.json.JsonConverter
(org.apache.kafka.connect.runtime.SinkConnectorConfig:372)