Using BOOTSTRAP_SERVERS=kafka:9092 Plugins are loaded from /kafka/connect WARNING: it is recommended to specify the STATUS_STORAGE_TOPIC variable for defining the name of the topic where connector statuses will be stored. This topic may have multiple partitions, be highly replicated (e.g., 3x or more) and should be configured for compaction. As no value is given, the default of 'connect-status' will be used. Using the following environment variables: GROUP_ID=sde_group CONFIG_STORAGE_TOPIC=sde_storage_topic OFFSET_STORAGE_TOPIC=sde_offset_topic BOOTSTRAP_SERVERS=kafka:9092 REST_HOST_NAME=172.17.0.4 REST_PORT=8083 ADVERTISED_HOST_NAME=172.17.0.4 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_OFFSET_STORAGE_TOPIC: offset.storage.topic=sde_offset_topic --- Setting property from CONNECT_KEY_CONVERTER: key.converter=org.apache.kafka.connect.json.JsonConverter --- Setting property from CONNECT_CONFIG_STORAGE_TOPIC: config.storage.topic=sde_storage_topic --- Setting property from CONNECT_GROUP_ID: group.id=sde_group --- Setting property from CONNECT_REST_ADVERTISED_HOST_NAME: rest.advertised.host.name=172.17.0.4 --- Setting property from CONNECT_REST_HOST_NAME: rest.host.name=172.17.0.4 --- Setting property from CONNECT_VALUE_CONVERTER: value.converter=org.apache.kafka.connect.json.JsonConverter --- Setting property from CONNECT_REST_PORT: rest.port=8083 --- Setting property from CONNECT_OFFSET_FLUSH_TIMEOUT_MS: offset.flush.timeout.ms=5000 --- 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=kafka:9092 --- Setting property from CONNECT_TASK_SHUTDOWN_GRACEFUL_TIMEOUT_MS: task.shutdown.graceful.timeout.ms=10000 2022-08-04 10:33:57,870 INFO || WorkerInfo values: jvm.args = -Xms256M, -Xmx2G, -XX:+UseG1GC, -XX:MaxGCPauseMillis=20, -XX:InitiatingHeapOccupancyPercent=35, -XX:+ExplicitGCInvokesConcurrent, -XX:MaxInlineLevel=15, -Djava.awt.headless=true, -Dcom.sun.management.jmxremote, -Dcom.sun.management.jmxremote.authenticate=false, -Dcom.sun.management.jmxremote.ssl=false, -Dkafka.logs.dir=/kafka/logs, -Dlog4j.configuration=file:/kafka/config/log4j.properties jvm.spec = Red Hat, Inc., OpenJDK 64-Bit Server VM, 11.0.15, 11.0.15+10 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.5.0.jar:/kafka/libs/avro-1.10.1.jar:/kafka/libs/common-config-7.0.1.jar:/kafka/libs/common-utils-7.0.1.jar:/kafka/libs/commons-cli-1.4.jar:/kafka/libs/commons-lang3-3.8.1.jar:/kafka/libs/connect-api-3.2.0.jar:/kafka/libs/connect-basic-auth-extension-3.2.0.jar:/kafka/libs/connect-json-3.2.0.jar:/kafka/libs/connect-mirror-3.2.0.jar:/kafka/libs/connect-mirror-client-3.2.0.jar:/kafka/libs/connect-runtime-3.2.0.jar:/kafka/libs/connect-transforms-3.2.0.jar:/kafka/libs/guava-31.0.1-jre.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.12.6.jar:/kafka/libs/jackson-core-2.12.6.jar:/kafka/libs/jackson-databind-2.12.6.1.jar:/kafka/libs/jackson-dataformat-csv-2.12.6.jar:/kafka/libs/jackson-datatype-jdk8-2.12.6.jar:/kafka/libs/jackson-jaxrs-base-2.12.6.jar:/kafka/libs/jackson-jaxrs-json-provider-2.12.6.jar:/kafka/libs/jackson-module-jaxb-annotations-2.12.6.jar:/kafka/libs/jackson-module-scala_2.13-2.12.6.jar:/kafka/libs/jakarta.activation-api-1.2.1.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.2.jar:/kafka/libs/javassist-3.27.0-GA.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.0.jar:/kafka/libs/jersey-client-2.34.jar:/kafka/libs/jersey-common-2.34.jar:/kafka/libs/jersey-container-servlet-2.34.jar:/kafka/libs/jersey-container-servlet-core-2.34.jar:/kafka/libs/jersey-hk2-2.34.jar:/kafka/libs/jersey-server-2.34.jar:/kafka/libs/jetty-client-9.4.44.v20210927.jar:/kafka/libs/jetty-continuation-9.4.44.v20210927.jar:/kafka/libs/jetty-http-9.4.44.v20210927.jar:/kafka/libs/jetty-io-9.4.44.v20210927.jar:/kafka/libs/jetty-security-9.4.44.v20210927.jar:/kafka/libs/jetty-server-9.4.44.v20210927.jar:/kafka/libs/jetty-servlet-9.4.44.v20210927.jar:/kafka/libs/jetty-servlets-9.4.44.v20210927.jar:/kafka/libs/jetty-util-9.4.44.v20210927.jar:/kafka/libs/jetty-util-ajax-9.4.44.v20210927.jar:/kafka/libs/jline-3.21.0.jar:/kafka/libs/jopt-simple-5.0.4.jar:/kafka/libs/jose4j-0.7.9.jar:/kafka/libs/kafka-avro-serializer-7.0.1.jar:/kafka/libs/kafka-clients-3.2.0.jar:/kafka/libs/kafka-connect-avro-converter-7.0.1.jar:/kafka/libs/kafka-connect-avro-data-7.0.1.jar:/kafka/libs/kafka-log4j-appender-3.2.0.jar:/kafka/libs/kafka-metadata-3.2.0.jar:/kafka/libs/kafka-raft-3.2.0.jar:/kafka/libs/kafka-schema-registry-client-7.0.1.jar:/kafka/libs/kafka-schema-serializer-7.0.1.jar:/kafka/libs/kafka-server-common-3.2.0.jar:/kafka/libs/kafka-shell-3.2.0.jar:/kafka/libs/kafka-storage-3.2.0.jar:/kafka/libs/kafka-storage-api-3.2.0.jar:/kafka/libs/kafka-streams-3.2.0.jar:/kafka/libs/kafka-streams-examples-3.2.0.jar:/kafka/libs/kafka-streams-scala_2.13-3.2.0.jar:/kafka/libs/kafka-streams-test-utils-3.2.0.jar:/kafka/libs/kafka-tools-3.2.0.jar:/kafka/libs/kafka_2.13-3.2.0.jar:/kafka/libs/lz4-java-1.8.0.jar:/kafka/libs/maven-artifact-3.8.4.jar:/kafka/libs/metrics-core-2.2.0.jar:/kafka/libs/metrics-core-4.1.12.1.jar:/kafka/libs/netty-buffer-4.1.73.Final.jar:/kafka/libs/netty-codec-4.1.73.Final.jar:/kafka/libs/netty-common-4.1.73.Final.jar:/kafka/libs/netty-handler-4.1.73.Final.jar:/kafka/libs/netty-resolver-4.1.73.Final.jar:/kafka/libs/netty-tcnative-classes-2.0.46.Final.jar:/kafka/libs/netty-transport-4.1.73.Final.jar:/kafka/libs/netty-transport-classes-epoll-4.1.73.Final.jar:/kafka/libs/netty-transport-native-epoll-4.1.73.Final.jar:/kafka/libs/netty-transport-native-unix-common-4.1.73.Final.jar:/kafka/libs/osgi-resource-locator-1.0.3.jar:/kafka/libs/paranamer-2.8.jar:/kafka/libs/plexus-utils-3.3.0.jar:/kafka/libs/reflections-0.9.12.jar:/kafka/libs/reload4j-1.2.19.jar:/kafka/libs/rocksdbjni-6.29.4.1.jar:/kafka/libs/scala-collection-compat_2.13-2.6.0.jar:/kafka/libs/scala-java8-compat_2.13-1.0.2.jar:/kafka/libs/scala-library-2.13.8.jar:/kafka/libs/scala-logging_2.13-3.9.4.jar:/kafka/libs/scala-reflect-2.13.8.jar:/kafka/libs/slf4j-api-1.7.36.jar:/kafka/libs/slf4j-reload4j-1.7.36.jar:/kafka/libs/snappy-java-1.1.8.4.jar:/kafka/libs/trogdor-3.2.0.jar:/kafka/libs/zookeeper-3.6.3.jar:/kafka/libs/zookeeper-jute-3.6.3.jar:/kafka/libs/zstd-jni-1.5.2-1.jar os.spec = Linux, amd64, 3.10.0-1062.9.1.el7.x86_64 os.vcpus = 2 [org.apache.kafka.connect.runtime.WorkerInfo] 2022-08-04 10:33:57,875 INFO || Scanning for plugin classes. This might take a moment ... [org.apache.kafka.connect.cli.ConnectDistributed] 2022-08-04 10:33:57,888 INFO || Loading plugin from: /kafka/connect/debezium-connector-mongodb [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:33:58,467 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-mongodb/} [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:33:58,468 INFO || Added plugin 'io.debezium.connector.mongodb.MongoDbConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:33:58,468 INFO || Added plugin 'io.debezium.converters.ByteArrayConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:33:58,469 INFO || Added plugin 'io.debezium.converters.ByteBufferConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:33:58,469 INFO || Added plugin 'io.debezium.converters.BinaryDataConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:33:58,469 INFO || Added plugin 'io.debezium.converters.CloudEventsConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:33:58,469 INFO || Added plugin 'io.debezium.transforms.outbox.EventRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:33:58,469 INFO || Added plugin 'io.debezium.transforms.ExtractNewRecordState' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:33:58,469 INFO || Added plugin 'io.debezium.connector.mongodb.transforms.outbox.MongoEventRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:33:58,469 INFO || Added plugin 'io.debezium.connector.mongodb.transforms.ExtractNewDocumentState' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:33:58,469 INFO || Added plugin 'io.debezium.transforms.ByLogicalTableRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:33:58,469 INFO || Added plugin 'io.debezium.transforms.tracing.ActivateTracingSpan' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:33:58,469 INFO || Added plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:33:58,469 INFO || Added plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:33:58,469 INFO || Added plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:33:58,472 INFO || Loading plugin from: /kafka/connect/debezium-connector-db2 [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:33:58,734 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-db2/} [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:33:58,734 INFO || Added plugin 'io.debezium.connector.db2.Db2Connector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:33:58,735 INFO || Loading plugin from: /kafka/connect/debezium-connector-sqlserver [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:33:59,335 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-sqlserver/} [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:33:59,335 INFO || Added plugin 'io.debezium.connector.sqlserver.SqlServerConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:33:59,384 INFO || Loading plugin from: /kafka/connect/debezium-connector-vitess [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:00,115 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-vitess/} [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:00,115 INFO || Added plugin 'io.debezium.connector.vitess.VitessConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:00,115 INFO || Loading plugin from: /kafka/connect/debezium-connector-postgres [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:00,349 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-postgres/} [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:00,349 INFO || Added plugin 'io.debezium.connector.postgresql.PostgresConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:00,352 INFO || Loading plugin from: /kafka/connect/debezium-connector-mysql [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:00,680 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-mysql/} [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:00,681 INFO || Added plugin 'io.debezium.connector.mysql.MySqlConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:00,681 INFO || Added plugin 'io.debezium.connector.mysql.transforms.ReadToInsertEvent' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:00,683 INFO || Loading plugin from: /kafka/connect/debezium-connector-oracle [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:01,516 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-oracle/} [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:01,516 INFO || Added plugin 'io.debezium.connector.oracle.OracleConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,110 INFO || Registered loader: jdk.internal.loader.ClassLoaders$AppClassLoader@3d4eac69 [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,111 INFO || Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,111 INFO || Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,111 INFO || Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,111 INFO || Added plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,111 INFO || Added plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,111 INFO || Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,111 INFO || Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,111 INFO || Added plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,111 INFO || Added plugin 'org.apache.kafka.connect.converters.FloatConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,111 INFO || Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,111 INFO || Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,111 INFO || Added plugin 'io.confluent.connect.avro.AvroConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,111 INFO || Added plugin 'org.apache.kafka.connect.converters.LongConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,111 INFO || Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,111 INFO || Added plugin 'org.apache.kafka.connect.json.JsonConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,111 INFO || Added plugin 'org.apache.kafka.connect.storage.StringConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,111 INFO || Added plugin 'org.apache.kafka.connect.converters.ShortConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,111 INFO || Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,111 INFO || Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,111 INFO || Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,111 INFO || Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,111 INFO || Added plugin 'org.apache.kafka.connect.transforms.Filter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,111 INFO || Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,112 INFO || Added plugin 'org.apache.kafka.connect.transforms.HeaderFrom$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,112 INFO || Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,112 INFO || Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,112 INFO || Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,112 INFO || Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,112 INFO || Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,112 INFO || Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,112 INFO || Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,112 INFO || Added plugin 'org.apache.kafka.connect.transforms.DropHeaders' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,112 INFO || Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,112 INFO || Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,112 INFO || Added plugin 'org.apache.kafka.connect.runtime.PredicatedTransformation' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,112 INFO || Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,112 INFO || Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,112 INFO || Added plugin 'org.apache.kafka.connect.transforms.InsertHeader' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,112 INFO || Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,112 INFO || Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,112 INFO || Added plugin 'org.apache.kafka.connect.transforms.HeaderFrom$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,112 INFO || Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,112 INFO || Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,112 INFO || Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,112 INFO || Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,112 INFO || Added plugin 'org.apache.kafka.connect.transforms.predicates.HasHeaderKey' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,112 INFO || Added plugin 'org.apache.kafka.connect.transforms.predicates.RecordIsTombstone' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,113 INFO || Added plugin 'org.apache.kafka.connect.transforms.predicates.TopicNameMatches' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,113 INFO || Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,113 INFO || Added plugin 'org.apache.kafka.common.config.provider.DirectoryConfigProvider' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,113 INFO || Added plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,113 INFO || Added aliases 'Db2Connector' and 'Db2' to plugin 'io.debezium.connector.db2.Db2Connector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,113 INFO || Added aliases 'MongoDbConnector' and 'MongoDb' to plugin 'io.debezium.connector.mongodb.MongoDbConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,113 INFO || Added aliases 'MySqlConnector' and 'MySql' to plugin 'io.debezium.connector.mysql.MySqlConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,113 INFO || Added aliases 'OracleConnector' and 'Oracle' to plugin 'io.debezium.connector.oracle.OracleConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,114 INFO || Added aliases 'PostgresConnector' and 'Postgres' to plugin 'io.debezium.connector.postgresql.PostgresConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,114 INFO || Added aliases 'SqlServerConnector' and 'SqlServer' to plugin 'io.debezium.connector.sqlserver.SqlServerConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,114 INFO || Added aliases 'VitessConnector' and 'Vitess' to plugin 'io.debezium.connector.vitess.VitessConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,114 INFO || Added aliases 'MirrorCheckpointConnector' and 'MirrorCheckpoint' to plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,114 INFO || Added aliases 'MirrorHeartbeatConnector' and 'MirrorHeartbeat' to plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,114 INFO || Added aliases 'MirrorSourceConnector' and 'MirrorSource' to plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,114 INFO || Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,114 INFO || Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,114 INFO || Added aliases 'SchemaSourceConnector' and 'SchemaSource' to plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,114 INFO || Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,114 INFO || Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,114 INFO || Added aliases 'AvroConverter' and 'Avro' to plugin 'io.confluent.connect.avro.AvroConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,115 INFO || Added aliases 'BinaryDataConverter' and 'BinaryData' to plugin 'io.debezium.converters.BinaryDataConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,117 INFO || Added aliases 'ByteBufferConverter' and 'ByteBuffer' to plugin 'io.debezium.converters.ByteBufferConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,117 INFO || Added aliases 'CloudEventsConverter' and 'CloudEvents' to plugin 'io.debezium.converters.CloudEventsConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,117 INFO || Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,117 INFO || Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,117 INFO || Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,117 INFO || Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,117 INFO || Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,117 INFO || Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,117 INFO || Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,117 INFO || Added aliases 'BinaryDataConverter' and 'BinaryData' to plugin 'io.debezium.converters.BinaryDataConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,117 INFO || Added aliases 'ByteBufferConverter' and 'ByteBuffer' to plugin 'io.debezium.converters.ByteBufferConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,117 INFO || Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,118 INFO || Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,118 INFO || Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,118 INFO || Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,118 INFO || Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,118 INFO || Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,118 INFO || Added aliases 'SimpleHeaderConverter' and 'Simple' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,118 INFO || Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,118 INFO || Added alias 'ExtractNewDocumentState' to plugin 'io.debezium.connector.mongodb.transforms.ExtractNewDocumentState' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,118 INFO || Added alias 'MongoEventRouter' to plugin 'io.debezium.connector.mongodb.transforms.outbox.MongoEventRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,118 INFO || Added alias 'ReadToInsertEvent' to plugin 'io.debezium.connector.mysql.transforms.ReadToInsertEvent' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,119 INFO || Added alias 'ByLogicalTableRouter' to plugin 'io.debezium.transforms.ByLogicalTableRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,119 INFO || Added alias 'ExtractNewRecordState' to plugin 'io.debezium.transforms.ExtractNewRecordState' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,119 INFO || Added alias 'EventRouter' to plugin 'io.debezium.transforms.outbox.EventRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,119 INFO || Added alias 'ActivateTracingSpan' to plugin 'io.debezium.transforms.tracing.ActivateTracingSpan' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,119 INFO || Added aliases 'PredicatedTransformation' and 'Predicated' to plugin 'org.apache.kafka.connect.runtime.PredicatedTransformation' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,119 INFO || Added alias 'DropHeaders' to plugin 'org.apache.kafka.connect.transforms.DropHeaders' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,119 INFO || Added alias 'Filter' to plugin 'org.apache.kafka.connect.transforms.Filter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,125 INFO || Added alias 'InsertHeader' to plugin 'org.apache.kafka.connect.transforms.InsertHeader' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,125 INFO || Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,125 INFO || Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,125 INFO || Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,125 INFO || Added alias 'HasHeaderKey' to plugin 'org.apache.kafka.connect.transforms.predicates.HasHeaderKey' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,125 INFO || Added alias 'RecordIsTombstone' to plugin 'org.apache.kafka.connect.transforms.predicates.RecordIsTombstone' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,125 INFO || Added alias 'TopicNameMatches' to plugin 'org.apache.kafka.connect.transforms.predicates.TopicNameMatches' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,125 INFO || Added alias 'BasicAuthSecurityRestExtension' to plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,125 INFO || Added aliases 'AllConnectorClientConfigOverridePolicy' and 'All' to plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,125 INFO || Added aliases 'NoneConnectorClientConfigOverridePolicy' and 'None' to plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,125 INFO || Added aliases 'PrincipalConnectorClientConfigOverridePolicy' and 'Principal' to plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 10:34:03,169 INFO || DistributedConfig values: access.control.allow.methods = access.control.allow.origin = admin.listeners = null bootstrap.servers = [kafka:9092] client.dns.lookup = use_all_dns_ips client.id = config.providers = [] config.storage.replication.factor = 1 config.storage.topic = sde_storage_topic connect.protocol = sessioned connections.max.idle.ms = 540000 connector.client.config.override.policy = All group.id = sde_group 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 = sde_offset_topic 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 = 172.17.0.4 rest.advertised.listener = null rest.advertised.port = 8083 rest.extension.classes = [] retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null scheduled.rebalance.max.delay.ms = 300000 security.protocol = PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 10000 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.client.auth = none ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS status.storage.partitions = 5 status.storage.replication.factor = 1 status.storage.topic = connect-status 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] 2022-08-04 10:34:03,173 INFO || Creating Kafka admin client [org.apache.kafka.connect.util.ConnectUtils] 2022-08-04 10:34:03,177 INFO || AdminClientConfig values: bootstrap.servers = [kafka:9092] 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 = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,254 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,254 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,254 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,254 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,254 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,254 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,254 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,254 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,255 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,255 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,255 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,255 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,255 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,255 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,255 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,255 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,255 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,255 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,255 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,255 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,255 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,255 INFO || Kafka startTimeMs: 1659609243255 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,555 INFO || Kafka cluster ID: KV0rawKYSeWt0oo0PE7lUw [org.apache.kafka.connect.util.ConnectUtils] 2022-08-04 10:34:03,556 INFO || App info kafka.admin.client for adminclient-1 unregistered [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,564 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2022-08-04 10:34:03,565 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2022-08-04 10:34:03,565 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2022-08-04 10:34:03,576 INFO || Logging initialized @6166ms to org.eclipse.jetty.util.log.Slf4jLog [org.eclipse.jetty.util.log] 2022-08-04 10:34:03,614 INFO || Added connector for http://:8083 [org.apache.kafka.connect.runtime.rest.RestServer] 2022-08-04 10:34:03,616 INFO || Initializing REST server [org.apache.kafka.connect.runtime.rest.RestServer] 2022-08-04 10:34:03,630 INFO || jetty-9.4.44.v20210927; built: 2021-09-27T23:02:44.612Z; git: 8da83308eeca865e495e53ef315a249d63ba9332; jvm 11.0.15+10 [org.eclipse.jetty.server.Server] 2022-08-04 10:34:03,658 INFO || Started http_8083@67e0ff3a{HTTP/1.1, (http/1.1)}{0.0.0.0:8083} [org.eclipse.jetty.server.AbstractConnector] 2022-08-04 10:34:03,658 INFO || Started @6249ms [org.eclipse.jetty.server.Server] 2022-08-04 10:34:03,683 INFO || Advertised URI: http://172.17.0.4:8083/ [org.apache.kafka.connect.runtime.rest.RestServer] 2022-08-04 10:34:03,683 INFO || REST server listening at http://172.17.0.4:8083/, advertising URL http://172.17.0.4:8083/ [org.apache.kafka.connect.runtime.rest.RestServer] 2022-08-04 10:34:03,684 INFO || Advertised URI: http://172.17.0.4:8083/ [org.apache.kafka.connect.runtime.rest.RestServer] 2022-08-04 10:34:03,684 INFO || REST admin endpoints at http://172.17.0.4:8083/ [org.apache.kafka.connect.runtime.rest.RestServer] 2022-08-04 10:34:03,685 INFO || Advertised URI: http://172.17.0.4:8083/ [org.apache.kafka.connect.runtime.rest.RestServer] 2022-08-04 10:34:03,687 INFO || Creating Kafka admin client [org.apache.kafka.connect.util.ConnectUtils] 2022-08-04 10:34:03,689 INFO || AdminClientConfig values: bootstrap.servers = [kafka:9092] 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 = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,696 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,696 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,696 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,696 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,696 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,697 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,697 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,697 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,697 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,697 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,697 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,697 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,697 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,697 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,697 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,697 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,697 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,697 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,697 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,697 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,697 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,697 INFO || Kafka startTimeMs: 1659609243697 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,712 INFO || Kafka cluster ID: KV0rawKYSeWt0oo0PE7lUw [org.apache.kafka.connect.util.ConnectUtils] 2022-08-04 10:34:03,713 INFO || App info kafka.admin.client for adminclient-2 unregistered [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,719 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2022-08-04 10:34:03,721 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2022-08-04 10:34:03,721 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2022-08-04 10:34:03,725 INFO || Setting up All Policy for ConnectorClientConfigOverride. This will allow all client configurations to be overridden [org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy] 2022-08-04 10:34:03,732 INFO || Creating Kafka admin client [org.apache.kafka.connect.util.ConnectUtils] 2022-08-04 10:34:03,732 INFO || AdminClientConfig values: bootstrap.servers = [kafka:9092] 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 = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,735 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,735 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,735 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,735 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,735 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,735 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,735 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,735 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,735 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,735 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,735 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,735 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,735 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,735 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,735 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,735 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,735 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,735 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,736 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,736 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,738 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,738 INFO || Kafka startTimeMs: 1659609243736 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,750 INFO || Kafka cluster ID: KV0rawKYSeWt0oo0PE7lUw [org.apache.kafka.connect.util.ConnectUtils] 2022-08-04 10:34:03,751 INFO || App info kafka.admin.client for adminclient-3 unregistered [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,753 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2022-08-04 10:34:03,753 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2022-08-04 10:34:03,759 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2022-08-04 10:34:03,762 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,762 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,762 INFO || Kafka startTimeMs: 1659609243762 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,867 INFO || JsonConverterConfig values: converter.type = key decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false [org.apache.kafka.connect.json.JsonConverterConfig] 2022-08-04 10:34:03,868 INFO || JsonConverterConfig values: converter.type = value decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false [org.apache.kafka.connect.json.JsonConverterConfig] 2022-08-04 10:34:03,868 INFO || Creating Kafka admin client [org.apache.kafka.connect.util.ConnectUtils] 2022-08-04 10:34:03,869 INFO || AdminClientConfig values: bootstrap.servers = [kafka:9092] 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 = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,871 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,871 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,871 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,871 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,871 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,871 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,871 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,871 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,871 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,871 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,871 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,871 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,872 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,872 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,872 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,872 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,872 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,872 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,872 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,872 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,872 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,872 INFO || Kafka startTimeMs: 1659609243872 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,886 INFO || Kafka cluster ID: KV0rawKYSeWt0oo0PE7lUw [org.apache.kafka.connect.util.ConnectUtils] 2022-08-04 10:34:03,887 INFO || App info kafka.admin.client for adminclient-4 unregistered [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,888 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2022-08-04 10:34:03,888 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2022-08-04 10:34:03,888 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2022-08-04 10:34:03,897 INFO || Creating Kafka admin client [org.apache.kafka.connect.util.ConnectUtils] 2022-08-04 10:34:03,898 INFO || AdminClientConfig values: bootstrap.servers = [kafka:9092] 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 = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,900 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,900 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,900 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,900 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,900 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,900 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,900 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,900 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,900 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,900 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,900 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,900 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,900 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,900 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,900 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,900 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,900 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,900 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,900 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,901 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,901 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,901 INFO || Kafka startTimeMs: 1659609243900 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,908 INFO || Kafka cluster ID: KV0rawKYSeWt0oo0PE7lUw [org.apache.kafka.connect.util.ConnectUtils] 2022-08-04 10:34:03,908 INFO || App info kafka.admin.client for adminclient-5 unregistered [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,909 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2022-08-04 10:34:03,909 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2022-08-04 10:34:03,909 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2022-08-04 10:34:03,913 INFO || Creating Kafka admin client [org.apache.kafka.connect.util.ConnectUtils] 2022-08-04 10:34:03,914 INFO || AdminClientConfig values: bootstrap.servers = [kafka:9092] 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 = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,916 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,916 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,916 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,916 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,916 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,916 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,916 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,916 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,916 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,916 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,916 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,916 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,916 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,916 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,916 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,916 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,916 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,916 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,916 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,916 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,917 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,917 INFO || Kafka startTimeMs: 1659609243916 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,936 INFO || Kafka cluster ID: KV0rawKYSeWt0oo0PE7lUw [org.apache.kafka.connect.util.ConnectUtils] 2022-08-04 10:34:03,936 INFO || App info kafka.admin.client for adminclient-6 unregistered [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,938 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2022-08-04 10:34:03,938 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2022-08-04 10:34:03,938 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2022-08-04 10:34:03,962 INFO || Creating Kafka admin client [org.apache.kafka.connect.util.ConnectUtils] 2022-08-04 10:34:03,962 INFO || AdminClientConfig values: bootstrap.servers = [kafka:9092] 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 = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,964 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,964 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,964 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,964 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,964 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,964 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,964 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,964 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,964 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,964 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,964 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,964 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,964 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,964 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,964 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,964 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,964 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,964 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,964 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:03,964 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,964 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,964 INFO || Kafka startTimeMs: 1659609243964 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,977 INFO || Kafka cluster ID: KV0rawKYSeWt0oo0PE7lUw [org.apache.kafka.connect.util.ConnectUtils] 2022-08-04 10:34:03,978 INFO || App info kafka.admin.client for adminclient-7 unregistered [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,979 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2022-08-04 10:34:03,979 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2022-08-04 10:34:03,979 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2022-08-04 10:34:03,997 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,998 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:03,998 INFO || Kafka startTimeMs: 1659609243997 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:04,000 INFO || Kafka Connect distributed worker initialization took 6125ms [org.apache.kafka.connect.cli.ConnectDistributed] 2022-08-04 10:34:04,000 INFO || Kafka Connect starting [org.apache.kafka.connect.runtime.Connect] 2022-08-04 10:34:04,001 INFO || Initializing REST resources [org.apache.kafka.connect.runtime.rest.RestServer] 2022-08-04 10:34:04,002 INFO || [Worker clientId=connect-1, groupId=sde_group] Herder starting [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-08-04 10:34:04,002 INFO || Worker starting [org.apache.kafka.connect.runtime.Worker] 2022-08-04 10:34:04,002 INFO || Starting KafkaOffsetBackingStore [org.apache.kafka.connect.storage.KafkaOffsetBackingStore] 2022-08-04 10:34:04,004 INFO || Starting KafkaBasedLog with topic sde_offset_topic [org.apache.kafka.connect.util.KafkaBasedLog] 2022-08-04 10:34:04,012 INFO || AdminClientConfig values: bootstrap.servers = [kafka:9092] 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 = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:04,014 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:04,014 WARN || The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:04,014 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:04,014 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:04,014 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:04,014 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:04,014 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:04,014 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:04,014 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:04,014 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:04,014 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:04,014 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:04,015 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:04,015 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:04,015 WARN || The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:04,015 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:04,015 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:04,015 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:04,015 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:04,015 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:04,015 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 10:34:04,015 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:04,015 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:04,015 INFO || Kafka startTimeMs: 1659609244015 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:04,079 INFO || Adding admin resources to main listener [org.apache.kafka.connect.runtime.rest.RestServer] 2022-08-04 10:34:04,108 INFO || ProducerConfig values: acks = -1 batch.size = 16384 bootstrap.servers = [kafka:9092] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = producer-1 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.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,148 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,148 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,148 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,148 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,148 WARN || The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,148 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,148 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,148 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,148 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,148 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,148 WARN || The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,148 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,148 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,148 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,148 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,148 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,148 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,148 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,148 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,148 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,148 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,148 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:04,148 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:04,148 INFO || Kafka startTimeMs: 1659609244148 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:04,159 INFO || DefaultSessionIdManager workerName=node0 [org.eclipse.jetty.server.session] 2022-08-04 10:34:04,162 INFO || No SessionScavenger set, using defaults [org.eclipse.jetty.server.session] 2022-08-04 10:34:04,163 INFO || node0 Scavenging every 600000ms [org.eclipse.jetty.server.session] 2022-08-04 10:34:04,162 INFO || ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [kafka:9092] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = consumer-sde_group-1 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 = sde_group 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 = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 45000 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,175 INFO || [Producer clientId=producer-1] Cluster ID: KV0rawKYSeWt0oo0PE7lUw [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,206 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,206 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,206 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,206 WARN || The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,206 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,206 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,206 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,206 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,206 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,206 WARN || The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,206 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,206 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,206 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,206 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,206 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,206 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,206 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,206 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,206 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,206 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,206 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:04,206 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:04,206 INFO || Kafka startTimeMs: 1659609244206 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:04,222 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Cluster ID: KV0rawKYSeWt0oo0PE7lUw [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,240 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Subscribed to partition(s): sde_offset_topic-0, sde_offset_topic-5, sde_offset_topic-10, sde_offset_topic-20, sde_offset_topic-15, sde_offset_topic-9, sde_offset_topic-11, sde_offset_topic-16, sde_offset_topic-4, sde_offset_topic-17, sde_offset_topic-3, sde_offset_topic-24, sde_offset_topic-23, sde_offset_topic-13, sde_offset_topic-18, sde_offset_topic-22, sde_offset_topic-2, sde_offset_topic-8, sde_offset_topic-12, sde_offset_topic-19, sde_offset_topic-14, sde_offset_topic-1, sde_offset_topic-6, sde_offset_topic-7, sde_offset_topic-21 [org.apache.kafka.clients.consumer.KafkaConsumer] 2022-08-04 10:34:04,242 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Seeking to EARLIEST offset of partition sde_offset_topic-0 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,243 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Seeking to EARLIEST offset of partition sde_offset_topic-5 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,243 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Seeking to EARLIEST offset of partition sde_offset_topic-10 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,243 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Seeking to EARLIEST offset of partition sde_offset_topic-20 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,243 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Seeking to EARLIEST offset of partition sde_offset_topic-15 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,243 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Seeking to EARLIEST offset of partition sde_offset_topic-9 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,243 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Seeking to EARLIEST offset of partition sde_offset_topic-11 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,243 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Seeking to EARLIEST offset of partition sde_offset_topic-16 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,243 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Seeking to EARLIEST offset of partition sde_offset_topic-4 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,243 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Seeking to EARLIEST offset of partition sde_offset_topic-17 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,243 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Seeking to EARLIEST offset of partition sde_offset_topic-3 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,243 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Seeking to EARLIEST offset of partition sde_offset_topic-24 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,243 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Seeking to EARLIEST offset of partition sde_offset_topic-23 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,243 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Seeking to EARLIEST offset of partition sde_offset_topic-13 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,243 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Seeking to EARLIEST offset of partition sde_offset_topic-18 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,243 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Seeking to EARLIEST offset of partition sde_offset_topic-22 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,243 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Seeking to EARLIEST offset of partition sde_offset_topic-2 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,243 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Seeking to EARLIEST offset of partition sde_offset_topic-8 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,243 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Seeking to EARLIEST offset of partition sde_offset_topic-12 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,243 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Seeking to EARLIEST offset of partition sde_offset_topic-19 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,243 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Seeking to EARLIEST offset of partition sde_offset_topic-14 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,243 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Seeking to EARLIEST offset of partition sde_offset_topic-1 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,243 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Seeking to EARLIEST offset of partition sde_offset_topic-6 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,243 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Seeking to EARLIEST offset of partition sde_offset_topic-7 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,243 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Seeking to EARLIEST offset of partition sde_offset_topic-21 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,294 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-0 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,294 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-5 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,294 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-10 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,294 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-20 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,294 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-15 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,294 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-9 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,294 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-11 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,294 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-16 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,294 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-4 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,294 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-17 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,294 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-3 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,294 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-24 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,294 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-23 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,295 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-13 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,295 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-18 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,295 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-22 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,295 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-2 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,295 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-8 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,295 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-12 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,295 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-19 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,295 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-14 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,295 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-1 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,295 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-6 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,295 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-7 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,295 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-21 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,310 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting offset for partition sde_offset_topic-16 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.3:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,311 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting offset for partition sde_offset_topic-18 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.3:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,311 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting offset for partition sde_offset_topic-20 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.3:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,311 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting offset for partition sde_offset_topic-22 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.3:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,311 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting offset for partition sde_offset_topic-24 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.3:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,311 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting offset for partition sde_offset_topic-1 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.3:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,311 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting offset for partition sde_offset_topic-3 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.3:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,311 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting offset for partition sde_offset_topic-5 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.3:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,311 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting offset for partition sde_offset_topic-7 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.3:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,311 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting offset for partition sde_offset_topic-9 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.3:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,311 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting offset for partition sde_offset_topic-11 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.3:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,311 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting offset for partition sde_offset_topic-13 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.3:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,311 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting offset for partition sde_offset_topic-15 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.3:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,311 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting offset for partition sde_offset_topic-17 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.3:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,311 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting offset for partition sde_offset_topic-19 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.3:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,311 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting offset for partition sde_offset_topic-21 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.3:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,311 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting offset for partition sde_offset_topic-23 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.3:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,311 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting offset for partition sde_offset_topic-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.3:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,311 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting offset for partition sde_offset_topic-2 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.3:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,312 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting offset for partition sde_offset_topic-4 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.3:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,312 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting offset for partition sde_offset_topic-6 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.3:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,312 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting offset for partition sde_offset_topic-8 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.3:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,312 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting offset for partition sde_offset_topic-10 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.3:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,312 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting offset for partition sde_offset_topic-12 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.3:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,312 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Resetting offset for partition sde_offset_topic-14 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.3:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,320 INFO || Finished reading KafkaBasedLog for topic sde_offset_topic [org.apache.kafka.connect.util.KafkaBasedLog] 2022-08-04 10:34:04,320 INFO || Started KafkaBasedLog for topic sde_offset_topic [org.apache.kafka.connect.util.KafkaBasedLog] 2022-08-04 10:34:04,320 INFO || Finished reading offsets topic and starting KafkaOffsetBackingStore [org.apache.kafka.connect.storage.KafkaOffsetBackingStore] 2022-08-04 10:34:04,321 INFO || Worker started [org.apache.kafka.connect.runtime.Worker] 2022-08-04 10:34:04,321 INFO || Starting KafkaBasedLog with topic connect-status [org.apache.kafka.connect.util.KafkaBasedLog] 2022-08-04 10:34:04,337 INFO || ProducerConfig values: acks = -1 batch.size = 16384 bootstrap.servers = [kafka:9092] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = producer-2 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.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner 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 = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,339 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,339 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,339 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,339 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,339 WARN || The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,339 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,339 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,339 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,339 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,339 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,339 WARN || The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,339 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,339 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,339 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,339 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,339 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,339 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,339 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,339 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,339 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,339 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,339 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:04,339 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:04,339 INFO || Kafka startTimeMs: 1659609244339 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:04,340 INFO || ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [kafka:9092] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = consumer-sde_group-2 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 = sde_group group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true internal.throw.on.fetch.stable.offset.unsupported = false isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 45000 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,342 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,342 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,342 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,342 WARN || The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,342 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,342 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,342 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,342 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,342 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,342 WARN || The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,342 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,342 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,342 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,342 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,342 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,342 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,342 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,342 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,342 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,342 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,342 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:04,342 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:04,342 INFO || Kafka startTimeMs: 1659609244342 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:04,358 INFO || [Consumer clientId=consumer-sde_group-1, groupId=sde_group] Discovered group coordinator 172.17.0.3:9092 (id: 2147483646 rack: null) [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2022-08-04 10:34:04,365 INFO || [Consumer clientId=consumer-sde_group-2, groupId=sde_group] Cluster ID: KV0rawKYSeWt0oo0PE7lUw [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,365 INFO || [Consumer clientId=consumer-sde_group-2, groupId=sde_group] Subscribed to partition(s): connect-status-0, connect-status-4, connect-status-1, connect-status-2, connect-status-3 [org.apache.kafka.clients.consumer.KafkaConsumer] 2022-08-04 10:34:04,365 INFO || [Consumer clientId=consumer-sde_group-2, groupId=sde_group] Seeking to EARLIEST offset of partition connect-status-0 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,365 INFO || [Consumer clientId=consumer-sde_group-2, groupId=sde_group] Seeking to EARLIEST offset of partition connect-status-4 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,365 INFO || [Consumer clientId=consumer-sde_group-2, groupId=sde_group] Seeking to EARLIEST offset of partition connect-status-1 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,365 INFO || [Consumer clientId=consumer-sde_group-2, groupId=sde_group] Seeking to EARLIEST offset of partition connect-status-2 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,365 INFO || [Consumer clientId=consumer-sde_group-2, groupId=sde_group] Seeking to EARLIEST offset of partition connect-status-3 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,366 INFO || [Producer clientId=producer-2] Cluster ID: KV0rawKYSeWt0oo0PE7lUw [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,395 INFO || [Consumer clientId=consumer-sde_group-2, groupId=sde_group] Resetting the last seen epoch of partition connect-status-0 to 0 since the associated topicId changed from null to mGA0qKrMQT26MtJ51zxxJQ [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,395 INFO || [Consumer clientId=consumer-sde_group-2, groupId=sde_group] Resetting the last seen epoch of partition connect-status-4 to 0 since the associated topicId changed from null to mGA0qKrMQT26MtJ51zxxJQ [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,395 INFO || [Consumer clientId=consumer-sde_group-2, groupId=sde_group] Resetting the last seen epoch of partition connect-status-1 to 0 since the associated topicId changed from null to mGA0qKrMQT26MtJ51zxxJQ [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,395 INFO || [Consumer clientId=consumer-sde_group-2, groupId=sde_group] Resetting the last seen epoch of partition connect-status-2 to 0 since the associated topicId changed from null to mGA0qKrMQT26MtJ51zxxJQ [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,395 INFO || [Consumer clientId=consumer-sde_group-2, groupId=sde_group] Resetting the last seen epoch of partition connect-status-3 to 0 since the associated topicId changed from null to mGA0qKrMQT26MtJ51zxxJQ [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,400 INFO || [Consumer clientId=consumer-sde_group-2, groupId=sde_group] Resetting offset for partition connect-status-1 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.3:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,400 INFO || [Consumer clientId=consumer-sde_group-2, groupId=sde_group] Resetting offset for partition connect-status-2 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.3:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,400 INFO || [Consumer clientId=consumer-sde_group-2, groupId=sde_group] Resetting offset for partition connect-status-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.3:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,400 INFO || [Consumer clientId=consumer-sde_group-2, groupId=sde_group] Resetting offset for partition connect-status-3 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.3:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,400 INFO || [Consumer clientId=consumer-sde_group-2, groupId=sde_group] Resetting offset for partition connect-status-4 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.3:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,401 INFO || Finished reading KafkaBasedLog for topic connect-status [org.apache.kafka.connect.util.KafkaBasedLog] 2022-08-04 10:34:04,401 INFO || Started KafkaBasedLog for topic connect-status [org.apache.kafka.connect.util.KafkaBasedLog] 2022-08-04 10:34:04,407 INFO || Starting KafkaConfigBackingStore [org.apache.kafka.connect.storage.KafkaConfigBackingStore] 2022-08-04 10:34:04,407 INFO || Starting KafkaBasedLog with topic sde_storage_topic [org.apache.kafka.connect.util.KafkaBasedLog] 2022-08-04 10:34:04,434 INFO || ProducerConfig values: acks = -1 batch.size = 16384 bootstrap.servers = [kafka:9092] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = producer-3 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.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,455 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,455 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,455 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,455 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,455 WARN || The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,455 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,455 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,455 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,455 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,455 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,455 WARN || The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,455 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,455 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,455 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,455 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,455 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,455 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,455 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,455 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,455 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,455 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 10:34:04,455 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:04,455 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:04,455 INFO || Kafka startTimeMs: 1659609244455 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:04,456 INFO || ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [kafka:9092] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = consumer-sde_group-3 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 = sde_group group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true internal.throw.on.fetch.stable.offset.unsupported = false isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 45000 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,460 INFO || [Consumer clientId=consumer-sde_group-2, groupId=sde_group] Discovered group coordinator 172.17.0.3:9092 (id: 2147483646 rack: null) [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2022-08-04 10:34:04,465 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,467 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,467 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,469 WARN || The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,469 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,469 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,469 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,469 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,469 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,469 WARN || The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,469 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,469 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,469 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,469 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,469 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,469 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,469 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,470 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,470 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,470 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 10:34:04,470 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:04,470 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:04,470 INFO || Kafka startTimeMs: 1659609244470 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 10:34:04,473 INFO || [Producer clientId=producer-3] Cluster ID: KV0rawKYSeWt0oo0PE7lUw [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,478 INFO || [Consumer clientId=consumer-sde_group-3, groupId=sde_group] Cluster ID: KV0rawKYSeWt0oo0PE7lUw [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,479 INFO || [Consumer clientId=consumer-sde_group-3, groupId=sde_group] Subscribed to partition(s): sde_storage_topic-0 [org.apache.kafka.clients.consumer.KafkaConsumer] 2022-08-04 10:34:04,479 INFO || [Consumer clientId=consumer-sde_group-3, groupId=sde_group] Seeking to EARLIEST offset of partition sde_storage_topic-0 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,499 INFO || [Consumer clientId=consumer-sde_group-3, groupId=sde_group] Resetting the last seen epoch of partition sde_storage_topic-0 to 0 since the associated topicId changed from null to MPWrR_4GRyarOEMudtxHrw [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,502 INFO || [Consumer clientId=consumer-sde_group-3, groupId=sde_group] Resetting offset for partition sde_storage_topic-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.3:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 10:34:04,508 INFO || [Consumer clientId=consumer-sde_group-3, groupId=sde_group] Discovered group coordinator 172.17.0.3:9092 (id: 2147483646 rack: null) [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2022-08-04 10:34:04,586 INFO || Finished reading KafkaBasedLog for topic sde_storage_topic [org.apache.kafka.connect.util.KafkaBasedLog] 2022-08-04 10:34:04,586 INFO || Started KafkaBasedLog for topic sde_storage_topic [org.apache.kafka.connect.util.KafkaBasedLog] 2022-08-04 10:34:04,586 INFO || Started KafkaConfigBackingStore [org.apache.kafka.connect.storage.KafkaConfigBackingStore] 2022-08-04 10:34:04,587 INFO || [Worker clientId=connect-1, groupId=sde_group] Herder started [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-08-04 10:34:04,602 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-0 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,602 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-5 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,602 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-10 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,602 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-20 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,602 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-15 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-9 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-11 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-16 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-4 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-17 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-3 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-24 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-23 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-13 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-18 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-22 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-2 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-8 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-12 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-19 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-14 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-1 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-6 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-7 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition sde_offset_topic-21 to 0 since the associated topicId changed from null to docXZFhqTF-g4Hafvzbv1g [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition connect-status-0 to 0 since the associated topicId changed from null to mGA0qKrMQT26MtJ51zxxJQ [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition connect-status-4 to 0 since the associated topicId changed from null to mGA0qKrMQT26MtJ51zxxJQ [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition connect-status-1 to 0 since the associated topicId changed from null to mGA0qKrMQT26MtJ51zxxJQ [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition connect-status-2 to 0 since the associated topicId changed from null to mGA0qKrMQT26MtJ51zxxJQ [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition connect-status-3 to 0 since the associated topicId changed from null to mGA0qKrMQT26MtJ51zxxJQ [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition sde_storage_topic-0 to 0 since the associated topicId changed from null to MPWrR_4GRyarOEMudtxHrw [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-0 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-10 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-20 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-40 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-30 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-9 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-11 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-31 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-39 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-13 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-18 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-22 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-8 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-32 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-43 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-29 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-34 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-1 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-6 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-41 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-27 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-48 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-5 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-15 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-35 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-25 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-46 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,603 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-26 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,604 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-36 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,604 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-44 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,604 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-16 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,604 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-37 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,604 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-17 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,604 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-45 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,604 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-3 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,604 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-24 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,604 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-38 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,604 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-33 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,604 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-23 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,604 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-28 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,604 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-2 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,604 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-12 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,604 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-19 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,604 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-14 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,604 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-4 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,604 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-47 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,604 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-49 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,604 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-42 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,604 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-7 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,604 INFO || [Worker clientId=connect-1, groupId=sde_group] Resetting the last seen epoch of partition __consumer_offsets-21 to 0 since the associated topicId changed from null to QxsK0TSWQOWOevCnl9Qg8A [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,607 INFO || [Worker clientId=connect-1, groupId=sde_group] Cluster ID: KV0rawKYSeWt0oo0PE7lUw [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,608 INFO || [Worker clientId=connect-1, groupId=sde_group] Discovered group coordinator 172.17.0.3:9092 (id: 2147483646 rack: null) [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-08-04 10:34:04,615 INFO || [Worker clientId=connect-1, groupId=sde_group] Rebalance started [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-08-04 10:34:04,615 INFO || [Worker clientId=connect-1, groupId=sde_group] (Re-)joining group [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-08-04 10:34:04,636 INFO || [Worker clientId=connect-1, groupId=sde_group] (Re-)joining group [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-08-04 10:34:04,642 INFO || [Worker clientId=connect-1, groupId=sde_group] Successfully joined group with generation Generation{generationId=1, memberId='connect-1-64ff087a-df35-4599-b3c0-5b0d4c0fc302', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-08-04 10:34:04,673 INFO || [Worker clientId=connect-1, groupId=sde_group] Successfully synced group in generation Generation{generationId=1, memberId='connect-1-64ff087a-df35-4599-b3c0-5b0d4c0fc302', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-08-04 10:34:04,673 INFO || [Worker clientId=connect-1, groupId=sde_group] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-64ff087a-df35-4599-b3c0-5b0d4c0fc302', leaderUrl='http://172.17.0.4:8083/', offset=43, connectorIds=[], taskIds=[], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-08-04 10:34:04,674 WARN || [Worker clientId=connect-1, groupId=sde_group] Catching up to assignment's config offset. [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-08-04 10:34:04,674 INFO || [Worker clientId=connect-1, groupId=sde_group] Current config state offset -1 is behind group assignment 43, reading to end of config log [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-08-04 10:34:04,707 INFO || [Worker clientId=connect-1, groupId=sde_group] Finished reading to end of log and updated config snapshot, new config log offset: 43 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-08-04 10:34:04,707 INFO || [Worker clientId=connect-1, groupId=sde_group] Starting connectors and tasks using config offset 43 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-08-04 10:34:04,707 INFO || [Worker clientId=connect-1, groupId=sde_group] Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-08-04 10:34:04,734 INFO || [Producer clientId=producer-3] Resetting the last seen epoch of partition sde_storage_topic-0 to 0 since the associated topicId changed from null to MPWrR_4GRyarOEMudtxHrw [org.apache.kafka.clients.Metadata] 2022-08-04 10:34:04,771 INFO || [Worker clientId=connect-1, groupId=sde_group] Session key updated [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-08-04 10:34:04,882 INFO || Started o.e.j.s.ServletContextHandler@2c48cede{/,null,AVAILABLE} [org.eclipse.jetty.server.handler.ContextHandler] 2022-08-04 10:34:04,882 INFO || REST resources initialized; server is started and ready to handle requests [org.apache.kafka.connect.runtime.rest.RestServer] 2022-08-04 10:34:04,882 INFO || Kafka Connect started [org.apache.kafka.connect.runtime.Connect] 2022-08-04 10:35:17,494 WARN || Configuration property 'truncate.handling.mode' is deprecated and will be removed in future versions. Please use 'skipped.operations' instead. [io.debezium.connector.postgresql.PostgresConnectorConfig] 2022-08-04 10:35:17,496 WARN || Configuration property 'toasted.value.placeholder' is deprecated and will be removed in future versions. Please use 'unavailable.value.placeholder' instead. [io.debezium.connector.postgresql.PostgresConnectorConfig] 2022-08-04 10:35:17,612 INFO || Successfully tested connection for jdbc:postgresql://10.126.86.10:5432/novounifodb with user 'postgres' [io.debezium.connector.postgresql.PostgresConnector] 2022-08-04 10:35:17,617 ERROR || Postgres server wal_level property must be "logical" but is: minimal [io.debezium.connector.postgresql.PostgresConnector] 2022-08-04 10:35:17,634 ERROR || Failed testing connection for jdbc:postgresql://10.126.86.10:5432/novounifodb with user 'postgres' [io.debezium.connector.postgresql.PostgresConnector] org.postgresql.util.PSQLException: ERROR: function array_position(name[], unknown) does not exist Hint: No function matches the given name and argument types. You might need to add explicit type casts. Position: 79 at org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2675) at org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:2365) at org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:355) at org.postgresql.jdbc.PgStatement.executeInternal(PgStatement.java:490) at org.postgresql.jdbc.PgStatement.execute(PgStatement.java:408) at org.postgresql.jdbc.PgStatement.executeWithFlags(PgStatement.java:329) at org.postgresql.jdbc.PgStatement.executeCachedSql(PgStatement.java:315) at org.postgresql.jdbc.PgStatement.executeWithFlags(PgStatement.java:291) at org.postgresql.jdbc.PgStatement.executeQuery(PgStatement.java:243) at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:635) at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:504) at io.debezium.connector.postgresql.PostgresConnector.validateConnection(PostgresConnector.java:105) at io.debezium.connector.common.RelationalBaseSourceConnector.validate(RelationalBaseSourceConnector.java:54) at org.apache.kafka.connect.runtime.AbstractHerder.validateConnectorConfig(AbstractHerder.java:471) at org.apache.kafka.connect.runtime.AbstractHerder.lambda$validateConnectorConfig$2(AbstractHerder.java:367) 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) 2022-08-04 10:35:17,637 INFO || Connection gracefully closed [io.debezium.jdbc.JdbcConnection] 2022-08-04 10:35:17,639 INFO || AbstractConfig values: [org.apache.kafka.common.config.AbstractConfig]