Using BOOTSTRAP_SERVERS=kafka1:9092,kafka2:9093 Plugins are loaded from /kafka/connect Using the following environment variables: GROUP_ID=oracle CONFIG_STORAGE_TOPIC=connect-configs OFFSET_STORAGE_TOPIC=connect-offsets STATUS_STORAGE_TOPIC=connect-status BOOTSTRAP_SERVERS=kafka1:9092,kafka2:9093 REST_HOST_NAME=192.168.48.6 REST_PORT=8083 ADVERTISED_HOST_NAME=192.168.48.6 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=connect-offsets --- Setting property from CONNECT_KEY_CONVERTER: key.converter=org.apache.kafka.connect.json.JsonConverter --- Setting property from CONNECT_CONFIG_STORAGE_TOPIC: config.storage.topic=connect-configs --- Setting property from CONNECT_GROUP_ID: group.id=oracle --- Setting property from CONNECT_REST_ADVERTISED_HOST_NAME: rest.advertised.host.name=192.168.48.6 --- Setting property from CONNECT_REST_HOST_NAME: rest.host.name=192.168.48.6 --- 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_STATUS_STORAGE_TOPIC: status.storage.topic=connect-status --- 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=kafka1:9092,kafka2:9093 --- Setting property from CONNECT_TASK_SHUTDOWN_GRACEFUL_TIMEOUT_MS: task.shutdown.graceful.timeout.ms=10000 Enabling Java debug options: -agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=0.0.0.0:5005 Listening for transport dt_socket at address: 5005 2022-10-07 06:01:39,730 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, -agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=0.0.0.0:5005 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/ojdbc8-21.1.0.0.jar:/kafka/libs/orai18n-19.3.0.0.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.104-linuxkit os.vcpus = 6 [org.apache.kafka.connect.runtime.WorkerInfo] 2022-10-07 06:01:39,743 INFO || Scanning for plugin classes. This might take a moment ... [org.apache.kafka.connect.cli.ConnectDistributed] 2022-10-07 06:01:39,788 INFO || Loading plugin from: /kafka/connect/debezium-connector-db2 [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:40,755 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-db2/} [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:40,755 INFO || Added plugin 'io.debezium.connector.db2.Db2Connector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:40,756 INFO || Added plugin 'io.debezium.converters.ByteBufferConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:40,756 INFO || Added plugin 'io.debezium.converters.ByteArrayConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:40,756 INFO || Added plugin 'io.debezium.converters.BinaryDataConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:40,756 INFO || Added plugin 'io.debezium.converters.CloudEventsConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:40,756 INFO || Added plugin 'io.debezium.transforms.outbox.EventRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:40,757 INFO || Added plugin 'io.debezium.transforms.ExtractNewRecordState' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:40,757 INFO || Added plugin 'io.debezium.transforms.ByLogicalTableRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:40,757 INFO || Added plugin 'io.debezium.transforms.tracing.ActivateTracingSpan' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:40,757 INFO || Added plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:40,757 INFO || Added plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:40,758 INFO || Added plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:40,948 INFO || Loading plugin from: /kafka/connect/debezium-connector-oracle [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:43,990 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-oracle/} [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:43,991 INFO || Added plugin 'io.debezium.connector.oracle.OracleConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:43,995 INFO || Loading plugin from: /kafka/connect/debezium-connector-mysql [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:44,807 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-mysql/} [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:44,808 INFO || Added plugin 'io.debezium.connector.mysql.MySqlConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:44,808 INFO || Added plugin 'io.debezium.connector.mysql.transforms.ReadToInsertEvent' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:44,822 INFO || Loading plugin from: /kafka/connect/debezium-connector-mongodb [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:45,349 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-mongodb/} [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:45,350 INFO || Added plugin 'io.debezium.connector.mongodb.MongoDbConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:45,350 INFO || Added plugin 'io.debezium.connector.mongodb.transforms.outbox.MongoEventRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:45,350 INFO || Added plugin 'io.debezium.connector.mongodb.transforms.ExtractNewDocumentState' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:45,352 INFO || Loading plugin from: /kafka/connect/debezium-connector-vitess [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:46,865 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-vitess/} [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:46,866 INFO || Added plugin 'io.debezium.connector.vitess.VitessConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:46,869 INFO || Loading plugin from: /kafka/connect/debezium-connector-postgres [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:47,322 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-postgres/} [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:47,322 INFO || Added plugin 'io.debezium.connector.postgresql.PostgresConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:47,328 INFO || Loading plugin from: /kafka/connect/debezium-connector-sqlserver [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:48,221 INFO || Registered loader: PluginClassLoader{pluginLocation=file:/kafka/connect/debezium-connector-sqlserver/} [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:48,221 INFO || Added plugin 'io.debezium.connector.sqlserver.SqlServerConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,211 INFO || Registered loader: jdk.internal.loader.ClassLoaders$AppClassLoader@3d4eac69 [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,211 INFO || Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,211 INFO || Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,211 INFO || Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,211 INFO || Added plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,211 INFO || Added plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,212 INFO || Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,212 INFO || Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,212 INFO || Added plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,212 INFO || Added plugin 'org.apache.kafka.connect.converters.FloatConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,212 INFO || Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,212 INFO || Added plugin 'io.confluent.connect.avro.AvroConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,212 INFO || Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,212 INFO || Added plugin 'org.apache.kafka.connect.converters.LongConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,213 INFO || Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,213 INFO || Added plugin 'org.apache.kafka.connect.json.JsonConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,213 INFO || Added plugin 'org.apache.kafka.connect.storage.StringConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,213 INFO || Added plugin 'org.apache.kafka.connect.converters.ShortConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,213 INFO || Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,213 INFO || Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,213 INFO || Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,214 INFO || Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,214 INFO || Added plugin 'org.apache.kafka.connect.transforms.Filter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,214 INFO || Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,214 INFO || Added plugin 'org.apache.kafka.connect.transforms.HeaderFrom$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,214 INFO || Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,214 INFO || Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,214 INFO || Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,215 INFO || Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,215 INFO || Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,215 INFO || Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,215 INFO || Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,215 INFO || Added plugin 'org.apache.kafka.connect.transforms.DropHeaders' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,215 INFO || Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,215 INFO || Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,216 INFO || Added plugin 'org.apache.kafka.connect.runtime.PredicatedTransformation' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,216 INFO || Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,216 INFO || Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,216 INFO || Added plugin 'org.apache.kafka.connect.transforms.InsertHeader' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,216 INFO || Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,216 INFO || Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,216 INFO || Added plugin 'org.apache.kafka.connect.transforms.HeaderFrom$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,216 INFO || Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,217 INFO || Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,217 INFO || Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,217 INFO || Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,217 INFO || Added plugin 'org.apache.kafka.connect.transforms.predicates.HasHeaderKey' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,217 INFO || Added plugin 'org.apache.kafka.connect.transforms.predicates.RecordIsTombstone' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,217 INFO || Added plugin 'org.apache.kafka.connect.transforms.predicates.TopicNameMatches' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,218 INFO || Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,218 INFO || Added plugin 'org.apache.kafka.common.config.provider.DirectoryConfigProvider' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,218 INFO || Added plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,220 INFO || Added aliases 'Db2Connector' and 'Db2' to plugin 'io.debezium.connector.db2.Db2Connector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,220 INFO || Added aliases 'MongoDbConnector' and 'MongoDb' to plugin 'io.debezium.connector.mongodb.MongoDbConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,221 INFO || Added aliases 'MySqlConnector' and 'MySql' to plugin 'io.debezium.connector.mysql.MySqlConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,221 INFO || Added aliases 'OracleConnector' and 'Oracle' to plugin 'io.debezium.connector.oracle.OracleConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,221 INFO || Added aliases 'PostgresConnector' and 'Postgres' to plugin 'io.debezium.connector.postgresql.PostgresConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,222 INFO || Added aliases 'SqlServerConnector' and 'SqlServer' to plugin 'io.debezium.connector.sqlserver.SqlServerConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,222 INFO || Added aliases 'VitessConnector' and 'Vitess' to plugin 'io.debezium.connector.vitess.VitessConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,222 INFO || Added aliases 'MirrorCheckpointConnector' and 'MirrorCheckpoint' to plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,222 INFO || Added aliases 'MirrorHeartbeatConnector' and 'MirrorHeartbeat' to plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,223 INFO || Added aliases 'MirrorSourceConnector' and 'MirrorSource' to plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,223 INFO || Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,223 INFO || Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,224 INFO || Added aliases 'SchemaSourceConnector' and 'SchemaSource' to plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,224 INFO || Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,224 INFO || Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,224 INFO || Added aliases 'AvroConverter' and 'Avro' to plugin 'io.confluent.connect.avro.AvroConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,225 INFO || Added aliases 'BinaryDataConverter' and 'BinaryData' to plugin 'io.debezium.converters.BinaryDataConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,225 INFO || Added aliases 'ByteBufferConverter' and 'ByteBuffer' to plugin 'io.debezium.converters.ByteBufferConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,225 INFO || Added aliases 'CloudEventsConverter' and 'CloudEvents' to plugin 'io.debezium.converters.CloudEventsConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,226 INFO || Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,226 INFO || Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,226 INFO || Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,226 INFO || Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,227 INFO || Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,227 INFO || Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,227 INFO || Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,227 INFO || Added aliases 'BinaryDataConverter' and 'BinaryData' to plugin 'io.debezium.converters.BinaryDataConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,228 INFO || Added aliases 'ByteBufferConverter' and 'ByteBuffer' to plugin 'io.debezium.converters.ByteBufferConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,228 INFO || Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,228 INFO || Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,228 INFO || Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,229 INFO || Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,229 INFO || Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,229 INFO || Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,229 INFO || Added aliases 'SimpleHeaderConverter' and 'Simple' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,230 INFO || Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,230 INFO || Added alias 'ExtractNewDocumentState' to plugin 'io.debezium.connector.mongodb.transforms.ExtractNewDocumentState' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,231 INFO || Added alias 'MongoEventRouter' to plugin 'io.debezium.connector.mongodb.transforms.outbox.MongoEventRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,231 INFO || Added alias 'ReadToInsertEvent' to plugin 'io.debezium.connector.mysql.transforms.ReadToInsertEvent' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,232 INFO || Added alias 'ByLogicalTableRouter' to plugin 'io.debezium.transforms.ByLogicalTableRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,232 INFO || Added alias 'ExtractNewRecordState' to plugin 'io.debezium.transforms.ExtractNewRecordState' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,232 INFO || Added alias 'EventRouter' to plugin 'io.debezium.transforms.outbox.EventRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,233 INFO || Added alias 'ActivateTracingSpan' to plugin 'io.debezium.transforms.tracing.ActivateTracingSpan' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,233 INFO || Added aliases 'PredicatedTransformation' and 'Predicated' to plugin 'org.apache.kafka.connect.runtime.PredicatedTransformation' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,234 INFO || Added alias 'DropHeaders' to plugin 'org.apache.kafka.connect.transforms.DropHeaders' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,234 INFO || Added alias 'Filter' to plugin 'org.apache.kafka.connect.transforms.Filter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,235 INFO || Added alias 'InsertHeader' to plugin 'org.apache.kafka.connect.transforms.InsertHeader' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,235 INFO || Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,245 INFO || Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,246 INFO || Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,246 INFO || Added alias 'HasHeaderKey' to plugin 'org.apache.kafka.connect.transforms.predicates.HasHeaderKey' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,246 INFO || Added alias 'RecordIsTombstone' to plugin 'org.apache.kafka.connect.transforms.predicates.RecordIsTombstone' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,246 INFO || Added alias 'TopicNameMatches' to plugin 'org.apache.kafka.connect.transforms.predicates.TopicNameMatches' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,246 INFO || Added alias 'BasicAuthSecurityRestExtension' to plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,247 INFO || Added aliases 'AllConnectorClientConfigOverridePolicy' and 'All' to plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,247 INFO || Added aliases 'NoneConnectorClientConfigOverridePolicy' and 'None' to plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,247 INFO || Added aliases 'PrincipalConnectorClientConfigOverridePolicy' and 'Principal' to plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' [org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader] 2022-10-07 06:01:52,415 INFO || DistributedConfig values: access.control.allow.methods = access.control.allow.origin = admin.listeners = null bootstrap.servers = [kafka1:9092, kafka2:9093] client.dns.lookup = use_all_dns_ips client.id = config.providers = [] config.storage.replication.factor = 1 config.storage.topic = connect-configs connect.protocol = sessioned connections.max.idle.ms = 540000 connector.client.config.override.policy = All group.id = oracle 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 = connect-offsets 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 = 192.168.48.6 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-10-07 06:01:52,419 INFO || Creating Kafka admin client [org.apache.kafka.connect.util.ConnectUtils] 2022-10-07 06:01:52,426 INFO || AdminClientConfig values: bootstrap.servers = [kafka1:9092, kafka2:9093] 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-10-07 06:01:52,687 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:52,687 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:52,687 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:52,688 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:52,688 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:52,688 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:52,688 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:52,689 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:52,689 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:52,689 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:52,689 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:52,689 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:52,690 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:52,690 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:52,690 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:52,691 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:52,691 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:52,691 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:52,691 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:52,692 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:52,693 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:52,693 INFO || Kafka startTimeMs: 1665122512692 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:53,667 INFO || Kafka cluster ID: O4lpFK1zTvu2J7OTeajnrw [org.apache.kafka.connect.util.ConnectUtils] 2022-10-07 06:01:53,669 INFO || App info kafka.admin.client for adminclient-1 unregistered [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:53,690 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:01:53,690 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:01:53,691 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:01:53,714 INFO || Logging initialized @15401ms to org.eclipse.jetty.util.log.Slf4jLog [org.eclipse.jetty.util.log] 2022-10-07 06:01:53,807 INFO || Added connector for http://:8083 [org.apache.kafka.connect.runtime.rest.RestServer] 2022-10-07 06:01:53,808 INFO || Initializing REST server [org.apache.kafka.connect.runtime.rest.RestServer] 2022-10-07 06:01:53,821 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-10-07 06:01:53,870 INFO || Started http_8083@681c0ae6{HTTP/1.1, (http/1.1)}{0.0.0.0:8083} [org.eclipse.jetty.server.AbstractConnector] 2022-10-07 06:01:53,871 INFO || Started @15558ms [org.eclipse.jetty.server.Server] 2022-10-07 06:01:53,916 INFO || Advertised URI: http://192.168.48.6:8083/ [org.apache.kafka.connect.runtime.rest.RestServer] 2022-10-07 06:01:53,916 INFO || REST server listening at http://192.168.48.6:8083/, advertising URL http://192.168.48.6:8083/ [org.apache.kafka.connect.runtime.rest.RestServer] 2022-10-07 06:01:53,917 INFO || Advertised URI: http://192.168.48.6:8083/ [org.apache.kafka.connect.runtime.rest.RestServer] 2022-10-07 06:01:53,917 INFO || REST admin endpoints at http://192.168.48.6:8083/ [org.apache.kafka.connect.runtime.rest.RestServer] 2022-10-07 06:01:53,918 INFO || Advertised URI: http://192.168.48.6:8083/ [org.apache.kafka.connect.runtime.rest.RestServer] 2022-10-07 06:01:53,925 INFO || Creating Kafka admin client [org.apache.kafka.connect.util.ConnectUtils] 2022-10-07 06:01:53,926 INFO || AdminClientConfig values: bootstrap.servers = [kafka1:9092, kafka2:9093] 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-10-07 06:01:53,938 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:53,939 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:53,939 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:53,939 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:53,939 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:53,939 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:53,939 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:53,940 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:53,940 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:53,940 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:53,940 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:53,940 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:53,940 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:53,940 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:53,941 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:53,941 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:53,941 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:53,941 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:53,941 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:53,941 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:53,941 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:53,942 INFO || Kafka startTimeMs: 1665122513941 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:54,002 INFO || Kafka cluster ID: O4lpFK1zTvu2J7OTeajnrw [org.apache.kafka.connect.util.ConnectUtils] 2022-10-07 06:01:54,004 INFO || App info kafka.admin.client for adminclient-2 unregistered [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:54,015 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:01:54,018 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:01:54,018 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:01:54,026 INFO || Setting up All Policy for ConnectorClientConfigOverride. This will allow all client configurations to be overridden [org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy] 2022-10-07 06:01:54,049 INFO || Creating Kafka admin client [org.apache.kafka.connect.util.ConnectUtils] 2022-10-07 06:01:54,055 INFO || AdminClientConfig values: bootstrap.servers = [kafka1:9092, kafka2:9093] 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-10-07 06:01:54,088 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,089 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,089 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,090 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,091 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,092 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,092 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,092 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,092 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,092 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,092 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,092 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,093 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,093 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,093 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,093 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,096 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,096 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,097 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,098 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:54,099 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:54,099 INFO || Kafka startTimeMs: 1665122514098 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:54,159 INFO || Kafka cluster ID: O4lpFK1zTvu2J7OTeajnrw [org.apache.kafka.connect.util.ConnectUtils] 2022-10-07 06:01:54,161 INFO || App info kafka.admin.client for adminclient-3 unregistered [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:54,176 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:01:54,176 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:01:54,183 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:01:54,193 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:54,193 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:54,193 INFO || Kafka startTimeMs: 1665122514193 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:54,445 INFO || JsonConverterConfig values: converter.type = key decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false [org.apache.kafka.connect.json.JsonConverterConfig] 2022-10-07 06:01:54,449 INFO || JsonConverterConfig values: converter.type = value decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false [org.apache.kafka.connect.json.JsonConverterConfig] 2022-10-07 06:01:54,449 INFO || Creating Kafka admin client [org.apache.kafka.connect.util.ConnectUtils] 2022-10-07 06:01:54,450 INFO || AdminClientConfig values: bootstrap.servers = [kafka1:9092, kafka2:9093] 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-10-07 06:01:54,475 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,475 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,475 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,476 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,476 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,477 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,477 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,477 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,489 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,489 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,489 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,489 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,489 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,490 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,490 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,491 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,492 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,492 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,492 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,493 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:54,493 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:54,493 INFO || Kafka startTimeMs: 1665122514493 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:54,588 INFO || Kafka cluster ID: O4lpFK1zTvu2J7OTeajnrw [org.apache.kafka.connect.util.ConnectUtils] 2022-10-07 06:01:54,589 INFO || App info kafka.admin.client for adminclient-4 unregistered [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:54,603 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:01:54,604 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:01:54,619 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:01:54,641 INFO || Creating Kafka admin client [org.apache.kafka.connect.util.ConnectUtils] 2022-10-07 06:01:54,645 INFO || AdminClientConfig values: bootstrap.servers = [kafka1:9092, kafka2:9093] 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-10-07 06:01:54,655 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,655 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,656 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,656 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,656 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,656 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,656 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,658 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,658 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,658 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,660 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,660 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,660 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,660 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,661 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,661 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,661 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,661 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,661 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,661 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:54,662 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:54,662 INFO || Kafka startTimeMs: 1665122514661 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:54,706 INFO || Kafka cluster ID: O4lpFK1zTvu2J7OTeajnrw [org.apache.kafka.connect.util.ConnectUtils] 2022-10-07 06:01:54,709 INFO || App info kafka.admin.client for adminclient-5 unregistered [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:54,714 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:01:54,714 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:01:54,714 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:01:54,725 INFO || Creating Kafka admin client [org.apache.kafka.connect.util.ConnectUtils] 2022-10-07 06:01:54,728 INFO || AdminClientConfig values: bootstrap.servers = [kafka1:9092, kafka2:9093] 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-10-07 06:01:54,753 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,753 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,753 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,753 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,753 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,753 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,753 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,753 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,753 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,754 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,754 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,754 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,754 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,754 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,754 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,754 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,754 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,754 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,754 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,754 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:54,758 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:54,759 INFO || Kafka startTimeMs: 1665122514754 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:54,803 INFO || Kafka cluster ID: O4lpFK1zTvu2J7OTeajnrw [org.apache.kafka.connect.util.ConnectUtils] 2022-10-07 06:01:54,804 INFO || App info kafka.admin.client for adminclient-6 unregistered [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:54,814 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:01:54,814 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:01:54,814 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:01:54,838 INFO || Creating Kafka admin client [org.apache.kafka.connect.util.ConnectUtils] 2022-10-07 06:01:54,839 INFO || AdminClientConfig values: bootstrap.servers = [kafka1:9092, kafka2:9093] 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-10-07 06:01:54,846 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,846 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,847 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,847 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,847 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,847 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,847 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,847 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,847 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,847 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,847 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,847 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,848 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,848 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,848 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,849 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,850 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,850 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,851 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,851 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:54,851 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:54,852 INFO || Kafka startTimeMs: 1665122514851 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:54,881 INFO || Kafka cluster ID: O4lpFK1zTvu2J7OTeajnrw [org.apache.kafka.connect.util.ConnectUtils] 2022-10-07 06:01:54,882 INFO || App info kafka.admin.client for adminclient-7 unregistered [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:54,887 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:01:54,887 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:01:54,887 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:01:54,936 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:54,937 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:54,938 INFO || Kafka startTimeMs: 1665122514936 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:54,945 INFO || Kafka Connect distributed worker initialization took 15219ms [org.apache.kafka.connect.cli.ConnectDistributed] 2022-10-07 06:01:54,945 INFO || Kafka Connect starting [org.apache.kafka.connect.runtime.Connect] 2022-10-07 06:01:54,951 INFO || Initializing REST resources [org.apache.kafka.connect.runtime.rest.RestServer] 2022-10-07 06:01:54,951 INFO || [Worker clientId=connect-1, groupId=oracle] Herder starting [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-10-07 06:01:54,952 INFO || Worker starting [org.apache.kafka.connect.runtime.Worker] 2022-10-07 06:01:54,952 INFO || Starting KafkaOffsetBackingStore [org.apache.kafka.connect.storage.KafkaOffsetBackingStore] 2022-10-07 06:01:54,952 INFO || Starting KafkaBasedLog with topic connect-offsets [org.apache.kafka.connect.util.KafkaBasedLog] 2022-10-07 06:01:54,957 INFO || AdminClientConfig values: bootstrap.servers = [kafka1:9092, kafka2:9093] 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-10-07 06:01:54,965 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,965 WARN || The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,965 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,965 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,966 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,966 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,966 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,967 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,967 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,967 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,967 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,967 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,967 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,967 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,967 WARN || The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,968 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,968 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,968 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,968 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,969 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,969 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:01:54,970 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:54,970 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:54,970 INFO || Kafka startTimeMs: 1665122514969 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:55,059 INFO || Adding admin resources to main listener [org.apache.kafka.connect.runtime.rest.RestServer] 2022-10-07 06:01:55,281 INFO || DefaultSessionIdManager workerName=node0 [org.eclipse.jetty.server.session] 2022-10-07 06:01:55,286 INFO || No SessionScavenger set, using defaults [org.eclipse.jetty.server.session] 2022-10-07 06:01:55,293 INFO || node0 Scavenging every 600000ms [org.eclipse.jetty.server.session] 2022-10-07 06:01:56,303 INFO || Created topic (name=connect-offsets, numPartitions=25, replicationFactor=1, replicasAssignments=null, configs={cleanup.policy=compact}) on brokers at kafka1:9092,kafka2:9093 [org.apache.kafka.connect.util.TopicAdmin] 2022-10-07 06:01:56,318 INFO || ProducerConfig values: acks = -1 batch.size = 16384 bootstrap.servers = [kafka1:9092, kafka2:9093] 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-10-07 06:01:56,405 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:56,405 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:56,405 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:56,405 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:56,406 WARN || The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:56,406 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:56,406 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:56,406 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:56,406 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:56,406 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:56,406 WARN || The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:56,406 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:56,407 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:56,407 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:56,407 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:56,407 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:56,407 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:56,407 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:56,407 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:56,407 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:56,407 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:56,408 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:56,408 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:56,408 INFO || Kafka startTimeMs: 1665122516407 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:56,438 INFO || ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [kafka1:9092, kafka2:9093] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = consumer-oracle-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 = oracle 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-10-07 06:01:56,442 INFO || [Producer clientId=producer-1] Cluster ID: O4lpFK1zTvu2J7OTeajnrw [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:56,575 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:56,580 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:56,580 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:56,581 WARN || The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:56,581 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:56,583 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:56,583 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:56,583 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:56,583 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:56,583 WARN || The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:56,583 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:56,583 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:56,584 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:56,584 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:56,584 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:56,588 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:56,588 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:56,588 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:56,589 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:56,589 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:56,589 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:56,590 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:56,590 INFO || Kafka startTimeMs: 1665122516589 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:56,632 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Cluster ID: O4lpFK1zTvu2J7OTeajnrw [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:56,673 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Subscribed to partition(s): connect-offsets-0, connect-offsets-5, connect-offsets-10, connect-offsets-20, connect-offsets-15, connect-offsets-9, connect-offsets-11, connect-offsets-4, connect-offsets-16, connect-offsets-17, connect-offsets-3, connect-offsets-24, connect-offsets-23, connect-offsets-13, connect-offsets-18, connect-offsets-22, connect-offsets-8, connect-offsets-2, connect-offsets-12, connect-offsets-19, connect-offsets-14, connect-offsets-1, connect-offsets-6, connect-offsets-7, connect-offsets-21 [org.apache.kafka.clients.consumer.KafkaConsumer] 2022-10-07 06:01:56,683 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Seeking to EARLIEST offset of partition connect-offsets-0 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,685 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Seeking to EARLIEST offset of partition connect-offsets-5 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,686 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Seeking to EARLIEST offset of partition connect-offsets-10 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,686 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Seeking to EARLIEST offset of partition connect-offsets-20 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,686 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Seeking to EARLIEST offset of partition connect-offsets-15 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,687 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Seeking to EARLIEST offset of partition connect-offsets-9 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,688 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Seeking to EARLIEST offset of partition connect-offsets-11 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,688 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Seeking to EARLIEST offset of partition connect-offsets-4 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,688 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Seeking to EARLIEST offset of partition connect-offsets-16 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,688 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Seeking to EARLIEST offset of partition connect-offsets-17 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,688 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Seeking to EARLIEST offset of partition connect-offsets-3 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,689 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Seeking to EARLIEST offset of partition connect-offsets-24 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,689 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Seeking to EARLIEST offset of partition connect-offsets-23 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,689 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Seeking to EARLIEST offset of partition connect-offsets-13 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,689 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Seeking to EARLIEST offset of partition connect-offsets-18 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,690 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Seeking to EARLIEST offset of partition connect-offsets-22 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,690 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Seeking to EARLIEST offset of partition connect-offsets-8 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,691 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Seeking to EARLIEST offset of partition connect-offsets-2 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,691 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Seeking to EARLIEST offset of partition connect-offsets-12 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,691 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Seeking to EARLIEST offset of partition connect-offsets-19 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,692 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Seeking to EARLIEST offset of partition connect-offsets-14 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,692 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Seeking to EARLIEST offset of partition connect-offsets-1 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,692 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Seeking to EARLIEST offset of partition connect-offsets-6 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,692 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Seeking to EARLIEST offset of partition connect-offsets-7 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,692 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Seeking to EARLIEST offset of partition connect-offsets-21 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,831 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-0 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:56,845 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-5 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:56,845 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-10 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:56,846 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-20 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:56,847 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-15 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:56,847 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-9 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:56,847 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-11 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:56,848 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-4 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:56,848 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-16 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:56,848 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-17 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:56,849 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-3 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:56,850 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-24 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:56,852 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-23 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:56,853 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-13 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:56,853 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-18 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:56,854 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-22 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:56,856 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-8 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:56,856 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-2 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:56,856 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-12 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:56,858 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-19 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:56,858 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-14 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:56,859 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-1 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:56,859 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-6 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:56,859 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-7 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:56,860 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-21 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:56,907 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting offset for partition connect-offsets-9 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka2:9093 (id: 2 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,910 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting offset for partition connect-offsets-7 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka2:9093 (id: 2 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,916 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting offset for partition connect-offsets-23 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka2:9093 (id: 2 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,918 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting offset for partition connect-offsets-13 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka2:9093 (id: 2 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,918 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting offset for partition connect-offsets-11 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka2:9093 (id: 2 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,919 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting offset for partition connect-offsets-1 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka2:9093 (id: 2 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,919 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting offset for partition connect-offsets-17 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka2:9093 (id: 2 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,919 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting offset for partition connect-offsets-15 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka2:9093 (id: 2 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,919 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting offset for partition connect-offsets-5 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka2:9093 (id: 2 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,920 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting offset for partition connect-offsets-21 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka2:9093 (id: 2 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,921 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting offset for partition connect-offsets-3 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka2:9093 (id: 2 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,921 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting offset for partition connect-offsets-19 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka2:9093 (id: 2 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,933 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting offset for partition connect-offsets-10 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka1:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,933 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting offset for partition connect-offsets-8 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka1:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,935 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting offset for partition connect-offsets-14 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka1:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,936 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting offset for partition connect-offsets-12 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka1:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,937 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting offset for partition connect-offsets-2 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka1:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,938 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting offset for partition connect-offsets-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka1:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,939 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting offset for partition connect-offsets-6 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka1:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,940 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting offset for partition connect-offsets-4 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka1:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,940 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting offset for partition connect-offsets-24 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka1:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,940 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting offset for partition connect-offsets-18 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka1:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,941 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting offset for partition connect-offsets-16 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka1:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,941 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting offset for partition connect-offsets-22 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka1:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,942 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Resetting offset for partition connect-offsets-20 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka1:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:56,944 INFO || Finished reading KafkaBasedLog for topic connect-offsets [org.apache.kafka.connect.util.KafkaBasedLog] 2022-10-07 06:01:56,944 INFO || Started KafkaBasedLog for topic connect-offsets [org.apache.kafka.connect.util.KafkaBasedLog] 2022-10-07 06:01:56,945 INFO || Finished reading offsets topic and starting KafkaOffsetBackingStore [org.apache.kafka.connect.storage.KafkaOffsetBackingStore] 2022-10-07 06:01:56,958 INFO || Worker started [org.apache.kafka.connect.runtime.Worker] 2022-10-07 06:01:56,958 INFO || Starting KafkaBasedLog with topic connect-status [org.apache.kafka.connect.util.KafkaBasedLog] 2022-10-07 06:01:57,318 INFO || Started o.e.j.s.ServletContextHandler@37314843{/,null,AVAILABLE} [org.eclipse.jetty.server.handler.ContextHandler] 2022-10-07 06:01:57,327 INFO || REST resources initialized; server is started and ready to handle requests [org.apache.kafka.connect.runtime.rest.RestServer] 2022-10-07 06:01:57,328 INFO || Kafka Connect started [org.apache.kafka.connect.runtime.Connect] 2022-10-07 06:01:57,447 INFO || Created topic (name=connect-status, numPartitions=5, replicationFactor=1, replicasAssignments=null, configs={cleanup.policy=compact}) on brokers at kafka1:9092,kafka2:9093 [org.apache.kafka.connect.util.TopicAdmin] 2022-10-07 06:01:57,449 INFO || ProducerConfig values: acks = -1 batch.size = 16384 bootstrap.servers = [kafka1:9092, kafka2:9093] 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-10-07 06:01:57,467 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:57,467 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:57,468 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:57,468 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:57,468 WARN || The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:57,468 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:57,468 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:57,468 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:57,468 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:57,468 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:57,468 WARN || The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:57,468 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:57,468 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:57,468 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:57,468 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:57,469 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:57,469 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:57,469 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:57,469 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:57,469 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:57,469 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:57,470 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:57,470 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:57,472 INFO || Kafka startTimeMs: 1665122517469 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:57,475 INFO || ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [kafka1:9092, kafka2:9093] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = consumer-oracle-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 = oracle 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-10-07 06:01:57,498 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:57,498 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:57,498 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:57,509 WARN || The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:57,509 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:57,509 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:57,509 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:57,509 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:57,509 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:57,509 WARN || The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:57,509 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:57,509 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:57,509 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:57,509 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:57,509 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:57,509 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:57,509 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:57,509 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:57,509 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:57,510 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:57,510 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:57,510 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:57,510 INFO || Kafka startTimeMs: 1665122517510 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:57,524 INFO || [Producer clientId=producer-2] Cluster ID: O4lpFK1zTvu2J7OTeajnrw [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:57,538 INFO || [Consumer clientId=consumer-oracle-2, groupId=oracle] Cluster ID: O4lpFK1zTvu2J7OTeajnrw [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:57,547 INFO || [Consumer clientId=consumer-oracle-2, groupId=oracle] 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-10-07 06:01:57,547 INFO || [Consumer clientId=consumer-oracle-2, groupId=oracle] Seeking to EARLIEST offset of partition connect-status-0 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:57,547 INFO || [Consumer clientId=consumer-oracle-2, groupId=oracle] Seeking to EARLIEST offset of partition connect-status-4 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:57,547 INFO || [Consumer clientId=consumer-oracle-2, groupId=oracle] Seeking to EARLIEST offset of partition connect-status-1 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:57,547 INFO || [Consumer clientId=consumer-oracle-2, groupId=oracle] Seeking to EARLIEST offset of partition connect-status-2 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:57,548 INFO || [Consumer clientId=consumer-oracle-2, groupId=oracle] Seeking to EARLIEST offset of partition connect-status-3 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:57,588 INFO || [Consumer clientId=consumer-oracle-2, groupId=oracle] Resetting the last seen epoch of partition connect-status-0 to 0 since the associated topicId changed from null to BLTjIZ2xT92JzkhVo-RNqg [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:57,593 INFO || [Consumer clientId=consumer-oracle-2, groupId=oracle] Resetting the last seen epoch of partition connect-status-4 to 0 since the associated topicId changed from null to BLTjIZ2xT92JzkhVo-RNqg [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:57,594 INFO || [Consumer clientId=consumer-oracle-2, groupId=oracle] Resetting the last seen epoch of partition connect-status-1 to 0 since the associated topicId changed from null to BLTjIZ2xT92JzkhVo-RNqg [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:57,596 INFO || [Consumer clientId=consumer-oracle-2, groupId=oracle] Resetting the last seen epoch of partition connect-status-2 to 0 since the associated topicId changed from null to BLTjIZ2xT92JzkhVo-RNqg [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:57,597 INFO || [Consumer clientId=consumer-oracle-2, groupId=oracle] Resetting the last seen epoch of partition connect-status-3 to 0 since the associated topicId changed from null to BLTjIZ2xT92JzkhVo-RNqg [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:57,626 INFO || [Consumer clientId=consumer-oracle-2, groupId=oracle] Resetting offset for partition connect-status-2 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka2:9093 (id: 2 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:57,627 INFO || [Consumer clientId=consumer-oracle-2, groupId=oracle] Resetting offset for partition connect-status-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka2:9093 (id: 2 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:57,634 INFO || [Consumer clientId=consumer-oracle-2, groupId=oracle] Resetting offset for partition connect-status-4 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka2:9093 (id: 2 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:57,666 INFO || [Consumer clientId=consumer-oracle-2, groupId=oracle] Resetting offset for partition connect-status-1 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka1:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:57,666 INFO || [Consumer clientId=consumer-oracle-2, groupId=oracle] Resetting offset for partition connect-status-3 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka1:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:57,668 INFO || Finished reading KafkaBasedLog for topic connect-status [org.apache.kafka.connect.util.KafkaBasedLog] 2022-10-07 06:01:57,668 INFO || Started KafkaBasedLog for topic connect-status [org.apache.kafka.connect.util.KafkaBasedLog] 2022-10-07 06:01:57,686 INFO || Starting KafkaConfigBackingStore [org.apache.kafka.connect.storage.KafkaConfigBackingStore] 2022-10-07 06:01:57,686 INFO || Starting KafkaBasedLog with topic connect-configs [org.apache.kafka.connect.util.KafkaBasedLog] 2022-10-07 06:01:59,015 INFO || Created topic (name=connect-configs, numPartitions=1, replicationFactor=1, replicasAssignments=null, configs={cleanup.policy=compact}) on brokers at kafka1:9092,kafka2:9093 [org.apache.kafka.connect.util.TopicAdmin] 2022-10-07 06:01:59,017 INFO || ProducerConfig values: acks = -1 batch.size = 16384 bootstrap.servers = [kafka1:9092, kafka2:9093] 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-10-07 06:01:59,033 WARN || The configuration 'group.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:59,036 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:59,036 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:59,037 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:59,037 WARN || The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:59,037 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:59,043 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:59,043 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:59,043 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:59,043 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:59,044 WARN || The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:59,044 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:59,044 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:59,044 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:59,045 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:59,045 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:59,045 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:59,045 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:59,046 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:59,046 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:59,046 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:01:59,046 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:59,047 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:59,047 INFO || Kafka startTimeMs: 1665122519046 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:59,056 INFO || ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [kafka1:9092, kafka2:9093] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = consumer-oracle-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 = oracle 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-10-07 06:01:59,059 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Discovered group coordinator kafka2:9093 (id: 2147483645 rack: null) [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2022-10-07 06:01:59,071 INFO || [Producer clientId=producer-3] Cluster ID: O4lpFK1zTvu2J7OTeajnrw [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:59,058 INFO || [Consumer clientId=consumer-oracle-2, groupId=oracle] Discovered group coordinator kafka2:9093 (id: 2147483645 rack: null) [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2022-10-07 06:01:59,115 WARN || The configuration 'rest.advertised.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:59,115 WARN || The configuration 'task.shutdown.graceful.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:59,115 WARN || The configuration 'plugin.path' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:59,115 WARN || The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:59,115 WARN || The configuration 'status.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:59,120 WARN || The configuration 'offset.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:59,123 WARN || The configuration 'value.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:59,123 WARN || The configuration 'key.converter' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:59,124 WARN || The configuration 'config.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:59,130 WARN || The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:59,132 WARN || The configuration 'rest.advertised.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:59,133 WARN || The configuration 'status.storage.topic' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:59,133 WARN || The configuration 'rest.host.name' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:59,133 WARN || The configuration 'offset.flush.timeout.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:59,135 WARN || The configuration 'config.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:59,173 WARN || The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:59,173 WARN || The configuration 'rest.port' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:59,173 WARN || The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:59,173 WARN || The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:59,174 WARN || The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:01:59,174 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:59,174 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:59,174 INFO || Kafka startTimeMs: 1665122519174 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:01:59,221 INFO || [Consumer clientId=consumer-oracle-3, groupId=oracle] Cluster ID: O4lpFK1zTvu2J7OTeajnrw [org.apache.kafka.clients.Metadata] 2022-10-07 06:01:59,246 INFO || [Consumer clientId=consumer-oracle-3, groupId=oracle] Subscribed to partition(s): connect-configs-0 [org.apache.kafka.clients.consumer.KafkaConsumer] 2022-10-07 06:01:59,246 INFO || [Consumer clientId=consumer-oracle-3, groupId=oracle] Seeking to EARLIEST offset of partition connect-configs-0 [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:01:59,270 WARN || Attempt 1 to list offsets for topic partitions resulted in RetriableException; retrying automatically. Reason: This server does not host this topic-partition. [org.apache.kafka.connect.util.RetryUtil] org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. 2022-10-07 06:02:09,294 INFO || [Consumer clientId=consumer-oracle-3, groupId=oracle] Resetting the last seen epoch of partition connect-configs-0 to 0 since the associated topicId changed from null to gqWAVvjGTGOgxBfU9UBvVw [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,303 INFO || [Consumer clientId=consumer-oracle-3, groupId=oracle] Resetting offset for partition connect-configs-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka1:9092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] 2022-10-07 06:02:09,304 INFO || Finished reading KafkaBasedLog for topic connect-configs [org.apache.kafka.connect.util.KafkaBasedLog] 2022-10-07 06:02:09,306 INFO || Started KafkaBasedLog for topic connect-configs [org.apache.kafka.connect.util.KafkaBasedLog] 2022-10-07 06:02:09,307 INFO || Started KafkaConfigBackingStore [org.apache.kafka.connect.storage.KafkaConfigBackingStore] 2022-10-07 06:02:09,308 INFO || [Worker clientId=connect-1, groupId=oracle] Herder started [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-10-07 06:02:09,313 INFO || [Consumer clientId=consumer-oracle-3, groupId=oracle] Discovered group coordinator kafka2:9093 (id: 2147483645 rack: null) [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2022-10-07 06:02:09,323 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-0 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,323 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-5 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,323 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-10 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,323 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-20 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,323 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-15 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,323 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-9 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,323 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-11 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,323 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-4 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,323 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-16 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,323 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-17 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,323 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-3 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,324 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-24 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,324 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-23 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,324 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-13 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,324 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-18 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,324 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-22 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,325 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-8 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,325 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-2 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,325 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-12 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,325 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-19 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,325 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-14 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,325 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-1 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,326 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-6 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,326 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-7 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,326 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition connect-offsets-21 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,326 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition connect-status-0 to 0 since the associated topicId changed from null to BLTjIZ2xT92JzkhVo-RNqg [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,326 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition connect-status-4 to 0 since the associated topicId changed from null to BLTjIZ2xT92JzkhVo-RNqg [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,327 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition connect-status-1 to 0 since the associated topicId changed from null to BLTjIZ2xT92JzkhVo-RNqg [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,327 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition connect-status-2 to 0 since the associated topicId changed from null to BLTjIZ2xT92JzkhVo-RNqg [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,327 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition connect-status-3 to 0 since the associated topicId changed from null to BLTjIZ2xT92JzkhVo-RNqg [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,327 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition connect-configs-0 to 0 since the associated topicId changed from null to gqWAVvjGTGOgxBfU9UBvVw [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,327 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-0 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,327 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-10 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,328 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-20 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,328 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-40 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,328 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-30 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,328 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-9 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,328 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-11 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,328 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-31 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,328 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-39 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,329 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-13 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,329 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-18 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,329 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-22 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,329 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-8 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,329 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-32 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,330 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-43 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,330 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-29 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,330 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-34 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,330 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-1 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,330 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-6 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,330 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-41 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,330 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-27 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,330 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-48 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,331 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-5 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,331 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-15 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,331 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-35 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,331 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-25 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,331 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-46 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,332 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-26 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,332 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-36 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,332 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-44 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,332 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-16 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,332 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-37 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,333 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-17 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,333 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-45 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,333 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-3 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,333 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-24 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,333 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-38 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,333 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-33 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,334 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-23 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,334 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-28 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,334 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-2 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,334 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-12 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,334 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-19 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,334 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-14 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,334 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-4 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,334 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-47 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,334 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-49 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,335 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-42 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,335 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-7 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,335 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition __consumer_offsets-21 to 0 since the associated topicId changed from null to MgglxUGrQDKSGVlQC357MQ [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,337 INFO || [Worker clientId=connect-1, groupId=oracle] Cluster ID: O4lpFK1zTvu2J7OTeajnrw [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:09,337 INFO || [Worker clientId=connect-1, groupId=oracle] Discovered group coordinator kafka2:9093 (id: 2147483645 rack: null) [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-10-07 06:02:09,341 INFO || [Worker clientId=connect-1, groupId=oracle] Rebalance started [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-10-07 06:02:09,342 INFO || [Worker clientId=connect-1, groupId=oracle] (Re-)joining group [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-10-07 06:02:09,380 INFO || [Worker clientId=connect-1, groupId=oracle] (Re-)joining group [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-10-07 06:02:12,406 INFO || [Worker clientId=connect-1, groupId=oracle] Successfully joined group with generation Generation{generationId=1, memberId='connect-1-0411ffe1-50b4-4bcb-a481-ea8b9232a789', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-10-07 06:02:12,563 INFO || [Worker clientId=connect-1, groupId=oracle] Successfully synced group in generation Generation{generationId=1, memberId='connect-1-0411ffe1-50b4-4bcb-a481-ea8b9232a789', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-10-07 06:02:12,564 INFO || [Worker clientId=connect-1, groupId=oracle] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-0411ffe1-50b4-4bcb-a481-ea8b9232a789', leaderUrl='http://192.168.48.6:8083/', offset=-1, connectorIds=[], taskIds=[], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-10-07 06:02:12,566 INFO || [Worker clientId=connect-1, groupId=oracle] Starting connectors and tasks using config offset -1 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-10-07 06:02:12,566 INFO || [Worker clientId=connect-1, groupId=oracle] Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-10-07 06:02:12,599 INFO || [Producer clientId=producer-3] Resetting the last seen epoch of partition connect-configs-0 to 0 since the associated topicId changed from null to gqWAVvjGTGOgxBfU9UBvVw [org.apache.kafka.clients.Metadata] 2022-10-07 06:02:12,763 INFO || [Worker clientId=connect-1, groupId=oracle] Session key updated [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-10-07 06:06:54,839 INFO || [AdminClient clientId=adminclient-8] Node -2 disconnected. [org.apache.kafka.clients.NetworkClient] 2022-10-07 06:08:25,621 INFO || Database Version: Oracle Database 12c Enterprise Edition Release 12.2.0.1.0 - 64bit Production [io.debezium.connector.oracle.OracleConnection] 2022-10-07 06:08:25,625 INFO || Connection gracefully closed [io.debezium.jdbc.JdbcConnection] 2022-10-07 06:08:25,627 INFO || AbstractConfig values: [org.apache.kafka.common.config.AbstractConfig] 2022-10-07 06:08:25,637 INFO || [AdminClient clientId=adminclient-8] Node 2 disconnected. [org.apache.kafka.clients.NetworkClient] 2022-10-07 06:08:25,643 INFO || [Worker clientId=connect-1, groupId=oracle] Connector dbz_oracle config updated [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-10-07 06:08:25,645 INFO || [Worker clientId=connect-1, groupId=oracle] Rebalance started [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-10-07 06:08:25,645 INFO || [Worker clientId=connect-1, groupId=oracle] (Re-)joining group [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-10-07 06:08:25,653 INFO || [Worker clientId=connect-1, groupId=oracle] Successfully joined group with generation Generation{generationId=2, memberId='connect-1-0411ffe1-50b4-4bcb-a481-ea8b9232a789', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-10-07 06:08:25,669 INFO || [Worker clientId=connect-1, groupId=oracle] Successfully synced group in generation Generation{generationId=2, memberId='connect-1-0411ffe1-50b4-4bcb-a481-ea8b9232a789', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-10-07 06:08:25,669 INFO || [Worker clientId=connect-1, groupId=oracle] Joined group at generation 2 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-0411ffe1-50b4-4bcb-a481-ea8b9232a789', leaderUrl='http://192.168.48.6:8083/', offset=2, connectorIds=[dbz_oracle], taskIds=[], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-10-07 06:08:25,669 INFO || [Worker clientId=connect-1, groupId=oracle] Starting connectors and tasks using config offset 2 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-10-07 06:08:25,671 INFO || [Worker clientId=connect-1, groupId=oracle] Starting connector dbz_oracle [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-10-07 06:08:25,676 INFO || Creating connector dbz_oracle of type io.debezium.connector.oracle.OracleConnector [org.apache.kafka.connect.runtime.Worker] 2022-10-07 06:08:25,677 INFO || SourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = dbz_oracle predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = null [org.apache.kafka.connect.runtime.SourceConnectorConfig] 2022-10-07 06:08:25,678 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = dbz_oracle predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = null [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2022-10-07 06:08:25,684 INFO || Instantiated connector dbz_oracle with version 1.9.6.Final of type class io.debezium.connector.oracle.OracleConnector [org.apache.kafka.connect.runtime.Worker] 2022-10-07 06:08:25,686 INFO || Finished creating connector dbz_oracle [org.apache.kafka.connect.runtime.Worker] 2022-10-07 06:08:25,686 INFO || [Worker clientId=connect-1, groupId=oracle] Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-10-07 06:08:25,694 INFO || [Producer clientId=producer-2] Resetting the last seen epoch of partition connect-status-0 to 0 since the associated topicId changed from null to BLTjIZ2xT92JzkhVo-RNqg [org.apache.kafka.clients.Metadata] 2022-10-07 06:08:25,694 INFO || [Producer clientId=producer-2] Resetting the last seen epoch of partition connect-status-4 to 0 since the associated topicId changed from null to BLTjIZ2xT92JzkhVo-RNqg [org.apache.kafka.clients.Metadata] 2022-10-07 06:08:25,695 INFO || [Producer clientId=producer-2] Resetting the last seen epoch of partition connect-status-1 to 0 since the associated topicId changed from null to BLTjIZ2xT92JzkhVo-RNqg [org.apache.kafka.clients.Metadata] 2022-10-07 06:08:25,695 INFO || [Producer clientId=producer-2] Resetting the last seen epoch of partition connect-status-2 to 0 since the associated topicId changed from null to BLTjIZ2xT92JzkhVo-RNqg [org.apache.kafka.clients.Metadata] 2022-10-07 06:08:25,695 INFO || [Producer clientId=producer-2] Resetting the last seen epoch of partition connect-status-3 to 0 since the associated topicId changed from null to BLTjIZ2xT92JzkhVo-RNqg [org.apache.kafka.clients.Metadata] 2022-10-07 06:08:25,707 INFO || SourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = dbz_oracle predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = null [org.apache.kafka.connect.runtime.SourceConnectorConfig] 2022-10-07 06:08:25,708 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = dbz_oracle predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = null [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2022-10-07 06:08:25,738 INFO || [Worker clientId=connect-1, groupId=oracle] Tasks [dbz_oracle-0] configs updated [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-10-07 06:08:25,742 INFO || [Worker clientId=connect-1, groupId=oracle] Handling task config update by restarting tasks [] [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-10-07 06:08:25,743 INFO || [Worker clientId=connect-1, groupId=oracle] Rebalance started [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-10-07 06:08:25,743 INFO || [Worker clientId=connect-1, groupId=oracle] (Re-)joining group [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-10-07 06:08:25,747 INFO || [Worker clientId=connect-1, groupId=oracle] Successfully joined group with generation Generation{generationId=3, memberId='connect-1-0411ffe1-50b4-4bcb-a481-ea8b9232a789', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-10-07 06:08:25,756 INFO || [Worker clientId=connect-1, groupId=oracle] Successfully synced group in generation Generation{generationId=3, memberId='connect-1-0411ffe1-50b4-4bcb-a481-ea8b9232a789', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2022-10-07 06:08:25,757 INFO || [Worker clientId=connect-1, groupId=oracle] Joined group at generation 3 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-0411ffe1-50b4-4bcb-a481-ea8b9232a789', leaderUrl='http://192.168.48.6:8083/', offset=4, connectorIds=[dbz_oracle], taskIds=[dbz_oracle-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-10-07 06:08:25,759 INFO || [Worker clientId=connect-1, groupId=oracle] Starting connectors and tasks using config offset 4 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-10-07 06:08:25,762 INFO || [Worker clientId=connect-1, groupId=oracle] Starting task dbz_oracle-0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-10-07 06:08:25,764 INFO || Creating task dbz_oracle-0 [org.apache.kafka.connect.runtime.Worker] 2022-10-07 06:08:25,767 INFO || ConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = dbz_oracle predicates = [] tasks.max = 1 transforms = [] value.converter = null [org.apache.kafka.connect.runtime.ConnectorConfig] 2022-10-07 06:08:25,768 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = dbz_oracle predicates = [] tasks.max = 1 transforms = [] value.converter = null [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2022-10-07 06:08:25,772 INFO || TaskConfig values: task.class = class io.debezium.connector.oracle.OracleConnectorTask [org.apache.kafka.connect.runtime.TaskConfig] 2022-10-07 06:08:25,774 INFO || Instantiated task dbz_oracle-0 with version 1.9.6.Final of type io.debezium.connector.oracle.OracleConnectorTask [org.apache.kafka.connect.runtime.Worker] 2022-10-07 06:08:25,775 INFO || JsonConverterConfig values: converter.type = key decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = true [org.apache.kafka.connect.json.JsonConverterConfig] 2022-10-07 06:08:25,776 INFO || Set up the key converter class org.apache.kafka.connect.json.JsonConverter for task dbz_oracle-0 using the worker config [org.apache.kafka.connect.runtime.Worker] 2022-10-07 06:08:25,776 INFO || JsonConverterConfig values: converter.type = value decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = true [org.apache.kafka.connect.json.JsonConverterConfig] 2022-10-07 06:08:25,776 INFO || Set up the value converter class org.apache.kafka.connect.json.JsonConverter for task dbz_oracle-0 using the worker config [org.apache.kafka.connect.runtime.Worker] 2022-10-07 06:08:25,777 INFO || Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task dbz_oracle-0 using the worker config [org.apache.kafka.connect.runtime.Worker] 2022-10-07 06:08:25,783 INFO || SourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = dbz_oracle predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = null [org.apache.kafka.connect.runtime.SourceConnectorConfig] 2022-10-07 06:08:25,784 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = null name = dbz_oracle predicates = [] tasks.max = 1 topic.creation.groups = [] transforms = [] value.converter = null [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2022-10-07 06:08:25,787 INFO || Initializing: org.apache.kafka.connect.runtime.TransformationChain{} [org.apache.kafka.connect.runtime.Worker] 2022-10-07 06:08:25,790 INFO || ProducerConfig values: acks = -1 batch.size = 16384 bootstrap.servers = [kafka1:9092, kafka2:9093] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = connector-producer-dbz_oracle-0 compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 2147483647 enable.idempotence = false interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer linger.ms = 0 max.block.ms = 9223372036854775807 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metadata.max.idle.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.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-10-07 06:08:25,836 WARN || The configuration 'metrics.context.connect.kafka.cluster.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:08:25,836 WARN || The configuration 'metrics.context.connect.group.id' was supplied but isn't a known config. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:08:25,837 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:08:25,837 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:08:25,837 INFO || Kafka startTimeMs: 1665122905836 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:08:25,844 INFO || [Producer clientId=connector-producer-dbz_oracle-0] Cluster ID: O4lpFK1zTvu2J7OTeajnrw [org.apache.kafka.clients.Metadata] 2022-10-07 06:08:25,859 INFO || [Worker clientId=connect-1, groupId=oracle] Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2022-10-07 06:08:25,860 INFO || Starting OracleConnectorTask with configuration: [io.debezium.connector.common.BaseSourceTask] 2022-10-07 06:08:25,862 INFO || connector.class = io.debezium.connector.oracle.OracleConnector [io.debezium.connector.common.BaseSourceTask] 2022-10-07 06:08:25,863 INFO || database.dbname = ORCLCDB [io.debezium.connector.common.BaseSourceTask] 2022-10-07 06:08:25,863 INFO || database.user = c##dbzuser [io.debezium.connector.common.BaseSourceTask] 2022-10-07 06:08:25,863 INFO || database.pdb.name = ORCLPDB1 [io.debezium.connector.common.BaseSourceTask] 2022-10-07 06:08:25,863 INFO || database.connection.adapter = logminer [io.debezium.connector.common.BaseSourceTask] 2022-10-07 06:08:25,863 INFO || database.history.kafka.topic = schema-changes.dbz_oracle [io.debezium.connector.common.BaseSourceTask] 2022-10-07 06:08:25,863 INFO || database.history.kafka.bootstrap.servers = kafka1:9092,kafka2:9093 [io.debezium.connector.common.BaseSourceTask] 2022-10-07 06:08:25,863 INFO || schema.include.list = TESTUSER [io.debezium.connector.common.BaseSourceTask] 2022-10-07 06:08:25,863 INFO || database.server.name = ORA [io.debezium.connector.common.BaseSourceTask] 2022-10-07 06:08:25,863 INFO || log.mining.strategy = online_catalog [io.debezium.connector.common.BaseSourceTask] 2022-10-07 06:08:25,864 INFO || database.port = 1521 [io.debezium.connector.common.BaseSourceTask] 2022-10-07 06:08:25,864 INFO || tombstones.on.delete = false [io.debezium.connector.common.BaseSourceTask] 2022-10-07 06:08:25,864 INFO || decimal.handling.mode = double [io.debezium.connector.common.BaseSourceTask] 2022-10-07 06:08:25,864 INFO || task.class = io.debezium.connector.oracle.OracleConnectorTask [io.debezium.connector.common.BaseSourceTask] 2022-10-07 06:08:25,864 INFO || database.hostname = oracle [io.debezium.connector.common.BaseSourceTask] 2022-10-07 06:08:25,864 INFO || database.password = ******** [io.debezium.connector.common.BaseSourceTask] 2022-10-07 06:08:25,864 INFO || name = dbz_oracle [io.debezium.connector.common.BaseSourceTask] 2022-10-07 06:08:25,864 INFO || database.history.skip.unparseable.ddl = true [io.debezium.connector.common.BaseSourceTask] 2022-10-07 06:08:25,864 INFO || lob.enabled = true [io.debezium.connector.common.BaseSourceTask] 2022-10-07 06:08:25,864 INFO || table.include.list = TESTUSER\.(DBZ_TEST_TABLE_UK) [io.debezium.connector.common.BaseSourceTask] 2022-10-07 06:08:25,865 INFO || snapshot.mode = schema_only [io.debezium.connector.common.BaseSourceTask] 2022-10-07 06:08:25,970 INFO || Database Version: Oracle Database 12c Enterprise Edition Release 12.2.0.1.0 - 64bit Production [io.debezium.connector.oracle.OracleConnection] 2022-10-07 06:08:26,012 INFO || KafkaDatabaseHistory Consumer config: {key.deserializer=org.apache.kafka.common.serialization.StringDeserializer, value.deserializer=org.apache.kafka.common.serialization.StringDeserializer, enable.auto.commit=false, group.id=ORA-dbhistory, bootstrap.servers=kafka1:9092,kafka2:9093, fetch.min.bytes=1, session.timeout.ms=10000, auto.offset.reset=earliest, client.id=ORA-dbhistory} [io.debezium.relational.history.KafkaDatabaseHistory] 2022-10-07 06:08:26,012 INFO || KafkaDatabaseHistory Producer config: {retries=1, value.serializer=org.apache.kafka.common.serialization.StringSerializer, acks=1, batch.size=32768, max.block.ms=10000, bootstrap.servers=kafka1:9092,kafka2:9093, buffer.memory=1048576, key.serializer=org.apache.kafka.common.serialization.StringSerializer, client.id=ORA-dbhistory, linger.ms=0} [io.debezium.relational.history.KafkaDatabaseHistory] 2022-10-07 06:08:26,014 INFO || Requested thread factory for connector OracleConnector, id = ORA named = db-history-config-check [io.debezium.util.Threads] 2022-10-07 06:08:26,017 INFO || Idempotence will be disabled because acks is set to 1, not set to 'all'. [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:08:26,018 INFO || ProducerConfig values: acks = 1 batch.size = 32768 bootstrap.servers = [kafka1:9092, kafka2:9093] buffer.memory = 1048576 client.dns.lookup = use_all_dns_ips client.id = ORA-dbhistory 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 = 10000 max.in.flight.requests.per.connection = 5 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 = 1 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.StringSerializer [org.apache.kafka.clients.producer.ProducerConfig] 2022-10-07 06:08:26,022 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:08:26,022 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:08:26,022 INFO || Kafka startTimeMs: 1665122906022 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:08:26,033 INFO || [Producer clientId=ORA-dbhistory] Cluster ID: O4lpFK1zTvu2J7OTeajnrw [org.apache.kafka.clients.Metadata] 2022-10-07 06:08:26,096 INFO || No previous offsets found [io.debezium.connector.common.BaseSourceTask] 2022-10-07 06:08:26,097 INFO || Connector started for the first time, database history recovery will not be executed [io.debezium.connector.oracle.OracleConnectorTask] 2022-10-07 06:08:26,098 INFO || ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = [kafka1:9092, kafka2:9093] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = ORA-dbhistory 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 = ORA-dbhistory 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 = 10000 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.StringDeserializer [org.apache.kafka.clients.consumer.ConsumerConfig] 2022-10-07 06:08:26,102 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:08:26,102 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:08:26,102 INFO || Kafka startTimeMs: 1665122906102 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:08:26,108 INFO || [Consumer clientId=ORA-dbhistory, groupId=ORA-dbhistory] Cluster ID: O4lpFK1zTvu2J7OTeajnrw [org.apache.kafka.clients.Metadata] 2022-10-07 06:08:26,111 INFO || [Consumer clientId=ORA-dbhistory, groupId=ORA-dbhistory] Resetting generation and member id due to: consumer pro-actively leaving the group [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2022-10-07 06:08:26,111 INFO || [Consumer clientId=ORA-dbhistory, groupId=ORA-dbhistory] Request joining group due to: consumer pro-actively leaving the group [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2022-10-07 06:08:26,111 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:08:26,111 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:08:26,111 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:08:26,113 INFO || App info kafka.consumer for ORA-dbhistory unregistered [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:08:26,113 INFO || AdminClientConfig values: bootstrap.servers = [kafka1:9092, kafka2:9093] client.dns.lookup = use_all_dns_ips client.id = ORA-dbhistory 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 = 1 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-10-07 06:08:26,116 WARN || The configuration 'value.serializer' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:08:26,116 WARN || The configuration 'acks' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:08:26,116 WARN || The configuration 'batch.size' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:08:26,117 WARN || The configuration 'max.block.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:08:26,117 WARN || The configuration 'buffer.memory' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:08:26,117 WARN || The configuration 'key.serializer' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:08:26,117 WARN || The configuration 'linger.ms' was supplied but isn't a known config. [org.apache.kafka.clients.admin.AdminClientConfig] 2022-10-07 06:08:26,117 INFO || Kafka version: 3.2.0 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:08:26,117 INFO || Kafka commitId: 38103ffaa962ef50 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:08:26,117 INFO || Kafka startTimeMs: 1665122906117 [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:08:26,119 INFO || Database history topic '(name=schema-changes.dbz_oracle, numPartitions=1, replicationFactor=default, replicasAssignments=null, configs={cleanup.policy=delete, retention.ms=9223372036854775807, retention.bytes=-1})' created [io.debezium.relational.history.KafkaDatabaseHistory] 2022-10-07 06:08:26,180 INFO || App info kafka.admin.client for ORA-dbhistory unregistered [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:08:26,183 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:08:26,183 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:08:26,183 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:08:26,199 INFO || Requested thread factory for connector OracleConnector, id = ORA named = change-event-source-coordinator [io.debezium.util.Threads] 2022-10-07 06:08:26,201 INFO || Creating thread debezium-oracleconnector-ORA-change-event-source-coordinator [io.debezium.util.Threads] 2022-10-07 06:08:26,202 INFO || WorkerSourceTask{id=dbz_oracle-0} Source task finished initialization and start [org.apache.kafka.connect.runtime.WorkerSourceTask] 2022-10-07 06:08:26,205 INFO || WorkerSourceTask{id=dbz_oracle-0} Executing source task [org.apache.kafka.connect.runtime.WorkerSourceTask] 2022-10-07 06:08:26,208 INFO Oracle|ORA|snapshot Metrics registered [io.debezium.pipeline.ChangeEventSourceCoordinator] 2022-10-07 06:08:26,209 INFO Oracle|ORA|snapshot Context created [io.debezium.pipeline.ChangeEventSourceCoordinator] 2022-10-07 06:08:26,217 INFO Oracle|ORA|snapshot No previous offset has been found. [io.debezium.connector.oracle.OracleSnapshotChangeEventSource] 2022-10-07 06:08:26,217 INFO Oracle|ORA|snapshot According to the connector configuration only schema will be snapshot. [io.debezium.connector.oracle.OracleSnapshotChangeEventSource] 2022-10-07 06:08:26,255 INFO Oracle|ORA|snapshot Snapshot step 1 - Preparing [io.debezium.relational.RelationalSnapshotChangeEventSource] 2022-10-07 06:08:26,256 INFO Oracle|ORA|snapshot Snapshot step 2 - Determining captured tables [io.debezium.relational.RelationalSnapshotChangeEventSource] 2022-10-07 06:08:26,573 INFO Oracle|ORA|snapshot Adding table ORCLPDB1.TESTUSER.DBZ_TEST_TABLE_UK to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] 2022-10-07 06:08:26,573 INFO Oracle|ORA|snapshot Adding table ORCLPDB1.TESTUSER.DBZ_TEST_TABLE_NPK_TARGET to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] 2022-10-07 06:08:26,574 INFO Oracle|ORA|snapshot Adding table ORCLPDB1.TESTUSER.DBZ_TEST_TABLE_TARGET to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] 2022-10-07 06:08:26,574 INFO Oracle|ORA|snapshot Adding table ORCLPDB1.TESTUSER.DBZ_TEST_TABLE_NPK to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] 2022-10-07 06:08:26,575 INFO Oracle|ORA|snapshot Adding table ORCLPDB1.TESTUSER.DBZ_TEST_TABLE to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] 2022-10-07 06:08:26,583 INFO Oracle|ORA|snapshot Snapshot step 3 - Locking captured tables [ORCLPDB1.TESTUSER.DBZ_TEST_TABLE_UK] [io.debezium.relational.RelationalSnapshotChangeEventSource] 2022-10-07 06:08:26,589 INFO Oracle|ORA|snapshot Snapshot step 4 - Determining snapshot offset [io.debezium.relational.RelationalSnapshotChangeEventSource] 2022-10-07 06:08:26,758 INFO Oracle|ORA|snapshot No in-progress transactions will be captured. [io.debezium.connector.oracle.logminer.LogMinerAdapter] 2022-10-07 06:08:26,766 INFO Oracle|ORA|snapshot Connection gracefully closed [io.debezium.jdbc.JdbcConnection] 2022-10-07 06:08:26,767 INFO Oracle|ORA|snapshot Snapshot step 5 - Reading structure of captured tables [io.debezium.relational.RelationalSnapshotChangeEventSource] 2022-10-07 06:08:26,767 INFO Oracle|ORA|snapshot All eligible tables schema should be captured, capturing: [ORCLPDB1.TESTUSER.DBZ_TEST_TABLE, ORCLPDB1.TESTUSER.DBZ_TEST_TABLE_NPK, ORCLPDB1.TESTUSER.DBZ_TEST_TABLE_NPK_TARGET, ORCLPDB1.TESTUSER.DBZ_TEST_TABLE_TARGET, ORCLPDB1.TESTUSER.DBZ_TEST_TABLE_UK] [io.debezium.connector.oracle.OracleSnapshotChangeEventSource] 2022-10-07 06:08:27,082 INFO Oracle|ORA|snapshot Snapshot step 6 - Persisting schema history [io.debezium.relational.RelationalSnapshotChangeEventSource] 2022-10-07 06:08:27,082 INFO Oracle|ORA|snapshot Capturing structure of table ORCLPDB1.TESTUSER.DBZ_TEST_TABLE [io.debezium.connector.oracle.OracleSnapshotChangeEventSource] 2022-10-07 06:08:30,052 INFO || [Producer clientId=ORA-dbhistory] Resetting the last seen epoch of partition schema-changes.dbz_oracle-0 to 0 since the associated topicId changed from null to SvWtVRuDR0mP8KqYIay2Hg [org.apache.kafka.clients.Metadata] 2022-10-07 06:08:30,072 INFO Oracle|ORA|snapshot Capturing structure of table ORCLPDB1.TESTUSER.DBZ_TEST_TABLE_NPK [io.debezium.connector.oracle.OracleSnapshotChangeEventSource] 2022-10-07 06:08:30,252 WARN || [Producer clientId=connector-producer-dbz_oracle-0] Error while fetching metadata with correlation id 3 : {ORA=LEADER_NOT_AVAILABLE} [org.apache.kafka.clients.NetworkClient] 2022-10-07 06:08:30,354 INFO || [Producer clientId=connector-producer-dbz_oracle-0] Resetting the last seen epoch of partition ORA-0 to 0 since the associated topicId changed from null to Q-KR20fPT6W6Jyl2K3Cltw [org.apache.kafka.clients.Metadata] 2022-10-07 06:08:30,452 INFO Oracle|ORA|snapshot Capturing structure of table ORCLPDB1.TESTUSER.DBZ_TEST_TABLE_NPK_TARGET [io.debezium.connector.oracle.OracleSnapshotChangeEventSource] 2022-10-07 06:08:30,739 INFO Oracle|ORA|snapshot Capturing structure of table ORCLPDB1.TESTUSER.DBZ_TEST_TABLE_TARGET [io.debezium.connector.oracle.OracleSnapshotChangeEventSource] 2022-10-07 06:08:30,856 INFO || 3 records sent during previous 00:00:05.081, last recorded offset: {snapshot_scn=1813227, snapshot=true, scn=1813227, snapshot_completed=false} [io.debezium.connector.common.BaseSourceTask] 2022-10-07 06:08:31,091 INFO Oracle|ORA|snapshot Capturing structure of table ORCLPDB1.TESTUSER.DBZ_TEST_TABLE_UK [io.debezium.connector.oracle.OracleSnapshotChangeEventSource] 2022-10-07 06:08:31,441 INFO Oracle|ORA|snapshot Snapshot step 7 - Skipping snapshotting of data [io.debezium.relational.RelationalSnapshotChangeEventSource] 2022-10-07 06:08:31,443 INFO Oracle|ORA|snapshot Snapshot - Final stage [io.debezium.pipeline.source.AbstractSnapshotChangeEventSource] 2022-10-07 06:08:31,445 INFO Oracle|ORA|snapshot Snapshot ended with SnapshotResult [status=COMPLETED, offset=OracleOffsetContext [scn=1813227, commit_scn=CommitScn [redoThreadCommitScns={}]]] [io.debezium.pipeline.ChangeEventSourceCoordinator] 2022-10-07 06:08:31,450 INFO Oracle|ORA|streaming Connected metrics set to 'true' [io.debezium.pipeline.ChangeEventSourceCoordinator] 2022-10-07 06:08:31,451 INFO Oracle|ORA|streaming Starting streaming [io.debezium.pipeline.ChangeEventSourceCoordinator] 2022-10-07 06:09:25,827 INFO || [Producer clientId=producer-1] Resetting the last seen epoch of partition connect-offsets-0 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:09:25,827 INFO || [Producer clientId=producer-1] Resetting the last seen epoch of partition connect-offsets-5 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:09:25,828 INFO || [Producer clientId=producer-1] Resetting the last seen epoch of partition connect-offsets-10 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:09:25,828 INFO || [Producer clientId=producer-1] Resetting the last seen epoch of partition connect-offsets-20 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:09:25,828 INFO || [Producer clientId=producer-1] Resetting the last seen epoch of partition connect-offsets-15 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:09:25,828 INFO || [Producer clientId=producer-1] Resetting the last seen epoch of partition connect-offsets-9 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:09:25,829 INFO || [Producer clientId=producer-1] Resetting the last seen epoch of partition connect-offsets-11 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:09:25,829 INFO || [Producer clientId=producer-1] Resetting the last seen epoch of partition connect-offsets-4 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:09:25,829 INFO || [Producer clientId=producer-1] Resetting the last seen epoch of partition connect-offsets-16 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:09:25,829 INFO || [Producer clientId=producer-1] Resetting the last seen epoch of partition connect-offsets-17 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:09:25,829 INFO || [Producer clientId=producer-1] Resetting the last seen epoch of partition connect-offsets-3 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:09:25,829 INFO || [Producer clientId=producer-1] Resetting the last seen epoch of partition connect-offsets-24 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:09:25,829 INFO || [Producer clientId=producer-1] Resetting the last seen epoch of partition connect-offsets-23 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:09:25,829 INFO || [Producer clientId=producer-1] Resetting the last seen epoch of partition connect-offsets-13 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:09:25,829 INFO || [Producer clientId=producer-1] Resetting the last seen epoch of partition connect-offsets-18 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:09:25,829 INFO || [Producer clientId=producer-1] Resetting the last seen epoch of partition connect-offsets-22 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:09:25,829 INFO || [Producer clientId=producer-1] Resetting the last seen epoch of partition connect-offsets-8 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:09:25,830 INFO || [Producer clientId=producer-1] Resetting the last seen epoch of partition connect-offsets-2 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:09:25,830 INFO || [Producer clientId=producer-1] Resetting the last seen epoch of partition connect-offsets-12 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:09:25,830 INFO || [Producer clientId=producer-1] Resetting the last seen epoch of partition connect-offsets-19 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:09:25,830 INFO || [Producer clientId=producer-1] Resetting the last seen epoch of partition connect-offsets-14 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:09:25,830 INFO || [Producer clientId=producer-1] Resetting the last seen epoch of partition connect-offsets-1 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:09:25,830 INFO || [Producer clientId=producer-1] Resetting the last seen epoch of partition connect-offsets-6 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:09:25,830 INFO || [Producer clientId=producer-1] Resetting the last seen epoch of partition connect-offsets-7 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:09:25,830 INFO || [Producer clientId=producer-1] Resetting the last seen epoch of partition connect-offsets-21 to 0 since the associated topicId changed from null to Q8ayRxjTSke_SojMCbz_qA [org.apache.kafka.clients.Metadata] 2022-10-07 06:10:56,771 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Node -1 disconnected. [org.apache.kafka.clients.NetworkClient] 2022-10-07 06:10:57,192 INFO || [Consumer clientId=consumer-oracle-2, groupId=oracle] Node -1 disconnected. [org.apache.kafka.clients.NetworkClient] 2022-10-07 06:10:58,898 INFO || [Consumer clientId=consumer-oracle-2, groupId=oracle] Node 2147483645 disconnected. [org.apache.kafka.clients.NetworkClient] 2022-10-07 06:10:58,900 INFO || [Consumer clientId=consumer-oracle-2, groupId=oracle] Group coordinator kafka2:9093 (id: 2147483645 rack: null) is unavailable or invalid due to cause: coordinator unavailable.isDisconnected: true. Rediscovery will be attempted. [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2022-10-07 06:10:58,908 INFO || [Consumer clientId=consumer-oracle-2, groupId=oracle] Discovered group coordinator kafka2:9093 (id: 2147483645 rack: null) [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2022-10-07 06:10:58,908 INFO || [Consumer clientId=consumer-oracle-2, groupId=oracle] Group coordinator kafka2:9093 (id: 2147483645 rack: null) is unavailable or invalid due to cause: coordinator unavailable.isDisconnected: false. Rediscovery will be attempted. [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2022-10-07 06:10:58,908 INFO || [Consumer clientId=consumer-oracle-2, groupId=oracle] Requesting disconnect from last known coordinator kafka2:9093 (id: 2147483645 rack: null) [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2022-10-07 06:10:59,010 INFO || [Consumer clientId=consumer-oracle-2, groupId=oracle] Discovered group coordinator kafka2:9093 (id: 2147483645 rack: null) [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2022-10-07 06:10:59,233 INFO || [Consumer clientId=consumer-oracle-3, groupId=oracle] Node -1 disconnected. [org.apache.kafka.clients.NetworkClient] 2022-10-07 06:10:59,282 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Node 2147483645 disconnected. [org.apache.kafka.clients.NetworkClient] 2022-10-07 06:10:59,283 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Group coordinator kafka2:9093 (id: 2147483645 rack: null) is unavailable or invalid due to cause: coordinator unavailable.isDisconnected: true. Rediscovery will be attempted. [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2022-10-07 06:10:59,313 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Discovered group coordinator kafka2:9093 (id: 2147483645 rack: null) [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2022-10-07 06:10:59,313 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Group coordinator kafka2:9093 (id: 2147483645 rack: null) is unavailable or invalid due to cause: coordinator unavailable.isDisconnected: false. Rediscovery will be attempted. [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2022-10-07 06:10:59,313 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Requesting disconnect from last known coordinator kafka2:9093 (id: 2147483645 rack: null) [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2022-10-07 06:10:59,416 INFO || [Consumer clientId=consumer-oracle-1, groupId=oracle] Discovered group coordinator kafka2:9093 (id: 2147483645 rack: null) [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2022-10-07 06:11:00,322 INFO || [Producer clientId=producer-2] Node -2 disconnected. [org.apache.kafka.clients.NetworkClient] 2022-10-07 06:11:09,036 INFO || [Worker clientId=connect-1, groupId=oracle] Node -1 disconnected. [org.apache.kafka.clients.NetworkClient] 2022-10-07 06:11:09,041 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition schema-changes.dbz_oracle-0 to 0 since the associated topicId changed from null to SvWtVRuDR0mP8KqYIay2Hg [org.apache.kafka.clients.Metadata] 2022-10-07 06:11:09,041 INFO || [Worker clientId=connect-1, groupId=oracle] Resetting the last seen epoch of partition ORA-0 to 0 since the associated topicId changed from null to Q-KR20fPT6W6Jyl2K3Cltw [org.apache.kafka.clients.Metadata] 2022-10-07 06:11:09,274 INFO || [Consumer clientId=consumer-oracle-3, groupId=oracle] Node 2147483645 disconnected. [org.apache.kafka.clients.NetworkClient] 2022-10-07 06:11:09,275 INFO || [Consumer clientId=consumer-oracle-3, groupId=oracle] Group coordinator kafka2:9093 (id: 2147483645 rack: null) is unavailable or invalid due to cause: coordinator unavailable.isDisconnected: true. Rediscovery will be attempted. [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2022-10-07 06:11:09,280 INFO || [Consumer clientId=consumer-oracle-3, groupId=oracle] Discovered group coordinator kafka2:9093 (id: 2147483645 rack: null) [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2022-10-07 06:11:09,280 INFO || [Consumer clientId=consumer-oracle-3, groupId=oracle] Group coordinator kafka2:9093 (id: 2147483645 rack: null) is unavailable or invalid due to cause: coordinator unavailable.isDisconnected: false. Rediscovery will be attempted. [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2022-10-07 06:11:09,280 INFO || [Consumer clientId=consumer-oracle-3, groupId=oracle] Requesting disconnect from last known coordinator kafka2:9093 (id: 2147483645 rack: null) [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2022-10-07 06:11:09,383 INFO || [Consumer clientId=consumer-oracle-3, groupId=oracle] Discovered group coordinator kafka2:9093 (id: 2147483645 rack: null) [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2022-10-07 06:11:25,752 INFO || [Producer clientId=producer-3] Node -2 disconnected. [org.apache.kafka.clients.NetworkClient] 2022-10-07 06:11:25,753 INFO || [Producer clientId=producer-3] Node 2 disconnected. [org.apache.kafka.clients.NetworkClient] 2022-10-07 06:11:25,831 INFO || [Producer clientId=producer-1] Node -1 disconnected. [org.apache.kafka.clients.NetworkClient] 2022-10-07 06:12:00,916 INFO || 3 records sent during previous 00:03:30.06, last recorded offset: {commit_scn=1814033:1:030007006d020000, transaction_id=null, snapshot_scn=1813227, scn=1814029} [io.debezium.connector.common.BaseSourceTask] 2022-10-07 06:12:00,997 WARN || [Producer clientId=connector-producer-dbz_oracle-0] Error while fetching metadata with correlation id 11 : {ORA.TESTUSER.DBZ_TEST_TABLE_UK=LEADER_NOT_AVAILABLE} [org.apache.kafka.clients.NetworkClient] 2022-10-07 06:12:01,141 WARN || [Producer clientId=connector-producer-dbz_oracle-0] Error while fetching metadata with correlation id 12 : {ORA.TESTUSER.DBZ_TEST_TABLE_UK=LEADER_NOT_AVAILABLE} [org.apache.kafka.clients.NetworkClient] 2022-10-07 06:12:01,142 INFO || [Producer clientId=connector-producer-dbz_oracle-0] Resetting the last seen epoch of partition ORA-0 to 0 since the associated topicId changed from null to Q-KR20fPT6W6Jyl2K3Cltw [org.apache.kafka.clients.Metadata] 2022-10-07 06:12:01,244 INFO || [Producer clientId=connector-producer-dbz_oracle-0] Resetting the last seen epoch of partition ORA.TESTUSER.DBZ_TEST_TABLE_UK-0 to 0 since the associated topicId changed from null to E7LOwSYRTsaGSKENXJUpgA [org.apache.kafka.clients.Metadata] 2022-10-07 06:13:03,436 ERROR Oracle|ORA|streaming Mining session stopped due to the {} [io.debezium.connector.oracle.logminer.LogMinerHelper] io.debezium.DebeziumException: Could not find column COL_VARCHAR in event at io.debezium.connector.oracle.logminer.processor.TransactionCommitConsumer.rowIdFromEvent(TransactionCommitConsumer.java:278) at io.debezium.connector.oracle.logminer.processor.TransactionCommitConsumer.acceptDmlEvent(TransactionCommitConsumer.java:134) at io.debezium.connector.oracle.logminer.processor.TransactionCommitConsumer.accept(TransactionCommitConsumer.java:114) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.handleCommit(AbstractLogMinerEventProcessor.java:439) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processRow(AbstractLogMinerEventProcessor.java:273) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:243) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.process(AbstractLogMinerEventProcessor.java:189) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:210) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:60) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:174) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:141) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:109) 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-10-07 06:13:03,438 ERROR Oracle|ORA|streaming Producer failure [io.debezium.pipeline.ErrorHandler] io.debezium.DebeziumException: Could not find column COL_VARCHAR in event at io.debezium.connector.oracle.logminer.processor.TransactionCommitConsumer.rowIdFromEvent(TransactionCommitConsumer.java:278) at io.debezium.connector.oracle.logminer.processor.TransactionCommitConsumer.acceptDmlEvent(TransactionCommitConsumer.java:134) at io.debezium.connector.oracle.logminer.processor.TransactionCommitConsumer.accept(TransactionCommitConsumer.java:114) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.handleCommit(AbstractLogMinerEventProcessor.java:439) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processRow(AbstractLogMinerEventProcessor.java:273) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:243) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.process(AbstractLogMinerEventProcessor.java:189) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:210) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:60) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:174) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:141) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:109) 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-10-07 06:13:03,442 INFO Oracle|ORA|streaming startScn=1814227, endScn=1814262 [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2022-10-07 06:13:03,444 INFO Oracle|ORA|streaming Streaming metrics dump: OracleStreamingChangeEventSourceMetrics{currentScn=1814262, oldestScn=-1, committedScn=1814254, offsetScn=1814227, logMinerQueryCount=85, totalProcessedRows=4627, totalCapturedDmlCount=62, totalDurationOfFetchingQuery=PT33.598832S, lastCapturedDmlCount=1, lastDurationOfFetchingQuery=PT0.288477S, maxCapturedDmlCount=3, maxDurationOfFetchingQuery=PT1.322188S, totalBatchProcessingDuration=PT34.711389S, lastBatchProcessingDuration=PT0.326303S, maxBatchProcessingThroughput=6, currentLogFileName=[/opt/oracle/oradata/ORCLCDB/redo02.log], minLogFilesMined=1, maxLogFilesMined=1, redoLogStatus=[/opt/oracle/oradata/ORCLCDB/redo02.log | CURRENT, /opt/oracle/oradata/ORCLCDB/redo01.log | INACTIVE, /opt/oracle/oradata/ORCLCDB/redo03.log | INACTIVE], switchCounter=0, batchSize=20000, millisecondToSleepBetweenMiningQuery=2800, hoursToKeepTransaction=0, networkConnectionProblemsCounter0, batchSizeDefault=20000, batchSizeMin=1000, batchSizeMax=100000, sleepTimeDefault=1000, sleepTimeMin=0, sleepTimeMax=3000, sleepTimeIncrement=200, totalParseTime=PT0.00432S, totalStartLogMiningSessionDuration=PT0.444578S, lastStartLogMiningSessionDuration=PT0.003959S, maxStartLogMiningSessionDuration=PT0.056594S, totalProcessTime=PT34.711389S, minBatchProcessTime=PT0.229201S, maxBatchProcessTime=PT1.346641S, totalResultSetNextTime=PT0.001948S, lagFromTheSource=DurationPT4.434376S, maxLagFromTheSourceDuration=PT5.33769S, minLagFromTheSourceDuration=PT1.033353S, lastCommitDuration=PT0.000065S, maxCommitDuration=PT0.048556S, activeTransactions=1, rolledBackTransactions=1, committedTransactions=141, abandonedTransactionIds={}, rolledbackTransactionIds={05001500bf020000=05001500bf020000}, registeredDmlCount=32, committedDmlCount=1, errorCount=1, warningCount=0, scnFreezeCount=0, unparsableDdlCount=0, miningSessionUserGlobalAreaMemory=53256, miningSessionUserGlobalAreaMaxMemory=684200, miningSessionProcessGlobalAreaMemory=185239736, miningSessionProcessGlobalAreaMaxMemory=185239736} [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2022-10-07 06:13:03,444 INFO Oracle|ORA|streaming Offsets: OracleOffsetContext [scn=1814227, commit_scn=CommitScn [redoThreadCommitScns={1=RedoThreadCommitScn{thread=1, commitScn=1814033, txIds=[030007006d020000]}}]] [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2022-10-07 06:13:03,445 INFO Oracle|ORA|streaming Finished streaming [io.debezium.pipeline.ChangeEventSourceCoordinator] 2022-10-07 06:13:03,445 INFO Oracle|ORA|streaming Connected metrics set to 'false' [io.debezium.pipeline.ChangeEventSourceCoordinator] 2022-10-07 06:13:03,892 ERROR || WorkerSourceTask{id=dbz_oracle-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted [org.apache.kafka.connect.runtime.WorkerTask] org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped. at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:50) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:222) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:60) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:174) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:141) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:109) 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) Caused by: io.debezium.DebeziumException: Could not find column COL_VARCHAR in event at io.debezium.connector.oracle.logminer.processor.TransactionCommitConsumer.rowIdFromEvent(TransactionCommitConsumer.java:278) at io.debezium.connector.oracle.logminer.processor.TransactionCommitConsumer.acceptDmlEvent(TransactionCommitConsumer.java:134) at io.debezium.connector.oracle.logminer.processor.TransactionCommitConsumer.accept(TransactionCommitConsumer.java:114) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.handleCommit(AbstractLogMinerEventProcessor.java:439) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processRow(AbstractLogMinerEventProcessor.java:273) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.processResults(AbstractLogMinerEventProcessor.java:243) at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.process(AbstractLogMinerEventProcessor.java:189) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:210) ... 9 more 2022-10-07 06:13:03,895 INFO || Stopping down connector [io.debezium.connector.common.BaseSourceTask] 2022-10-07 06:13:03,996 INFO || Connection gracefully closed [io.debezium.jdbc.JdbcConnection] 2022-10-07 06:13:03,997 INFO || [Producer clientId=ORA-dbhistory] Closing the Kafka producer with timeoutMillis = 30000 ms. [org.apache.kafka.clients.producer.KafkaProducer] 2022-10-07 06:13:04,001 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:13:04,001 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:13:04,001 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:13:04,001 INFO || App info kafka.producer for ORA-dbhistory unregistered [org.apache.kafka.common.utils.AppInfoParser] 2022-10-07 06:13:04,001 INFO || [Producer clientId=connector-producer-dbz_oracle-0] Closing the Kafka producer with timeoutMillis = 30000 ms. [org.apache.kafka.clients.producer.KafkaProducer] 2022-10-07 06:13:04,006 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:13:04,006 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:13:04,006 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2022-10-07 06:13:04,007 INFO || App info kafka.producer for connector-producer-dbz_oracle-0 unregistered [org.apache.kafka.common.utils.AppInfoParser]