Using BOOTSTRAP_SERVERS=devl-kaf2-0.sdde.deere.com:9094,devl-kaf2-1.sdde.deere.com:9094,devl-kaf2-2.sdde.deere.com:9094 Plugins are loaded from /kafka/connect Debezium Scripting enabled! Using the following environment variables: GROUP_ID=mdo_debezium_SSL CONFIG_STORAGE_TOPIC=my_connect_configs_SSL OFFSET_STORAGE_TOPIC=my_connect_offsets_SSL STATUS_STORAGE_TOPIC=my_connect_statuses_SSL BOOTSTRAP_SERVERS=devl-kaf2-0.sdde.deere.com:9094,devl-kaf2-1.sdde.deere.com:9094,devl-kaf2-2.sdde.deere.com:9094 REST_HOST_NAME=100.94.27.150 REST_PORT=8083 ADVERTISED_HOST_NAME=100.94.27.150 ADVERTISED_PORT=8083 KEY_CONVERTER=org.apache.kafka.connect.json.JsonConverter VALUE_CONVERTER=org.apache.kafka.connect.json.JsonConverter OFFSET_FLUSH_INTERVAL_MS=60000 OFFSET_FLUSH_TIMEOUT_MS=5000 SHUTDOWN_TIMEOUT=10000 --- Setting property from CONNECT_REST_ADVERTISED_PORT: rest.advertised.port=8083 --- Setting property from CONNECT_PRODUCER_SSL_ENDPOINT_IDENTIFICATION_ALGORITHM: producer.ssl.endpoint.identification.algorithm= --- Setting property from CONNECT_OFFSET_STORAGE_TOPIC: offset.storage.topic=my_connect_offsets_SSL --- Setting property from CONNECT_SASL_JAAS_CONFIG: sasl.jaas.config=[hidden] --- Setting property from CONNECT_KEY_CONVERTER: key.converter=org.apache.kafka.connect.json.JsonConverter --- Setting property from CONNECT_CONFIG_STORAGE_TOPIC: config.storage.topic=my_connect_configs_SSL --- Setting property from CONNECT_GROUP_ID: group.id=mdo_debezium_SSL --- Setting property from CONNECT_REST_ADVERTISED_HOST_NAME: rest.advertised.host.name=100.94.27.150 --- Setting property from CONNECT_SSL_TRUSTSTORE_TYPE: ssl.truststore.type=PEM --- Setting property from CONNECT_REST_HOST_NAME: rest.host.name=100.94.27.150 --- Setting property from CONNECT_PRODUCER_SASL_MECHANISM: producer.sasl.mechanism=SCRAM-SHA-256 --- Setting property from CONNECT_PRODUCER_BOOTSTRAP_SERVERS: producer.bootstrap.servers=devl-kaf2-0.sdde.deere.com:9094,devl-kaf2-1.sdde.deere.com:9094,devl-kaf2-2.sdde.deere.com:9094 --- Setting property from CONNECT_SSL_TRUSTSTORE_LOCATION: ssl.truststore.location=/etc/ssl/certs/ca-crt.pem --- Setting property from CONNECT_PRODUCER_SECURITY_PROTOCOL: producer.security.protocol=SASL_SSL --- Setting property from CONNECT_PRODUCER_SASL_JAAS_CONFIG: producer.sasl.jaas.config=[hidden] --- Setting property from CONNECT_VALUE_CONVERTER: value.converter=org.apache.kafka.connect.json.JsonConverter --- Setting property from CONNECT_SECURITY_PROTOCOL: security.protocol=SASL_SSL --- Setting property from CONNECT_REST_PORT: rest.port=8083 --- Setting property from CONNECT_STATUS_STORAGE_TOPIC: status.storage.topic=my_connect_statuses_SSL --- Setting property from CONNECT_OFFSET_FLUSH_TIMEOUT_MS: offset.flush.timeout.ms=5000 --- Setting property from CONNECT_PRODUCER_SSL_TRUSTSTORE_LOCATION: producer.ssl.truststore.location=/etc/ssl/certs/ca-crt.pem --- Setting property from CONNECT_SSL_ENDPOINT_IDENTIFICATION_ALGORITHM: ssl.endpoint.identification.algorithm= --- Setting property from CONNECT_PLUGIN_PATH: plugin.path=/kafka/connect --- Setting property from CONNECT_OFFSET_FLUSH_INTERVAL_MS: offset.flush.interval.ms=60000 --- Setting property from CONNECT_BOOTSTRAP_SERVERS: bootstrap.servers=devl-kaf2-0.sdde.deere.com:9094,devl-kaf2-1.sdde.deere.com:9094,devl-kaf2-2.sdde.deere.com:9094 --- Setting property from CONNECT_TASK_SHUTDOWN_GRACEFUL_TIMEOUT_MS: task.shutdown.graceful.timeout.ms=10000 --- Setting property from CONNECT_PRODUCER_SSL_TRUSTSTORE_TYPE: producer.ssl.truststore.type=PEM --- Setting property from CONNECT_SASL_MECHANISM: sasl.mechanism=SCRAM-SHA-256 2024-05-30 11:22:13,003 INFO || Kafka Connect worker initializing ... [org.apache.kafka.connect.cli.AbstractConnectCli] 2024-05-30 11:22:13,007 INFO || WorkerInfo values: jvm.args = -Xms256M, -Xmx2G, -Djava.security.properties=/security/java.security, -XX:+UseG1GC, -XX:MaxGCPauseMillis=20, -XX:InitiatingHeapOccupancyPercent=35, -XX:+ExplicitGCInvokesConcurrent, -XX:MaxInlineLevel=15, -Djava.awt.headless=true, -Dcom.sun.management.jmxremote, -Dcom.sun.management.jmxremote.authenticate=false, -Dcom.sun.management.jmxremote.ssl=false, -Dkafka.logs.dir=/kafka/logs, -Dlog4j.configuration=file:/kafka/config/log4j.properties, -javaagent:/kafka/etc/jmx_prometheus_javaagent.jar=5559:/kafka/etc/config.yml jvm.spec = Red Hat, Inc., OpenJDK 64-Bit Server VM, 11.0.20, 11.0.20+8 jvm.classpath = /kafka/libs/activation-1.1.1.jar:/kafka/libs/aopalliance-repackaged-2.6.1.jar:/kafka/libs/argparse4j-0.7.0.jar:/kafka/libs/audience-annotations-0.12.0.jar:/kafka/libs/caffeine-2.9.3.jar:/kafka/libs/checker-qual-3.19.0.jar:/kafka/libs/commons-beanutils-1.9.4.jar:/kafka/libs/commons-cli-1.4.jar:/kafka/libs/commons-collections-3.2.2.jar:/kafka/libs/commons-digester-2.1.jar:/kafka/libs/commons-io-2.11.0.jar:/kafka/libs/commons-lang3-3.8.1.jar:/kafka/libs/commons-logging-1.2.jar:/kafka/libs/commons-validator-1.7.jar:/kafka/libs/connect-api-3.6.1.jar:/kafka/libs/connect-basic-auth-extension-3.6.1.jar:/kafka/libs/connect-json-3.6.1.jar:/kafka/libs/connect-mirror-3.6.1.jar:/kafka/libs/connect-mirror-client-3.6.1.jar:/kafka/libs/connect-runtime-3.6.1.jar:/kafka/libs/connect-transforms-3.6.1.jar:/kafka/libs/error_prone_annotations-2.10.0.jar:/kafka/libs/hk2-api-2.6.1.jar:/kafka/libs/hk2-locator-2.6.1.jar:/kafka/libs/hk2-utils-2.6.1.jar:/kafka/libs/jackson-annotations-2.13.5.jar:/kafka/libs/jackson-core-2.13.5.jar:/kafka/libs/jackson-databind-2.13.5.jar:/kafka/libs/jackson-dataformat-csv-2.13.5.jar:/kafka/libs/jackson-datatype-jdk8-2.13.5.jar:/kafka/libs/jackson-jaxrs-base-2.13.5.jar:/kafka/libs/jackson-jaxrs-json-provider-2.13.5.jar:/kafka/libs/jackson-module-jaxb-annotations-2.13.5.jar:/kafka/libs/jackson-module-scala_2.13-2.13.5.jar:/kafka/libs/jakarta.activation-api-1.2.2.jar:/kafka/libs/jakarta.annotation-api-1.3.5.jar:/kafka/libs/jakarta.inject-2.6.1.jar:/kafka/libs/jakarta.validation-api-2.0.2.jar:/kafka/libs/jakarta.ws.rs-api-2.1.6.jar:/kafka/libs/jakarta.xml.bind-api-2.3.3.jar:/kafka/libs/javassist-3.29.2-GA.jar:/kafka/libs/javax.activation-api-1.2.0.jar:/kafka/libs/javax.annotation-api-1.3.2.jar:/kafka/libs/javax.servlet-api-3.1.0.jar:/kafka/libs/javax.ws.rs-api-2.1.1.jar:/kafka/libs/jaxb-api-2.3.1.jar:/kafka/libs/jersey-client-2.39.1.jar:/kafka/libs/jersey-common-2.39.1.jar:/kafka/libs/jersey-container-servlet-2.39.1.jar:/kafka/libs/jersey-container-servlet-core-2.39.1.jar:/kafka/libs/jersey-hk2-2.39.1.jar:/kafka/libs/jersey-server-2.39.1.jar:/kafka/libs/jetty-client-9.4.52.v20230823.jar:/kafka/libs/jetty-continuation-9.4.52.v20230823.jar:/kafka/libs/jetty-http-9.4.52.v20230823.jar:/kafka/libs/jetty-io-9.4.52.v20230823.jar:/kafka/libs/jetty-security-9.4.52.v20230823.jar:/kafka/libs/jetty-server-9.4.52.v20230823.jar:/kafka/libs/jetty-servlet-9.4.52.v20230823.jar:/kafka/libs/jetty-servlets-9.4.52.v20230823.jar:/kafka/libs/jetty-util-9.4.52.v20230823.jar:/kafka/libs/jetty-util-ajax-9.4.52.v20230823.jar:/kafka/libs/jline-3.22.0.jar:/kafka/libs/jolokia-jvm-1.7.2.jar:/kafka/libs/jopt-simple-5.0.4.jar:/kafka/libs/jose4j-0.9.3.jar:/kafka/libs/jsr305-3.0.2.jar:/kafka/libs/kafka-clients-3.6.1.jar:/kafka/libs/kafka-group-coordinator-3.6.1.jar:/kafka/libs/kafka-log4j-appender-3.6.1.jar:/kafka/libs/kafka-metadata-3.6.1.jar:/kafka/libs/kafka-raft-3.6.1.jar:/kafka/libs/kafka-server-common-3.6.1.jar:/kafka/libs/kafka-shell-3.6.1.jar:/kafka/libs/kafka-storage-3.6.1.jar:/kafka/libs/kafka-storage-api-3.6.1.jar:/kafka/libs/kafka-streams-3.6.1.jar:/kafka/libs/kafka-streams-examples-3.6.1.jar:/kafka/libs/kafka-streams-scala_2.13-3.6.1.jar:/kafka/libs/kafka-streams-test-utils-3.6.1.jar:/kafka/libs/kafka-tools-3.6.1.jar:/kafka/libs/kafka-tools-api-3.6.1.jar:/kafka/libs/kafka_2.13-3.6.1.jar:/kafka/libs/lz4-java-1.8.0.jar:/kafka/libs/maven-artifact-3.8.8.jar:/kafka/libs/metrics-core-2.2.0.jar:/kafka/libs/metrics-core-4.1.12.1.jar:/kafka/libs/netty-buffer-4.1.100.Final.jar:/kafka/libs/netty-codec-4.1.100.Final.jar:/kafka/libs/netty-common-4.1.100.Final.jar:/kafka/libs/netty-handler-4.1.100.Final.jar:/kafka/libs/netty-resolver-4.1.100.Final.jar:/kafka/libs/netty-transport-4.1.100.Final.jar:/kafka/libs/netty-transport-classes-epoll-4.1.100.Final.jar:/kafka/libs/netty-transport-native-epoll-4.1.100.Final.jar:/kafka/libs/netty-transport-native-unix-common-4.1.100.Final.jar:/kafka/libs/osgi-resource-locator-1.0.3.jar:/kafka/libs/paranamer-2.8.jar:/kafka/libs/pcollections-4.0.1.jar:/kafka/libs/plexus-utils-3.3.1.jar:/kafka/libs/reflections-0.10.2.jar:/kafka/libs/reload4j-1.2.25.jar:/kafka/libs/rocksdbjni-7.9.2.jar:/kafka/libs/scala-collection-compat_2.13-2.10.0.jar:/kafka/libs/scala-java8-compat_2.13-1.0.2.jar:/kafka/libs/scala-library-2.13.11.jar:/kafka/libs/scala-logging_2.13-3.9.4.jar:/kafka/libs/scala-reflect-2.13.11.jar:/kafka/libs/slf4j-api-1.7.36.jar:/kafka/libs/slf4j-reload4j-1.7.36.jar:/kafka/libs/snappy-java-1.1.10.5.jar:/kafka/libs/swagger-annotations-2.2.8.jar:/kafka/libs/trogdor-3.6.1.jar:/kafka/libs/zookeeper-3.8.3.jar:/kafka/libs/zookeeper-jute-3.8.3.jar:/kafka/libs/zstd-jni-1.5.5-1.jar os.spec = Linux, amd64, 5.4.0-163-generic os.vcpus = 4 [org.apache.kafka.connect.runtime.WorkerInfo] 2024-05-30 11:22:13,007 INFO || Scanning for plugin classes. This might take a moment ... [org.apache.kafka.connect.cli.AbstractConnectCli] 2024-05-30 11:22:13,063 INFO || Loading plugin from: /kafka/connect/debezium-connector-jdbc [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:13,160 INFO || Using up-to-date JsonConverter implementation [io.debezium.converters.CloudEventsConverter] 2024-05-30 11:22:13,395 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-jdbc/} [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:13,529 INFO || Loading plugin from: /kafka/connect/debezium-connector-sqlserver [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:13,545 INFO || Using up-to-date JsonConverter implementation [io.debezium.converters.CloudEventsConverter] 2024-05-30 11:22:13,588 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-sqlserver/} [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:13,634 INFO || Loading plugin from: /kafka/connect/debezium-connector-oracle [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:13,668 INFO || Using up-to-date JsonConverter implementation [io.debezium.converters.CloudEventsConverter] 2024-05-30 11:22:13,711 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-oracle/} [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:13,711 INFO || Loading plugin from: /kafka/connect/debezium-connector-db2 [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:13,721 INFO || Using up-to-date JsonConverter implementation [io.debezium.converters.CloudEventsConverter] 2024-05-30 11:22:13,764 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-db2/} [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:13,764 INFO || Loading plugin from: /kafka/connect/debezium-connector-vitess [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:13,821 INFO || Using up-to-date JsonConverter implementation [io.debezium.converters.CloudEventsConverter] 2024-05-30 11:22:13,859 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-vitess/} [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:13,860 INFO || Loading plugin from: /kafka/connect/debezium-connector-mongodb [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:13,871 INFO || Using up-to-date JsonConverter implementation [io.debezium.converters.CloudEventsConverter] 2024-05-30 11:22:13,923 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-mongodb/} [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:13,923 INFO || Loading plugin from: /kafka/connect/debezium-connector-mysql [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:13,951 INFO || Using up-to-date JsonConverter implementation [io.debezium.converters.CloudEventsConverter] 2024-05-30 11:22:13,989 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-mysql/} [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:13,993 INFO || Loading plugin from: /kafka/connect/debezium-connector-informix [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:14,005 INFO || Using up-to-date JsonConverter implementation [io.debezium.converters.CloudEventsConverter] 2024-05-30 11:22:14,049 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-informix/} [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:14,052 INFO || Loading plugin from: /kafka/connect/debezium-connector-spanner [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:14,079 INFO || Using up-to-date JsonConverter implementation [io.debezium.converters.CloudEventsConverter] 2024-05-30 11:22:14,116 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-spanner/} [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:14,116 INFO || Loading plugin from: /kafka/connect/debezium-connector-postgres [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:14,127 INFO || Using up-to-date JsonConverter implementation [io.debezium.converters.CloudEventsConverter] 2024-05-30 11:22:14,163 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-postgres/} [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:14,166 INFO || Loading plugin from: classpath [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:14,171 INFO || Registered loader: jdk.internal.loader.ClassLoaders$AppClassLoader@3d4eac69 [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:14,171 INFO || Scanning plugins with ServiceLoaderScanner took 1110 ms [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:14,174 INFO || Loading plugin from: /kafka/connect/debezium-connector-jdbc [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:15,969 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-jdbc/} [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:15,978 INFO || Loading plugin from: /kafka/connect/debezium-connector-sqlserver [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:16,089 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-sqlserver/} [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:16,098 INFO || Loading plugin from: /kafka/connect/debezium-connector-oracle [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:17,033 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-oracle/} [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:17,033 INFO || Loading plugin from: /kafka/connect/debezium-connector-db2 [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:17,104 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-db2/} [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:17,104 INFO || Loading plugin from: /kafka/connect/debezium-connector-vitess [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:17,725 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-vitess/} [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:17,726 INFO || Loading plugin from: /kafka/connect/debezium-connector-mongodb [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:17,870 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-mongodb/} [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:17,871 INFO || Loading plugin from: /kafka/connect/debezium-connector-mysql [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:18,172 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-mysql/} [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:18,173 INFO || Loading plugin from: /kafka/connect/debezium-connector-informix [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:18,244 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-informix/} [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:18,245 INFO || Loading plugin from: /kafka/connect/debezium-connector-spanner [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:19,248 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-spanner/} [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:19,248 INFO || Loading plugin from: /kafka/connect/debezium-connector-postgres [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:19,360 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-postgres/} [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:19,361 INFO || Loading plugin from: classpath [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:20,625 INFO || Registered loader: jdk.internal.loader.ClassLoaders$AppClassLoader@3d4eac69 [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:20,625 INFO || Scanning plugins with ReflectionScanner took 6451 ms [org.apache.kafka.connect.runtime.isolation.PluginScanner] 2024-05-30 11:22:20,632 WARN || One or more plugins are missing ServiceLoader manifests may not be usable with plugin.discovery=service_load: [ file:/kafka/connect/debezium-connector-db2/ io.debezium.transforms.ContentBasedRouter transformation undefined file:/kafka/connect/debezium-connector-informix/ io.debezium.transforms.ContentBasedRouter transformation undefined file:/kafka/connect/debezium-connector-jdbc/ io.debezium.transforms.ContentBasedRouter transformation undefined file:/kafka/connect/debezium-connector-mongodb/ io.debezium.transforms.ContentBasedRouter transformation undefined file:/kafka/connect/debezium-connector-mysql/ io.debezium.transforms.ContentBasedRouter transformation undefined file:/kafka/connect/debezium-connector-oracle/ io.debezium.transforms.ContentBasedRouter transformation undefined file:/kafka/connect/debezium-connector-postgres/ io.debezium.transforms.ContentBasedRouter transformation undefined file:/kafka/connect/debezium-connector-spanner/ io.debezium.transforms.ContentBasedRouter transformation undefined file:/kafka/connect/debezium-connector-sqlserver/ io.debezium.transforms.ContentBasedRouter transformation undefined file:/kafka/connect/debezium-connector-vitess/ io.debezium.transforms.ContentBasedRouter transformation undefined file:/kafka/connect/debezium-connector-db2/ io.debezium.transforms.Filter transformation undefined file:/kafka/connect/debezium-connector-informix/ io.debezium.transforms.Filter transformation undefined file:/kafka/connect/debezium-connector-jdbc/ io.debezium.transforms.Filter transformation undefined file:/kafka/connect/debezium-connector-mongodb/ io.debezium.transforms.Filter transformation undefined file:/kafka/connect/debezium-connector-mysql/ io.debezium.transforms.Filter transformation undefined file:/kafka/connect/debezium-connector-oracle/ io.debezium.transforms.Filter transformation undefined file:/kafka/connect/debezium-connector-postgres/ io.debezium.transforms.Filter transformation undefined file:/kafka/connect/debezium-connector-spanner/ io.debezium.transforms.Filter transformation undefined file:/kafka/connect/debezium-connector-sqlserver/ io.debezium.transforms.Filter transformation undefined file:/kafka/connect/debezium-connector-vitess/ io.debezium.transforms.Filter 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] 2024-05-30 11:22:20,633 INFO || Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,633 INFO || Added plugin 'org.apache.kafka.connect.transforms.Filter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,633 INFO || Added plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,633 INFO || Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,633 INFO || Added plugin 'io.debezium.connector.spanner.SpannerConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,633 INFO || Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,633 INFO || Added plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,633 INFO || Added plugin 'io.debezium.connector.sqlserver.SqlServerConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,633 INFO || Added plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,633 INFO || Added plugin 'org.apache.kafka.connect.transforms.DropHeaders' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,633 INFO || Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,633 INFO || Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,634 INFO || Added plugin 'org.apache.kafka.connect.transforms.InsertHeader' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,634 INFO || Added plugin 'io.debezium.converters.BinaryDataConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,634 INFO || Added plugin 'org.apache.kafka.common.config.provider.DirectoryConfigProvider' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,634 INFO || Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,634 INFO || Added plugin 'io.debezium.connector.postgresql.transforms.timescaledb.TimescaleDb' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,634 INFO || Added plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,634 INFO || Added plugin 'org.apache.kafka.connect.transforms.HeaderFrom$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,634 INFO || Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,634 INFO || Added plugin 'io.debezium.transforms.ExtractNewRecordState' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,634 INFO || Added plugin 'io.debezium.converters.ByteArrayConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,634 INFO || Added plugin 'io.debezium.connector.mongodb.MongoDbConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,634 INFO || Added plugin 'io.debezium.transforms.partitions.PartitionRouting' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,634 INFO || Added plugin 'io.debezium.connector.jdbc.JdbcSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,634 INFO || Added plugin 'org.apache.kafka.connect.transforms.predicates.TopicNameMatches' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,634 INFO || Added plugin 'io.debezium.transforms.Filter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,634 INFO || Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,634 INFO || Added plugin 'io.debezium.transforms.outbox.EventRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,634 INFO || Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,634 INFO || Added plugin 'io.debezium.connector.vitess.VitessConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,634 INFO || Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,634 INFO || Added plugin 'org.apache.kafka.connect.transforms.predicates.RecordIsTombstone' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,634 INFO || Added plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,635 INFO || Added plugin 'io.debezium.connector.mysql.MySqlConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,635 INFO || Added plugin 'io.debezium.connector.mongodb.transforms.outbox.MongoEventRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,635 INFO || Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,635 INFO || Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,635 INFO || Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,635 INFO || Added plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,635 INFO || Added plugin 'io.debezium.connector.postgresql.rest.DebeziumPostgresConnectRestExtension' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,635 INFO || Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,635 INFO || Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,635 INFO || Added plugin 'org.apache.kafka.connect.converters.FloatConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,635 INFO || Added plugin 'io.debezium.connector.oracle.OracleConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,635 INFO || Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,635 INFO || Added plugin 'io.debezium.transforms.HeaderToValue' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,635 INFO || Added plugin 'io.debezium.transforms.SchemaChangeEventFilter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,635 INFO || Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,635 INFO || Added plugin 'io.debezium.transforms.ExtractSchemaToNewRecord' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,635 INFO || Added plugin 'io.debezium.connector.db2.Db2Connector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,635 INFO || Added plugin 'io.debezium.transforms.ByLogicalTableRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,635 INFO || Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,635 INFO || Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,635 INFO || Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,635 INFO || Added plugin 'org.apache.kafka.connect.converters.LongConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,636 INFO || Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,636 INFO || Added plugin 'io.debezium.connector.mongodb.rest.DebeziumMongoDbConnectRestExtension' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,636 INFO || Added plugin 'io.debezium.connector.jdbc.transforms.ConvertCloudEventToSaveableForm' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,636 INFO || Added plugin 'org.apache.kafka.connect.json.JsonConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,636 INFO || Added plugin 'io.debezium.transforms.TimezoneConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,636 INFO || Added plugin 'io.debezium.connector.informix.InformixConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,636 INFO || Added plugin 'org.apache.kafka.connect.transforms.HeaderFrom$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,636 INFO || Added plugin 'org.apache.kafka.connect.transforms.predicates.HasHeaderKey' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,636 INFO || Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,636 INFO || Added plugin 'org.apache.kafka.common.config.provider.EnvVarConfigProvider' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,636 INFO || Added plugin 'io.debezium.transforms.ExtractChangedRecordState' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,636 INFO || Added plugin 'io.debezium.connector.mongodb.transforms.ExtractNewDocumentState' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,636 INFO || Added plugin 'org.apache.kafka.connect.storage.StringConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,636 INFO || Added plugin 'io.debezium.transforms.tracing.ActivateTracingSpan' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,636 INFO || Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,636 INFO || Added plugin 'io.debezium.connector.mysql.rest.DebeziumMySqlConnectRestExtension' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,636 INFO || Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,636 INFO || Added plugin 'io.debezium.connector.mysql.transforms.ReadToInsertEvent' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,636 INFO || Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,636 INFO || Added plugin 'io.debezium.connector.oracle.rest.DebeziumOracleConnectRestExtension' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,636 INFO || Added plugin 'io.debezium.transforms.ContentBasedRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,636 INFO || Added plugin 'io.debezium.connector.postgresql.PostgresConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,636 INFO || Added plugin 'io.debezium.connector.sqlserver.rest.DebeziumSqlServerConnectRestExtension' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,636 INFO || Added plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,637 INFO || Added plugin 'io.debezium.converters.CloudEventsConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,637 INFO || Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,637 INFO || Added plugin 'org.apache.kafka.connect.converters.ShortConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,639 INFO || Added alias 'VitessConnector' to plugin 'io.debezium.connector.vitess.VitessConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,639 INFO || Added alias 'ContentBasedRouter' to plugin 'io.debezium.transforms.ContentBasedRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,639 INFO || Added alias 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,639 INFO || Added alias 'MySql' to plugin 'io.debezium.connector.mysql.MySqlConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,639 INFO || Added alias 'MirrorCheckpointConnector' to plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,639 INFO || Added alias 'HeaderToValue' to plugin 'io.debezium.transforms.HeaderToValue' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,639 INFO || Added alias 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,640 INFO || Added alias 'SimpleHeaderConverter' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,640 INFO || Added alias 'SqlServerConnector' to plugin 'io.debezium.connector.sqlserver.SqlServerConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,640 INFO || Added alias 'DirectoryConfigProvider' to plugin 'org.apache.kafka.common.config.provider.DirectoryConfigProvider' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,640 INFO || Added alias 'TimezoneConverter' to plugin 'io.debezium.transforms.TimezoneConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,640 INFO || Added alias 'BasicAuthSecurityRestExtension' to plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,640 INFO || Added alias 'Simple' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,640 INFO || Added alias 'DebeziumPostgres' to plugin 'io.debezium.connector.postgresql.rest.DebeziumPostgresConnectRestExtension' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,640 INFO || Added alias 'AllConnectorClientConfigOverridePolicy' to plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,640 INFO || Added alias 'MirrorSource' to plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,640 INFO || Added alias 'Directory' to plugin 'org.apache.kafka.common.config.provider.DirectoryConfigProvider' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,640 INFO || Added alias 'MirrorHeartbeat' to plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,640 INFO || Added alias 'JsonConverter' to plugin 'org.apache.kafka.connect.json.JsonConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,640 INFO || Added alias 'DebeziumMySql' to plugin 'io.debezium.connector.mysql.rest.DebeziumMySqlConnectRestExtension' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,640 INFO || Added alias 'JdbcSinkConnector' to plugin 'io.debezium.connector.jdbc.JdbcSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,640 INFO || Added alias 'DebeziumPostgresConnectRestExtension' to plugin 'io.debezium.connector.postgresql.rest.DebeziumPostgresConnectRestExtension' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,640 INFO || Added alias 'SpannerConnector' to plugin 'io.debezium.connector.spanner.SpannerConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,640 INFO || Added alias 'MongoDb' to plugin 'io.debezium.connector.mongodb.MongoDbConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,640 INFO || Added alias 'Postgres' to plugin 'io.debezium.connector.postgresql.PostgresConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,640 INFO || Added alias 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,640 INFO || Added alias 'ByLogicalTableRouter' to plugin 'io.debezium.transforms.ByLogicalTableRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,640 INFO || Added alias 'FileConfigProvider' to plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,640 INFO || Added alias 'SchemaChangeEventFilter' to plugin 'io.debezium.transforms.SchemaChangeEventFilter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,640 INFO || Added alias 'ConvertCloudEventToSaveableForm' to plugin 'io.debezium.connector.jdbc.transforms.ConvertCloudEventToSaveableForm' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,640 INFO || Added alias 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,640 INFO || Added alias 'FloatConverter' to plugin 'org.apache.kafka.connect.converters.FloatConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,641 INFO || Added alias 'Spanner' to plugin 'io.debezium.connector.spanner.SpannerConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,641 INFO || Added alias 'ActivateTracingSpan' to plugin 'io.debezium.transforms.tracing.ActivateTracingSpan' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,641 INFO || Added alias 'DebeziumSqlServerConnectRestExtension' to plugin 'io.debezium.connector.sqlserver.rest.DebeziumSqlServerConnectRestExtension' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,641 INFO || Added alias 'MirrorHeartbeatConnector' to plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,641 INFO || Added alias 'Oracle' to plugin 'io.debezium.connector.oracle.OracleConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,641 INFO || Added alias 'PrincipalConnectorClientConfigOverridePolicy' to plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,641 INFO || Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,641 INFO || Added alias 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,641 INFO || Added alias 'Informix' to plugin 'io.debezium.connector.informix.InformixConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,641 INFO || Added alias 'ExtractNewDocumentState' to plugin 'io.debezium.connector.mongodb.transforms.ExtractNewDocumentState' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,641 INFO || Added alias 'RecordIsTombstone' to plugin 'org.apache.kafka.connect.transforms.predicates.RecordIsTombstone' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,641 INFO || Added alias 'CloudEventsConverter' to plugin 'io.debezium.converters.CloudEventsConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,641 INFO || Added alias 'DebeziumOracle' to plugin 'io.debezium.connector.oracle.rest.DebeziumOracleConnectRestExtension' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,641 INFO || Added alias 'EnvVar' to plugin 'org.apache.kafka.common.config.provider.EnvVarConfigProvider' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,641 INFO || Added alias 'EnvVarConfigProvider' to plugin 'org.apache.kafka.common.config.provider.EnvVarConfigProvider' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,641 INFO || Added alias 'MySqlConnector' to plugin 'io.debezium.connector.mysql.MySqlConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,641 INFO || Added alias 'DebeziumSqlServer' to plugin 'io.debezium.connector.sqlserver.rest.DebeziumSqlServerConnectRestExtension' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,641 INFO || Added alias 'PartitionRouting' to plugin 'io.debezium.transforms.partitions.PartitionRouting' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,641 INFO || Added alias 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,641 INFO || Added alias 'StringConverter' to plugin 'org.apache.kafka.connect.storage.StringConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,641 INFO || Added alias 'MongoDbConnector' to plugin 'io.debezium.connector.mongodb.MongoDbConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,641 INFO || Added alias 'IntegerConverter' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,641 INFO || Added alias 'LongConverter' to plugin 'org.apache.kafka.connect.converters.LongConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,641 INFO || Added alias 'DropHeaders' to plugin 'org.apache.kafka.connect.transforms.DropHeaders' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,641 INFO || Added alias 'ExtractSchemaToNewRecord' to plugin 'io.debezium.transforms.ExtractSchemaToNewRecord' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,641 INFO || Added alias 'BinaryData' to plugin 'io.debezium.converters.BinaryDataConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,642 INFO || Added alias 'ReadToInsertEvent' to plugin 'io.debezium.connector.mysql.transforms.ReadToInsertEvent' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,642 INFO || Added alias 'ShortConverter' to plugin 'org.apache.kafka.connect.converters.ShortConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,642 INFO || Added alias 'CloudEvents' to plugin 'io.debezium.converters.CloudEventsConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,642 INFO || Added alias 'DebeziumOracleConnectRestExtension' to plugin 'io.debezium.connector.oracle.rest.DebeziumOracleConnectRestExtension' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,642 INFO || Added alias 'ExtractNewRecordState' to plugin 'io.debezium.transforms.ExtractNewRecordState' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,642 INFO || Added alias 'DebeziumMongoDb' to plugin 'io.debezium.connector.mongodb.rest.DebeziumMongoDbConnectRestExtension' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,642 INFO || Added alias 'Db2' to plugin 'io.debezium.connector.db2.Db2Connector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,642 INFO || Added alias 'Db2Connector' to plugin 'io.debezium.connector.db2.Db2Connector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,642 INFO || Added alias 'Vitess' to plugin 'io.debezium.connector.vitess.VitessConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,642 INFO || Added alias 'InformixConnector' to plugin 'io.debezium.connector.informix.InformixConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,642 INFO || Added alias 'DebeziumMongoDbConnectRestExtension' to plugin 'io.debezium.connector.mongodb.rest.DebeziumMongoDbConnectRestExtension' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,642 INFO || Added alias 'HasHeaderKey' to plugin 'org.apache.kafka.connect.transforms.predicates.HasHeaderKey' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,642 INFO || Added alias 'MirrorCheckpoint' to plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,642 INFO || Added alias 'ExtractChangedRecordState' to plugin 'io.debezium.transforms.ExtractChangedRecordState' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,642 INFO || Added alias 'OracleConnector' to plugin 'io.debezium.connector.oracle.OracleConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,642 INFO || Added alias 'None' to plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,642 INFO || Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,642 INFO || Added alias 'Principal' to plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,642 INFO || Added alias 'All' to plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,642 INFO || Added alias 'SqlServer' to plugin 'io.debezium.connector.sqlserver.SqlServerConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,642 INFO || Added alias 'DebeziumMySqlConnectRestExtension' to plugin 'io.debezium.connector.mysql.rest.DebeziumMySqlConnectRestExtension' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,642 INFO || Added alias 'JdbcSink' to plugin 'io.debezium.connector.jdbc.JdbcSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,642 INFO || Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,642 INFO || Added alias 'NoneConnectorClientConfigOverridePolicy' to plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,642 INFO || Added alias 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,642 INFO || Added alias 'EventRouter' to plugin 'io.debezium.transforms.outbox.EventRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,642 INFO || Added alias 'File' to plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,642 INFO || Added alias 'DoubleConverter' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,643 INFO || Added alias 'BinaryDataConverter' to plugin 'io.debezium.converters.BinaryDataConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,643 INFO || Added alias 'TimescaleDb' to plugin 'io.debezium.connector.postgresql.transforms.timescaledb.TimescaleDb' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,643 INFO || Added alias 'TopicNameMatches' to plugin 'org.apache.kafka.connect.transforms.predicates.TopicNameMatches' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,643 INFO || Added alias 'InsertHeader' to plugin 'org.apache.kafka.connect.transforms.InsertHeader' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,643 INFO || Added alias 'MirrorSourceConnector' to plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,643 INFO || Added alias 'PostgresConnector' to plugin 'io.debezium.connector.postgresql.PostgresConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,643 INFO || Added alias 'MongoEventRouter' to plugin 'io.debezium.connector.mongodb.transforms.outbox.MongoEventRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2024-05-30 11:22:20,681 INFO || DistributedConfig values: access.control.allow.methods = access.control.allow.origin = admin.listeners = null auto.include.jmx.reporter = true bootstrap.servers = [devl-kaf2-0.sdde.deere.com:9094, devl-kaf2-1.sdde.deere.com:9094, devl-kaf2-2.sdde.deere.com:9094] client.dns.lookup = use_all_dns_ips client.id = config.providers = [] config.storage.replication.factor = 1 config.storage.topic = my_connect_configs_SSL connect.protocol = sessioned connections.max.idle.ms = 540000 connector.client.config.override.policy = All exactly.once.source.support = disabled group.id = mdo_debezium_SSL 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 = 25 offset.storage.replication.factor = 1 offset.storage.topic = my_connect_offsets_SSL plugin.discovery = hybrid_warn plugin.path = [/kafka/connect] 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 = 100.94.27.150 rest.advertised.listener = null rest.advertised.port = 8083 rest.extension.classes = [] 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 = SCRAM-SHA-256 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 = 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 = /etc/ssl/certs/ca-crt.pem ssl.truststore.password = null ssl.truststore.type = PEM status.storage.partitions = 5 status.storage.replication.factor = 1 status.storage.topic = my_connect_statuses_SSL task.shutdown.graceful.timeout.ms = 10000 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] 2024-05-30 11:22:20,682 INFO || Creating Kafka admin client [org.apache.kafka.connect.runtime.WorkerConfig] 2024-05-30 11:22:20,685 INFO || AdminClientConfig values: auto.include.jmx.reporter = true bootstrap.servers = [devl-kaf2-0.sdde.deere.com:9094, devl-kaf2-1.sdde.deere.com:9094, devl-kaf2-2.sdde.deere.com:9094] client.dns.lookup = use_all_dns_ips client.id = connections.max.idle.ms = 300000 default.api.timeout.ms = 60000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 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 = SCRAM-SHA-256 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 = 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 = /etc/ssl/certs/ca-crt.pem ssl.truststore.password = null ssl.truststore.type = PEM [org.apache.kafka.clients.admin.AdminClientConfig] 2024-05-30 11:22:20,784 INFO || Successfully logged in. [org.apache.kafka.common.security.authenticator.AbstractLogin] 2024-05-30 11:22:20,857 INFO || These configurations '[producer.sasl.jaas.config, producer.bootstrap.servers, group.id, rest.advertised.port, task.shutdown.graceful.timeout.ms, plugin.path, producer.ssl.truststore.location, status.storage.replication.factor, offset.storage.topic, value.converter, key.converter, config.storage.topic, producer.security.protocol, rest.advertised.host.name, status.storage.topic, rest.host.name, offset.flush.timeout.ms, producer.sasl.mechanism, config.storage.replication.factor, offset.flush.interval.ms, rest.port, key.converter.schemas.enable, producer.ssl.truststore.type, value.converter.schemas.enable, offset.storage.replication.factor, producer.ssl.endpoint.identification.algorithm]' were supplied but are not used yet. [org.apache.kafka.clients.admin.AdminClientConfig] 2024-05-30 11:22:20,857 INFO || Kafka version: 3.6.1 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:20,858 INFO || Kafka commitId: 5e3c2b738d253ff5 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:20,858 INFO || Kafka startTimeMs: 1717068140857 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:21,435 INFO || Kafka cluster ID: UxJUAE7HSEOrlGmu-JXBGA [org.apache.kafka.connect.runtime.WorkerConfig] 2024-05-30 11:22:21,436 INFO || App info kafka.admin.client for adminclient-1 unregistered [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:21,445 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2024-05-30 11:22:21,446 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2024-05-30 11:22:21,446 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2024-05-30 11:22:21,449 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 = 100.94.27.150 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 = 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 = /etc/ssl/certs/ca-crt.pem ssl.truststore.password = null ssl.truststore.type = PEM topic.tracking.allow.reset = true topic.tracking.enable = true [org.apache.kafka.connect.runtime.rest.RestServerConfig$PublicConfig] 2024-05-30 11:22:21,459 INFO || Logging initialized @9154ms to org.eclipse.jetty.util.log.Slf4jLog [org.eclipse.jetty.util.log] 2024-05-30 11:22:21,523 INFO || Added connector for http://:8083 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:22:21,523 INFO || Initializing REST server [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:22:21,549 INFO || jetty-9.4.52.v20230823; built: 2023-08-23T19:29:37.669Z; git: abdcda73818a1a2c705da276edb0bf6581e7997e; jvm 11.0.20+8 [org.eclipse.jetty.server.Server] 2024-05-30 11:22:21,577 INFO || Started http_8083@1f6fe574{HTTP/1.1, (http/1.1)}{0.0.0.0:8083} [org.eclipse.jetty.server.AbstractConnector] 2024-05-30 11:22:21,579 INFO || Started @9274ms [org.eclipse.jetty.server.Server] 2024-05-30 11:22:21,605 INFO || Advertised URI: http://100.94.27.150:8083/ [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:22:21,605 INFO || REST server listening at http://100.94.27.150:8083/, advertising URL http://100.94.27.150:8083/ [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:22:21,606 INFO || Advertised URI: http://100.94.27.150:8083/ [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:22:21,606 INFO || REST admin endpoints at http://100.94.27.150:8083/ [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:22:21,606 INFO || Advertised URI: http://100.94.27.150:8083/ [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:22:21,606 INFO || Setting up All Policy for ConnectorClientConfigOverride. This will allow all client configurations to be overridden [org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy] 2024-05-30 11:22:21,613 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] 2024-05-30 11:22:21,633 INFO || Kafka version: 3.6.1 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:21,634 INFO || Kafka commitId: 5e3c2b738d253ff5 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:21,634 INFO || Kafka startTimeMs: 1717068141633 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:21,640 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] 2024-05-30 11:22:21,640 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] 2024-05-30 11:22:21,659 INFO || Advertised URI: http://100.94.27.150:8083/ [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:22:21,667 INFO || Successfully logged in. [org.apache.kafka.common.security.authenticator.AbstractLogin] 2024-05-30 11:22:21,693 INFO || Kafka version: 3.6.1 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:21,693 INFO || Kafka commitId: 5e3c2b738d253ff5 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:21,693 INFO || Kafka startTimeMs: 1717068141693 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:21,696 INFO || Kafka Connect worker initialization took 8691ms [org.apache.kafka.connect.cli.AbstractConnectCli] 2024-05-30 11:22:21,696 INFO || Kafka Connect starting [org.apache.kafka.connect.runtime.Connect] 2024-05-30 11:22:21,699 INFO || Initializing REST resources [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:22:21,699 INFO || [Worker clientId=connect-1, groupId=mdo_debezium_SSL] Herder starting [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2024-05-30 11:22:21,700 INFO || Worker starting [org.apache.kafka.connect.runtime.Worker] 2024-05-30 11:22:21,700 INFO || Starting KafkaOffsetBackingStore [org.apache.kafka.connect.storage.KafkaOffsetBackingStore] 2024-05-30 11:22:21,700 INFO || Starting KafkaBasedLog with topic my_connect_offsets_SSL [org.apache.kafka.connect.util.KafkaBasedLog] 2024-05-30 11:22:21,701 INFO || AdminClientConfig values: auto.include.jmx.reporter = true bootstrap.servers = [devl-kaf2-0.sdde.deere.com:9094, devl-kaf2-1.sdde.deere.com:9094, devl-kaf2-2.sdde.deere.com:9094] client.dns.lookup = use_all_dns_ips client.id = mdo_debezium_SSL-shared-admin connections.max.idle.ms = 300000 default.api.timeout.ms = 60000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 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 = SCRAM-SHA-256 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 = 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 = /etc/ssl/certs/ca-crt.pem ssl.truststore.password = null ssl.truststore.type = PEM [org.apache.kafka.clients.admin.AdminClientConfig] 2024-05-30 11:22:21,709 INFO || These configurations '[producer.sasl.jaas.config, producer.bootstrap.servers, group.id, rest.advertised.port, task.shutdown.graceful.timeout.ms, plugin.path, producer.ssl.truststore.location, metrics.context.connect.kafka.cluster.id, status.storage.replication.factor, offset.storage.topic, value.converter, key.converter, config.storage.topic, producer.security.protocol, metrics.context.connect.group.id, rest.advertised.host.name, status.storage.topic, rest.host.name, offset.flush.timeout.ms, producer.sasl.mechanism, config.storage.replication.factor, offset.flush.interval.ms, rest.port, key.converter.schemas.enable, producer.ssl.truststore.type, value.converter.schemas.enable, offset.storage.replication.factor, producer.ssl.endpoint.identification.algorithm]' were supplied but are not used yet. [org.apache.kafka.clients.admin.AdminClientConfig] 2024-05-30 11:22:21,709 INFO || Kafka version: 3.6.1 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:21,709 INFO || Kafka commitId: 5e3c2b738d253ff5 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:21,709 INFO || Kafka startTimeMs: 1717068141709 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:21,758 INFO || Adding admin resources to main listener [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:22:21,859 INFO || DefaultSessionIdManager workerName=node0 [org.eclipse.jetty.server.session] 2024-05-30 11:22:21,860 INFO || No SessionScavenger set, using defaults [org.eclipse.jetty.server.session] 2024-05-30 11:22:21,861 INFO || node0 Scavenging every 660000ms [org.eclipse.jetty.server.session] 2024-05-30 11:22:21,900 INFO || ProducerConfig values: acks = -1 auto.include.jmx.reporter = true batch.size = 16384 bootstrap.servers = [devl-kaf2-0.sdde.deere.com:9094, devl-kaf2-1.sdde.deere.com:9094, devl-kaf2-2.sdde.deere.com:9094] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = mdo_debezium_SSL-offsets compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 2147483647 enable.idempotence = false interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer linger.ms = 0 max.block.ms = 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.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 = SCRAM-SHA-256 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 = 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 = /etc/ssl/certs/ca-crt.pem ssl.truststore.password = null ssl.truststore.type = PEM transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer [org.apache.kafka.clients.producer.ProducerConfig] 2024-05-30 11:22:21,921 INFO || These configurations '[producer.sasl.jaas.config, producer.bootstrap.servers, group.id, rest.advertised.port, task.shutdown.graceful.timeout.ms, plugin.path, producer.ssl.truststore.location, metrics.context.connect.kafka.cluster.id, status.storage.replication.factor, offset.storage.topic, value.converter, key.converter, config.storage.topic, producer.security.protocol, metrics.context.connect.group.id, rest.advertised.host.name, status.storage.topic, rest.host.name, offset.flush.timeout.ms, producer.sasl.mechanism, config.storage.replication.factor, offset.flush.interval.ms, rest.port, key.converter.schemas.enable, producer.ssl.truststore.type, value.converter.schemas.enable, offset.storage.replication.factor, producer.ssl.endpoint.identification.algorithm]' were supplied but are not used yet. [org.apache.kafka.clients.producer.ProducerConfig] 2024-05-30 11:22:21,921 INFO || Kafka version: 3.6.1 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:21,921 INFO || Kafka commitId: 5e3c2b738d253ff5 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:21,921 INFO || Kafka startTimeMs: 1717068141921 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:21,937 INFO || ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.include.jmx.reporter = true auto.offset.reset = earliest bootstrap.servers = [devl-kaf2-0.sdde.deere.com:9094, devl-kaf2-1.sdde.deere.com:9094, devl-kaf2-2.sdde.deere.com:9094] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = mdo_debezium_SSL-offsets client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = mdo_debezium_SSL group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true internal.throw.on.fetch.stable.offset.unsupported = false isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.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.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 = SCRAM-SHA-256 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 = 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 = /etc/ssl/certs/ca-crt.pem ssl.truststore.password = null ssl.truststore.type = PEM value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer [org.apache.kafka.clients.consumer.ConsumerConfig] 2024-05-30 11:22:22,012 INFO || [Producer clientId=mdo_debezium_SSL-offsets] Cluster ID: UxJUAE7HSEOrlGmu-JXBGA [org.apache.kafka.clients.Metadata] 2024-05-30 11:22:22,014 INFO || These configurations '[producer.sasl.jaas.config, producer.bootstrap.servers, rest.advertised.port, task.shutdown.graceful.timeout.ms, plugin.path, producer.ssl.truststore.location, metrics.context.connect.kafka.cluster.id, status.storage.replication.factor, offset.storage.topic, value.converter, key.converter, config.storage.topic, producer.security.protocol, metrics.context.connect.group.id, rest.advertised.host.name, status.storage.topic, rest.host.name, offset.flush.timeout.ms, producer.sasl.mechanism, config.storage.replication.factor, offset.flush.interval.ms, rest.port, key.converter.schemas.enable, producer.ssl.truststore.type, value.converter.schemas.enable, offset.storage.replication.factor, producer.ssl.endpoint.identification.algorithm]' were supplied but are not used yet. [org.apache.kafka.clients.consumer.ConsumerConfig] 2024-05-30 11:22:22,015 INFO || Kafka version: 3.6.1 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:22,015 INFO || Kafka commitId: 5e3c2b738d253ff5 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:22,015 INFO || Kafka startTimeMs: 1717068142015 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:22,098 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Cluster ID: UxJUAE7HSEOrlGmu-JXBGA [org.apache.kafka.clients.Metadata] 2024-05-30 11:22:22,103 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Assigned to partition(s): my_connect_offsets_SSL-0, my_connect_offsets_SSL-5, my_connect_offsets_SSL-10, my_connect_offsets_SSL-20, my_connect_offsets_SSL-15, my_connect_offsets_SSL-9, my_connect_offsets_SSL-11, my_connect_offsets_SSL-16, my_connect_offsets_SSL-4, my_connect_offsets_SSL-17, my_connect_offsets_SSL-3, my_connect_offsets_SSL-24, my_connect_offsets_SSL-23, my_connect_offsets_SSL-13, my_connect_offsets_SSL-18, my_connect_offsets_SSL-22, my_connect_offsets_SSL-8, my_connect_offsets_SSL-2, my_connect_offsets_SSL-12, my_connect_offsets_SSL-19, my_connect_offsets_SSL-14, my_connect_offsets_SSL-1, my_connect_offsets_SSL-6, my_connect_offsets_SSL-7, my_connect_offsets_SSL-21 [org.apache.kafka.clients.consumer.KafkaConsumer] 2024-05-30 11:22:22,109 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Seeking to earliest offset of partition my_connect_offsets_SSL-0 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,109 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Seeking to earliest offset of partition my_connect_offsets_SSL-5 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,109 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Seeking to earliest offset of partition my_connect_offsets_SSL-10 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,109 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Seeking to earliest offset of partition my_connect_offsets_SSL-20 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,109 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Seeking to earliest offset of partition my_connect_offsets_SSL-15 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,109 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Seeking to earliest offset of partition my_connect_offsets_SSL-9 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,109 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Seeking to earliest offset of partition my_connect_offsets_SSL-11 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,110 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Seeking to earliest offset of partition my_connect_offsets_SSL-16 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,110 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Seeking to earliest offset of partition my_connect_offsets_SSL-4 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,110 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Seeking to earliest offset of partition my_connect_offsets_SSL-17 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,110 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Seeking to earliest offset of partition my_connect_offsets_SSL-3 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,110 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Seeking to earliest offset of partition my_connect_offsets_SSL-24 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,110 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Seeking to earliest offset of partition my_connect_offsets_SSL-23 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,110 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Seeking to earliest offset of partition my_connect_offsets_SSL-13 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,110 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Seeking to earliest offset of partition my_connect_offsets_SSL-18 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,110 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Seeking to earliest offset of partition my_connect_offsets_SSL-22 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,110 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Seeking to earliest offset of partition my_connect_offsets_SSL-8 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,110 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Seeking to earliest offset of partition my_connect_offsets_SSL-2 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,110 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Seeking to earliest offset of partition my_connect_offsets_SSL-12 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,110 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Seeking to earliest offset of partition my_connect_offsets_SSL-19 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,110 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Seeking to earliest offset of partition my_connect_offsets_SSL-14 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,110 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Seeking to earliest offset of partition my_connect_offsets_SSL-1 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,110 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Seeking to earliest offset of partition my_connect_offsets_SSL-6 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,110 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Seeking to earliest offset of partition my_connect_offsets_SSL-7 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,110 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Seeking to earliest offset of partition my_connect_offsets_SSL-21 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,269 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Resetting offset for partition my_connect_offsets_SSL-9 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.178.6.94:9094 (id: 0 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,269 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Resetting offset for partition my_connect_offsets_SSL-24 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.178.6.94:9094 (id: 0 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,270 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Resetting offset for partition my_connect_offsets_SSL-12 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.178.6.94:9094 (id: 0 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,270 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Resetting offset for partition my_connect_offsets_SSL-18 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.178.6.94:9094 (id: 0 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,270 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Resetting offset for partition my_connect_offsets_SSL-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.178.6.94:9094 (id: 0 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,270 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Resetting offset for partition my_connect_offsets_SSL-15 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.178.6.94:9094 (id: 0 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,270 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Resetting offset for partition my_connect_offsets_SSL-6 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.178.6.94:9094 (id: 0 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,270 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Resetting offset for partition my_connect_offsets_SSL-21 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.178.6.94:9094 (id: 0 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,270 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Resetting offset for partition my_connect_offsets_SSL-3 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.178.6.94:9094 (id: 0 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] May 30, 2024 11:22:22 AM 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. May 30, 2024 11:22:22 AM 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. May 30, 2024 11:22:22 AM 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. May 30, 2024 11:22:22 AM 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. May 30, 2024 11:22:22 AM 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-05-30 11:22:22,320 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Resetting offset for partition my_connect_offsets_SSL-10 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.178.6.99:9094 (id: 2 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,320 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Resetting offset for partition my_connect_offsets_SSL-7 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.178.6.99:9094 (id: 2 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,320 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Resetting offset for partition my_connect_offsets_SSL-13 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.178.6.99:9094 (id: 2 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,320 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Resetting offset for partition my_connect_offsets_SSL-1 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.178.6.99:9094 (id: 2 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,320 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Resetting offset for partition my_connect_offsets_SSL-16 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.178.6.99:9094 (id: 2 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,320 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Resetting offset for partition my_connect_offsets_SSL-22 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.178.6.99:9094 (id: 2 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,320 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Resetting offset for partition my_connect_offsets_SSL-4 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.178.6.99:9094 (id: 2 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,320 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Resetting offset for partition my_connect_offsets_SSL-19 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.178.6.99:9094 (id: 2 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,321 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Resetting offset for partition my_connect_offsets_SSL-8 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.178.6.96:9094 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,321 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Resetting offset for partition my_connect_offsets_SSL-23 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.178.6.96:9094 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,321 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Resetting offset for partition my_connect_offsets_SSL-14 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.178.6.96:9094 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,321 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Resetting offset for partition my_connect_offsets_SSL-11 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.178.6.96:9094 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,321 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Resetting offset for partition my_connect_offsets_SSL-2 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.178.6.96:9094 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,321 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Resetting offset for partition my_connect_offsets_SSL-17 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.178.6.96:9094 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,321 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Resetting offset for partition my_connect_offsets_SSL-5 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.178.6.96:9094 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,322 INFO || [Consumer clientId=mdo_debezium_SSL-offsets, groupId=mdo_debezium_SSL] Resetting offset for partition my_connect_offsets_SSL-20 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.178.6.96:9094 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,401 INFO || Finished reading KafkaBasedLog for topic my_connect_offsets_SSL [org.apache.kafka.connect.util.KafkaBasedLog] 2024-05-30 11:22:22,401 INFO || Started KafkaBasedLog for topic my_connect_offsets_SSL [org.apache.kafka.connect.util.KafkaBasedLog] 2024-05-30 11:22:22,401 INFO || Finished reading offsets topic and starting KafkaOffsetBackingStore [org.apache.kafka.connect.storage.KafkaOffsetBackingStore] 2024-05-30 11:22:22,405 INFO || Worker started [org.apache.kafka.connect.runtime.Worker] 2024-05-30 11:22:22,405 INFO || Starting KafkaBasedLog with topic my_connect_statuses_SSL [org.apache.kafka.connect.util.KafkaBasedLog] 2024-05-30 11:22:22,415 INFO || ProducerConfig values: acks = -1 auto.include.jmx.reporter = true batch.size = 16384 bootstrap.servers = [devl-kaf2-0.sdde.deere.com:9094, devl-kaf2-1.sdde.deere.com:9094, devl-kaf2-2.sdde.deere.com:9094] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = mdo_debezium_SSL-statuses compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 120000 enable.idempotence = false interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.StringSerializer linger.ms = 0 max.block.ms = 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.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 = SCRAM-SHA-256 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 = 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 = /etc/ssl/certs/ca-crt.pem ssl.truststore.password = null ssl.truststore.type = PEM transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer [org.apache.kafka.clients.producer.ProducerConfig] 2024-05-30 11:22:22,420 INFO || These configurations '[producer.sasl.jaas.config, producer.bootstrap.servers, group.id, rest.advertised.port, task.shutdown.graceful.timeout.ms, plugin.path, producer.ssl.truststore.location, metrics.context.connect.kafka.cluster.id, status.storage.replication.factor, offset.storage.topic, value.converter, key.converter, config.storage.topic, producer.security.protocol, metrics.context.connect.group.id, rest.advertised.host.name, status.storage.topic, rest.host.name, offset.flush.timeout.ms, producer.sasl.mechanism, config.storage.replication.factor, offset.flush.interval.ms, rest.port, key.converter.schemas.enable, producer.ssl.truststore.type, value.converter.schemas.enable, offset.storage.replication.factor, producer.ssl.endpoint.identification.algorithm]' were supplied but are not used yet. [org.apache.kafka.clients.producer.ProducerConfig] 2024-05-30 11:22:22,421 INFO || Kafka version: 3.6.1 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:22,421 INFO || Kafka commitId: 5e3c2b738d253ff5 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:22,421 INFO || Kafka startTimeMs: 1717068142420 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:22,422 INFO || ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.include.jmx.reporter = true auto.offset.reset = earliest bootstrap.servers = [devl-kaf2-0.sdde.deere.com:9094, devl-kaf2-1.sdde.deere.com:9094, devl-kaf2-2.sdde.deere.com:9094] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = mdo_debezium_SSL-statuses client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = mdo_debezium_SSL group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true internal.throw.on.fetch.stable.offset.unsupported = false isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = [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 = SCRAM-SHA-256 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 = 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 = /etc/ssl/certs/ca-crt.pem ssl.truststore.password = null ssl.truststore.type = PEM value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer [org.apache.kafka.clients.consumer.ConsumerConfig] 2024-05-30 11:22:22,427 INFO || These configurations '[producer.sasl.jaas.config, producer.bootstrap.servers, rest.advertised.port, task.shutdown.graceful.timeout.ms, plugin.path, producer.ssl.truststore.location, metrics.context.connect.kafka.cluster.id, status.storage.replication.factor, offset.storage.topic, value.converter, key.converter, config.storage.topic, producer.security.protocol, metrics.context.connect.group.id, rest.advertised.host.name, status.storage.topic, rest.host.name, offset.flush.timeout.ms, producer.sasl.mechanism, config.storage.replication.factor, offset.flush.interval.ms, rest.port, key.converter.schemas.enable, producer.ssl.truststore.type, value.converter.schemas.enable, offset.storage.replication.factor, producer.ssl.endpoint.identification.algorithm]' were supplied but are not used yet. [org.apache.kafka.clients.consumer.ConsumerConfig] 2024-05-30 11:22:22,427 INFO || Kafka version: 3.6.1 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:22,427 INFO || Kafka commitId: 5e3c2b738d253ff5 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:22,427 INFO || Kafka startTimeMs: 1717068142427 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:22,458 INFO || [Producer clientId=mdo_debezium_SSL-statuses] Cluster ID: UxJUAE7HSEOrlGmu-JXBGA [org.apache.kafka.clients.Metadata] 2024-05-30 11:22:22,470 INFO || [Consumer clientId=mdo_debezium_SSL-statuses, groupId=mdo_debezium_SSL] Cluster ID: UxJUAE7HSEOrlGmu-JXBGA [org.apache.kafka.clients.Metadata] 2024-05-30 11:22:22,471 INFO || [Consumer clientId=mdo_debezium_SSL-statuses, groupId=mdo_debezium_SSL] Assigned to partition(s): my_connect_statuses_SSL-0 [org.apache.kafka.clients.consumer.KafkaConsumer] 2024-05-30 11:22:22,471 INFO || [Consumer clientId=mdo_debezium_SSL-statuses, groupId=mdo_debezium_SSL] Seeking to earliest offset of partition my_connect_statuses_SSL-0 [org.apache.kafka.clients.consumer.internals.SubscriptionState] May 30, 2024 11:22:22 AM 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-05-30 11:22:22,495 INFO || Started o.e.j.s.ServletContextHandler@32c60fec{/,null,AVAILABLE} [org.eclipse.jetty.server.handler.ContextHandler] 2024-05-30 11:22:22,496 INFO || REST resources initialized; server is started and ready to handle requests [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:22:22,496 INFO || Kafka Connect started [org.apache.kafka.connect.runtime.Connect] 2024-05-30 11:22:22,559 INFO || [Consumer clientId=mdo_debezium_SSL-statuses, groupId=mdo_debezium_SSL] Resetting offset for partition my_connect_statuses_SSL-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.178.6.96:9094 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,570 INFO || Finished reading KafkaBasedLog for topic my_connect_statuses_SSL [org.apache.kafka.connect.util.KafkaBasedLog] 2024-05-30 11:22:22,571 INFO || Started KafkaBasedLog for topic my_connect_statuses_SSL [org.apache.kafka.connect.util.KafkaBasedLog] 2024-05-30 11:22:22,575 INFO || Starting KafkaConfigBackingStore [org.apache.kafka.connect.storage.KafkaConfigBackingStore] 2024-05-30 11:22:22,575 INFO || Starting KafkaBasedLog with topic my_connect_configs_SSL [org.apache.kafka.connect.util.KafkaBasedLog] 2024-05-30 11:22:22,584 INFO || ProducerConfig values: acks = -1 auto.include.jmx.reporter = true batch.size = 16384 bootstrap.servers = [devl-kaf2-0.sdde.deere.com:9094, devl-kaf2-1.sdde.deere.com:9094, devl-kaf2-2.sdde.deere.com:9094] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = mdo_debezium_SSL-configs compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 2147483647 enable.idempotence = false interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.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.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 = SCRAM-SHA-256 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 = 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 = /etc/ssl/certs/ca-crt.pem ssl.truststore.password = null ssl.truststore.type = PEM transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer [org.apache.kafka.clients.producer.ProducerConfig] 2024-05-30 11:22:22,588 INFO || These configurations '[producer.sasl.jaas.config, producer.bootstrap.servers, group.id, rest.advertised.port, task.shutdown.graceful.timeout.ms, plugin.path, producer.ssl.truststore.location, metrics.context.connect.kafka.cluster.id, status.storage.replication.factor, offset.storage.topic, value.converter, key.converter, config.storage.topic, producer.security.protocol, metrics.context.connect.group.id, rest.advertised.host.name, status.storage.topic, rest.host.name, offset.flush.timeout.ms, producer.sasl.mechanism, config.storage.replication.factor, offset.flush.interval.ms, rest.port, key.converter.schemas.enable, producer.ssl.truststore.type, value.converter.schemas.enable, offset.storage.replication.factor, producer.ssl.endpoint.identification.algorithm]' were supplied but are not used yet. [org.apache.kafka.clients.producer.ProducerConfig] 2024-05-30 11:22:22,588 INFO || Kafka version: 3.6.1 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:22,588 INFO || Kafka commitId: 5e3c2b738d253ff5 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:22,588 INFO || Kafka startTimeMs: 1717068142588 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:22,589 INFO || ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.include.jmx.reporter = true auto.offset.reset = earliest bootstrap.servers = [devl-kaf2-0.sdde.deere.com:9094, devl-kaf2-1.sdde.deere.com:9094, devl-kaf2-2.sdde.deere.com:9094] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = mdo_debezium_SSL-configs client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = mdo_debezium_SSL group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true internal.throw.on.fetch.stable.offset.unsupported = false isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = [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 = SCRAM-SHA-256 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 = 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 = /etc/ssl/certs/ca-crt.pem ssl.truststore.password = null ssl.truststore.type = PEM value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer [org.apache.kafka.clients.consumer.ConsumerConfig] 2024-05-30 11:22:22,593 INFO || These configurations '[producer.sasl.jaas.config, producer.bootstrap.servers, rest.advertised.port, task.shutdown.graceful.timeout.ms, plugin.path, producer.ssl.truststore.location, metrics.context.connect.kafka.cluster.id, status.storage.replication.factor, offset.storage.topic, value.converter, key.converter, config.storage.topic, producer.security.protocol, metrics.context.connect.group.id, rest.advertised.host.name, status.storage.topic, rest.host.name, offset.flush.timeout.ms, producer.sasl.mechanism, config.storage.replication.factor, offset.flush.interval.ms, rest.port, key.converter.schemas.enable, producer.ssl.truststore.type, value.converter.schemas.enable, offset.storage.replication.factor, producer.ssl.endpoint.identification.algorithm]' were supplied but are not used yet. [org.apache.kafka.clients.consumer.ConsumerConfig] 2024-05-30 11:22:22,593 INFO || Kafka version: 3.6.1 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:22,593 INFO || Kafka commitId: 5e3c2b738d253ff5 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:22,593 INFO || Kafka startTimeMs: 1717068142593 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:22,621 INFO || [Producer clientId=mdo_debezium_SSL-configs] Cluster ID: UxJUAE7HSEOrlGmu-JXBGA [org.apache.kafka.clients.Metadata] 2024-05-30 11:22:22,653 INFO || [Consumer clientId=mdo_debezium_SSL-configs, groupId=mdo_debezium_SSL] Cluster ID: UxJUAE7HSEOrlGmu-JXBGA [org.apache.kafka.clients.Metadata] 2024-05-30 11:22:22,655 INFO || [Consumer clientId=mdo_debezium_SSL-configs, groupId=mdo_debezium_SSL] Assigned to partition(s): my_connect_configs_SSL-0 [org.apache.kafka.clients.consumer.KafkaConsumer] 2024-05-30 11:22:22,656 INFO || [Consumer clientId=mdo_debezium_SSL-configs, groupId=mdo_debezium_SSL] Seeking to earliest offset of partition my_connect_configs_SSL-0 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,740 INFO || [Consumer clientId=mdo_debezium_SSL-configs, groupId=mdo_debezium_SSL] Resetting offset for partition my_connect_configs_SSL-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.178.6.96:9094 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2024-05-30 11:22:22,750 INFO || Successfully processed removal of connector 'oee-2' [org.apache.kafka.connect.storage.KafkaConfigBackingStore] 2024-05-30 11:22:22,751 INFO || Successfully processed removal of connector 'oee-2' [org.apache.kafka.connect.storage.KafkaConfigBackingStore] 2024-05-30 11:22:22,753 INFO || Finished reading KafkaBasedLog for topic my_connect_configs_SSL [org.apache.kafka.connect.util.KafkaBasedLog] 2024-05-30 11:22:22,753 INFO || Started KafkaBasedLog for topic my_connect_configs_SSL [org.apache.kafka.connect.util.KafkaBasedLog] 2024-05-30 11:22:22,753 INFO || Started KafkaConfigBackingStore [org.apache.kafka.connect.storage.KafkaConfigBackingStore] 2024-05-30 11:22:22,754 INFO || [Worker clientId=connect-1, groupId=mdo_debezium_SSL] Herder started [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2024-05-30 11:22:22,796 INFO || [Worker clientId=connect-1, groupId=mdo_debezium_SSL] Cluster ID: UxJUAE7HSEOrlGmu-JXBGA [org.apache.kafka.clients.Metadata] 2024-05-30 11:22:22,797 INFO || [Worker clientId=connect-1, groupId=mdo_debezium_SSL] Discovered group coordinator 10.178.6.99:9094 (id: 2147483645 rack: null) [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2024-05-30 11:22:22,803 INFO || [Worker clientId=connect-1, groupId=mdo_debezium_SSL] Rebalance started [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2024-05-30 11:22:22,803 INFO || [Worker clientId=connect-1, groupId=mdo_debezium_SSL] (Re-)joining group [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2024-05-30 11:22:22,844 INFO || [Worker clientId=connect-1, groupId=mdo_debezium_SSL] Request joining group due to: rebalance failed due to 'The group member needs to have a valid member id before actually entering a consumer group.' (MemberIdRequiredException) [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2024-05-30 11:22:22,844 INFO || [Worker clientId=connect-1, groupId=mdo_debezium_SSL] (Re-)joining group [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2024-05-30 11:22:22,847 INFO || [Worker clientId=connect-1, groupId=mdo_debezium_SSL] Successfully joined group with generation Generation{generationId=17, memberId='connect-1-6569c049-293b-4df6-804c-395d4cd94572', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2024-05-30 11:22:22,874 INFO || [Worker clientId=connect-1, groupId=mdo_debezium_SSL] Successfully synced group in generation Generation{generationId=17, memberId='connect-1-6569c049-293b-4df6-804c-395d4cd94572', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2024-05-30 11:22:22,875 INFO || [Worker clientId=connect-1, groupId=mdo_debezium_SSL] Joined group at generation 17 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-6569c049-293b-4df6-804c-395d4cd94572', leaderUrl='http://100.94.27.150:8083/', offset=14, connectorIds=[oee-3], taskIds=[oee-3-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2024-05-30 11:22:22,876 WARN || [Worker clientId=connect-1, groupId=mdo_debezium_SSL] Catching up to assignment's config offset. [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2024-05-30 11:22:22,876 INFO || [Worker clientId=connect-1, groupId=mdo_debezium_SSL] Current config state offset -1 is behind group assignment 14, reading to end of config log [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2024-05-30 11:22:22,881 INFO || [Worker clientId=connect-1, groupId=mdo_debezium_SSL] Finished reading to end of log and updated config snapshot, new config log offset: 14 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2024-05-30 11:22:22,881 INFO || [Worker clientId=connect-1, groupId=mdo_debezium_SSL] Starting connectors and tasks using config offset 14 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2024-05-30 11:22:22,882 INFO || [Worker clientId=connect-1, groupId=mdo_debezium_SSL] Starting task oee-3-0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2024-05-30 11:22:22,883 INFO || [Worker clientId=connect-1, groupId=mdo_debezium_SSL] Starting connector oee-3 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2024-05-30 11:22:22,889 INFO || Creating task oee-3-0 [org.apache.kafka.connect.runtime.Worker] 2024-05-30 11:22:22,890 INFO || Creating connector oee-3 of type io.debezium.connector.sqlserver.SqlServerConnector [org.apache.kafka.connect.runtime.Worker] 2024-05-30 11:22:22,893 INFO || ConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.sqlserver.SqlServerConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = oee-3 predicates = [] tasks.max = 1 transforms = [] value.converter = null [org.apache.kafka.connect.runtime.ConnectorConfig] 2024-05-30 11:22:22,894 INFO || SourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.sqlserver.SqlServerConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = null name = oee-3 offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = null [org.apache.kafka.connect.runtime.SourceConnectorConfig] 2024-05-30 11:22:22,895 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.sqlserver.SqlServerConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = null name = oee-3 offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = null [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2024-05-30 11:22:22,895 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.sqlserver.SqlServerConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = oee-3 predicates = [] tasks.max = 1 transforms = [] value.converter = null [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2024-05-30 11:22:22,908 INFO || Instantiated connector oee-3 with version 2.5.4.Final of type class io.debezium.connector.sqlserver.SqlServerConnector [org.apache.kafka.connect.runtime.Worker] 2024-05-30 11:22:22,910 INFO || Finished creating connector oee-3 [org.apache.kafka.connect.runtime.Worker] 2024-05-30 11:22:22,911 INFO || TaskConfig values: task.class = class io.debezium.connector.sqlserver.SqlServerConnectorTask [org.apache.kafka.connect.runtime.TaskConfig] 2024-05-30 11:22:22,917 INFO || Instantiated task oee-3-0 with version 2.5.4.Final of type io.debezium.connector.sqlserver.SqlServerConnectorTask [org.apache.kafka.connect.runtime.Worker] 2024-05-30 11:22:22,918 INFO || JsonConverterConfig values: converter.type = key decimal.format = BASE64 replace.null.with.default = true schemas.cache.size = 1000 schemas.enable = true [org.apache.kafka.connect.json.JsonConverterConfig] 2024-05-30 11:22:22,918 INFO || Set up the key converter class org.apache.kafka.connect.json.JsonConverter for task oee-3-0 using the worker config [org.apache.kafka.connect.runtime.Worker] 2024-05-30 11:22:22,918 INFO || JsonConverterConfig values: converter.type = value decimal.format = BASE64 replace.null.with.default = true schemas.cache.size = 1000 schemas.enable = true [org.apache.kafka.connect.json.JsonConverterConfig] 2024-05-30 11:22:22,919 INFO || Set up the value converter class org.apache.kafka.connect.json.JsonConverter for task oee-3-0 using the worker config [org.apache.kafka.connect.runtime.Worker] 2024-05-30 11:22:22,919 INFO || Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task oee-3-0 using the worker config [org.apache.kafka.connect.runtime.Worker] 2024-05-30 11:22:22,922 INFO || SourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.sqlserver.SqlServerConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = null name = oee-3 offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = null [org.apache.kafka.connect.runtime.SourceConnectorConfig] 2024-05-30 11:22:22,922 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.sqlserver.SqlServerConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = null name = oee-3 offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = null [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2024-05-30 11:22:22,923 INFO || Initializing: org.apache.kafka.connect.runtime.TransformationChain{} [org.apache.kafka.connect.runtime.Worker] 2024-05-30 11:22:22,924 INFO || ProducerConfig values: acks = -1 auto.include.jmx.reporter = true batch.size = 16384 bootstrap.servers = [devl-kaf2-0.sdde.deere.com:9094, devl-kaf2-1.sdde.deere.com:9094, devl-kaf2-2.sdde.deere.com:9094] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = connector-producer-oee-3-0 compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 2147483647 enable.idempotence = false interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer linger.ms = 0 max.block.ms = 9223372036854775807 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metadata.max.idle.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.adaptive.partitioning.enable = true partitioner.availability.timeout.ms = 0 partitioner.class = null partitioner.ignore.keys = false receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = [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 = SCRAM-SHA-256 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 = 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 = /etc/ssl/certs/ca-crt.pem ssl.truststore.password = null ssl.truststore.type = PEM transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer [org.apache.kafka.clients.producer.ProducerConfig] 2024-05-30 11:22:22,930 INFO || 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] 2024-05-30 11:22:22,931 INFO || Kafka version: 3.6.1 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:22,931 INFO || Kafka commitId: 5e3c2b738d253ff5 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:22,931 INFO || Kafka startTimeMs: 1717068142930 [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:22,945 INFO || [Worker clientId=connect-1, groupId=mdo_debezium_SSL] Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2024-05-30 11:22:22,964 INFO || [Producer clientId=connector-producer-oee-3-0] Cluster ID: UxJUAE7HSEOrlGmu-JXBGA [org.apache.kafka.clients.Metadata] 2024-05-30 11:22:22,978 INFO || SourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.sqlserver.SqlServerConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = null name = oee-3 offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = null [org.apache.kafka.connect.runtime.SourceConnectorConfig] 2024-05-30 11:22:22,978 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.sqlserver.SqlServerConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = null name = oee-3 offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = null [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2024-05-30 11:22:22,997 INFO || Starting SqlServerConnectorTask with configuration: [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:22,999 INFO || Loading the custom source info struct maker plugin: io.debezium.connector.sqlserver.SqlServerSourceInfoStructMaker [io.debezium.config.CommonConnectorConfig] 2024-05-30 11:22:23,000 INFO || connector.class = io.debezium.connector.sqlserver.SqlServerConnector [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:23,000 INFO || driver.encrypt = false [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:23,000 INFO || producer.sasl.jaas.config = ******** [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:23,000 INFO || producer.bootstrap.servers = devl-kaf2-0.sdde.deere.com:9094,devl-kaf2-1.sdde.deere.com:9094,devl-kaf2-2.sdde.deere.com:9094 [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:23,000 INFO || tasks.max = 1 [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:23,000 INFO || database.history.kafka.topic = oee-1.history [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:23,000 INFO || schema.history.internal.file.filename = /security/schistory.dat [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:23,000 INFO || producer.ssl.truststore.location = /etc/ssl/certs/ca-crt.pem [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:23,000 INFO || topic.prefix = oee-3 [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:23,000 INFO || schema.history.internal.kafka.topic = oee-history [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:23,000 INFO || connect.protocol = eager [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:23,000 INFO || database.user = eam_ignitionUser [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:23,000 INFO || database.dbname = IgnitionEnterprise [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:23,000 INFO || database.names = IgnitionEnterprise [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:23,000 INFO || producer.security.protocol = SASL_SSL [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:23,000 INFO || database.history.kafka.bootstrap.servers = devl-kaf2-0.sdde.deere.com:9094,devl-kaf2-1.sdde.deere.com:9094,devl-kaf2-2.sdde.deere.com:9094 [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:23,000 INFO || database.server.name = INST2 [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:23,000 INFO || database.port = 1434 [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:23,000 INFO || producer.sasl.mechanism = SCRAM-SHA-256 [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:23,000 INFO || schema.history.internal = io.debezium.storage.file.history.FileSchemaHistory [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:23,000 INFO || producer.ssl.truststore.type = PEM [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:23,000 INFO || task.class = io.debezium.connector.sqlserver.SqlServerConnectorTask [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:23,000 INFO || database.hostname = ignitionenterprise-dev-90-db.sde.deere.com [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:23,000 INFO || database.password = ******** [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:23,000 INFO || value.converter.schemas.enable = true [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:23,000 INFO || name = oee-3 [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:23,000 INFO || task.id = 0 [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:23,000 INFO || database.trustServerCertificate = false [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:23,000 INFO || table.include.list = dbo.OEEdowntime [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:23,000 INFO || database.include.list = IgnitionEnterprise [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:23,002 INFO || Loading the custom source info struct maker plugin: io.debezium.connector.sqlserver.SqlServerSourceInfoStructMaker [io.debezium.config.CommonConnectorConfig] 2024-05-30 11:22:23,018 INFO || Loading the custom topic naming strategy plugin: io.debezium.schema.SchemaTopicNamingStrategy [io.debezium.config.CommonConnectorConfig] 2024-05-30 11:22:23,093 INFO || Found previous partition offset SqlServerPartition [sourcePartition={server=oee-3, database=IgnitionEnterprise}]: {commit_lsn=00003d4d:00004980:0003, snapshot=true, snapshot_completed=false} [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:23,094 ERROR || WorkerSourceTask{id=oee-3-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] io.debezium.DebeziumException: The db history topic or its content is fully or partially missing. Please check database schema history topic configuration and re-execute the snapshot. at io.debezium.relational.HistorizedRelationalDatabaseSchema.recover(HistorizedRelationalDatabaseSchema.java:68) at io.debezium.connector.sqlserver.SqlServerConnectorTask.start(SqlServerConnectorTask.java:94) at io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:141) at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.initializeAndStart(AbstractWorkerSourceTask.java:280) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:202) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:259) at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:77) at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:236) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:829) 2024-05-30 11:22:23,096 INFO || Stopping down connector [io.debezium.connector.common.BaseSourceTask] 2024-05-30 11:22:23,097 INFO || [Producer clientId=connector-producer-oee-3-0] Closing the Kafka producer with timeoutMillis = 30000 ms. [org.apache.kafka.clients.producer.KafkaProducer] 2024-05-30 11:22:23,100 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2024-05-30 11:22:23,100 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2024-05-30 11:22:23,100 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2024-05-30 11:22:23,100 INFO || App info kafka.producer for connector-producer-oee-3-0 unregistered [org.apache.kafka.common.utils.AppInfoParser] 2024-05-30 11:22:23,254 INFO || Connection gracefully closed [io.debezium.jdbc.JdbcConnection] 2024-05-30 11:23:33,925 INFO || 100.94.86.178 - - [30/May/2024:11:23:33 +0000] "GET /connectors HTTP/1.1" 200 9 "-" "ReactorNetty/1.1.6" 97 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:23:33,971 INFO || 100.94.86.178 - - [30/May/2024:11:23:33 +0000] "GET /connectors/oee-3 HTTP/1.1" 200 1532 "-" "ReactorNetty/1.1.6" 53 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:23:33,991 INFO || 100.94.86.178 - - [30/May/2024:11:23:33 +0000] "GET /connectors/oee-3/status HTTP/1.1" 200 1537 "-" "ReactorNetty/1.1.6" 11 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:23:34,002 INFO || 100.94.86.178 - - [30/May/2024:11:23:33 +0000] "GET /connectors/oee-3/config HTTP/1.1" 200 1449 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:23:34,012 INFO || 100.94.86.178 - - [30/May/2024:11:23:34 +0000] "GET /connectors/oee-3/tasks HTTP/1.1" 200 1582 "-" "ReactorNetty/1.1.6" 7 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:23:34,020 INFO || 100.94.86.178 - - [30/May/2024:11:23:34 +0000] "GET /connectors/oee-3/tasks/0/status HTTP/1.1" 200 1429 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:23:34,030 INFO || 100.94.86.178 - - [30/May/2024:11:23:34 +0000] "GET /connectors/oee-3/topics HTTP/1.1" 200 73 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:23:36,578 INFO || 100.94.86.178 - - [30/May/2024:11:23:36 +0000] "GET /connectors/oee-3 HTTP/1.1" 200 1532 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:23:36,578 INFO || 100.94.86.178 - - [30/May/2024:11:23:36 +0000] "GET /connectors/oee-3/tasks HTTP/1.1" 200 1582 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:23:36,586 INFO || 100.94.86.178 - - [30/May/2024:11:23:36 +0000] "GET /connectors/oee-3/tasks/0/status HTTP/1.1" 200 1429 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:23:36,588 INFO || 100.94.91.169 - - [30/May/2024:11:23:36 +0000] "GET /connectors/oee-3/status HTTP/1.1" 200 1537 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:23:36,590 INFO || 100.94.86.178 - - [30/May/2024:11:23:36 +0000] "GET /connectors HTTP/1.1" 200 9 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:23:36,598 INFO || 100.94.86.178 - - [30/May/2024:11:23:36 +0000] "GET /connectors/oee-3 HTTP/1.1" 200 1532 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:23:36,603 INFO || 100.94.86.178 - - [30/May/2024:11:23:36 +0000] "GET /connectors/oee-3/status HTTP/1.1" 200 1537 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:23:36,610 INFO || 100.94.91.169 - - [30/May/2024:11:23:36 +0000] "GET /connectors/oee-3/config HTTP/1.1" 200 1449 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:23:36,617 INFO || 100.94.86.178 - - [30/May/2024:11:23:36 +0000] "GET /connectors/oee-3/tasks HTTP/1.1" 200 1582 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:23:36,625 INFO || 100.94.86.178 - - [30/May/2024:11:23:36 +0000] "GET /connectors/oee-3/tasks/0/status HTTP/1.1" 200 1429 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:23:36,632 INFO || 100.94.86.178 - - [30/May/2024:11:23:36 +0000] "GET /connectors/oee-3/topics HTTP/1.1" 200 73 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:23:49,856 INFO || 100.94.91.169 - - [30/May/2024:11:23:49 +0000] "GET /connectors/oee-3 HTTP/1.1" 200 1532 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:23:49,857 INFO || 100.94.86.178 - - [30/May/2024:11:23:49 +0000] "GET /connectors/oee-3/tasks HTTP/1.1" 200 1582 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:23:49,862 INFO || 100.94.86.178 - - [30/May/2024:11:23:49 +0000] "GET /connectors/oee-3/tasks/0/status HTTP/1.1" 200 1429 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:23:49,864 INFO || 100.94.86.178 - - [30/May/2024:11:23:49 +0000] "GET /connectors/oee-3/status HTTP/1.1" 200 1537 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:24:11,650 INFO || 100.94.86.178 - - [30/May/2024:11:24:11 +0000] "GET /connectors/oee-3/tasks HTTP/1.1" 200 1582 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:24:11,653 INFO || 100.94.91.169 - - [30/May/2024:11:24:11 +0000] "GET /connectors/oee-3 HTTP/1.1" 200 1532 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:24:11,656 INFO || 100.94.86.178 - - [30/May/2024:11:24:11 +0000] "GET /connectors/oee-3/tasks/0/status HTTP/1.1" 200 1429 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:24:11,659 INFO || 100.94.86.178 - - [30/May/2024:11:24:11 +0000] "GET /connectors/oee-3/status HTTP/1.1" 200 1537 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:24:16,656 INFO || Stopping connector oee-3 [org.apache.kafka.connect.runtime.Worker] 2024-05-30 11:24:16,656 INFO || Scheduled shutdown for WorkerConnector{id=oee-3} [org.apache.kafka.connect.runtime.WorkerConnector] 2024-05-30 11:24:16,657 INFO || Completed shutdown for WorkerConnector{id=oee-3} [org.apache.kafka.connect.runtime.WorkerConnector] 2024-05-30 11:24:16,659 INFO || [Worker clientId=connect-1, groupId=mdo_debezium_SSL] Starting connector oee-3 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2024-05-30 11:24:16,659 INFO || Creating connector oee-3 of type io.debezium.connector.sqlserver.SqlServerConnector [org.apache.kafka.connect.runtime.Worker] 2024-05-30 11:24:16,660 INFO || SourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.sqlserver.SqlServerConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = null name = oee-3 offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = null [org.apache.kafka.connect.runtime.SourceConnectorConfig] 2024-05-30 11:24:16,660 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.sqlserver.SqlServerConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = null name = oee-3 offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = null [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2024-05-30 11:24:16,660 INFO || Instantiated connector oee-3 with version 2.5.4.Final of type class io.debezium.connector.sqlserver.SqlServerConnector [org.apache.kafka.connect.runtime.Worker] 2024-05-30 11:24:16,660 INFO || Finished creating connector oee-3 [org.apache.kafka.connect.runtime.Worker] 2024-05-30 11:24:16,662 INFO || SourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.sqlserver.SqlServerConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = null name = oee-3 offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = null [org.apache.kafka.connect.runtime.SourceConnectorConfig] 2024-05-30 11:24:16,662 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.sqlserver.SqlServerConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = null name = oee-3 offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = null [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2024-05-30 11:24:16,662 INFO || Loading the custom source info struct maker plugin: io.debezium.connector.sqlserver.SqlServerSourceInfoStructMaker [io.debezium.config.CommonConnectorConfig] 2024-05-30 11:24:16,699 INFO || Connection gracefully closed [io.debezium.jdbc.JdbcConnection] 2024-05-30 11:24:16,703 INFO || 100.94.86.178 - - [30/May/2024:11:24:16 +0000] "POST /connectors/oee-3/restart?includeTasks=false&onlyFailed=false HTTP/1.1" 204 0 "-" "ReactorNetty/1.1.6" 52 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:24:20,010 INFO || 100.94.91.169 - - [30/May/2024:11:24:20 +0000] "GET /connectors/oee-3/config HTTP/1.1" 200 1449 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:26:51,594 INFO || 100.94.43.66 - - [30/May/2024:11:26:51 +0000] "GET /connectors/oee-3 HTTP/1.1" 200 1532 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:26:51,595 INFO || 100.94.86.178 - - [30/May/2024:11:26:51 +0000] "GET /connectors/oee-3/config HTTP/1.1" 200 1449 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:26:51,595 INFO || 100.94.43.66 - - [30/May/2024:11:26:51 +0000] "GET /connectors/oee-3/tasks HTTP/1.1" 200 1582 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:26:51,603 INFO || 100.94.43.66 - - [30/May/2024:11:26:51 +0000] "GET /connectors/oee-3/tasks/0/status HTTP/1.1" 200 1429 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:26:51,605 INFO || 100.94.85.46 - - [30/May/2024:11:26:51 +0000] "GET /connectors/oee-3/status HTTP/1.1" 200 1537 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2024-05-30 11:27:20,414 INFO || [Worker clientId=connect-1, groupId=mdo_debezium_SSL] Session key updated [org.apache.kafka.connect.runtime.distributed.DistributedHerder]