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=sonae_group CONFIG_STORAGE_TOPIC=sonae_storage_topic OFFSET_STORAGE_TOPIC=sonae_offset_topic BOOTSTRAP_SERVERS=kafka:9092 REST_HOST_NAME=172.17.0.5 REST_PORT=8083 ADVERTISED_HOST_NAME=172.17.0.5 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=sonae_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=sonae_storage_topic --- Setting property from CONNECT_GROUP_ID: group.id=sonae_group --- Setting property from CONNECT_REST_ADVERTISED_HOST_NAME: rest.advertised.host.name=172.17.0.5 --- Setting property from CONNECT_REST_HOST_NAME: rest.host.name=172.17.0.5 --- 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 15:34:19,099 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, 5.10.16.3-microsoft-standard-WSL2 os.vcpus = 4 [org.apache.kafka.connect.runtime.WorkerInfo] 2022-08-04 15:34:19,109 INFO || Scanning for plugin classes. This might take a moment ... [org.apache.kafka.connect.cli.ConnectDistributed] 2022-08-04 15:34:19,146 INFO || Loading plugin from: /kafka/connect/debezium-connector-postgres [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:20,757 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-postgres/} [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:20,758 INFO || Added plugin 'io.debezium.connector.postgresql.PostgresConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:20,758 INFO || Added plugin 'io.debezium.converters.ByteArrayConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:20,759 INFO || Added plugin 'io.debezium.converters.ByteBufferConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:20,759 INFO || Added plugin 'io.debezium.converters.BinaryDataConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:20,759 INFO || Added plugin 'io.debezium.converters.CloudEventsConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:20,759 INFO || Added plugin 'io.debezium.transforms.outbox.EventRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:20,759 INFO || Added plugin 'io.debezium.transforms.ExtractNewRecordState' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:20,760 INFO || Added plugin 'io.debezium.transforms.ByLogicalTableRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:20,760 INFO || Added plugin 'io.debezium.transforms.tracing.ActivateTracingSpan' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:20,760 INFO || Added plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:20,760 INFO || Added plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:20,761 INFO || Added plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:20,779 INFO || Loading plugin from: /kafka/connect/debezium-connector-oracle [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:22,844 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-oracle/} [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:22,844 INFO || Added plugin 'io.debezium.connector.oracle.OracleConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:22,852 INFO || Loading plugin from: /kafka/connect/debezium-connector-vitess [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:24,121 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-vitess/} [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:24,121 INFO || Added plugin 'io.debezium.connector.vitess.VitessConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:24,125 INFO || Loading plugin from: /kafka/connect/debezium-connector-mongodb [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:24,974 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-mongodb/} [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:24,974 INFO || Added plugin 'io.debezium.connector.mongodb.MongoDbConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:24,974 INFO || Added plugin 'io.debezium.connector.mongodb.transforms.outbox.MongoEventRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:24,974 INFO || Added plugin 'io.debezium.connector.mongodb.transforms.ExtractNewDocumentState' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:24,975 INFO || Loading plugin from: /kafka/connect/debezium-connector-sqlserver [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:26,386 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-sqlserver/} [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:26,390 INFO || Added plugin 'io.debezium.connector.sqlserver.SqlServerConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:26,521 INFO || Loading plugin from: /kafka/connect/debezium-connector-db2 [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:26,848 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-db2/} [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:26,848 INFO || Added plugin 'io.debezium.connector.db2.Db2Connector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:26,853 INFO || Loading plugin from: /kafka/connect/debezium-connector-mysql [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:27,356 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-mysql/} [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:27,356 INFO || Added plugin 'io.debezium.connector.mysql.MySqlConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:27,356 INFO || Added plugin 'io.debezium.connector.mysql.transforms.ReadToInsertEvent' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,196 INFO || Registered loader: jdk.internal.loader.ClassLoaders$AppClassLoader@3d4eac69 [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,196 INFO || Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,197 INFO || Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,197 INFO || Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,198 INFO || Added plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,198 INFO || Added plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,198 INFO || Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,198 INFO || Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,198 INFO || Added plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,199 INFO || Added plugin 'org.apache.kafka.connect.converters.FloatConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,199 INFO || Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,199 INFO || Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,199 INFO || Added plugin 'io.confluent.connect.avro.AvroConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,200 INFO || Added plugin 'org.apache.kafka.connect.converters.LongConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,200 INFO || Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,200 INFO || Added plugin 'org.apache.kafka.connect.json.JsonConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,211 INFO || Added plugin 'org.apache.kafka.connect.storage.StringConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,212 INFO || Added plugin 'org.apache.kafka.connect.converters.ShortConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,212 INFO || Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,212 INFO || Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,212 INFO || Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,213 INFO || Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,213 INFO || Added plugin 'org.apache.kafka.connect.transforms.Filter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,213 INFO || Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,213 INFO || Added plugin 'org.apache.kafka.connect.transforms.HeaderFrom$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,213 INFO || Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,213 INFO || Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,213 INFO || Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,214 INFO || Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,214 INFO || Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,214 INFO || Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,214 INFO || Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,214 INFO || Added plugin 'org.apache.kafka.connect.transforms.DropHeaders' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,214 INFO || Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,214 INFO || Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,215 INFO || Added plugin 'org.apache.kafka.connect.runtime.PredicatedTransformation' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,215 INFO || Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,215 INFO || Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,215 INFO || Added plugin 'org.apache.kafka.connect.transforms.InsertHeader' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,216 INFO || Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,216 INFO || Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,216 INFO || Added plugin 'org.apache.kafka.connect.transforms.HeaderFrom$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,216 INFO || Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,216 INFO || Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,216 INFO || Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,216 INFO || Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,228 INFO || Added plugin 'org.apache.kafka.connect.transforms.predicates.HasHeaderKey' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,228 INFO || Added plugin 'org.apache.kafka.connect.transforms.predicates.RecordIsTombstone' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,228 INFO || Added plugin 'org.apache.kafka.connect.transforms.predicates.TopicNameMatches' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,228 INFO || Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,228 INFO || Added plugin 'org.apache.kafka.common.config.provider.DirectoryConfigProvider' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,229 INFO || Added plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,230 INFO || Added aliases 'Db2Connector' and 'Db2' to plugin 'io.debezium.connector.db2.Db2Connector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,230 INFO || Added aliases 'MongoDbConnector' and 'MongoDb' to plugin 'io.debezium.connector.mongodb.MongoDbConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,230 INFO || Added aliases 'MySqlConnector' and 'MySql' to plugin 'io.debezium.connector.mysql.MySqlConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,231 INFO || Added aliases 'OracleConnector' and 'Oracle' to plugin 'io.debezium.connector.oracle.OracleConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,231 INFO || Added aliases 'PostgresConnector' and 'Postgres' to plugin 'io.debezium.connector.postgresql.PostgresConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,232 INFO || Added aliases 'SqlServerConnector' and 'SqlServer' to plugin 'io.debezium.connector.sqlserver.SqlServerConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,232 INFO || Added aliases 'VitessConnector' and 'Vitess' to plugin 'io.debezium.connector.vitess.VitessConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,232 INFO || Added aliases 'MirrorCheckpointConnector' and 'MirrorCheckpoint' to plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,244 INFO || Added aliases 'MirrorHeartbeatConnector' and 'MirrorHeartbeat' to plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,245 INFO || Added aliases 'MirrorSourceConnector' and 'MirrorSource' to plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,247 INFO || Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,247 INFO || Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,248 INFO || Added aliases 'SchemaSourceConnector' and 'SchemaSource' to plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,248 INFO || Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,248 INFO || Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,260 INFO || Added aliases 'AvroConverter' and 'Avro' to plugin 'io.confluent.connect.avro.AvroConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,260 INFO || Added aliases 'BinaryDataConverter' and 'BinaryData' to plugin 'io.debezium.converters.BinaryDataConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,261 INFO || Added aliases 'ByteBufferConverter' and 'ByteBuffer' to plugin 'io.debezium.converters.ByteBufferConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,261 INFO || Added aliases 'CloudEventsConverter' and 'CloudEvents' to plugin 'io.debezium.converters.CloudEventsConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,261 INFO || Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,262 INFO || Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,262 INFO || Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,262 INFO || Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,263 INFO || Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,263 INFO || Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,263 INFO || Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,264 INFO || Added aliases 'BinaryDataConverter' and 'BinaryData' to plugin 'io.debezium.converters.BinaryDataConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,264 INFO || Added aliases 'ByteBufferConverter' and 'ByteBuffer' to plugin 'io.debezium.converters.ByteBufferConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,264 INFO || Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,265 INFO || Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,276 INFO || Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,276 INFO || Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,277 INFO || Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,277 INFO || Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,277 INFO || Added aliases 'SimpleHeaderConverter' and 'Simple' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,278 INFO || Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,278 INFO || Added alias 'ExtractNewDocumentState' to plugin 'io.debezium.connector.mongodb.transforms.ExtractNewDocumentState' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,278 INFO || Added alias 'MongoEventRouter' to plugin 'io.debezium.connector.mongodb.transforms.outbox.MongoEventRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,279 INFO || Added alias 'ReadToInsertEvent' to plugin 'io.debezium.connector.mysql.transforms.ReadToInsertEvent' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,279 INFO || Added alias 'ByLogicalTableRouter' to plugin 'io.debezium.transforms.ByLogicalTableRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,280 INFO || Added alias 'ExtractNewRecordState' to plugin 'io.debezium.transforms.ExtractNewRecordState' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,280 INFO || Added alias 'EventRouter' to plugin 'io.debezium.transforms.outbox.EventRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,280 INFO || Added alias 'ActivateTracingSpan' to plugin 'io.debezium.transforms.tracing.ActivateTracingSpan' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,281 INFO || Added aliases 'PredicatedTransformation' and 'Predicated' to plugin 'org.apache.kafka.connect.runtime.PredicatedTransformation' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,292 INFO || Added alias 'DropHeaders' to plugin 'org.apache.kafka.connect.transforms.DropHeaders' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,292 INFO || Added alias 'Filter' to plugin 'org.apache.kafka.connect.transforms.Filter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,292 INFO || Added alias 'InsertHeader' to plugin 'org.apache.kafka.connect.transforms.InsertHeader' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,293 INFO || Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,293 INFO || Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,293 INFO || Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,293 INFO || Added alias 'HasHeaderKey' to plugin 'org.apache.kafka.connect.transforms.predicates.HasHeaderKey' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,293 INFO || Added alias 'RecordIsTombstone' to plugin 'org.apache.kafka.connect.transforms.predicates.RecordIsTombstone' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,294 INFO || Added alias 'TopicNameMatches' to plugin 'org.apache.kafka.connect.transforms.predicates.TopicNameMatches' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-08-04 15:34:30,294 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 15:34:30,294 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 15:34:30,294 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 15:34:30,294 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 15:34:30,572 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 = sonae_storage_topic connect.protocol = sessioned connections.max.idle.ms = 540000 connector.client.config.override.policy = All group.id = sonae_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 = sonae_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.5 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 15:34:30,587 INFO || Creating Kafka admin client [org.apache.kafka.connect.util.ConnectUtils] 2022-08-04 15:34:30,617 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 15:34:30,850 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:30,853 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:30,854 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:30,854 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:30,854 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:30,854 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:30,854 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 15:34:30,855 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:30,855 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:30,855 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:30,855 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:30,855 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:30,855 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:30,855 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:30,855 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:30,855 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:30,856 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:30,856 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:30,856 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:30,857 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:30,857 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:30,857 INFO || Kafka startTimeMs: 1659627270856 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:31,667 INFO || Kafka cluster ID: KsVZckQ1RrSWFK7OfxqSvQ [org.apache.kafka.connect.util.ConnectUtils] 2022-08-04 15:34:31,669 INFO || App info kafka.admin.client for adminclient-1 unregistered [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:31,737 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2022-08-04 15:34:31,738 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2022-08-04 15:34:31,741 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2022-08-04 15:34:31,854 INFO || Logging initialized @14008ms to org.eclipse.jetty.util.log.Slf4jLog [org.eclipse.jetty.util.log] 2022-08-04 15:34:32,058 INFO || Added connector for http://:8083 [org.apache.kafka.connect.runtime.rest.RestServer] 2022-08-04 15:34:32,059 INFO || Initializing REST server [org.apache.kafka.connect.runtime.rest.RestServer] 2022-08-04 15:34:32,085 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 15:34:32,194 INFO || Started http_8083@5190010f{HTTP/1.1, (http/1.1)}{0.0.0.0:8083} [org.eclipse.jetty.server.AbstractConnector] 2022-08-04 15:34:32,194 INFO || Started @14349ms [org.eclipse.jetty.server.Server] 2022-08-04 15:34:32,262 INFO || Advertised URI: http://172.17.0.5:8083/ [org.apache.kafka.connect.runtime.rest.RestServer] 2022-08-04 15:34:32,264 INFO || REST server listening at http://172.17.0.5:8083/, advertising URL http://172.17.0.5:8083/ [org.apache.kafka.connect.runtime.rest.RestServer] 2022-08-04 15:34:32,265 INFO || Advertised URI: http://172.17.0.5:8083/ [org.apache.kafka.connect.runtime.rest.RestServer] 2022-08-04 15:34:32,265 INFO || REST admin endpoints at http://172.17.0.5:8083/ [org.apache.kafka.connect.runtime.rest.RestServer] 2022-08-04 15:34:32,265 INFO || Advertised URI: http://172.17.0.5:8083/ [org.apache.kafka.connect.runtime.rest.RestServer] 2022-08-04 15:34:32,274 INFO || Creating Kafka admin client [org.apache.kafka.connect.util.ConnectUtils] 2022-08-04 15:34:32,277 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 15:34:32,306 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,307 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,307 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,307 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,307 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,307 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,307 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 15:34:32,307 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,308 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,308 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,308 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,308 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,308 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,308 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,308 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,308 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,308 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,309 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,309 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,309 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:32,309 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:32,309 INFO || Kafka startTimeMs: 1659627272309 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:32,373 INFO || Kafka cluster ID: KsVZckQ1RrSWFK7OfxqSvQ [org.apache.kafka.connect.util.ConnectUtils] 2022-08-04 15:34:32,374 INFO || App info kafka.admin.client for adminclient-2 unregistered [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:32,394 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2022-08-04 15:34:32,395 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2022-08-04 15:34:32,395 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2022-08-04 15:34:32,425 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 15:34:32,473 INFO || Creating Kafka admin client [org.apache.kafka.connect.util.ConnectUtils] 2022-08-04 15:34:32,474 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 15:34:32,490 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,491 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,491 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,491 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,491 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,491 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,491 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 15:34:32,503 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,503 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,503 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,503 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,503 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,503 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,503 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,503 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,504 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,504 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,504 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,504 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,504 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:32,504 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:32,504 INFO || Kafka startTimeMs: 1659627272504 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:32,562 INFO || Kafka cluster ID: KsVZckQ1RrSWFK7OfxqSvQ [org.apache.kafka.connect.util.ConnectUtils] 2022-08-04 15:34:32,567 INFO || App info kafka.admin.client for adminclient-3 unregistered [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:32,579 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2022-08-04 15:34:32,579 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2022-08-04 15:34:32,579 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2022-08-04 15:34:32,602 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:32,602 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:32,602 INFO || Kafka startTimeMs: 1659627272602 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:32,883 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 15:34:32,894 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 15:34:32,894 INFO || Creating Kafka admin client [org.apache.kafka.connect.util.ConnectUtils] 2022-08-04 15:34:32,895 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 15:34:32,909 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,909 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,909 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,911 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,912 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,912 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,912 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 15:34:32,914 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,915 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,915 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,915 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,915 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,915 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,915 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,915 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,915 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,915 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,915 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,915 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:32,916 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:32,916 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:32,916 INFO || Kafka startTimeMs: 1659627272915 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:32,970 INFO || Kafka cluster ID: KsVZckQ1RrSWFK7OfxqSvQ [org.apache.kafka.connect.util.ConnectUtils] 2022-08-04 15:34:32,972 INFO || App info kafka.admin.client for adminclient-4 unregistered [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:32,980 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2022-08-04 15:34:32,981 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2022-08-04 15:34:32,982 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2022-08-04 15:34:33,025 INFO || Creating Kafka admin client [org.apache.kafka.connect.util.ConnectUtils] 2022-08-04 15:34:33,026 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 15:34:33,058 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,059 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,059 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,059 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,059 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,059 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,059 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 15:34:33,060 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,060 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,060 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,060 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,060 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,060 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,060 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,060 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,060 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,060 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,060 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,060 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,060 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:33,061 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:33,061 INFO || Kafka startTimeMs: 1659627273060 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:33,124 INFO || Kafka cluster ID: KsVZckQ1RrSWFK7OfxqSvQ [org.apache.kafka.connect.util.ConnectUtils] 2022-08-04 15:34:33,126 INFO || App info kafka.admin.client for adminclient-5 unregistered [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:33,142 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2022-08-04 15:34:33,143 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2022-08-04 15:34:33,143 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2022-08-04 15:34:33,165 INFO || Creating Kafka admin client [org.apache.kafka.connect.util.ConnectUtils] 2022-08-04 15:34:33,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 15:34:33,213 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,214 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,214 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,214 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,215 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,215 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,215 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 15:34:33,215 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,215 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,216 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,216 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,216 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,216 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,216 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,216 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,216 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,216 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,216 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,217 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,217 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:33,217 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:33,217 INFO || Kafka startTimeMs: 1659627273217 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:33,258 INFO || Kafka cluster ID: KsVZckQ1RrSWFK7OfxqSvQ [org.apache.kafka.connect.util.ConnectUtils] 2022-08-04 15:34:33,259 INFO || App info kafka.admin.client for adminclient-6 unregistered [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:33,264 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2022-08-04 15:34:33,278 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2022-08-04 15:34:33,279 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2022-08-04 15:34:33,330 INFO || Creating Kafka admin client [org.apache.kafka.connect.util.ConnectUtils] 2022-08-04 15:34:33,336 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 15:34:33,341 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,341 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,341 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,341 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,341 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,341 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,341 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 15:34:33,341 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,341 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,341 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,341 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,341 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,341 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,342 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,342 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,342 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,342 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,342 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,342 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,352 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:33,352 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:33,352 INFO || Kafka startTimeMs: 1659627273352 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:33,395 INFO || Kafka cluster ID: KsVZckQ1RrSWFK7OfxqSvQ [org.apache.kafka.connect.util.ConnectUtils] 2022-08-04 15:34:33,396 INFO || App info kafka.admin.client for adminclient-7 unregistered [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:33,400 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2022-08-04 15:34:33,400 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2022-08-04 15:34:33,400 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2022-08-04 15:34:33,529 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:33,529 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:33,529 INFO || Kafka startTimeMs: 1659627273529 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:33,535 INFO || Kafka Connect distributed worker initialization took 14426ms [org.apache.kafka.connect.cli.ConnectDistributed] 2022-08-04 15:34:33,536 INFO || Kafka Connect starting [org.apache.kafka.connect.runtime.Connect] 2022-08-04 15:34:33,547 INFO || Initializing REST resources [org.apache.kafka.connect.runtime.rest.RestServer] 2022-08-04 15:34:33,548 INFO || [Worker clientId=connect-1, groupId=sonae_group] Herder starting [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-08-04 15:34:33,552 INFO || Worker starting [org.apache.kafka.connect.runtime.Worker] 2022-08-04 15:34:33,552 INFO || Starting KafkaOffsetBackingStore [org.apache.kafka.connect.storage.KafkaOffsetBackingStore] 2022-08-04 15:34:33,552 INFO || Starting KafkaBasedLog with topic sonae_offset_topic [org.apache.kafka.connect.util.KafkaBasedLog] 2022-08-04 15:34:33,554 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 15:34:33,587 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,587 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 15:34:33,587 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,587 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,587 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,587 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,588 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,588 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 15:34:33,588 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,588 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,588 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,588 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,588 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,588 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,588 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 15:34:33,589 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,589 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,589 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,589 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,589 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,589 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-08-04 15:34:33,589 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:33,589 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:33,589 INFO || Kafka startTimeMs: 1659627273589 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:33,739 INFO || Adding admin resources to main listener [org.apache.kafka.connect.runtime.rest.RestServer] 2022-08-04 15:34:33,920 INFO || DefaultSessionIdManager workerName=node0 [org.eclipse.jetty.server.session] 2022-08-04 15:34:33,928 INFO || No SessionScavenger set, using defaults [org.eclipse.jetty.server.session] 2022-08-04 15:34:33,933 INFO || node0 Scavenging every 600000ms [org.eclipse.jetty.server.session] Aug 04, 2022 3:34:34 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.RootResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.RootResource will be ignored. Aug 04, 2022 3:34:34 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource will be ignored. Aug 04, 2022 3:34:34 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource will be ignored. Aug 04, 2022 3:34:34 PM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.LoggingResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.LoggingResource will be ignored. Aug 04, 2022 3:34:35 PM org.glassfish.jersey.internal.Errors logErrors WARNING: The following warnings have been detected: WARNING: The (sub)resource method listLoggers in org.apache.kafka.connect.runtime.rest.resources.LoggingResource contains empty path annotation. WARNING: The (sub)resource method createConnector in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation. WARNING: The (sub)resource method listConnectors in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation. WARNING: The (sub)resource method listConnectorPlugins in org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource contains empty path annotation. WARNING: The (sub)resource method serverInfo in org.apache.kafka.connect.runtime.rest.resources.RootResource contains empty path annotation. 2022-08-04 15:34:35,691 INFO || Started o.e.j.s.ServletContextHandler@a91119b{/,null,AVAILABLE} [org.eclipse.jetty.server.handler.ContextHandler] 2022-08-04 15:34:35,692 INFO || REST resources initialized; server is started and ready to handle requests [org.apache.kafka.connect.runtime.rest.RestServer] 2022-08-04 15:34:35,692 INFO || Kafka Connect started [org.apache.kafka.connect.runtime.Connect] 2022-08-04 15:34:37,476 INFO || Created topic (name=sonae_offset_topic, numPartitions=25, replicationFactor=1, replicasAssignments=null, configs={cleanup.policy=compact}) on brokers at kafka:9092 [org.apache.kafka.connect.util.TopicAdmin] 2022-08-04 15:34:37,490 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 15:34:37,587 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:37,587 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:37,587 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 15:34:37,587 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:37,588 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 15:34:37,588 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:37,588 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:37,588 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:37,588 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:37,588 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:37,588 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 15:34:37,588 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:37,588 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:37,588 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:37,588 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:37,588 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:37,588 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:37,588 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:37,588 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:37,588 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:37,588 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:37,588 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:37,589 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:37,589 INFO || Kafka startTimeMs: 1659627277588 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:37,626 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-sonae_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 = sonae_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 15:34:37,665 INFO || [Producer clientId=producer-1] Cluster ID: KsVZckQ1RrSWFK7OfxqSvQ [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:37,728 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:37,736 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 15:34:37,736 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:37,736 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 15:34:37,737 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:37,737 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:37,737 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:37,737 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:37,737 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:37,739 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 15:34:37,739 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:37,739 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:37,739 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:37,739 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:37,739 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:37,739 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:37,739 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:37,739 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:37,739 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:37,739 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:37,740 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:37,740 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:37,740 INFO || Kafka startTimeMs: 1659627277739 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:37,764 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Cluster ID: KsVZckQ1RrSWFK7OfxqSvQ [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:37,786 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Subscribed to partition(s): sonae_offset_topic-0, sonae_offset_topic-5, sonae_offset_topic-10, sonae_offset_topic-20, sonae_offset_topic-15, sonae_offset_topic-9, sonae_offset_topic-11, sonae_offset_topic-4, sonae_offset_topic-16, sonae_offset_topic-17, sonae_offset_topic-3, sonae_offset_topic-24, sonae_offset_topic-23, sonae_offset_topic-13, sonae_offset_topic-18, sonae_offset_topic-22, sonae_offset_topic-8, sonae_offset_topic-2, sonae_offset_topic-12, sonae_offset_topic-19, sonae_offset_topic-14, sonae_offset_topic-1, sonae_offset_topic-6, sonae_offset_topic-7, sonae_offset_topic-21 [org.apache.kafka.clients.consumer.KafkaConsumer] 2022-08-04 15:34:37,805 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Seeking to EARLIEST offset of partition sonae_offset_topic-0 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,807 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Seeking to EARLIEST offset of partition sonae_offset_topic-5 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,808 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Seeking to EARLIEST offset of partition sonae_offset_topic-10 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,808 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Seeking to EARLIEST offset of partition sonae_offset_topic-20 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,808 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Seeking to EARLIEST offset of partition sonae_offset_topic-15 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,808 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Seeking to EARLIEST offset of partition sonae_offset_topic-9 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,809 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Seeking to EARLIEST offset of partition sonae_offset_topic-11 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,809 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Seeking to EARLIEST offset of partition sonae_offset_topic-4 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,809 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Seeking to EARLIEST offset of partition sonae_offset_topic-16 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,809 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Seeking to EARLIEST offset of partition sonae_offset_topic-17 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,809 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Seeking to EARLIEST offset of partition sonae_offset_topic-3 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,809 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Seeking to EARLIEST offset of partition sonae_offset_topic-24 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,809 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Seeking to EARLIEST offset of partition sonae_offset_topic-23 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,809 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Seeking to EARLIEST offset of partition sonae_offset_topic-13 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,809 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Seeking to EARLIEST offset of partition sonae_offset_topic-18 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,809 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Seeking to EARLIEST offset of partition sonae_offset_topic-22 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,809 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Seeking to EARLIEST offset of partition sonae_offset_topic-8 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,809 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Seeking to EARLIEST offset of partition sonae_offset_topic-2 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,809 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Seeking to EARLIEST offset of partition sonae_offset_topic-12 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,809 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Seeking to EARLIEST offset of partition sonae_offset_topic-19 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,809 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Seeking to EARLIEST offset of partition sonae_offset_topic-14 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,809 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Seeking to EARLIEST offset of partition sonae_offset_topic-1 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,810 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Seeking to EARLIEST offset of partition sonae_offset_topic-6 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,810 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Seeking to EARLIEST offset of partition sonae_offset_topic-7 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,810 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Seeking to EARLIEST offset of partition sonae_offset_topic-21 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,902 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-0 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:37,903 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-5 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:37,907 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-10 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:37,907 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-20 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:37,907 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-15 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:37,907 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-9 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:37,907 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-11 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:37,907 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-4 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:37,907 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-16 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:37,908 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-17 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:37,908 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-3 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:37,908 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-24 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:37,908 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-23 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:37,908 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-13 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:37,908 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-18 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:37,908 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-22 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:37,908 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-8 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:37,908 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-2 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:37,908 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-12 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:37,908 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-19 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:37,908 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-14 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:37,908 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-1 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:37,908 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-6 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:37,909 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-7 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:37,909 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-21 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:37,960 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting offset for partition sonae_offset_topic-8 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.4:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,971 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting offset for partition sonae_offset_topic-6 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.4:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,972 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting offset for partition sonae_offset_topic-12 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.4:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,972 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting offset for partition sonae_offset_topic-10 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.4:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,973 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting offset for partition sonae_offset_topic-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.4:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,973 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting offset for partition sonae_offset_topic-4 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.4:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,973 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting offset for partition sonae_offset_topic-2 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.4:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,973 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting offset for partition sonae_offset_topic-23 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.4:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,973 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting offset for partition sonae_offset_topic-17 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.4:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,973 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting offset for partition sonae_offset_topic-15 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.4:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,973 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting offset for partition sonae_offset_topic-21 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.4:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,973 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting offset for partition sonae_offset_topic-19 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.4:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,974 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting offset for partition sonae_offset_topic-9 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.4:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,974 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting offset for partition sonae_offset_topic-7 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.4:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,974 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting offset for partition sonae_offset_topic-13 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.4:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,974 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting offset for partition sonae_offset_topic-11 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.4:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,974 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting offset for partition sonae_offset_topic-1 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.4:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,975 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting offset for partition sonae_offset_topic-5 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.4:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,975 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting offset for partition sonae_offset_topic-3 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.4:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,976 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting offset for partition sonae_offset_topic-24 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.4:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,976 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting offset for partition sonae_offset_topic-22 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.4:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,977 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting offset for partition sonae_offset_topic-16 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.4:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,977 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting offset for partition sonae_offset_topic-14 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.4:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,977 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting offset for partition sonae_offset_topic-20 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.4:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,977 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Resetting offset for partition sonae_offset_topic-18 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.4:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:37,983 INFO || Finished reading KafkaBasedLog for topic sonae_offset_topic [org.apache.kafka.connect.util.KafkaBasedLog] 2022-08-04 15:34:37,983 INFO || Started KafkaBasedLog for topic sonae_offset_topic [org.apache.kafka.connect.util.KafkaBasedLog] 2022-08-04 15:34:37,983 INFO || Finished reading offsets topic and starting KafkaOffsetBackingStore [org.apache.kafka.connect.storage.KafkaOffsetBackingStore] 2022-08-04 15:34:37,996 INFO || Worker started [org.apache.kafka.connect.runtime.Worker] 2022-08-04 15:34:37,997 INFO || Starting KafkaBasedLog with topic connect-status [org.apache.kafka.connect.util.KafkaBasedLog] 2022-08-04 15:34:38,023 INFO || [Consumer clientId=consumer-sonae_group-1, groupId=sonae_group] Discovered group coordinator 172.17.0.4:9092 (id: 2147483646 rack: null) [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2022-08-04 15:34:38,170 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 15:34:38,200 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,201 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,201 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 15:34:38,202 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,203 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 15:34:38,203 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,204 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,204 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,204 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,205 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,205 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 15:34:38,205 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,206 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,221 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,221 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,222 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,222 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,222 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,222 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,222 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,222 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,222 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:38,222 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:38,222 INFO || Kafka startTimeMs: 1659627278222 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:38,236 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-sonae_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 = sonae_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 15:34:38,245 INFO || [Producer clientId=producer-2] Cluster ID: KsVZckQ1RrSWFK7OfxqSvQ [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,271 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,274 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 15:34:38,274 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,274 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 15:34:38,274 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,274 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,274 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,274 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,274 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,274 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 15:34:38,274 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,274 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,274 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,274 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,274 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,274 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,274 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,274 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,274 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,274 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,275 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:38,275 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:38,275 INFO || Kafka startTimeMs: 1659627278275 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:38,307 INFO || [Consumer clientId=consumer-sonae_group-2, groupId=sonae_group] Cluster ID: KsVZckQ1RrSWFK7OfxqSvQ [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,311 INFO || [Consumer clientId=consumer-sonae_group-2, groupId=sonae_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 15:34:38,312 INFO || [Consumer clientId=consumer-sonae_group-2, groupId=sonae_group] Seeking to EARLIEST offset of partition connect-status-0 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:38,312 INFO || [Consumer clientId=consumer-sonae_group-2, groupId=sonae_group] Seeking to EARLIEST offset of partition connect-status-4 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:38,312 INFO || [Consumer clientId=consumer-sonae_group-2, groupId=sonae_group] Seeking to EARLIEST offset of partition connect-status-1 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:38,312 INFO || [Consumer clientId=consumer-sonae_group-2, groupId=sonae_group] Seeking to EARLIEST offset of partition connect-status-2 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:38,312 INFO || [Consumer clientId=consumer-sonae_group-2, groupId=sonae_group] Seeking to EARLIEST offset of partition connect-status-3 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:38,360 INFO || [Consumer clientId=consumer-sonae_group-2, groupId=sonae_group] Resetting the last seen epoch of partition connect-status-0 to 0 since the associated topicId changed from null to q3hBYYBORNm43zSfIuakBA [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,361 INFO || [Consumer clientId=consumer-sonae_group-2, groupId=sonae_group] Resetting the last seen epoch of partition connect-status-4 to 0 since the associated topicId changed from null to q3hBYYBORNm43zSfIuakBA [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,362 INFO || [Consumer clientId=consumer-sonae_group-2, groupId=sonae_group] Resetting the last seen epoch of partition connect-status-1 to 0 since the associated topicId changed from null to q3hBYYBORNm43zSfIuakBA [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,362 INFO || [Consumer clientId=consumer-sonae_group-2, groupId=sonae_group] Resetting the last seen epoch of partition connect-status-2 to 0 since the associated topicId changed from null to q3hBYYBORNm43zSfIuakBA [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,363 INFO || [Consumer clientId=consumer-sonae_group-2, groupId=sonae_group] Resetting the last seen epoch of partition connect-status-3 to 0 since the associated topicId changed from null to q3hBYYBORNm43zSfIuakBA [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,389 INFO || [Consumer clientId=consumer-sonae_group-2, groupId=sonae_group] Resetting offset for partition connect-status-1 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.4:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:38,389 INFO || [Consumer clientId=consumer-sonae_group-2, groupId=sonae_group] Resetting offset for partition connect-status-2 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.4:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:38,389 INFO || [Consumer clientId=consumer-sonae_group-2, groupId=sonae_group] Resetting offset for partition connect-status-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.4:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:38,390 INFO || [Consumer clientId=consumer-sonae_group-2, groupId=sonae_group] Resetting offset for partition connect-status-3 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.4:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:38,390 INFO || [Consumer clientId=consumer-sonae_group-2, groupId=sonae_group] Resetting offset for partition connect-status-4 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.4:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:38,391 INFO || Finished reading KafkaBasedLog for topic connect-status [org.apache.kafka.connect.util.KafkaBasedLog] 2022-08-04 15:34:38,391 INFO || Started KafkaBasedLog for topic connect-status [org.apache.kafka.connect.util.KafkaBasedLog] 2022-08-04 15:34:38,395 INFO || Starting KafkaConfigBackingStore [org.apache.kafka.connect.storage.KafkaConfigBackingStore] 2022-08-04 15:34:38,395 INFO || Starting KafkaBasedLog with topic sonae_storage_topic [org.apache.kafka.connect.util.KafkaBasedLog] 2022-08-04 15:34:38,732 INFO || Created topic (name=sonae_storage_topic, numPartitions=1, replicationFactor=1, replicasAssignments=null, configs={cleanup.policy=compact}) on brokers at kafka:9092 [org.apache.kafka.connect.util.TopicAdmin] 2022-08-04 15:34:38,733 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 15:34:38,739 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,740 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,741 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 15:34:38,741 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,748 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 15:34:38,748 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,748 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,748 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,748 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,748 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,748 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 15:34:38,748 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,748 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,748 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,748 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,748 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,749 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,749 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,750 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,750 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,750 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-08-04 15:34:38,750 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:38,750 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:38,750 INFO || Kafka startTimeMs: 1659627278750 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:38,753 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-sonae_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 = sonae_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 15:34:38,782 INFO || [Consumer clientId=consumer-sonae_group-2, groupId=sonae_group] Discovered group coordinator 172.17.0.4:9092 (id: 2147483646 rack: null) [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2022-08-04 15:34:38,802 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,805 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 15:34:38,805 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,805 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 15:34:38,805 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,805 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,805 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,805 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,805 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,805 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 15:34:38,806 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,806 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,806 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,807 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,807 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,807 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,807 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,807 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,807 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,807 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-08-04 15:34:38,808 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:38,808 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:38,808 INFO || Kafka startTimeMs: 1659627278808 [org.apache.kafka.common.utils.AppInfoParser] 2022-08-04 15:34:38,836 INFO || [Producer clientId=producer-3] Cluster ID: KsVZckQ1RrSWFK7OfxqSvQ [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,858 INFO || [Consumer clientId=consumer-sonae_group-3, groupId=sonae_group] Cluster ID: KsVZckQ1RrSWFK7OfxqSvQ [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,860 INFO || [Consumer clientId=consumer-sonae_group-3, groupId=sonae_group] Subscribed to partition(s): sonae_storage_topic-0 [org.apache.kafka.clients.consumer.KafkaConsumer] 2022-08-04 15:34:38,861 INFO || [Consumer clientId=consumer-sonae_group-3, groupId=sonae_group] Seeking to EARLIEST offset of partition sonae_storage_topic-0 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:38,898 INFO || [Consumer clientId=consumer-sonae_group-3, groupId=sonae_group] Resetting the last seen epoch of partition sonae_storage_topic-0 to 0 since the associated topicId changed from null to aJRH4u39ScaBEBFNwZbLqw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,910 INFO || [Consumer clientId=consumer-sonae_group-3, groupId=sonae_group] Resetting offset for partition sonae_storage_topic-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.4:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-08-04 15:34:38,911 INFO || Finished reading KafkaBasedLog for topic sonae_storage_topic [org.apache.kafka.connect.util.KafkaBasedLog] 2022-08-04 15:34:38,911 INFO || Started KafkaBasedLog for topic sonae_storage_topic [org.apache.kafka.connect.util.KafkaBasedLog] 2022-08-04 15:34:38,911 INFO || Started KafkaConfigBackingStore [org.apache.kafka.connect.storage.KafkaConfigBackingStore] 2022-08-04 15:34:38,911 INFO || [Worker clientId=connect-1, groupId=sonae_group] Herder started [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-08-04 15:34:38,949 INFO || [Consumer clientId=consumer-sonae_group-3, groupId=sonae_group] Discovered group coordinator 172.17.0.4:9092 (id: 2147483646 rack: null) [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2022-08-04 15:34:38,953 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-0 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,953 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-10 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,954 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-20 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,954 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-40 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,954 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-30 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,954 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-9 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,957 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-11 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,957 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-31 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,957 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-39 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,958 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-13 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,961 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-18 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,962 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-22 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,962 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-8 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,963 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-32 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,964 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-43 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,965 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-29 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,966 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-34 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,967 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-1 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,967 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-6 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,967 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-41 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,977 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-27 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,977 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-48 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,977 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-5 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,977 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-15 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,979 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-35 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,979 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-25 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,979 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-46 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,980 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-26 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,980 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-36 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,981 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-44 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,982 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-16 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,982 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-37 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,982 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-17 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,982 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-45 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,983 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-3 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,983 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-24 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,984 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-38 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,985 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-33 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,986 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-23 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,987 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-28 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,988 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-2 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,988 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-12 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,989 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-19 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,989 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-14 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,989 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-4 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,989 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-47 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,989 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-49 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,989 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-42 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,989 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-7 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,989 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition __consumer_offsets-21 to 0 since the associated topicId changed from null to U9VIQVh-QJWwNO5gYvf7Tw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,990 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_storage_topic-0 to 0 since the associated topicId changed from null to aJRH4u39ScaBEBFNwZbLqw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,998 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition connect-status-0 to 0 since the associated topicId changed from null to q3hBYYBORNm43zSfIuakBA [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:38,999 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition connect-status-4 to 0 since the associated topicId changed from null to q3hBYYBORNm43zSfIuakBA [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,000 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition connect-status-1 to 0 since the associated topicId changed from null to q3hBYYBORNm43zSfIuakBA [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,000 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition connect-status-2 to 0 since the associated topicId changed from null to q3hBYYBORNm43zSfIuakBA [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,001 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition connect-status-3 to 0 since the associated topicId changed from null to q3hBYYBORNm43zSfIuakBA [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,001 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sde_offset_topic-0 to 0 since the associated topicId changed from null to Tm5RaTUVTyebnDWNga3_ug [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,002 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sde_offset_topic-5 to 0 since the associated topicId changed from null to Tm5RaTUVTyebnDWNga3_ug [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,003 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sde_offset_topic-10 to 0 since the associated topicId changed from null to Tm5RaTUVTyebnDWNga3_ug [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,004 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sde_offset_topic-20 to 0 since the associated topicId changed from null to Tm5RaTUVTyebnDWNga3_ug [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,005 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sde_offset_topic-15 to 0 since the associated topicId changed from null to Tm5RaTUVTyebnDWNga3_ug [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,005 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sde_offset_topic-9 to 0 since the associated topicId changed from null to Tm5RaTUVTyebnDWNga3_ug [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,006 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sde_offset_topic-11 to 0 since the associated topicId changed from null to Tm5RaTUVTyebnDWNga3_ug [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,017 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sde_offset_topic-16 to 0 since the associated topicId changed from null to Tm5RaTUVTyebnDWNga3_ug [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,018 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sde_offset_topic-4 to 0 since the associated topicId changed from null to Tm5RaTUVTyebnDWNga3_ug [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,018 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sde_offset_topic-17 to 0 since the associated topicId changed from null to Tm5RaTUVTyebnDWNga3_ug [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,018 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sde_offset_topic-3 to 0 since the associated topicId changed from null to Tm5RaTUVTyebnDWNga3_ug [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,018 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sde_offset_topic-24 to 0 since the associated topicId changed from null to Tm5RaTUVTyebnDWNga3_ug [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,018 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sde_offset_topic-23 to 0 since the associated topicId changed from null to Tm5RaTUVTyebnDWNga3_ug [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,018 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sde_offset_topic-13 to 0 since the associated topicId changed from null to Tm5RaTUVTyebnDWNga3_ug [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,018 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sde_offset_topic-18 to 0 since the associated topicId changed from null to Tm5RaTUVTyebnDWNga3_ug [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,019 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sde_offset_topic-22 to 0 since the associated topicId changed from null to Tm5RaTUVTyebnDWNga3_ug [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,019 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sde_offset_topic-2 to 0 since the associated topicId changed from null to Tm5RaTUVTyebnDWNga3_ug [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,019 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sde_offset_topic-8 to 0 since the associated topicId changed from null to Tm5RaTUVTyebnDWNga3_ug [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,019 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sde_offset_topic-12 to 0 since the associated topicId changed from null to Tm5RaTUVTyebnDWNga3_ug [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,019 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sde_offset_topic-19 to 0 since the associated topicId changed from null to Tm5RaTUVTyebnDWNga3_ug [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,020 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sde_offset_topic-14 to 0 since the associated topicId changed from null to Tm5RaTUVTyebnDWNga3_ug [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,020 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sde_offset_topic-1 to 0 since the associated topicId changed from null to Tm5RaTUVTyebnDWNga3_ug [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,020 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sde_offset_topic-6 to 0 since the associated topicId changed from null to Tm5RaTUVTyebnDWNga3_ug [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,020 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sde_offset_topic-7 to 0 since the associated topicId changed from null to Tm5RaTUVTyebnDWNga3_ug [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,020 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sde_offset_topic-21 to 0 since the associated topicId changed from null to Tm5RaTUVTyebnDWNga3_ug [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,020 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-0 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,020 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-5 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,021 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-10 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,021 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-20 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,021 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-15 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,021 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-9 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,021 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-11 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,021 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-4 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,021 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-16 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,021 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-17 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,021 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-3 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,022 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-24 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,022 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-23 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,022 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-13 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,022 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-18 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,033 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-22 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,033 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-8 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,033 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-2 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,034 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-12 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,034 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-19 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,034 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-14 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,034 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-1 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,034 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-6 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,034 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-7 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,034 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sonae_offset_topic-21 to 0 since the associated topicId changed from null to N2YOeqRHTNKhPGRJugOHxw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,034 INFO || [Worker clientId=connect-1, groupId=sonae_group] Resetting the last seen epoch of partition sde_storage_topic-0 to 0 since the associated topicId changed from null to bTs-fwLTSh6fKXmqM2piOg [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,050 INFO || [Worker clientId=connect-1, groupId=sonae_group] Cluster ID: KsVZckQ1RrSWFK7OfxqSvQ [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,051 INFO || [Worker clientId=connect-1, groupId=sonae_group] Discovered group coordinator 172.17.0.4:9092 (id: 2147483646 rack: null) [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-08-04 15:34:39,099 INFO || [Worker clientId=connect-1, groupId=sonae_group] Rebalance started [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-08-04 15:34:39,100 INFO || [Worker clientId=connect-1, groupId=sonae_group] (Re-)joining group [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-08-04 15:34:39,155 INFO || [Worker clientId=connect-1, groupId=sonae_group] (Re-)joining group [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-08-04 15:34:39,200 INFO || [Worker clientId=connect-1, groupId=sonae_group] Successfully joined group with generation Generation{generationId=1, memberId='connect-1-6388e7c9-a97d-42d7-b5de-076c403f72be', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-08-04 15:34:39,305 INFO || [Worker clientId=connect-1, groupId=sonae_group] Successfully synced group in generation Generation{generationId=1, memberId='connect-1-6388e7c9-a97d-42d7-b5de-076c403f72be', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-08-04 15:34:39,312 INFO || [Worker clientId=connect-1, groupId=sonae_group] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-6388e7c9-a97d-42d7-b5de-076c403f72be', leaderUrl='http://172.17.0.5:8083/', offset=-1, connectorIds=[], taskIds=[], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-08-04 15:34:39,314 INFO || [Worker clientId=connect-1, groupId=sonae_group] Starting connectors and tasks using config offset -1 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-08-04 15:34:39,314 INFO || [Worker clientId=connect-1, groupId=sonae_group] Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-08-04 15:34:39,376 INFO || [Producer clientId=producer-3] Resetting the last seen epoch of partition sonae_storage_topic-0 to 0 since the associated topicId changed from null to aJRH4u39ScaBEBFNwZbLqw [org.apache.kafka.clients.Metadata] 2022-08-04 15:34:39,477 INFO || [Worker clientId=connect-1, groupId=sonae_group] Session key updated [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-08-04 15:35:40,874 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 15:35:40,887 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 15:35:41,088 INFO || Successfully tested connection for jdbc:postgresql://postgres123:5432/postgres with user 'start_data_engineer' [io.debezium.connector.postgresql.PostgresConnector] 2022-08-04 15:35:41,108 ERROR || Failed testing connection for jdbc:postgresql://postgres123:5432/postgres with user 'start_data_engineer' [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 15:35:41,121 INFO || Connection gracefully closed [io.debezium.jdbc.JdbcConnection] 2022-08-04 15:35:41,126 INFO || AbstractConfig values: [org.apache.kafka.common.config.AbstractConfig]