Preparing truststore Preparing truststore is complete Starting Kafka Connect with configuration: # Bootstrap servers bootstrap.servers=debezium-cluster-kafka-bootstrap:9092 # REST Listeners rest.port=8083 rest.advertised.host.name=10.130.6.170 rest.advertised.port=8083 # Plugins plugin.path=/opt/kafka/plugins # Provided configuration offset.storage.topic=oracle-connect-cluster-offsets value.converter=org.apache.kafka.connect.json.JsonConverter config.storage.topic=oracle-connect-cluster-configs key.converter=org.apache.kafka.connect.json.JsonConverter group.id=connect-oracle-cluster status.storage.topic=oracle-connect-cluster-status config.providers=secrets config.providers.secrets.class=io.strimzi.kafka.KubernetesSecretConfigProvider config.storage.replication.factor=-1 offset.storage.replication.factor=-1 status.storage.replication.factor=-1 security.protocol=PLAINTEXT producer.security.protocol=PLAINTEXT consumer.security.protocol=PLAINTEXT admin.security.protocol=PLAINTEXT # Additional configuration consumer.client.rack= + exec /usr/bin/tini -w -e 143 -- /opt/kafka/bin/connect-distributed.sh /tmp/strimzi-connect.properties 2023-05-17 08:42:53,524 INFO WorkerInfo values: jvm.args = -Xms1g, -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=/opt/kafka, -Dlog4j.configuration=file:/opt/kafka/custom-config/log4j.properties jvm.spec = Red Hat, Inc., OpenJDK 64-Bit Server VM, 17.0.6, 17.0.6+10-LTS jvm.classpath = /opt/kafka/bin/../libs/accessors-smart-2.4.7.jar:/opt/kafka/bin/../libs/activation-1.1.1.jar:/opt/kafka/bin/../libs/annotations-13.0.jar:/opt/kafka/bin/../libs/aopalliance-repackaged-2.6.1.jar:/opt/kafka/bin/../libs/argparse4j-0.7.0.jar:/opt/kafka/bin/../libs/audience-annotations-0.5.0.jar:/opt/kafka/bin/../libs/checker-qual-3.5.0.jar:/opt/kafka/bin/../libs/commons-cli-1.4.jar:/opt/kafka/bin/../libs/commons-lang-2.6.jar:/opt/kafka/bin/../libs/commons-lang3-3.8.1.jar:/opt/kafka/bin/../libs/connect-api-3.4.0.jar:/opt/kafka/bin/../libs/connect-basic-auth-extension-3.4.0.jar:/opt/kafka/bin/../libs/connect-json-3.4.0.jar:/opt/kafka/bin/../libs/connect-mirror-3.4.0.jar:/opt/kafka/bin/../libs/connect-mirror-client-3.4.0.jar:/opt/kafka/bin/../libs/connect-runtime-3.4.0.jar:/opt/kafka/bin/../libs/connect-transforms-3.4.0.jar:/opt/kafka/bin/../libs/cruise-control-metrics-reporter-2.5.112.jar:/opt/kafka/bin/../libs/error_prone_annotations-2.3.4.jar:/opt/kafka/bin/../libs/failureaccess-1.0.1.jar:/opt/kafka/bin/../libs/gson-2.9.0.jar:/opt/kafka/bin/../libs/guava-30.1-jre.jar:/opt/kafka/bin/../libs/hk2-api-2.6.1.jar:/opt/kafka/bin/../libs/hk2-locator-2.6.1.jar:/opt/kafka/bin/../libs/hk2-utils-2.6.1.jar:/opt/kafka/bin/../libs/j2objc-annotations-1.3.jar:/opt/kafka/bin/../libs/jackson-annotations-2.13.4.jar:/opt/kafka/bin/../libs/jackson-core-2.13.4.jar:/opt/kafka/bin/../libs/jackson-databind-2.13.4.2.jar:/opt/kafka/bin/../libs/jackson-dataformat-csv-2.13.4.jar:/opt/kafka/bin/../libs/jackson-dataformat-yaml-2.13.4.jar:/opt/kafka/bin/../libs/jackson-datatype-jdk8-2.13.4.jar:/opt/kafka/bin/../libs/jackson-datatype-jsr310-2.13.4.jar:/opt/kafka/bin/../libs/jackson-jaxrs-base-2.13.4.jar:/opt/kafka/bin/../libs/jackson-jaxrs-json-provider-2.13.4.jar:/opt/kafka/bin/../libs/jackson-module-jaxb-annotations-2.13.4.jar:/opt/kafka/bin/../libs/jackson-module-scala_2.13-2.13.4.jar:/opt/kafka/bin/../libs/jaeger-client-1.8.1.jar:/opt/kafka/bin/../libs/jaeger-core-1.8.1.jar:/opt/kafka/bin/../libs/jaeger-thrift-1.8.1.jar:/opt/kafka/bin/../libs/jaeger-tracerresolver-1.8.1.jar:/opt/kafka/bin/../libs/jakarta.activation-api-1.2.2.jar:/opt/kafka/bin/../libs/jakarta.annotation-api-1.3.5.jar:/opt/kafka/bin/../libs/jakarta.inject-2.6.1.jar:/opt/kafka/bin/../libs/jakarta.validation-api-2.0.2.jar:/opt/kafka/bin/../libs/jakarta.ws.rs-api-2.1.6.jar:/opt/kafka/bin/../libs/jakarta.xml.bind-api-2.3.3.jar:/opt/kafka/bin/../libs/javassist-3.27.0-GA.jar:/opt/kafka/bin/../libs/javax.annotation-api-1.3.2.jar:/opt/kafka/bin/../libs/javax.servlet-api-3.1.0.jar:/opt/kafka/bin/../libs/javax.ws.rs-api-2.1.1.jar:/opt/kafka/bin/../libs/jaxb-api-2.3.0.jar:/opt/kafka/bin/../libs/jersey-client-2.34.jar:/opt/kafka/bin/../libs/jersey-common-2.34.jar:/opt/kafka/bin/../libs/jersey-container-servlet-2.34.jar:/opt/kafka/bin/../libs/jersey-container-servlet-core-2.34.jar:/opt/kafka/bin/../libs/jersey-hk2-2.34.jar:/opt/kafka/bin/../libs/jersey-server-2.34.jar:/opt/kafka/bin/../libs/jetty-client-9.4.48.v20220622.jar:/opt/kafka/bin/../libs/jetty-continuation-9.4.48.v20220622.jar:/opt/kafka/bin/../libs/jetty-http-9.4.48.v20220622.jar:/opt/kafka/bin/../libs/jetty-io-9.4.48.v20220622.jar:/opt/kafka/bin/../libs/jetty-security-9.4.48.v20220622.jar:/opt/kafka/bin/../libs/jetty-server-9.4.48.v20220622.jar:/opt/kafka/bin/../libs/jetty-servlet-9.4.48.v20220622.jar:/opt/kafka/bin/../libs/jetty-servlets-9.4.48.v20220622.jar:/opt/kafka/bin/../libs/jetty-util-9.4.48.v20220622.jar:/opt/kafka/bin/../libs/jetty-util-ajax-9.4.48.v20220622.jar:/opt/kafka/bin/../libs/jline-3.21.0.jar:/opt/kafka/bin/../libs/jmx_prometheus_javaagent-0.17.2.jar:/opt/kafka/bin/../libs/jopt-simple-5.0.4.jar:/opt/kafka/bin/../libs/jose4j-0.7.9.jar:/opt/kafka/bin/../libs/json-path-2.6.0.jar:/opt/kafka/bin/../libs/json-smart-2.4.7.jar:/opt/kafka/bin/../libs/jsonevent-layout-1.7.jar:/opt/kafka/bin/../libs/jsr305-3.0.2.jar:/opt/kafka/bin/../libs/kafka-agent-0.34.0.jar:/opt/kafka/bin/../libs/kafka-clients-3.4.0.jar:/opt/kafka/bin/../libs/kafka-env-var-config-provider-1.1.0.jar:/opt/kafka/bin/../libs/kafka-group-coordinator-3.4.0.jar:/opt/kafka/bin/../libs/kafka-kubernetes-config-provider-1.1.0.jar:/opt/kafka/bin/../libs/kafka-log4j-appender-3.4.0.jar:/opt/kafka/bin/../libs/kafka-metadata-3.4.0.jar:/opt/kafka/bin/../libs/kafka-oauth-client-0.12.0.jar:/opt/kafka/bin/../libs/kafka-oauth-common-0.12.0.jar:/opt/kafka/bin/../libs/kafka-oauth-keycloak-authorizer-0.12.0.jar:/opt/kafka/bin/../libs/kafka-oauth-server-0.12.0.jar:/opt/kafka/bin/../libs/kafka-oauth-server-plain-0.12.0.jar:/opt/kafka/bin/../libs/kafka-quotas-plugin-0.2.0.jar:/opt/kafka/bin/../libs/kafka-raft-3.4.0.jar:/opt/kafka/bin/../libs/kafka-server-common-3.4.0.jar:/opt/kafka/bin/../libs/kafka-shell-3.4.0.jar:/opt/kafka/bin/../libs/kafka-storage-3.4.0.jar:/opt/kafka/bin/../libs/kafka-storage-api-3.4.0.jar:/opt/kafka/bin/../libs/kafka-streams-3.4.0.jar:/opt/kafka/bin/../libs/kafka-streams-examples-3.4.0.jar:/opt/kafka/bin/../libs/kafka-streams-scala_2.13-3.4.0.jar:/opt/kafka/bin/../libs/kafka-streams-test-utils-3.4.0.jar:/opt/kafka/bin/../libs/kafka-tools-3.4.0.jar:/opt/kafka/bin/../libs/kafka_2.13-3.4.0.jar:/opt/kafka/bin/../libs/kotlin-stdlib-1.4.10.jar:/opt/kafka/bin/../libs/kotlin-stdlib-common-1.4.0.jar:/opt/kafka/bin/../libs/kubernetes-client-6.2.0.jar:/opt/kafka/bin/../libs/kubernetes-client-api-6.2.0.jar:/opt/kafka/bin/../libs/kubernetes-httpclient-okhttp-6.2.0.jar:/opt/kafka/bin/../libs/kubernetes-model-apps-6.2.0.jar:/opt/kafka/bin/../libs/kubernetes-model-batch-6.2.0.jar:/opt/kafka/bin/../libs/kubernetes-model-certificates-6.2.0.jar:/opt/kafka/bin/../libs/kubernetes-model-common-6.2.0.jar:/opt/kafka/bin/../libs/kubernetes-model-core-6.2.0.jar:/opt/kafka/bin/../libs/kubernetes-model-extensions-6.2.0.jar:/opt/kafka/bin/../libs/kubernetes-model-gatewayapi-6.2.0.jar:/opt/kafka/bin/../libs/libthrift-0.15.0.jar:/opt/kafka/bin/../libs/listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar:/opt/kafka/bin/../libs/logging-interceptor-3.12.12.jar:/opt/kafka/bin/../libs/lz4-java-1.8.0.jar:/opt/kafka/bin/../libs/maven-artifact-3.8.4.jar:/opt/kafka/bin/../libs/metrics-core-2.2.0.jar:/opt/kafka/bin/../libs/metrics-core-4.1.12.1.jar:/opt/kafka/bin/../libs/mirror-maker-2-extensions-1.2.0.jar:/opt/kafka/bin/../libs/mirror-maker-agent-0.34.0.jar:/opt/kafka/bin/../libs/netty-buffer-4.1.78.Final.jar:/opt/kafka/bin/../libs/netty-codec-4.1.78.Final.jar:/opt/kafka/bin/../libs/netty-common-4.1.78.Final.jar:/opt/kafka/bin/../libs/netty-handler-4.1.78.Final.jar:/opt/kafka/bin/../libs/netty-resolver-4.1.78.Final.jar:/opt/kafka/bin/../libs/netty-transport-4.1.78.Final.jar:/opt/kafka/bin/../libs/netty-transport-classes-epoll-4.1.78.Final.jar:/opt/kafka/bin/../libs/netty-transport-native-epoll-4.1.78.Final.jar:/opt/kafka/bin/../libs/netty-transport-native-unix-common-4.1.78.Final.jar:/opt/kafka/bin/../libs/nimbus-jose-jwt-9.10.jar:/opt/kafka/bin/../libs/okhttp-4.9.3.jar:/opt/kafka/bin/../libs/okio-2.8.0.jar:/opt/kafka/bin/../libs/opa-authorizer-1.5.1.jar:/opt/kafka/bin/../libs/opentelemetry-api-1.18.0.jar:/opt/kafka/bin/../libs/opentelemetry-context-1.18.0.jar:/opt/kafka/bin/../libs/opentelemetry-exporter-common-1.18.0.jar:/opt/kafka/bin/../libs/opentelemetry-exporter-otlp-1.18.0.jar:/opt/kafka/bin/../libs/opentelemetry-exporter-otlp-common-1.18.0.jar:/opt/kafka/bin/../libs/opentelemetry-instrumentation-api-1.18.0.jar:/opt/kafka/bin/../libs/opentelemetry-instrumentation-api-semconv-1.18.0-alpha.jar:/opt/kafka/bin/../libs/opentelemetry-kafka-clients-2.6-1.18.0-alpha.jar:/opt/kafka/bin/../libs/opentelemetry-kafka-clients-common-1.18.0-alpha.jar:/opt/kafka/bin/../libs/opentelemetry-sdk-1.18.0.jar:/opt/kafka/bin/../libs/opentelemetry-sdk-common-1.18.0.jar:/opt/kafka/bin/../libs/opentelemetry-sdk-extension-autoconfigure-1.18.0-alpha.jar:/opt/kafka/bin/../libs/opentelemetry-sdk-extension-autoconfigure-spi-1.18.0.jar:/opt/kafka/bin/../libs/opentelemetry-sdk-logs-1.18.0-alpha.jar:/opt/kafka/bin/../libs/opentelemetry-sdk-metrics-1.18.0.jar:/opt/kafka/bin/../libs/opentelemetry-sdk-trace-1.18.0.jar:/opt/kafka/bin/../libs/opentelemetry-semconv-1.18.0-alpha.jar:/opt/kafka/bin/../libs/opentracing-api-0.33.0.jar:/opt/kafka/bin/../libs/opentracing-kafka-client-0.1.15.jar:/opt/kafka/bin/../libs/opentracing-noop-0.33.0.jar:/opt/kafka/bin/../libs/opentracing-tracerresolver-0.1.8.jar:/opt/kafka/bin/../libs/opentracing-util-0.33.0.jar:/opt/kafka/bin/../libs/osgi-resource-locator-1.0.3.jar:/opt/kafka/bin/../libs/paranamer-2.8.jar:/opt/kafka/bin/../libs/plexus-utils-3.3.0.jar:/opt/kafka/bin/../libs/reflections-0.9.12.jar:/opt/kafka/bin/../libs/reload4j-1.2.19.jar:/opt/kafka/bin/../libs/rocksdbjni-7.1.2.jar:/opt/kafka/bin/../libs/scala-collection-compat_2.13-2.6.0.jar:/opt/kafka/bin/../libs/scala-java8-compat_2.13-1.0.2.jar:/opt/kafka/bin/../libs/scala-library-2.13.10.jar:/opt/kafka/bin/../libs/scala-logging_2.13-3.9.4.jar:/opt/kafka/bin/../libs/scala-reflect-2.13.10.jar:/opt/kafka/bin/../libs/slf4j-api-1.7.30.jar:/opt/kafka/bin/../libs/slf4j-api-1.7.36.jar:/opt/kafka/bin/../libs/slf4j-reload4j-1.7.36.jar:/opt/kafka/bin/../libs/snakeyaml-1.33.jar:/opt/kafka/bin/../libs/snappy-java-1.1.8.4.jar:/opt/kafka/bin/../libs/swagger-annotations-2.2.0.jar:/opt/kafka/bin/../libs/tracing-agent-0.34.0.jar:/opt/kafka/bin/../libs/trogdor-3.4.0.jar:/opt/kafka/bin/../libs/zjsonpatch-0.3.0.jar:/opt/kafka/bin/../libs/zookeeper-3.6.3.jar:/opt/kafka/bin/../libs/zookeeper-jute-3.6.3.jar:/opt/kafka/bin/../libs/zstd-jni-1.5.2-1.jar os.spec = Linux, amd64, 4.18.0-305.86.2.el8_4.x86_64 os.vcpus = 1 (org.apache.kafka.connect.runtime.WorkerInfo) [main] 2023-05-17 08:42:53,528 INFO Scanning for plugin classes. This might take a moment ... (org.apache.kafka.connect.cli.ConnectDistributed) [main] 2023-05-17 08:42:53,605 INFO Loading plugin from: /opt/kafka/plugins/debezium-oracle-connector (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:42:58,313 INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/plugins/debezium-oracle-connector/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:42:58,314 INFO Added plugin 'io.debezium.connector.oracle.OracleConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:42:58,314 INFO Added plugin 'io.debezium.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:42:58,314 INFO Added plugin 'io.debezium.converters.BinaryDataConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:42:58,314 INFO Added plugin 'io.debezium.converters.CloudEventsConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:42:58,315 INFO Added plugin 'io.debezium.transforms.outbox.EventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:42:58,315 INFO Added plugin 'io.debezium.transforms.ExtractNewRecordState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:42:58,315 INFO Added plugin 'io.debezium.transforms.ExtractChangedRecordState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:42:58,315 INFO Added plugin 'io.debezium.transforms.HeaderToValue' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:42:58,315 INFO Added plugin 'io.debezium.transforms.partitions.PartitionRouting' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:42:58,315 INFO Added plugin 'io.debezium.transforms.partitions.ComputePartition' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:42:58,315 INFO Added plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:42:58,315 INFO Added plugin 'io.debezium.transforms.tracing.ActivateTracingSpan' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:42:58,315 INFO Added plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:42:58,315 INFO Added plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:42:58,316 INFO Added plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,102 INFO Registered loader: jdk.internal.loader.ClassLoaders$AppClassLoader@7ad041f3 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,102 INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,102 INFO Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,102 INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,103 INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,103 INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,103 INFO Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,103 INFO Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,103 INFO Added plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,104 INFO Added plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,104 INFO Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,104 INFO Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,104 INFO Added plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,104 INFO Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,105 INFO Added plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,105 INFO Added plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,105 INFO Added plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,105 INFO Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,105 INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,105 INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,106 INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,106 INFO Added plugin 'org.apache.kafka.connect.transforms.Filter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,106 INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,106 INFO Added plugin 'org.apache.kafka.connect.transforms.HeaderFrom$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,106 INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,106 INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,106 INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,106 INFO Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,106 INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,106 INFO Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,106 INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,107 INFO Added plugin 'org.apache.kafka.connect.transforms.DropHeaders' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,107 INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,107 INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,107 INFO Added plugin 'org.apache.kafka.connect.runtime.PredicatedTransformation' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,107 INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,107 INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,107 INFO Added plugin 'org.apache.kafka.connect.transforms.InsertHeader' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,107 INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,107 INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,108 INFO Added plugin 'org.apache.kafka.connect.transforms.HeaderFrom$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,108 INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,108 INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,108 INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,108 INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,108 INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.HasHeaderKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,108 INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.RecordIsTombstone' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,108 INFO Added plugin 'org.apache.kafka.connect.transforms.predicates.TopicNameMatches' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,108 INFO Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,109 INFO Added plugin 'org.apache.kafka.common.config.provider.DirectoryConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,109 INFO Added plugin 'io.strimzi.kafka.EnvVarConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,109 INFO Added plugin 'io.strimzi.kafka.KubernetesConfigMapConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,109 INFO Added plugin 'io.strimzi.kafka.KubernetesSecretConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,109 INFO Added plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,110 INFO Added aliases 'OracleConnector' and 'Oracle' to plugin 'io.debezium.connector.oracle.OracleConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,111 INFO Added aliases 'MirrorCheckpointConnector' and 'MirrorCheckpoint' to plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,111 INFO Added aliases 'MirrorHeartbeatConnector' and 'MirrorHeartbeat' to plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,111 INFO Added aliases 'MirrorSourceConnector' and 'MirrorSource' to plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,111 INFO Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,111 INFO Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,111 INFO Added aliases 'SchemaSourceConnector' and 'SchemaSource' to plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,111 INFO Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,112 INFO Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,112 INFO Added aliases 'BinaryDataConverter' and 'BinaryData' to plugin 'io.debezium.converters.BinaryDataConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,112 INFO Added aliases 'CloudEventsConverter' and 'CloudEvents' to plugin 'io.debezium.converters.CloudEventsConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,112 INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,112 INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,113 INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,113 INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,113 INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,113 INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,113 INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,113 INFO Added aliases 'BinaryDataConverter' and 'BinaryData' to plugin 'io.debezium.converters.BinaryDataConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,113 INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,114 INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,114 INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,114 INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,114 INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,114 INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,114 INFO Added aliases 'SimpleHeaderConverter' and 'Simple' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,114 INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,115 INFO Added alias 'ByLogicalTableRouter' to plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,115 INFO Added alias 'ExtractChangedRecordState' to plugin 'io.debezium.transforms.ExtractChangedRecordState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,115 INFO Added alias 'ExtractNewRecordState' to plugin 'io.debezium.transforms.ExtractNewRecordState' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,115 INFO Added alias 'HeaderToValue' to plugin 'io.debezium.transforms.HeaderToValue' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,115 INFO Added alias 'EventRouter' to plugin 'io.debezium.transforms.outbox.EventRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,115 INFO Added alias 'ComputePartition' to plugin 'io.debezium.transforms.partitions.ComputePartition' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,115 INFO Added alias 'PartitionRouting' to plugin 'io.debezium.transforms.partitions.PartitionRouting' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,115 INFO Added alias 'ActivateTracingSpan' to plugin 'io.debezium.transforms.tracing.ActivateTracingSpan' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,115 INFO Added aliases 'PredicatedTransformation' and 'Predicated' to plugin 'org.apache.kafka.connect.runtime.PredicatedTransformation' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,116 INFO Added alias 'DropHeaders' to plugin 'org.apache.kafka.connect.transforms.DropHeaders' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,116 INFO Added alias 'Filter' to plugin 'org.apache.kafka.connect.transforms.Filter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,116 INFO Added alias 'InsertHeader' to plugin 'org.apache.kafka.connect.transforms.InsertHeader' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,116 INFO Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,116 INFO Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,116 INFO Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,116 INFO Added alias 'HasHeaderKey' to plugin 'org.apache.kafka.connect.transforms.predicates.HasHeaderKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,116 INFO Added alias 'RecordIsTombstone' to plugin 'org.apache.kafka.connect.transforms.predicates.RecordIsTombstone' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,116 INFO Added alias 'TopicNameMatches' to plugin 'org.apache.kafka.connect.transforms.predicates.TopicNameMatches' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,116 INFO Added alias 'BasicAuthSecurityRestExtension' to plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,116 INFO Added aliases 'AllConnectorClientConfigOverridePolicy' and 'All' to plugin 'org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,116 INFO Added aliases 'NoneConnectorClientConfigOverridePolicy' and 'None' to plugin 'org.apache.kafka.connect.connector.policy.NoneConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,116 INFO Added aliases 'PrincipalConnectorClientConfigOverridePolicy' and 'Principal' to plugin 'org.apache.kafka.connect.connector.policy.PrincipalConnectorClientConfigOverridePolicy' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader) [main] 2023-05-17 08:43:04,239 INFO Configuring Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main] 2023-05-17 08:43:05,237 INFO Closing Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main] 2023-05-17 08:43:05,250 INFO DistributedConfig values: access.control.allow.methods = access.control.allow.origin = admin.listeners = null auto.include.jmx.reporter = true bootstrap.servers = [debezium-cluster-kafka-bootstrap:9092] client.dns.lookup = use_all_dns_ips client.id = config.providers = [secrets] config.storage.replication.factor = -1 config.storage.topic = oracle-connect-cluster-configs connect.protocol = sessioned connections.max.idle.ms = 540000 connector.client.config.override.policy = All exactly.once.source.support = disabled group.id = connect-oracle-cluster 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 = oracle-connect-cluster-offsets plugin.path = [/opt/kafka/plugins] 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 = 10.130.6.170 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 = oracle-connect-cluster-status task.shutdown.graceful.timeout.ms = 5000 topic.creation.enable = true topic.tracking.allow.reset = true topic.tracking.enable = true value.converter = class org.apache.kafka.connect.json.JsonConverter worker.sync.timeout.ms = 3000 worker.unsync.backoff.ms = 300000 (org.apache.kafka.connect.runtime.distributed.DistributedConfig) [main] 2023-05-17 08:43:05,252 INFO Creating Kafka admin client (org.apache.kafka.connect.runtime.WorkerConfig) [main] 2023-05-17 08:43:05,302 INFO Configuring Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main] 2023-05-17 08:43:05,322 INFO Closing Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main] 2023-05-17 08:43:05,323 INFO AdminClientConfig values: auto.include.jmx.reporter = true bootstrap.servers = [debezium-cluster-kafka-bootstrap:9092] client.dns.lookup = use_all_dns_ips client.id = connections.max.idle.ms = 300000 default.api.timeout.ms = 60000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2023-05-17 08:43:05,528 WARN These configurations '[consumer.client.rack, config.storage.topic, producer.security.protocol, rest.advertised.host.name, group.id, status.storage.topic, rest.advertised.port, plugin.path, config.providers, admin.security.protocol, rest.port, config.storage.replication.factor, config.providers.secrets.class, status.storage.replication.factor, offset.storage.replication.factor, offset.storage.topic, consumer.security.protocol, value.converter, key.converter]' were supplied but are not used yet. (org.apache.kafka.clients.admin.AdminClientConfig) [main] 2023-05-17 08:43:05,528 INFO Kafka version: 3.4.0 (org.apache.kafka.common.utils.AppInfoParser) [main] 2023-05-17 08:43:05,529 INFO Kafka commitId: 2e1947d240607d53 (org.apache.kafka.common.utils.AppInfoParser) [main] 2023-05-17 08:43:05,529 INFO Kafka startTimeMs: 1684312985528 (org.apache.kafka.common.utils.AppInfoParser) [main] 2023-05-17 08:43:06,219 INFO Kafka cluster ID: MFQYQMmHSbSn3zMjPTI8gA (org.apache.kafka.connect.runtime.WorkerConfig) [main] 2023-05-17 08:43:06,220 INFO App info kafka.admin.client for adminclient-1 unregistered (org.apache.kafka.common.utils.AppInfoParser) [kafka-admin-client-thread | adminclient-1] 2023-05-17 08:43:06,226 INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-1] 2023-05-17 08:43:06,226 INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-1] 2023-05-17 08:43:06,226 INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [kafka-admin-client-thread | adminclient-1] 2023-05-17 08:43:06,529 INFO Logging initialized @14165ms to org.eclipse.jetty.util.log.Slf4jLog (org.eclipse.jetty.util.log) [main] 2023-05-17 08:43:06,570 INFO Added connector for http://:8083 (org.apache.kafka.connect.runtime.rest.RestServer) [main] 2023-05-17 08:43:06,570 INFO Initializing REST server (org.apache.kafka.connect.runtime.rest.RestServer) [main] 2023-05-17 08:43:06,626 INFO jetty-9.4.48.v20220622; built: 2022-06-21T20:42:25.880Z; git: 6b67c5719d1f4371b33655ff2d047d24e171e49a; jvm 17.0.6+10-LTS (org.eclipse.jetty.server.Server) [main] 2023-05-17 08:43:06,650 INFO Started http_8083@53d2d002{HTTP/1.1, (http/1.1)}{0.0.0.0:8083} (org.eclipse.jetty.server.AbstractConnector) [main] 2023-05-17 08:43:06,650 INFO Started @14285ms (org.eclipse.jetty.server.Server) [main] 2023-05-17 08:43:06,725 INFO Advertised URI: http://10.130.6.170:8083/ (org.apache.kafka.connect.runtime.rest.RestServer) [main] 2023-05-17 08:43:06,725 INFO REST server listening at http://10.130.6.170:8083/, advertising URL http://10.130.6.170:8083/ (org.apache.kafka.connect.runtime.rest.RestServer) [main] 2023-05-17 08:43:06,725 INFO Advertised URI: http://10.130.6.170:8083/ (org.apache.kafka.connect.runtime.rest.RestServer) [main] 2023-05-17 08:43:06,725 INFO REST admin endpoints at http://10.130.6.170:8083/ (org.apache.kafka.connect.runtime.rest.RestServer) [main] 2023-05-17 08:43:06,725 INFO Advertised URI: http://10.130.6.170:8083/ (org.apache.kafka.connect.runtime.rest.RestServer) [main] 2023-05-17 08:43:06,734 INFO Setting up All Policy for ConnectorClientConfigOverride. This will allow all client configurations to be overridden (org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy) [main] 2023-05-17 08:43:06,744 INFO Kafka version: 3.4.0 (org.apache.kafka.common.utils.AppInfoParser) [main] 2023-05-17 08:43:06,744 INFO Kafka commitId: 2e1947d240607d53 (org.apache.kafka.common.utils.AppInfoParser) [main] 2023-05-17 08:43:06,744 INFO Kafka startTimeMs: 1684312986744 (org.apache.kafka.common.utils.AppInfoParser) [main] 2023-05-17 08:43:06,808 INFO JsonConverterConfig values: converter.type = key decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false (org.apache.kafka.connect.json.JsonConverterConfig) [main] 2023-05-17 08:43:06,811 INFO JsonConverterConfig values: converter.type = value decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = false (org.apache.kafka.connect.json.JsonConverterConfig) [main] 2023-05-17 08:43:06,812 INFO Configuring Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [main] 2023-05-17 08:43:06,943 INFO Kafka version: 3.4.0 (org.apache.kafka.common.utils.AppInfoParser) [main] 2023-05-17 08:43:06,943 INFO Kafka commitId: 2e1947d240607d53 (org.apache.kafka.common.utils.AppInfoParser) [main] 2023-05-17 08:43:06,943 INFO Kafka startTimeMs: 1684312986943 (org.apache.kafka.common.utils.AppInfoParser) [main] 2023-05-17 08:43:06,945 INFO Kafka Connect distributed worker initialization took 13418ms (org.apache.kafka.connect.cli.ConnectDistributed) [main] 2023-05-17 08:43:06,946 INFO Kafka Connect starting (org.apache.kafka.connect.runtime.Connect) [main] 2023-05-17 08:43:06,996 INFO Initializing REST resources (org.apache.kafka.connect.runtime.rest.RestServer) [main] 2023-05-17 08:43:06,997 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Herder starting (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1] 2023-05-17 08:43:06,997 INFO Worker starting (org.apache.kafka.connect.runtime.Worker) [DistributedHerder-connect-1-1] 2023-05-17 08:43:06,997 INFO Starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore) [DistributedHerder-connect-1-1] 2023-05-17 08:43:06,997 INFO Starting KafkaBasedLog with topic oracle-connect-cluster-offsets (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-1-1] 2023-05-17 08:43:06,999 INFO Configuring Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1] 2023-05-17 08:43:07,017 INFO Closing Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1] 2023-05-17 08:43:07,017 INFO AdminClientConfig values: auto.include.jmx.reporter = true bootstrap.servers = [debezium-cluster-kafka-bootstrap:9092] client.dns.lookup = use_all_dns_ips client.id = connect-oracle-cluster--shared-admin connections.max.idle.ms = 300000 default.api.timeout.ms = 60000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = 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) [DistributedHerder-connect-1-1] 2023-05-17 08:43:07,021 WARN These configurations '[group.id, rest.advertised.port, plugin.path, config.providers, admin.security.protocol, config.providers.secrets.class, metrics.context.connect.kafka.cluster.id, status.storage.replication.factor, offset.storage.topic, consumer.security.protocol, value.converter, key.converter, consumer.client.rack, config.storage.topic, producer.security.protocol, metrics.context.connect.group.id, rest.advertised.host.name, status.storage.topic, rest.port, config.storage.replication.factor, offset.storage.replication.factor]' were supplied but are not used yet. (org.apache.kafka.clients.admin.AdminClientConfig) [DistributedHerder-connect-1-1] 2023-05-17 08:43:07,021 INFO Kafka version: 3.4.0 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2023-05-17 08:43:07,021 INFO Kafka commitId: 2e1947d240607d53 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2023-05-17 08:43:07,021 INFO Kafka startTimeMs: 1684312987021 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2023-05-17 08:43:07,205 INFO Adding admin resources to main listener (org.apache.kafka.connect.runtime.rest.RestServer) [main] 2023-05-17 08:43:07,310 INFO DefaultSessionIdManager workerName=node0 (org.eclipse.jetty.server.session) [main] 2023-05-17 08:43:07,310 INFO No SessionScavenger set, using defaults (org.eclipse.jetty.server.session) [main] 2023-05-17 08:43:07,312 INFO node0 Scavenging every 600000ms (org.eclipse.jetty.server.session) [main] May 17, 2023 8:43:08 AM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.RootResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.RootResource will be ignored. May 17, 2023 8:43:08 AM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource will be ignored. May 17, 2023 8:43:08 AM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource will be ignored. May 17, 2023 8:43:08 AM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.LoggingResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.LoggingResource will be ignored. 2023-05-17 08:43:08,598 INFO 10.130.6.1 - - [17/May/2023:08:43:08 +0000] "GET / HTTP/1.1" 404 444 "-" "kube-probe/1.23" 300 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-24] 2023-05-17 08:43:08,602 INFO 10.130.6.1 - - [17/May/2023:08:43:08 +0000] "GET / HTTP/1.1" 404 444 "-" "kube-probe/1.23" 304 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-23] 2023-05-17 08:43:08,610 INFO Created topic (name=oracle-connect-cluster-offsets, numPartitions=25, replicationFactor=-1, replicasAssignments=null, configs={cleanup.policy=compact}) on brokers at debezium-cluster-kafka-bootstrap:9092 (org.apache.kafka.connect.util.TopicAdmin) [DistributedHerder-connect-1-1] 2023-05-17 08:43:08,709 INFO Configuring Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1] 2023-05-17 08:43:08,719 INFO Closing Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1] 2023-05-17 08:43:08,720 INFO ProducerConfig values: acks = -1 auto.include.jmx.reporter = true batch.size = 16384 bootstrap.servers = [debezium-cluster-kafka-bootstrap:9092] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = connect-oracle-cluster--offsets compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 2147483647 enable.idempotence = false interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer linger.ms = 0 max.block.ms = 60000 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metadata.max.idle.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.adaptive.partitioning.enable = true partitioner.availability.timeout.ms = 0 partitioner.class = null partitioner.ignore.keys = false receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = 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) [DistributedHerder-connect-1-1] 2023-05-17 08:43:08,820 WARN These configurations '[group.id, rest.advertised.port, plugin.path, config.providers, admin.security.protocol, config.providers.secrets.class, metrics.context.connect.kafka.cluster.id, status.storage.replication.factor, offset.storage.topic, consumer.security.protocol, value.converter, key.converter, consumer.client.rack, config.storage.topic, producer.security.protocol, metrics.context.connect.group.id, rest.advertised.host.name, status.storage.topic, rest.port, config.storage.replication.factor, offset.storage.replication.factor]' were supplied but are not used yet. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2023-05-17 08:43:08,820 INFO Kafka version: 3.4.0 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2023-05-17 08:43:08,820 INFO Kafka commitId: 2e1947d240607d53 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2023-05-17 08:43:08,820 INFO Kafka startTimeMs: 1684312988820 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2023-05-17 08:43:08,903 INFO [Producer clientId=connect-oracle-cluster--offsets] Cluster ID: MFQYQMmHSbSn3zMjPTI8gA (org.apache.kafka.clients.Metadata) [kafka-producer-network-thread | connect-oracle-cluster--offsets] 2023-05-17 08:43:08,913 INFO Configuring Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1] 2023-05-17 08:43:08,921 INFO Closing Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1] 2023-05-17 08:43:08,922 INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.include.jmx.reporter = true auto.offset.reset = earliest bootstrap.servers = [debezium-cluster-kafka-bootstrap:9092] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = connect-oracle-cluster--offsets client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = connect-oracle-cluster 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) [DistributedHerder-connect-1-1] May 17, 2023 8:43:09 AM org.glassfish.jersey.internal.Errors logErrors WARNING: The following warnings have been detected: WARNING: The (sub)resource method listLoggers in org.apache.kafka.connect.runtime.rest.resources.LoggingResource contains empty path annotation. WARNING: The (sub)resource method createConnector in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation. WARNING: The (sub)resource method listConnectors in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation. WARNING: The (sub)resource method listConnectorPlugins in org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource contains empty path annotation. WARNING: The (sub)resource method serverInfo in org.apache.kafka.connect.runtime.rest.resources.RootResource contains empty path annotation. 2023-05-17 08:43:09,102 INFO Started o.e.j.s.ServletContextHandler@58eac00e{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler) [main] 2023-05-17 08:43:09,102 INFO REST resources initialized; server is started and ready to handle requests (org.apache.kafka.connect.runtime.rest.RestServer) [main] 2023-05-17 08:43:09,102 INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect) [main] 2023-05-17 08:43:09,111 WARN These configurations '[rest.advertised.port, plugin.path, config.providers, admin.security.protocol, config.providers.secrets.class, metrics.context.connect.kafka.cluster.id, status.storage.replication.factor, offset.storage.topic, consumer.security.protocol, value.converter, key.converter, consumer.client.rack, config.storage.topic, producer.security.protocol, metrics.context.connect.group.id, rest.advertised.host.name, status.storage.topic, rest.port, config.storage.replication.factor, offset.storage.replication.factor]' were supplied but are not used yet. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,111 INFO Kafka version: 3.4.0 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,111 INFO Kafka commitId: 2e1947d240607d53 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,111 INFO Kafka startTimeMs: 1684312989111 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,120 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Cluster ID: MFQYQMmHSbSn3zMjPTI8gA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,124 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Assigned to partition(s): oracle-connect-cluster-offsets-0, oracle-connect-cluster-offsets-5, oracle-connect-cluster-offsets-10, oracle-connect-cluster-offsets-20, oracle-connect-cluster-offsets-15, oracle-connect-cluster-offsets-9, oracle-connect-cluster-offsets-11, oracle-connect-cluster-offsets-16, oracle-connect-cluster-offsets-4, oracle-connect-cluster-offsets-17, oracle-connect-cluster-offsets-3, oracle-connect-cluster-offsets-24, oracle-connect-cluster-offsets-23, oracle-connect-cluster-offsets-13, oracle-connect-cluster-offsets-18, oracle-connect-cluster-offsets-22, oracle-connect-cluster-offsets-2, oracle-connect-cluster-offsets-8, oracle-connect-cluster-offsets-12, oracle-connect-cluster-offsets-19, oracle-connect-cluster-offsets-14, oracle-connect-cluster-offsets-1, oracle-connect-cluster-offsets-6, oracle-connect-cluster-offsets-7, oracle-connect-cluster-offsets-21 (org.apache.kafka.clients.consumer.KafkaConsumer) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,126 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Seeking to earliest offset of partition oracle-connect-cluster-offsets-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,127 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Seeking to earliest offset of partition oracle-connect-cluster-offsets-5 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,127 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Seeking to earliest offset of partition oracle-connect-cluster-offsets-10 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,127 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Seeking to earliest offset of partition oracle-connect-cluster-offsets-20 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,127 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Seeking to earliest offset of partition oracle-connect-cluster-offsets-15 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,127 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Seeking to earliest offset of partition oracle-connect-cluster-offsets-9 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,127 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Seeking to earliest offset of partition oracle-connect-cluster-offsets-11 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,127 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Seeking to earliest offset of partition oracle-connect-cluster-offsets-16 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,127 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Seeking to earliest offset of partition oracle-connect-cluster-offsets-4 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,127 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Seeking to earliest offset of partition oracle-connect-cluster-offsets-17 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,127 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Seeking to earliest offset of partition oracle-connect-cluster-offsets-3 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,127 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Seeking to earliest offset of partition oracle-connect-cluster-offsets-24 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,127 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Seeking to earliest offset of partition oracle-connect-cluster-offsets-23 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,127 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Seeking to earliest offset of partition oracle-connect-cluster-offsets-13 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,127 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Seeking to earliest offset of partition oracle-connect-cluster-offsets-18 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,127 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Seeking to earliest offset of partition oracle-connect-cluster-offsets-22 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,127 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Seeking to earliest offset of partition oracle-connect-cluster-offsets-2 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,127 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Seeking to earliest offset of partition oracle-connect-cluster-offsets-8 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,127 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Seeking to earliest offset of partition oracle-connect-cluster-offsets-12 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,127 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Seeking to earliest offset of partition oracle-connect-cluster-offsets-19 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,127 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Seeking to earliest offset of partition oracle-connect-cluster-offsets-14 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,127 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Seeking to earliest offset of partition oracle-connect-cluster-offsets-1 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,127 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Seeking to earliest offset of partition oracle-connect-cluster-offsets-6 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,127 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Seeking to earliest offset of partition oracle-connect-cluster-offsets-7 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,127 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Seeking to earliest offset of partition oracle-connect-cluster-offsets-21 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,311 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-0 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,311 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-5 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,311 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-10 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,312 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-20 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,312 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-15 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,312 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-9 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,312 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-11 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,312 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-16 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,312 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-4 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,312 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-17 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,312 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-3 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,312 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-24 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,312 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-23 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,312 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-13 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,312 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-18 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,313 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-22 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,313 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-2 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,313 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-8 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,313 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-12 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,313 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-19 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,313 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-14 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,313 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-1 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,313 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-6 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,313 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-7 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,313 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-21 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,323 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting offset for partition oracle-connect-cluster-offsets-20 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[debezium-cluster-kafka-0.debezium-cluster-kafka-brokers.cytric-cdc.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,323 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting offset for partition oracle-connect-cluster-offsets-18 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[debezium-cluster-kafka-0.debezium-cluster-kafka-brokers.cytric-cdc.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,323 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting offset for partition oracle-connect-cluster-offsets-16 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[debezium-cluster-kafka-0.debezium-cluster-kafka-brokers.cytric-cdc.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,323 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting offset for partition oracle-connect-cluster-offsets-14 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[debezium-cluster-kafka-0.debezium-cluster-kafka-brokers.cytric-cdc.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,324 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting offset for partition oracle-connect-cluster-offsets-24 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[debezium-cluster-kafka-0.debezium-cluster-kafka-brokers.cytric-cdc.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,324 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting offset for partition oracle-connect-cluster-offsets-22 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[debezium-cluster-kafka-0.debezium-cluster-kafka-brokers.cytric-cdc.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,324 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting offset for partition oracle-connect-cluster-offsets-4 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[debezium-cluster-kafka-0.debezium-cluster-kafka-brokers.cytric-cdc.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,324 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting offset for partition oracle-connect-cluster-offsets-2 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[debezium-cluster-kafka-0.debezium-cluster-kafka-brokers.cytric-cdc.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,324 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting offset for partition oracle-connect-cluster-offsets-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[debezium-cluster-kafka-0.debezium-cluster-kafka-brokers.cytric-cdc.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,324 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting offset for partition oracle-connect-cluster-offsets-12 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[debezium-cluster-kafka-0.debezium-cluster-kafka-brokers.cytric-cdc.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,324 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting offset for partition oracle-connect-cluster-offsets-10 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[debezium-cluster-kafka-0.debezium-cluster-kafka-brokers.cytric-cdc.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,324 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting offset for partition oracle-connect-cluster-offsets-8 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[debezium-cluster-kafka-0.debezium-cluster-kafka-brokers.cytric-cdc.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,324 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting offset for partition oracle-connect-cluster-offsets-6 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[debezium-cluster-kafka-0.debezium-cluster-kafka-brokers.cytric-cdc.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,324 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting offset for partition oracle-connect-cluster-offsets-19 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[debezium-cluster-kafka-0.debezium-cluster-kafka-brokers.cytric-cdc.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,324 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting offset for partition oracle-connect-cluster-offsets-17 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[debezium-cluster-kafka-0.debezium-cluster-kafka-brokers.cytric-cdc.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,324 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting offset for partition oracle-connect-cluster-offsets-15 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[debezium-cluster-kafka-0.debezium-cluster-kafka-brokers.cytric-cdc.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,324 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting offset for partition oracle-connect-cluster-offsets-13 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[debezium-cluster-kafka-0.debezium-cluster-kafka-brokers.cytric-cdc.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,324 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting offset for partition oracle-connect-cluster-offsets-23 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[debezium-cluster-kafka-0.debezium-cluster-kafka-brokers.cytric-cdc.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,324 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting offset for partition oracle-connect-cluster-offsets-21 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[debezium-cluster-kafka-0.debezium-cluster-kafka-brokers.cytric-cdc.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,324 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting offset for partition oracle-connect-cluster-offsets-3 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[debezium-cluster-kafka-0.debezium-cluster-kafka-brokers.cytric-cdc.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,324 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting offset for partition oracle-connect-cluster-offsets-1 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[debezium-cluster-kafka-0.debezium-cluster-kafka-brokers.cytric-cdc.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,324 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting offset for partition oracle-connect-cluster-offsets-11 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[debezium-cluster-kafka-0.debezium-cluster-kafka-brokers.cytric-cdc.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,324 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting offset for partition oracle-connect-cluster-offsets-9 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[debezium-cluster-kafka-0.debezium-cluster-kafka-brokers.cytric-cdc.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,324 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting offset for partition oracle-connect-cluster-offsets-7 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[debezium-cluster-kafka-0.debezium-cluster-kafka-brokers.cytric-cdc.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,324 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Resetting offset for partition oracle-connect-cluster-offsets-5 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[debezium-cluster-kafka-0.debezium-cluster-kafka-brokers.cytric-cdc.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,325 INFO Finished reading KafkaBasedLog for topic oracle-connect-cluster-offsets (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,325 INFO Started KafkaBasedLog for topic oracle-connect-cluster-offsets (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,325 INFO Finished reading offsets topic and starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,327 INFO Worker started (org.apache.kafka.connect.runtime.Worker) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,327 INFO Starting KafkaBasedLog with topic oracle-connect-cluster-status (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,578 INFO Created topic (name=oracle-connect-cluster-status, numPartitions=5, replicationFactor=-1, replicasAssignments=null, configs={cleanup.policy=compact}) on brokers at debezium-cluster-kafka-bootstrap:9092 (org.apache.kafka.connect.util.TopicAdmin) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,579 INFO Configuring Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,599 INFO Closing Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,601 INFO ProducerConfig values: acks = -1 auto.include.jmx.reporter = true batch.size = 16384 bootstrap.servers = [debezium-cluster-kafka-bootstrap:9092] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = connect-oracle-cluster--statuses compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 120000 enable.idempotence = false interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.StringSerializer linger.ms = 0 max.block.ms = 60000 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metadata.max.idle.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.adaptive.partitioning.enable = true partitioner.availability.timeout.ms = 0 partitioner.class = null partitioner.ignore.keys = false receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 0 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = 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) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,609 WARN These configurations '[group.id, rest.advertised.port, plugin.path, config.providers, admin.security.protocol, config.providers.secrets.class, metrics.context.connect.kafka.cluster.id, status.storage.replication.factor, offset.storage.topic, consumer.security.protocol, value.converter, key.converter, consumer.client.rack, config.storage.topic, producer.security.protocol, metrics.context.connect.group.id, rest.advertised.host.name, status.storage.topic, rest.port, config.storage.replication.factor, offset.storage.replication.factor]' were supplied but are not used yet. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,609 INFO Kafka version: 3.4.0 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,609 INFO Kafka commitId: 2e1947d240607d53 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,609 INFO Kafka startTimeMs: 1684312989609 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,610 INFO Configuring Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,617 INFO [Producer clientId=connect-oracle-cluster--statuses] Cluster ID: MFQYQMmHSbSn3zMjPTI8gA (org.apache.kafka.clients.Metadata) [kafka-producer-network-thread | connect-oracle-cluster--statuses] 2023-05-17 08:43:09,618 INFO Closing Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,618 INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.include.jmx.reporter = true auto.offset.reset = earliest bootstrap.servers = [debezium-cluster-kafka-bootstrap:9092] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = connect-oracle-cluster--statuses client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = connect-oracle-cluster 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) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,622 WARN These configurations '[rest.advertised.port, plugin.path, config.providers, admin.security.protocol, config.providers.secrets.class, metrics.context.connect.kafka.cluster.id, status.storage.replication.factor, offset.storage.topic, consumer.security.protocol, value.converter, key.converter, consumer.client.rack, config.storage.topic, producer.security.protocol, metrics.context.connect.group.id, rest.advertised.host.name, status.storage.topic, rest.port, config.storage.replication.factor, offset.storage.replication.factor]' were supplied but are not used yet. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,622 INFO Kafka version: 3.4.0 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,623 INFO Kafka commitId: 2e1947d240607d53 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,623 INFO Kafka startTimeMs: 1684312989622 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,628 INFO [Consumer clientId=connect-oracle-cluster--statuses, groupId=connect-oracle-cluster] Cluster ID: MFQYQMmHSbSn3zMjPTI8gA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,629 INFO [Consumer clientId=connect-oracle-cluster--statuses, groupId=connect-oracle-cluster] Assigned to partition(s): oracle-connect-cluster-status-0, oracle-connect-cluster-status-1, oracle-connect-cluster-status-4, oracle-connect-cluster-status-2, oracle-connect-cluster-status-3 (org.apache.kafka.clients.consumer.KafkaConsumer) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,629 INFO [Consumer clientId=connect-oracle-cluster--statuses, groupId=connect-oracle-cluster] Seeking to earliest offset of partition oracle-connect-cluster-status-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,629 INFO [Consumer clientId=connect-oracle-cluster--statuses, groupId=connect-oracle-cluster] Seeking to earliest offset of partition oracle-connect-cluster-status-1 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,629 INFO [Consumer clientId=connect-oracle-cluster--statuses, groupId=connect-oracle-cluster] Seeking to earliest offset of partition oracle-connect-cluster-status-4 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,629 INFO [Consumer clientId=connect-oracle-cluster--statuses, groupId=connect-oracle-cluster] Seeking to earliest offset of partition oracle-connect-cluster-status-2 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,629 INFO [Consumer clientId=connect-oracle-cluster--statuses, groupId=connect-oracle-cluster] Seeking to earliest offset of partition oracle-connect-cluster-status-3 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,710 INFO [Consumer clientId=connect-oracle-cluster--statuses, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-status-0 to 0 since the associated topicId changed from null to aqu-EAXJSWehkiwvYrUILg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,710 INFO [Consumer clientId=connect-oracle-cluster--statuses, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-status-1 to 0 since the associated topicId changed from null to aqu-EAXJSWehkiwvYrUILg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,710 INFO [Consumer clientId=connect-oracle-cluster--statuses, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-status-4 to 0 since the associated topicId changed from null to aqu-EAXJSWehkiwvYrUILg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,710 INFO [Consumer clientId=connect-oracle-cluster--statuses, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-status-2 to 0 since the associated topicId changed from null to aqu-EAXJSWehkiwvYrUILg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,711 INFO [Consumer clientId=connect-oracle-cluster--statuses, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-status-3 to 0 since the associated topicId changed from null to aqu-EAXJSWehkiwvYrUILg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,715 INFO [Consumer clientId=connect-oracle-cluster--statuses, groupId=connect-oracle-cluster] Resetting offset for partition oracle-connect-cluster-status-4 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[debezium-cluster-kafka-0.debezium-cluster-kafka-brokers.cytric-cdc.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,715 INFO [Consumer clientId=connect-oracle-cluster--statuses, groupId=connect-oracle-cluster] Resetting offset for partition oracle-connect-cluster-status-3 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[debezium-cluster-kafka-0.debezium-cluster-kafka-brokers.cytric-cdc.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,715 INFO [Consumer clientId=connect-oracle-cluster--statuses, groupId=connect-oracle-cluster] Resetting offset for partition oracle-connect-cluster-status-2 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[debezium-cluster-kafka-0.debezium-cluster-kafka-brokers.cytric-cdc.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,715 INFO [Consumer clientId=connect-oracle-cluster--statuses, groupId=connect-oracle-cluster] Resetting offset for partition oracle-connect-cluster-status-1 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[debezium-cluster-kafka-0.debezium-cluster-kafka-brokers.cytric-cdc.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,715 INFO [Consumer clientId=connect-oracle-cluster--statuses, groupId=connect-oracle-cluster] Resetting offset for partition oracle-connect-cluster-status-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[debezium-cluster-kafka-0.debezium-cluster-kafka-brokers.cytric-cdc.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,716 INFO Finished reading KafkaBasedLog for topic oracle-connect-cluster-status (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,716 INFO Started KafkaBasedLog for topic oracle-connect-cluster-status (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,719 INFO Starting KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,719 INFO Starting KafkaBasedLog with topic oracle-connect-cluster-configs (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,769 INFO Created topic (name=oracle-connect-cluster-configs, numPartitions=1, replicationFactor=-1, replicasAssignments=null, configs={cleanup.policy=compact}) on brokers at debezium-cluster-kafka-bootstrap:9092 (org.apache.kafka.connect.util.TopicAdmin) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,770 INFO Configuring Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,798 INFO Closing Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,799 INFO ProducerConfig values: acks = -1 auto.include.jmx.reporter = true batch.size = 16384 bootstrap.servers = [debezium-cluster-kafka-bootstrap:9092] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = connect-oracle-cluster--configs compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 2147483647 enable.idempotence = false interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.StringSerializer linger.ms = 0 max.block.ms = 60000 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metadata.max.idle.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.adaptive.partitioning.enable = true partitioner.availability.timeout.ms = 0 partitioner.class = null partitioner.ignore.keys = false receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = 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) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,807 WARN These configurations '[group.id, rest.advertised.port, plugin.path, config.providers, admin.security.protocol, config.providers.secrets.class, metrics.context.connect.kafka.cluster.id, status.storage.replication.factor, offset.storage.topic, consumer.security.protocol, value.converter, key.converter, consumer.client.rack, config.storage.topic, producer.security.protocol, metrics.context.connect.group.id, rest.advertised.host.name, status.storage.topic, rest.port, config.storage.replication.factor, offset.storage.replication.factor]' were supplied but are not used yet. (org.apache.kafka.clients.producer.ProducerConfig) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,807 INFO Kafka version: 3.4.0 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,808 INFO Kafka commitId: 2e1947d240607d53 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,808 INFO Kafka startTimeMs: 1684312989807 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,808 INFO Configuring Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,814 INFO [Producer clientId=connect-oracle-cluster--configs] Cluster ID: MFQYQMmHSbSn3zMjPTI8gA (org.apache.kafka.clients.Metadata) [kafka-producer-network-thread | connect-oracle-cluster--configs] 2023-05-17 08:43:09,815 INFO Closing Kubernetes Secret config provider (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,816 INFO ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.include.jmx.reporter = true auto.offset.reset = earliest bootstrap.servers = [debezium-cluster-kafka-bootstrap:9092] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = connect-oracle-cluster--configs client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = connect-oracle-cluster 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) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,818 WARN These configurations '[rest.advertised.port, plugin.path, config.providers, admin.security.protocol, config.providers.secrets.class, metrics.context.connect.kafka.cluster.id, status.storage.replication.factor, offset.storage.topic, consumer.security.protocol, value.converter, key.converter, consumer.client.rack, config.storage.topic, producer.security.protocol, metrics.context.connect.group.id, rest.advertised.host.name, status.storage.topic, rest.port, config.storage.replication.factor, offset.storage.replication.factor]' were supplied but are not used yet. (org.apache.kafka.clients.consumer.ConsumerConfig) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,819 INFO Kafka version: 3.4.0 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,819 INFO Kafka commitId: 2e1947d240607d53 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,819 INFO Kafka startTimeMs: 1684312989818 (org.apache.kafka.common.utils.AppInfoParser) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,824 INFO [Consumer clientId=connect-oracle-cluster--configs, groupId=connect-oracle-cluster] Cluster ID: MFQYQMmHSbSn3zMjPTI8gA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,825 INFO [Consumer clientId=connect-oracle-cluster--configs, groupId=connect-oracle-cluster] Assigned to partition(s): oracle-connect-cluster-configs-0 (org.apache.kafka.clients.consumer.KafkaConsumer) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,825 INFO [Consumer clientId=connect-oracle-cluster--configs, groupId=connect-oracle-cluster] Seeking to earliest offset of partition oracle-connect-cluster-configs-0 (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,835 INFO [Consumer clientId=connect-oracle-cluster--configs, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-configs-0 to 0 since the associated topicId changed from null to z2jlOuFsRRKRrobT8ZzDOQ (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,899 INFO [Consumer clientId=connect-oracle-cluster--configs, groupId=connect-oracle-cluster] Resetting offset for partition oracle-connect-cluster-configs-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[debezium-cluster-kafka-0.debezium-cluster-kafka-brokers.cytric-cdc.svc:9092 (id: 0 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,900 INFO Finished reading KafkaBasedLog for topic oracle-connect-cluster-configs (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,900 INFO Started KafkaBasedLog for topic oracle-connect-cluster-configs (org.apache.kafka.connect.util.KafkaBasedLog) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,900 INFO Started KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,900 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Herder started (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,911 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition mysql.inventory.customers-0 to 0 since the associated topicId changed from null to Fryh-JFkS8SS1rvINBOVMw (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,911 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition connect-cluster-offsets-0 to 0 since the associated topicId changed from null to lwI1uye1RWSDXoX9nNPq6w (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,911 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition connect-cluster-offsets-5 to 0 since the associated topicId changed from null to lwI1uye1RWSDXoX9nNPq6w (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,911 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition connect-cluster-offsets-10 to 0 since the associated topicId changed from null to lwI1uye1RWSDXoX9nNPq6w (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,911 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition connect-cluster-offsets-20 to 0 since the associated topicId changed from null to lwI1uye1RWSDXoX9nNPq6w (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,911 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition connect-cluster-offsets-15 to 0 since the associated topicId changed from null to lwI1uye1RWSDXoX9nNPq6w (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,911 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition connect-cluster-offsets-9 to 0 since the associated topicId changed from null to lwI1uye1RWSDXoX9nNPq6w (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,911 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition connect-cluster-offsets-11 to 0 since the associated topicId changed from null to lwI1uye1RWSDXoX9nNPq6w (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,911 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition connect-cluster-offsets-16 to 0 since the associated topicId changed from null to lwI1uye1RWSDXoX9nNPq6w (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,912 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition connect-cluster-offsets-4 to 0 since the associated topicId changed from null to lwI1uye1RWSDXoX9nNPq6w (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,912 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition connect-cluster-offsets-17 to 0 since the associated topicId changed from null to lwI1uye1RWSDXoX9nNPq6w (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,912 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition connect-cluster-offsets-3 to 0 since the associated topicId changed from null to lwI1uye1RWSDXoX9nNPq6w (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,912 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition connect-cluster-offsets-24 to 0 since the associated topicId changed from null to lwI1uye1RWSDXoX9nNPq6w (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,912 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition connect-cluster-offsets-23 to 0 since the associated topicId changed from null to lwI1uye1RWSDXoX9nNPq6w (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,912 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition connect-cluster-offsets-13 to 0 since the associated topicId changed from null to lwI1uye1RWSDXoX9nNPq6w (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,912 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition connect-cluster-offsets-18 to 0 since the associated topicId changed from null to lwI1uye1RWSDXoX9nNPq6w (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,912 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition connect-cluster-offsets-22 to 0 since the associated topicId changed from null to lwI1uye1RWSDXoX9nNPq6w (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,912 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition connect-cluster-offsets-8 to 0 since the associated topicId changed from null to lwI1uye1RWSDXoX9nNPq6w (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,912 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition connect-cluster-offsets-2 to 0 since the associated topicId changed from null to lwI1uye1RWSDXoX9nNPq6w (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,912 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition connect-cluster-offsets-12 to 0 since the associated topicId changed from null to lwI1uye1RWSDXoX9nNPq6w (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,912 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition connect-cluster-offsets-19 to 0 since the associated topicId changed from null to lwI1uye1RWSDXoX9nNPq6w (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,912 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition connect-cluster-offsets-14 to 0 since the associated topicId changed from null to lwI1uye1RWSDXoX9nNPq6w (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,912 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition connect-cluster-offsets-1 to 0 since the associated topicId changed from null to lwI1uye1RWSDXoX9nNPq6w (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,912 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition connect-cluster-offsets-6 to 0 since the associated topicId changed from null to lwI1uye1RWSDXoX9nNPq6w (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,913 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition connect-cluster-offsets-7 to 0 since the associated topicId changed from null to lwI1uye1RWSDXoX9nNPq6w (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,913 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition connect-cluster-offsets-21 to 0 since the associated topicId changed from null to lwI1uye1RWSDXoX9nNPq6w (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,913 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle.cytric-poc.-0 to 0 since the associated topicId changed from null to _jO9QZBWTBSCES0-UrhYtw (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,913 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-configs-0 to 0 since the associated topicId changed from null to z2jlOuFsRRKRrobT8ZzDOQ (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,913 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition schema-changes.inventory-0 to 0 since the associated topicId changed from null to fIPeCU63TlSjKgFAa7tKsw (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,913 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-0 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,913 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-5 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,913 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-10 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,913 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-20 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,913 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-15 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,913 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-9 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,913 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-11 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,913 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-16 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,913 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-4 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,913 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-17 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,914 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-3 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,914 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-24 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,914 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-23 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,914 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-13 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,914 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-18 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,914 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-22 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,914 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-2 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,914 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-8 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,914 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-12 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,914 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-19 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,914 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-14 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,914 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-1 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,914 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-6 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,914 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-7 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,914 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-offsets-21 to 0 since the associated topicId changed from null to qNkjkdVNRyONlgq81saUfg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,915 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition mysql.inventory.addresses-0 to 0 since the associated topicId changed from null to fz1JjDQuQLq9ouhfyRmf7A (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,915 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition mysql-0 to 0 since the associated topicId changed from null to ylhjLSIhQ_i7zlIPQOqcjA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,915 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition connect-cluster-status-0 to 0 since the associated topicId changed from null to 7A_a41wxSPa7OgoYpkc29w (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,915 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition connect-cluster-status-1 to 0 since the associated topicId changed from null to 7A_a41wxSPa7OgoYpkc29w (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,915 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition connect-cluster-status-4 to 0 since the associated topicId changed from null to 7A_a41wxSPa7OgoYpkc29w (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,915 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition connect-cluster-status-2 to 0 since the associated topicId changed from null to 7A_a41wxSPa7OgoYpkc29w (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,915 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition connect-cluster-status-3 to 0 since the associated topicId changed from null to 7A_a41wxSPa7OgoYpkc29w (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,915 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition mysql.inventory.orders-0 to 0 since the associated topicId changed from null to ctXv3iLvQK6DDSnBcaVEJg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,915 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-status-0 to 0 since the associated topicId changed from null to aqu-EAXJSWehkiwvYrUILg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,915 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-status-1 to 0 since the associated topicId changed from null to aqu-EAXJSWehkiwvYrUILg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,915 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-status-4 to 0 since the associated topicId changed from null to aqu-EAXJSWehkiwvYrUILg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,915 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-status-2 to 0 since the associated topicId changed from null to aqu-EAXJSWehkiwvYrUILg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,915 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle-connect-cluster-status-3 to 0 since the associated topicId changed from null to aqu-EAXJSWehkiwvYrUILg (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,915 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition connect-cluster-configs-0 to 0 since the associated topicId changed from null to E-ivKa0DTBqd_KfnIMCJTQ (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,915 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition mysql.inventory.products_on_hand-0 to 0 since the associated topicId changed from null to AiJxw8obR-y7J6H9pZJF1g (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,915 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition mysql.inventory.geom-0 to 0 since the associated topicId changed from null to Ze4m-YYwRmSXFrXgayNz-g (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,915 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition oracle.CYTRICQA.schema-history-0 to 0 since the associated topicId changed from null to 0aKMd1DUTw2XOxAN6fYJWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,916 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-0 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,916 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-10 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,916 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-20 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,916 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-40 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,916 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-30 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,916 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-39 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,916 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-9 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,916 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-11 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,916 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-31 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,916 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-13 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,916 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-18 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,916 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-22 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,916 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-32 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,916 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-8 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,916 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-43 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,917 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-29 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,917 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-34 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,917 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-1 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,917 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-6 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,917 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-41 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,917 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-27 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,917 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-48 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,917 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-5 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,917 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-15 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,917 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-35 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,917 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-25 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,917 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-46 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,917 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-26 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,917 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-36 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,917 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-44 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,917 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-37 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,917 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-4 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,917 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-17 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,918 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-45 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,918 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-3 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,918 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-16 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,918 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-24 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,918 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-38 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,918 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-33 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,918 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-23 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,918 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-28 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,918 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-2 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,918 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-12 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,918 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-19 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,918 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-14 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,918 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-47 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,918 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-49 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,918 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-42 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,918 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-7 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,918 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __consumer_offsets-21 to 0 since the associated topicId changed from null to 5QdAIbtsRjKzU6WjVOXeWA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,918 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __strimzi-topic-operator-kstreams-topic-store-changelog-0 to 0 since the associated topicId changed from null to DFZBXMSATCC50oMTR_cj9Q (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,918 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition mysql.inventory.products-0 to 0 since the associated topicId changed from null to feMj0nMXQ2ap66ak50qiDw (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,918 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Resetting the last seen epoch of partition __strimzi_store_topic-0 to 0 since the associated topicId changed from null to 1ljpiWQKQf-OGJJ-vHHhXw (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,920 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Cluster ID: MFQYQMmHSbSn3zMjPTI8gA (org.apache.kafka.clients.Metadata) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,921 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Discovered group coordinator debezium-cluster-kafka-0.debezium-cluster-kafka-brokers.cytric-cdc.svc:9092 (id: 2147483647 rack: null) (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,997 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1-1] 2023-05-17 08:43:09,997 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] (Re-)joining group (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1-1] 2023-05-17 08:43:10,014 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Request joining group due to: rebalance failed due to 'The group member needs to have a valid member id before actually entering a consumer group.' (MemberIdRequiredException) (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1-1] 2023-05-17 08:43:10,014 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] (Re-)joining group (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1-1] 2023-05-17 08:43:13,018 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Successfully joined group with generation Generation{generationId=1, memberId='connect-1-ef3a3090-2da8-47cc-a328-e1045c299556', protocol='sessioned'} (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1-1] 2023-05-17 08:43:13,040 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Successfully synced group in generation Generation{generationId=1, memberId='connect-1-ef3a3090-2da8-47cc-a328-e1045c299556', protocol='sessioned'} (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1-1] 2023-05-17 08:43:13,041 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Joined group at generation 1 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-ef3a3090-2da8-47cc-a328-e1045c299556', leaderUrl='http://10.130.6.170:8083/', offset=-1, connectorIds=[], taskIds=[], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1] 2023-05-17 08:43:13,041 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Starting connectors and tasks using config offset -1 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1] 2023-05-17 08:43:13,041 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1] 2023-05-17 08:43:13,064 INFO [Producer clientId=connect-oracle-cluster--configs] Resetting the last seen epoch of partition oracle-connect-cluster-configs-0 to 0 since the associated topicId changed from null to z2jlOuFsRRKRrobT8ZzDOQ (org.apache.kafka.clients.Metadata) [kafka-producer-network-thread | connect-oracle-cluster--configs] 2023-05-17 08:43:13,145 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Session key updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [KafkaBasedLog Work Thread - oracle-connect-cluster-configs] 2023-05-17 08:43:18,137 INFO 10.130.6.1 - - [17/May/2023:08:43:18 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 95 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-19] 2023-05-17 08:43:18,198 INFO 10.130.6.1 - - [17/May/2023:08:43:18 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 155 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-22] 2023-05-17 08:43:19,001 INFO 10.129.3.16 - - [17/May/2023:08:43:18 +0000] "GET /admin/loggers/ HTTP/1.1" 200 142 "-" "-" 12 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-25] 2023-05-17 08:43:19,002 INFO 10.129.3.16 - - [17/May/2023:08:43:18 +0000] "GET /connectors HTTP/1.1" 200 2 "-" "-" 12 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-23] 2023-05-17 08:43:19,005 INFO 10.129.3.16 - - [17/May/2023:08:43:18 +0000] "GET /connector-plugins HTTP/1.1" 200 406 "-" "-" 15 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-21] 2023-05-17 08:43:19,154 INFO 10.129.3.16 - - [17/May/2023:08:43:19 +0000] "GET /connectors HTTP/1.1" 200 2 "-" "-" 5 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-22] 2023-05-17 08:43:19,156 INFO 10.129.3.16 - - [17/May/2023:08:43:19 +0000] "GET /admin/loggers/ HTTP/1.1" 200 142 "-" "-" 6 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-20] 2023-05-17 08:43:19,157 INFO 10.129.3.16 - - [17/May/2023:08:43:19 +0000] "GET /connector-plugins HTTP/1.1" 200 406 "-" "-" 7 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-21] 2023-05-17 08:43:28,049 INFO 10.130.6.1 - - [17/May/2023:08:43:28 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 6 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-24] 2023-05-17 08:43:28,050 INFO 10.130.6.1 - - [17/May/2023:08:43:28 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 7 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-19] 2023-05-17 08:43:38,045 INFO 10.130.6.1 - - [17/May/2023:08:43:38 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-23] 2023-05-17 08:43:38,049 INFO 10.130.6.1 - - [17/May/2023:08:43:38 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 7 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-21] 2023-05-17 08:43:48,046 INFO 10.130.6.1 - - [17/May/2023:08:43:48 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-25] 2023-05-17 08:43:48,047 INFO 10.130.6.1 - - [17/May/2023:08:43:48 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-20] 2023-05-17 08:43:58,045 INFO 10.130.6.1 - - [17/May/2023:08:43:58 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-23] 2023-05-17 08:43:58,045 INFO 10.130.6.1 - - [17/May/2023:08:43:58 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-24] 2023-05-17 08:44:08,044 INFO 10.130.6.1 - - [17/May/2023:08:44:08 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-19] 2023-05-17 08:44:08,046 INFO 10.130.6.1 - - [17/May/2023:08:44:08 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 5 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-21] 2023-05-17 08:44:18,046 INFO 10.130.6.1 - - [17/May/2023:08:44:18 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-20] 2023-05-17 08:44:18,048 INFO 10.130.6.1 - - [17/May/2023:08:44:18 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 6 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-22] 2023-05-17 08:44:28,044 INFO 10.130.6.1 - - [17/May/2023:08:44:28 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-25] 2023-05-17 08:44:28,046 INFO 10.130.6.1 - - [17/May/2023:08:44:28 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-23] 2023-05-17 08:44:38,047 INFO 10.130.6.1 - - [17/May/2023:08:44:38 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 5 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-19] 2023-05-17 08:44:38,048 INFO 10.130.6.1 - - [17/May/2023:08:44:38 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 6 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-20] 2023-05-17 08:44:46,343 INFO 10.129.3.16 - - [17/May/2023:08:44:46 +0000] "GET /connectors HTTP/1.1" 200 2 "-" "-" 2 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-21] 2023-05-17 08:44:46,344 INFO 10.129.3.16 - - [17/May/2023:08:44:46 +0000] "GET /connector-plugins HTTP/1.1" 200 406 "-" "-" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-24] 2023-05-17 08:44:46,345 INFO 10.129.3.16 - - [17/May/2023:08:44:46 +0000] "GET /admin/loggers/ HTTP/1.1" 200 142 "-" "-" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-22] 2023-05-17 08:44:48,045 INFO 10.130.6.1 - - [17/May/2023:08:44:48 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-25] 2023-05-17 08:44:48,048 INFO 10.130.6.1 - - [17/May/2023:08:44:48 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 5 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-20] 2023-05-17 08:44:58,046 INFO 10.130.6.1 - - [17/May/2023:08:44:58 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-19] 2023-05-17 08:44:58,047 INFO 10.130.6.1 - - [17/May/2023:08:44:58 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-21] 2023-05-17 08:45:08,045 INFO 10.130.6.1 - - [17/May/2023:08:45:08 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-24] 2023-05-17 08:45:08,047 INFO 10.130.6.1 - - [17/May/2023:08:45:08 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-22] 2023-05-17 08:45:18,048 INFO 10.130.6.1 - - [17/May/2023:08:45:18 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 6 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-19] 2023-05-17 08:45:18,048 INFO 10.130.6.1 - - [17/May/2023:08:45:18 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 6 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-23] 2023-05-17 08:45:28,044 INFO 10.130.6.1 - - [17/May/2023:08:45:28 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-25] 2023-05-17 08:45:28,045 INFO 10.130.6.1 - - [17/May/2023:08:45:28 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-21] 2023-05-17 08:45:38,044 INFO 10.130.6.1 - - [17/May/2023:08:45:38 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 2 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-24] 2023-05-17 08:45:38,046 INFO 10.130.6.1 - - [17/May/2023:08:45:38 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-20] 2023-05-17 08:45:48,044 INFO 10.130.6.1 - - [17/May/2023:08:45:48 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 2 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-23] 2023-05-17 08:45:48,046 INFO 10.130.6.1 - - [17/May/2023:08:45:48 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-19] 2023-05-17 08:45:58,046 INFO 10.130.6.1 - - [17/May/2023:08:45:58 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-21] 2023-05-17 08:45:58,047 INFO 10.130.6.1 - - [17/May/2023:08:45:58 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 5 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-22] 2023-05-17 08:46:08,045 INFO 10.130.6.1 - - [17/May/2023:08:46:08 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-20] 2023-05-17 08:46:08,047 INFO 10.130.6.1 - - [17/May/2023:08:46:08 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 5 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-25] 2023-05-17 08:46:18,047 INFO 10.130.6.1 - - [17/May/2023:08:46:18 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-19] 2023-05-17 08:46:18,047 INFO 10.130.6.1 - - [17/May/2023:08:46:18 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-22] 2023-05-17 08:46:28,043 INFO 10.130.6.1 - - [17/May/2023:08:46:28 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 2 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-20] 2023-05-17 08:46:28,045 INFO 10.130.6.1 - - [17/May/2023:08:46:28 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-23] 2023-05-17 08:46:38,046 INFO 10.130.6.1 - - [17/May/2023:08:46:38 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-24] 2023-05-17 08:46:38,046 INFO 10.130.6.1 - - [17/May/2023:08:46:38 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-25] 2023-05-17 08:46:46,340 INFO 10.129.3.16 - - [17/May/2023:08:46:46 +0000] "GET /connectors HTTP/1.1" 200 2 "-" "-" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-22] 2023-05-17 08:46:46,341 INFO 10.129.3.16 - - [17/May/2023:08:46:46 +0000] "GET /admin/loggers/ HTTP/1.1" 200 142 "-" "-" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-25] 2023-05-17 08:46:46,343 INFO 10.129.3.16 - - [17/May/2023:08:46:46 +0000] "GET /connector-plugins HTTP/1.1" 200 406 "-" "-" 6 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-19] 2023-05-17 08:46:48,047 INFO 10.130.6.1 - - [17/May/2023:08:46:48 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 5 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-23] 2023-05-17 08:46:48,047 INFO 10.130.6.1 - - [17/May/2023:08:46:48 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 5 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-21] 2023-05-17 08:46:58,044 INFO 10.130.6.1 - - [17/May/2023:08:46:58 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-22] 2023-05-17 08:46:58,045 INFO 10.130.6.1 - - [17/May/2023:08:46:58 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-24] 2023-05-17 08:47:08,047 INFO 10.130.6.1 - - [17/May/2023:08:47:08 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-25] 2023-05-17 08:47:08,047 INFO 10.130.6.1 - - [17/May/2023:08:47:08 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 5 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-23] 2023-05-17 08:47:18,046 INFO 10.130.6.1 - - [17/May/2023:08:47:18 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-22] 2023-05-17 08:47:18,047 INFO 10.130.6.1 - - [17/May/2023:08:47:18 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 5 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-19] 2023-05-17 08:47:28,045 INFO 10.130.6.1 - - [17/May/2023:08:47:28 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 2 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-25] 2023-05-17 08:47:28,047 INFO 10.130.6.1 - - [17/May/2023:08:47:28 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 5 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-22] 2023-05-17 08:47:38,043 INFO 10.130.6.1 - - [17/May/2023:08:47:38 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 2 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-20] 2023-05-17 08:47:38,045 INFO 10.130.6.1 - - [17/May/2023:08:47:38 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-23] 2023-05-17 08:47:48,045 INFO 10.130.6.1 - - [17/May/2023:08:47:48 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 2 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-25] 2023-05-17 08:47:48,046 INFO 10.130.6.1 - - [17/May/2023:08:47:48 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-24] 2023-05-17 08:47:58,043 INFO 10.130.6.1 - - [17/May/2023:08:47:58 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 2 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-22] 2023-05-17 08:47:58,043 INFO 10.130.6.1 - - [17/May/2023:08:47:58 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 2 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-21] 2023-05-17 08:48:07,125 INFO [AdminClient clientId=connect-oracle-cluster--shared-admin] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient) [kafka-admin-client-thread | connect-oracle-cluster--shared-admin] 2023-05-17 08:48:08,045 INFO 10.130.6.1 - - [17/May/2023:08:48:08 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-21] 2023-05-17 08:48:08,046 INFO 10.130.6.1 - - [17/May/2023:08:48:08 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-19] 2023-05-17 08:48:18,045 INFO 10.130.6.1 - - [17/May/2023:08:48:18 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-24] 2023-05-17 08:48:18,045 INFO 10.130.6.1 - - [17/May/2023:08:48:18 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-23] 2023-05-17 08:48:28,046 INFO 10.130.6.1 - - [17/May/2023:08:48:28 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-21] 2023-05-17 08:48:28,046 INFO 10.130.6.1 - - [17/May/2023:08:48:28 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-25] 2023-05-17 08:48:38,045 INFO 10.130.6.1 - - [17/May/2023:08:48:38 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-24] 2023-05-17 08:48:38,046 INFO 10.130.6.1 - - [17/May/2023:08:48:38 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-22] 2023-05-17 08:48:46,329 INFO 10.129.3.16 - - [17/May/2023:08:48:46 +0000] "GET /connectors HTTP/1.1" 200 2 "-" "-" 2 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-24] 2023-05-17 08:48:46,330 INFO 10.129.3.16 - - [17/May/2023:08:48:46 +0000] "GET /admin/loggers/ HTTP/1.1" 200 142 "-" "-" 2 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-20] 2023-05-17 08:48:46,332 INFO 10.129.3.16 - - [17/May/2023:08:48:46 +0000] "GET /connector-plugins HTTP/1.1" 200 406 "-" "-" 5 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-23] 2023-05-17 08:48:48,047 INFO 10.130.6.1 - - [17/May/2023:08:48:48 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-22] 2023-05-17 08:48:48,047 INFO 10.130.6.1 - - [17/May/2023:08:48:48 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-23] 2023-05-17 08:48:58,046 INFO 10.130.6.1 - - [17/May/2023:08:48:58 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-21] 2023-05-17 08:48:58,046 INFO 10.130.6.1 - - [17/May/2023:08:48:58 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-23] 2023-05-17 08:49:08,043 INFO 10.130.6.1 - - [17/May/2023:08:49:08 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 2 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-25] 2023-05-17 08:49:08,045 INFO 10.130.6.1 - - [17/May/2023:08:49:08 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-22] 2023-05-17 08:49:18,046 INFO 10.130.6.1 - - [17/May/2023:08:49:18 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-20] 2023-05-17 08:49:18,046 INFO 10.130.6.1 - - [17/May/2023:08:49:18 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-19] 2023-05-17 08:49:28,043 INFO 10.130.6.1 - - [17/May/2023:08:49:28 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 1 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-24] 2023-05-17 08:49:28,043 INFO 10.130.6.1 - - [17/May/2023:08:49:28 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 1 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-25] 2023-05-17 08:49:38,047 INFO 10.130.6.1 - - [17/May/2023:08:49:38 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-21] 2023-05-17 08:49:38,047 INFO 10.130.6.1 - - [17/May/2023:08:49:38 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-22] 2023-05-17 08:49:48,043 INFO 10.130.6.1 - - [17/May/2023:08:49:48 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 2 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-24] 2023-05-17 08:49:48,045 INFO 10.130.6.1 - - [17/May/2023:08:49:48 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-20] 2023-05-17 08:49:58,046 INFO 10.130.6.1 - - [17/May/2023:08:49:58 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-25] 2023-05-17 08:49:58,046 INFO 10.130.6.1 - - [17/May/2023:08:49:58 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-19] 2023-05-17 08:50:08,045 INFO 10.130.6.1 - - [17/May/2023:08:50:08 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-23] 2023-05-17 08:50:08,045 INFO 10.130.6.1 - - [17/May/2023:08:50:08 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-21] 2023-05-17 08:50:18,047 INFO 10.130.6.1 - - [17/May/2023:08:50:18 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-25] 2023-05-17 08:50:18,047 INFO 10.130.6.1 - - [17/May/2023:08:50:18 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 5 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-20] 2023-05-17 08:50:28,043 INFO 10.130.6.1 - - [17/May/2023:08:50:28 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 2 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-19] 2023-05-17 08:50:28,044 INFO 10.130.6.1 - - [17/May/2023:08:50:28 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 1 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-24] 2023-05-17 08:50:38,047 INFO 10.130.6.1 - - [17/May/2023:08:50:38 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-23] 2023-05-17 08:50:38,047 INFO 10.130.6.1 - - [17/May/2023:08:50:38 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-21] 2023-05-17 08:50:46,328 INFO 10.129.3.16 - - [17/May/2023:08:50:46 +0000] "GET /admin/loggers/ HTTP/1.1" 200 142 "-" "-" 2 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-24] 2023-05-17 08:50:46,329 INFO 10.129.3.16 - - [17/May/2023:08:50:46 +0000] "GET /connectors HTTP/1.1" 200 2 "-" "-" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-19] 2023-05-17 08:50:46,331 INFO 10.129.3.16 - - [17/May/2023:08:50:46 +0000] "GET /connector-plugins HTTP/1.1" 200 406 "-" "-" 5 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-22] 2023-05-17 08:50:48,047 INFO 10.130.6.1 - - [17/May/2023:08:50:48 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-20] 2023-05-17 08:50:48,047 INFO 10.130.6.1 - - [17/May/2023:08:50:48 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 5 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-23] 2023-05-17 08:50:58,044 INFO 10.130.6.1 - - [17/May/2023:08:50:58 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 2 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-24] 2023-05-17 08:50:58,045 INFO 10.130.6.1 - - [17/May/2023:08:50:58 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-21] 2023-05-17 08:51:08,046 INFO 10.130.6.1 - - [17/May/2023:08:51:08 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-20] 2023-05-17 08:51:08,047 INFO 10.130.6.1 - - [17/May/2023:08:51:08 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 5 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-19] 2023-05-17 08:51:18,046 INFO 10.130.6.1 - - [17/May/2023:08:51:18 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 5 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-23] 2023-05-17 08:51:18,046 INFO 10.130.6.1 - - [17/May/2023:08:51:18 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-25] 2023-05-17 08:51:28,044 INFO 10.130.6.1 - - [17/May/2023:08:51:28 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 2 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-24] 2023-05-17 08:51:28,046 INFO 10.130.6.1 - - [17/May/2023:08:51:28 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-20] 2023-05-17 08:51:38,045 INFO 10.130.6.1 - - [17/May/2023:08:51:38 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-22] 2023-05-17 08:51:38,045 INFO 10.130.6.1 - - [17/May/2023:08:51:38 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-19] 2023-05-17 08:51:48,046 INFO 10.130.6.1 - - [17/May/2023:08:51:48 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-25] 2023-05-17 08:51:48,046 INFO 10.130.6.1 - - [17/May/2023:08:51:48 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-24] 2023-05-17 08:51:58,046 INFO 10.130.6.1 - - [17/May/2023:08:51:58 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-23] 2023-05-17 08:51:58,046 INFO 10.130.6.1 - - [17/May/2023:08:51:58 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-21] 2023-05-17 08:52:08,047 INFO 10.130.6.1 - - [17/May/2023:08:52:08 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-22] 2023-05-17 08:52:08,047 INFO 10.130.6.1 - - [17/May/2023:08:52:08 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-19] 2023-05-17 08:52:09,109 INFO [Producer clientId=connect-oracle-cluster--offsets] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient) [kafka-producer-network-thread | connect-oracle-cluster--offsets] 2023-05-17 08:52:09,511 INFO [Consumer clientId=connect-oracle-cluster--offsets, groupId=connect-oracle-cluster] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient) [KafkaBasedLog Work Thread - oracle-connect-cluster-offsets] 2023-05-17 08:52:09,814 INFO [Producer clientId=connect-oracle-cluster--statuses] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient) [kafka-producer-network-thread | connect-oracle-cluster--statuses] 2023-05-17 08:52:09,962 INFO [Consumer clientId=connect-oracle-cluster--configs, groupId=connect-oracle-cluster] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient) [KafkaBasedLog Work Thread - oracle-connect-cluster-configs] 2023-05-17 08:52:09,992 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient) [DistributedHerder-connect-1-1] 2023-05-17 08:52:10,069 INFO [Producer clientId=connect-oracle-cluster--configs] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient) [kafka-producer-network-thread | connect-oracle-cluster--configs] 2023-05-17 08:52:10,091 INFO [Consumer clientId=connect-oracle-cluster--statuses, groupId=connect-oracle-cluster] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient) [KafkaBasedLog Work Thread - oracle-connect-cluster-status] 2023-05-17 08:52:18,048 INFO 10.130.6.1 - - [17/May/2023:08:52:18 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 6 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-20] 2023-05-17 08:52:18,049 INFO 10.130.6.1 - - [17/May/2023:08:52:18 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 7 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-21] 2023-05-17 08:52:28,044 INFO 10.130.6.1 - - [17/May/2023:08:52:28 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 2 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-24] 2023-05-17 08:52:28,047 INFO 10.130.6.1 - - [17/May/2023:08:52:28 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 5 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-22] 2023-05-17 08:52:38,045 INFO 10.130.6.1 - - [17/May/2023:08:52:38 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-25] 2023-05-17 08:52:38,046 INFO 10.130.6.1 - - [17/May/2023:08:52:38 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-20] 2023-05-17 08:52:46,329 INFO 10.129.3.16 - - [17/May/2023:08:52:46 +0000] "GET /connector-plugins HTTP/1.1" 200 406 "-" "-" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-23] 2023-05-17 08:52:46,331 INFO 10.129.3.16 - - [17/May/2023:08:52:46 +0000] "GET /connectors HTTP/1.1" 200 2 "-" "-" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-21] 2023-05-17 08:52:46,331 INFO 10.129.3.16 - - [17/May/2023:08:52:46 +0000] "GET /admin/loggers/ HTTP/1.1" 200 142 "-" "-" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-19] 2023-05-17 08:52:46,357 INFO 10.129.3.16 - - [17/May/2023:08:52:46 +0000] "GET /connectors/debezium-connector-oracle-poc/config HTTP/1.1" 404 80 "-" "-" 23 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-20] 2023-05-17 08:52:46,410 INFO Retrieving configuration from Secret debezium-oracle-poc-secret in namespace cytric-cdc (io.strimzi.kafka.AbstractKubernetesConfigProvider) [pool-5-thread-1] 2023-05-17 08:52:48,098 INFO 10.130.6.1 - - [17/May/2023:08:52:48 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 57 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-19] 2023-05-17 08:52:48,100 INFO 10.130.6.1 - - [17/May/2023:08:52:48 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 58 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-23] 2023-05-17 08:52:48,336 INFO Database Version: Oracle Database 12c Enterprise Edition Release 12.2.0.1.0 - 64bit Production (io.debezium.connector.oracle.OracleConnection) [pool-5-thread-1] 2023-05-17 08:52:48,340 INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection) [pool-14-thread-1] 2023-05-17 08:52:48,343 INFO AbstractConfig values: (org.apache.kafka.common.config.AbstractConfig) [pool-5-thread-1] 2023-05-17 08:52:48,414 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Connector debezium-connector-oracle-poc config updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [KafkaBasedLog Work Thread - oracle-connect-cluster-configs] 2023-05-17 08:52:48,417 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1-1] 2023-05-17 08:52:48,417 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] (Re-)joining group (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1-1] 2023-05-17 08:52:48,422 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Successfully joined group with generation Generation{generationId=2, memberId='connect-1-ef3a3090-2da8-47cc-a328-e1045c299556', protocol='sessioned'} (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1-1] 2023-05-17 08:52:48,424 INFO 10.129.3.16 - - [17/May/2023:08:52:46 +0000] "PUT /connectors/debezium-connector-oracle-poc/config HTTP/1.1" 201 983 "-" "-" 2061 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-25] 2023-05-17 08:52:48,431 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Successfully synced group in generation Generation{generationId=2, memberId='connect-1-ef3a3090-2da8-47cc-a328-e1045c299556', protocol='sessioned'} (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1-1] 2023-05-17 08:52:48,432 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Joined group at generation 2 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-ef3a3090-2da8-47cc-a328-e1045c299556', leaderUrl='http://10.130.6.170:8083/', offset=2, connectorIds=[debezium-connector-oracle-poc], taskIds=[], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1] 2023-05-17 08:52:48,432 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Starting connectors and tasks using config offset 2 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1] 2023-05-17 08:52:48,433 INFO 10.129.3.16 - - [17/May/2023:08:52:48 +0000] "GET /connectors/debezium-connector-oracle-poc/status HTTP/1.1" 404 90 "-" "-" 5 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-21] 2023-05-17 08:52:48,434 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Starting connector debezium-connector-oracle-poc (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [StartAndStopExecutor-connect-1-1] 2023-05-17 08:52:48,435 INFO Retrieving configuration from Secret debezium-oracle-poc-secret in namespace cytric-cdc (io.strimzi.kafka.AbstractKubernetesConfigProvider) [StartAndStopExecutor-connect-1-1] 2023-05-17 08:52:48,500 INFO 10.129.3.16 - - [17/May/2023:08:52:48 +0000] "GET /connectors/debezium-connector-oracle-poc/status HTTP/1.1" 404 90 "-" "-" 62 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-22] 2023-05-17 08:52:48,511 INFO [debezium-connector-oracle-poc|worker] Creating connector debezium-connector-oracle-poc of type io.debezium.connector.oracle.OracleConnector (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-1] 2023-05-17 08:52:48,511 INFO [debezium-connector-oracle-poc|worker] 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 exactly.once.support = requested header.converter = null key.converter = null name = debezium-connector-oracle-poc offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = null (org.apache.kafka.connect.runtime.SourceConnectorConfig) [StartAndStopExecutor-connect-1-1] 2023-05-17 08:52:48,512 INFO [debezium-connector-oracle-poc|worker] 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 exactly.once.support = requested header.converter = null key.converter = null name = debezium-connector-oracle-poc offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig) [StartAndStopExecutor-connect-1-1] 2023-05-17 08:52:48,519 INFO [debezium-connector-oracle-poc|worker] Instantiated connector debezium-connector-oracle-poc with version 2.3.0.Alpha1 of type class io.debezium.connector.oracle.OracleConnector (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-1] 2023-05-17 08:52:48,519 INFO [debezium-connector-oracle-poc|worker] Finished creating connector debezium-connector-oracle-poc (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-1] 2023-05-17 08:52:48,520 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1] 2023-05-17 08:52:48,526 INFO [Producer clientId=connect-oracle-cluster--statuses] Resetting the last seen epoch of partition oracle-connect-cluster-status-0 to 0 since the associated topicId changed from null to aqu-EAXJSWehkiwvYrUILg (org.apache.kafka.clients.Metadata) [kafka-producer-network-thread | connect-oracle-cluster--statuses] 2023-05-17 08:52:48,526 INFO [Producer clientId=connect-oracle-cluster--statuses] Resetting the last seen epoch of partition oracle-connect-cluster-status-1 to 0 since the associated topicId changed from null to aqu-EAXJSWehkiwvYrUILg (org.apache.kafka.clients.Metadata) [kafka-producer-network-thread | connect-oracle-cluster--statuses] 2023-05-17 08:52:48,526 INFO [Producer clientId=connect-oracle-cluster--statuses] Resetting the last seen epoch of partition oracle-connect-cluster-status-4 to 0 since the associated topicId changed from null to aqu-EAXJSWehkiwvYrUILg (org.apache.kafka.clients.Metadata) [kafka-producer-network-thread | connect-oracle-cluster--statuses] 2023-05-17 08:52:48,526 INFO [Producer clientId=connect-oracle-cluster--statuses] Resetting the last seen epoch of partition oracle-connect-cluster-status-2 to 0 since the associated topicId changed from null to aqu-EAXJSWehkiwvYrUILg (org.apache.kafka.clients.Metadata) [kafka-producer-network-thread | connect-oracle-cluster--statuses] 2023-05-17 08:52:48,526 INFO [Producer clientId=connect-oracle-cluster--statuses] Resetting the last seen epoch of partition oracle-connect-cluster-status-3 to 0 since the associated topicId changed from null to aqu-EAXJSWehkiwvYrUILg (org.apache.kafka.clients.Metadata) [kafka-producer-network-thread | connect-oracle-cluster--statuses] 2023-05-17 08:52:48,531 INFO Retrieving configuration from Secret debezium-oracle-poc-secret in namespace cytric-cdc (io.strimzi.kafka.AbstractKubernetesConfigProvider) [DistributedHerder-connect-1-1] 2023-05-17 08:52:48,599 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 exactly.once.support = requested header.converter = null key.converter = null name = debezium-connector-oracle-poc offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = null (org.apache.kafka.connect.runtime.SourceConnectorConfig) [DistributedHerder-connect-1-1] 2023-05-17 08:52:48,599 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 exactly.once.support = requested header.converter = null key.converter = null name = debezium-connector-oracle-poc offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig) [DistributedHerder-connect-1-1] 2023-05-17 08:52:48,625 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Tasks [debezium-connector-oracle-poc-0] configs updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [KafkaBasedLog Work Thread - oracle-connect-cluster-configs] 2023-05-17 08:52:48,630 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1-1] 2023-05-17 08:52:48,631 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] (Re-)joining group (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1-1] 2023-05-17 08:52:48,634 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Successfully joined group with generation Generation{generationId=3, memberId='connect-1-ef3a3090-2da8-47cc-a328-e1045c299556', protocol='sessioned'} (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1-1] 2023-05-17 08:52:48,644 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Successfully synced group in generation Generation{generationId=3, memberId='connect-1-ef3a3090-2da8-47cc-a328-e1045c299556', protocol='sessioned'} (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder-connect-1-1] 2023-05-17 08:52:48,644 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Joined group at generation 3 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-ef3a3090-2da8-47cc-a328-e1045c299556', leaderUrl='http://10.130.6.170:8083/', offset=4, connectorIds=[debezium-connector-oracle-poc], taskIds=[debezium-connector-oracle-poc-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1] 2023-05-17 08:52:48,646 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Starting connectors and tasks using config offset 4 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1] 2023-05-17 08:52:48,647 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Starting task debezium-connector-oracle-poc-0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [StartAndStopExecutor-connect-1-2] 2023-05-17 08:52:48,647 INFO Retrieving configuration from Secret debezium-oracle-poc-secret in namespace cytric-cdc (io.strimzi.kafka.AbstractKubernetesConfigProvider) [StartAndStopExecutor-connect-1-2] 2023-05-17 08:52:48,659 INFO Retrieving configuration from Secret debezium-oracle-poc-secret in namespace cytric-cdc (io.strimzi.kafka.AbstractKubernetesConfigProvider) [StartAndStopExecutor-connect-1-2] 2023-05-17 08:52:48,702 INFO [debezium-connector-oracle-poc|task-0] Creating task debezium-connector-oracle-poc-0 (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-2] 2023-05-17 08:52:48,703 INFO [debezium-connector-oracle-poc|task-0] 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 = debezium-connector-oracle-poc predicates = [] tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig) [StartAndStopExecutor-connect-1-2] 2023-05-17 08:52:48,703 INFO [debezium-connector-oracle-poc|task-0] 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 = debezium-connector-oracle-poc predicates = [] tasks.max = 1 transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig) [StartAndStopExecutor-connect-1-2] 2023-05-17 08:52:48,705 INFO [debezium-connector-oracle-poc|task-0] TaskConfig values: task.class = class io.debezium.connector.oracle.OracleConnectorTask (org.apache.kafka.connect.runtime.TaskConfig) [StartAndStopExecutor-connect-1-2] 2023-05-17 08:52:48,708 INFO [debezium-connector-oracle-poc|task-0] Instantiated task debezium-connector-oracle-poc-0 with version 2.3.0.Alpha1 of type io.debezium.connector.oracle.OracleConnectorTask (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-2] 2023-05-17 08:52:48,708 INFO [debezium-connector-oracle-poc|task-0] JsonConverterConfig values: converter.type = key decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = true (org.apache.kafka.connect.json.JsonConverterConfig) [StartAndStopExecutor-connect-1-2] 2023-05-17 08:52:48,708 INFO [debezium-connector-oracle-poc|task-0] Set up the key converter class org.apache.kafka.connect.json.JsonConverter for task debezium-connector-oracle-poc-0 using the worker config (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-2] 2023-05-17 08:52:48,708 INFO [debezium-connector-oracle-poc|task-0] JsonConverterConfig values: converter.type = value decimal.format = BASE64 schemas.cache.size = 1000 schemas.enable = true (org.apache.kafka.connect.json.JsonConverterConfig) [StartAndStopExecutor-connect-1-2] 2023-05-17 08:52:48,708 INFO [debezium-connector-oracle-poc|task-0] Set up the value converter class org.apache.kafka.connect.json.JsonConverter for task debezium-connector-oracle-poc-0 using the worker config (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-2] 2023-05-17 08:52:48,709 INFO [debezium-connector-oracle-poc|task-0] Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task debezium-connector-oracle-poc-0 using the worker config (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-2] 2023-05-17 08:52:48,713 INFO [debezium-connector-oracle-poc|task-0] 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 exactly.once.support = requested header.converter = null key.converter = null name = debezium-connector-oracle-poc offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = null (org.apache.kafka.connect.runtime.SourceConnectorConfig) [StartAndStopExecutor-connect-1-2] 2023-05-17 08:52:48,713 INFO [debezium-connector-oracle-poc|task-0] 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 exactly.once.support = requested header.converter = null key.converter = null name = debezium-connector-oracle-poc offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = null (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig) [StartAndStopExecutor-connect-1-2] 2023-05-17 08:52:48,714 INFO [debezium-connector-oracle-poc|task-0] Initializing: org.apache.kafka.connect.runtime.TransformationChain{} (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor-connect-1-2] 2023-05-17 08:52:48,715 INFO [debezium-connector-oracle-poc|task-0] ProducerConfig values: acks = -1 auto.include.jmx.reporter = true batch.size = 16384 bootstrap.servers = [debezium-cluster-kafka-bootstrap:9092] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = connector-producer-debezium-connector-oracle-poc-0 compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 2147483647 enable.idempotence = false interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer linger.ms = 0 max.block.ms = 9223372036854775807 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metadata.max.idle.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.adaptive.partitioning.enable = true partitioner.availability.timeout.ms = 0 partitioner.class = null partitioner.ignore.keys = false receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = 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) [StartAndStopExecutor-connect-1-2] 2023-05-17 08:52:48,717 INFO 10.129.3.16 - - [17/May/2023:08:52:48 +0000] "GET /connectors/debezium-connector-oracle-poc/status HTTP/1.1" 200 131 "-" "-" 11 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-23] 2023-05-17 08:52:48,719 WARN [debezium-connector-oracle-poc|task-0] These configurations '[metrics.context.connect.group.id, metrics.context.connect.kafka.cluster.id]' were supplied but are not used yet. (org.apache.kafka.clients.producer.ProducerConfig) [StartAndStopExecutor-connect-1-2] 2023-05-17 08:52:48,719 INFO [debezium-connector-oracle-poc|task-0] Kafka version: 3.4.0 (org.apache.kafka.common.utils.AppInfoParser) [StartAndStopExecutor-connect-1-2] 2023-05-17 08:52:48,719 INFO [debezium-connector-oracle-poc|task-0] Kafka commitId: 2e1947d240607d53 (org.apache.kafka.common.utils.AppInfoParser) [StartAndStopExecutor-connect-1-2] 2023-05-17 08:52:48,719 INFO [debezium-connector-oracle-poc|task-0] Kafka startTimeMs: 1684313568719 (org.apache.kafka.common.utils.AppInfoParser) [StartAndStopExecutor-connect-1-2] 2023-05-17 08:52:48,724 INFO 10.129.3.16 - - [17/May/2023:08:52:48 +0000] "GET /connectors/debezium-connector-oracle-poc/status HTTP/1.1" 200 131 "-" "-" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-24] 2023-05-17 08:52:48,729 INFO [Worker clientId=connect-1, groupId=connect-oracle-cluster] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder-connect-1-1] 2023-05-17 08:52:48,797 INFO [debezium-connector-oracle-poc|task-0] [Producer clientId=connector-producer-debezium-connector-oracle-poc-0] Cluster ID: MFQYQMmHSbSn3zMjPTI8gA (org.apache.kafka.clients.Metadata) [kafka-producer-network-thread | connector-producer-debezium-connector-oracle-poc-0] 2023-05-17 08:52:48,799 INFO [debezium-connector-oracle-poc|task-0] Starting OracleConnectorTask with configuration: (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:48,802 INFO [debezium-connector-oracle-poc|task-0] connector.class = io.debezium.connector.oracle.OracleConnector (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:48,802 INFO [debezium-connector-oracle-poc|task-0] snapshot.include.collection.list = CYTRICQA.TLABEL_T (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:48,802 INFO [debezium-connector-oracle-poc|task-0] database.dbname = ORCLCDB.localdomain (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:48,802 INFO [debezium-connector-oracle-poc|task-0] database.user = c##dbzuser (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:48,802 INFO [debezium-connector-oracle-poc|task-0] database.pdb.name = ORCLPDB1 (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:48,802 INFO [debezium-connector-oracle-poc|task-0] tasks.max = 1 (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:48,802 INFO [debezium-connector-oracle-poc|task-0] schema.include.list = CYTRICQA (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:48,802 INFO [debezium-connector-oracle-poc|task-0] schema.history.internal.kafka.bootstrap.servers = debezium-cluster-kafka-bootstrap:9092 (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:48,802 INFO [debezium-connector-oracle-poc|task-0] database.port = 8002 (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:48,802 INFO [debezium-connector-oracle-poc|task-0] schema.history.internal.store.only.captured.databases.ddl = true (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:48,802 INFO [debezium-connector-oracle-poc|task-0] schema.history.internal.store.only.captured.tables.ddl = true (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:48,802 INFO [debezium-connector-oracle-poc|task-0] topic.prefix = oracle.cytric-poc. (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:48,802 INFO [debezium-connector-oracle-poc|task-0] schema.history.internal.kafka.topic = oracle.CYTRICQA.schema-history (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:48,802 INFO [debezium-connector-oracle-poc|task-0] task.class = io.debezium.connector.oracle.OracleConnectorTask (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:48,802 INFO [debezium-connector-oracle-poc|task-0] database.hostname = dockerqa01.sofia.ifao.net (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:48,802 INFO [debezium-connector-oracle-poc|task-0] database.password = ******** (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:48,802 INFO [debezium-connector-oracle-poc|task-0] name = debezium-connector-oracle-poc (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:48,802 INFO [debezium-connector-oracle-poc|task-0] table.include.list = CYTRICQA.TLABEL_T (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:48,802 INFO [debezium-connector-oracle-poc|task-0] snapshot.mode = schema_only (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:48,802 INFO [debezium-connector-oracle-poc|task-0] WorkerSourceTask{id=debezium-connector-oracle-poc-0} Source task finished initialization and start (org.apache.kafka.connect.runtime.AbstractWorkerSourceTask) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:48,803 INFO 10.129.3.16 - - [17/May/2023:08:52:48 +0000] "GET /connectors/debezium-connector-oracle-poc/topics HTTP/1.1" 200 47 "-" "-" 75 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-21] 2023-05-17 08:52:48,805 INFO [debezium-connector-oracle-poc|task-0] Attempting to start task (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:48,809 INFO [debezium-connector-oracle-poc|task-0] Loading the custom topic naming strategy plugin: io.debezium.schema.SchemaTopicNamingStrategy (io.debezium.config.CommonConnectorConfig) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:49,001 INFO [debezium-connector-oracle-poc|task-0] Database Version: Oracle Database 12c Enterprise Edition Release 12.2.0.1.0 - 64bit Production (io.debezium.connector.oracle.OracleConnection) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:49,103 INFO [debezium-connector-oracle-poc|task-0] KafkaSchemaHistory Consumer config: {key.deserializer=org.apache.kafka.common.serialization.StringDeserializer, value.deserializer=org.apache.kafka.common.serialization.StringDeserializer, enable.auto.commit=false, group.id=oracle.cytric-poc.-schemahistory, bootstrap.servers=debezium-cluster-kafka-bootstrap:9092, fetch.min.bytes=1, session.timeout.ms=10000, auto.offset.reset=earliest, client.id=oracle.cytric-poc.-schemahistory} (io.debezium.storage.kafka.history.KafkaSchemaHistory) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:49,104 INFO [debezium-connector-oracle-poc|task-0] KafkaSchemaHistory Producer config: {retries=1, value.serializer=org.apache.kafka.common.serialization.StringSerializer, acks=1, batch.size=32768, max.block.ms=10000, bootstrap.servers=debezium-cluster-kafka-bootstrap:9092, buffer.memory=1048576, key.serializer=org.apache.kafka.common.serialization.StringSerializer, client.id=oracle.cytric-poc.-schemahistory, linger.ms=0} (io.debezium.storage.kafka.history.KafkaSchemaHistory) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:49,105 INFO [debezium-connector-oracle-poc|task-0] Requested thread factory for connector OracleConnector, id = oracle.cytric-poc. named = db-history-config-check (io.debezium.util.Threads) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:49,108 INFO [debezium-connector-oracle-poc|task-0] Idempotence will be disabled because acks is set to 1, not set to 'all'. (org.apache.kafka.clients.producer.ProducerConfig) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:49,109 INFO [debezium-connector-oracle-poc|task-0] ProducerConfig values: acks = 1 auto.include.jmx.reporter = true batch.size = 32768 bootstrap.servers = [debezium-cluster-kafka-bootstrap:9092] buffer.memory = 1048576 client.dns.lookup = use_all_dns_ips client.id = oracle.cytric-poc.-schemahistory 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.adaptive.partitioning.enable = true partitioner.availability.timeout.ms = 0 partitioner.class = null partitioner.ignore.keys = false receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 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) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:49,111 INFO [debezium-connector-oracle-poc|task-0] Kafka version: 3.4.0 (org.apache.kafka.common.utils.AppInfoParser) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:49,111 INFO [debezium-connector-oracle-poc|task-0] Kafka commitId: 2e1947d240607d53 (org.apache.kafka.common.utils.AppInfoParser) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:49,111 INFO [debezium-connector-oracle-poc|task-0] Kafka startTimeMs: 1684313569111 (org.apache.kafka.common.utils.AppInfoParser) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:49,118 INFO [debezium-connector-oracle-poc|task-0] [Producer clientId=oracle.cytric-poc.-schemahistory] Cluster ID: MFQYQMmHSbSn3zMjPTI8gA (org.apache.kafka.clients.Metadata) [kafka-producer-network-thread | oracle.cytric-poc.-schemahistory] 2023-05-17 08:52:49,238 INFO [debezium-connector-oracle-poc|task-0] No previous offsets found (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:49,239 INFO [debezium-connector-oracle-poc|task-0] Connector started for the first time, database schema history recovery will not be executed (io.debezium.connector.oracle.OracleConnectorTask) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:49,239 INFO [debezium-connector-oracle-poc|task-0] ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.include.jmx.reporter = true auto.offset.reset = earliest bootstrap.servers = [debezium-cluster-kafka-bootstrap:9092] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = oracle.cytric-poc.-schemahistory 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.cytric-poc.-schemahistory 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) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:49,242 INFO [debezium-connector-oracle-poc|task-0] Kafka version: 3.4.0 (org.apache.kafka.common.utils.AppInfoParser) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:49,242 INFO [debezium-connector-oracle-poc|task-0] Kafka commitId: 2e1947d240607d53 (org.apache.kafka.common.utils.AppInfoParser) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:49,242 INFO [debezium-connector-oracle-poc|task-0] Kafka startTimeMs: 1684313569242 (org.apache.kafka.common.utils.AppInfoParser) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:49,246 INFO [debezium-connector-oracle-poc|task-0] [Consumer clientId=oracle.cytric-poc.-schemahistory, groupId=oracle.cytric-poc.-schemahistory] Cluster ID: MFQYQMmHSbSn3zMjPTI8gA (org.apache.kafka.clients.Metadata) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:49,248 INFO [debezium-connector-oracle-poc|task-0] [Consumer clientId=oracle.cytric-poc.-schemahistory, groupId=oracle.cytric-poc.-schemahistory] Resetting generation and member id due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:49,248 INFO [debezium-connector-oracle-poc|task-0] [Consumer clientId=oracle.cytric-poc.-schemahistory, groupId=oracle.cytric-poc.-schemahistory] Request joining group due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:49,249 INFO [debezium-connector-oracle-poc|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:49,249 INFO [debezium-connector-oracle-poc|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:49,249 INFO [debezium-connector-oracle-poc|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:49,249 INFO [debezium-connector-oracle-poc|task-0] App info kafka.consumer for oracle.cytric-poc.-schemahistory unregistered (org.apache.kafka.common.utils.AppInfoParser) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:49,303 INFO [debezium-connector-oracle-poc|task-0] Requested thread factory for connector OracleConnector, id = oracle.cytric-poc. named = SignalProcessor (io.debezium.util.Threads) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:49,318 INFO [debezium-connector-oracle-poc|task-0] Requested thread factory for connector OracleConnector, id = oracle.cytric-poc. named = change-event-source-coordinator (io.debezium.util.Threads) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:49,320 INFO [debezium-connector-oracle-poc|task-0] Creating thread debezium-oracleconnector-oracle.cytric-poc.-change-event-source-coordinator (io.debezium.util.Threads) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:49,321 INFO [debezium-connector-oracle-poc|task-0] SignalProcessor started. Scheduling it every 5ms (io.debezium.pipeline.signal.SignalProcessor) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:49,322 INFO [debezium-connector-oracle-poc|task-0] Creating thread debezium-oracleconnector-oracle.cytric-poc.-SignalProcessor (io.debezium.util.Threads) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:49,322 INFO [debezium-connector-oracle-poc|task-0] Successfully started task (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:49,329 INFO [debezium-connector-oracle-poc|task-0] Metrics registered (io.debezium.pipeline.ChangeEventSourceCoordinator) [debezium-oracleconnector-oracle.cytric-poc.-change-event-source-coordinator] 2023-05-17 08:52:49,330 INFO [debezium-connector-oracle-poc|task-0] Context created (io.debezium.pipeline.ChangeEventSourceCoordinator) [debezium-oracleconnector-oracle.cytric-poc.-change-event-source-coordinator] 2023-05-17 08:52:49,406 INFO [debezium-connector-oracle-poc|task-0] No previous offset has been found. (io.debezium.connector.oracle.OracleSnapshotChangeEventSource) [debezium-oracleconnector-oracle.cytric-poc.-change-event-source-coordinator] 2023-05-17 08:52:49,406 INFO [debezium-connector-oracle-poc|task-0] According to the connector configuration only schema will be snapshot. (io.debezium.connector.oracle.OracleSnapshotChangeEventSource) [debezium-oracleconnector-oracle.cytric-poc.-change-event-source-coordinator] 2023-05-17 08:52:49,413 INFO [debezium-connector-oracle-poc|task-0] Snapshot step 1 - Preparing (io.debezium.relational.RelationalSnapshotChangeEventSource) [debezium-oracleconnector-oracle.cytric-poc.-change-event-source-coordinator] 2023-05-17 08:52:49,413 INFO [debezium-connector-oracle-poc|task-0] Snapshot step 2 - Determining captured tables (io.debezium.relational.RelationalSnapshotChangeEventSource) [debezium-oracleconnector-oracle.cytric-poc.-change-event-source-coordinator] 2023-05-17 08:52:53,227 INFO [debezium-connector-oracle-poc|task-0] Adding table ORCLPDB1.CYTRICQA.TLABEL_T to the list of capture schema tables (io.debezium.relational.RelationalSnapshotChangeEventSource) [debezium-oracleconnector-oracle.cytric-poc.-change-event-source-coordinator] 2023-05-17 08:52:53,230 INFO [debezium-connector-oracle-poc|task-0] Snapshot step 3 - Locking captured tables [] (io.debezium.relational.RelationalSnapshotChangeEventSource) [debezium-oracleconnector-oracle.cytric-poc.-change-event-source-coordinator] 2023-05-17 08:52:53,232 INFO [debezium-connector-oracle-poc|task-0] Snapshot step 4 - Determining snapshot offset (io.debezium.relational.RelationalSnapshotChangeEventSource) [debezium-oracleconnector-oracle.cytric-poc.-change-event-source-coordinator] 2023-05-17 08:52:53,533 INFO [debezium-connector-oracle-poc|task-0] No in-progress transactions will be captured. (io.debezium.connector.oracle.logminer.LogMinerAdapter) [debezium-oracleconnector-oracle.cytric-poc.-change-event-source-coordinator] 2023-05-17 08:52:53,607 INFO [debezium-connector-oracle-poc|task-0] Connection gracefully closed (io.debezium.jdbc.JdbcConnection) [pool-15-thread-1] 2023-05-17 08:52:53,608 INFO [debezium-connector-oracle-poc|task-0] Snapshot step 5 - Reading structure of captured tables (io.debezium.relational.RelationalSnapshotChangeEventSource) [debezium-oracleconnector-oracle.cytric-poc.-change-event-source-coordinator] 2023-05-17 08:52:53,608 INFO [debezium-connector-oracle-poc|task-0] Only captured tables schema should be captured, capturing: [] (io.debezium.connector.oracle.OracleSnapshotChangeEventSource) [debezium-oracleconnector-oracle.cytric-poc.-change-event-source-coordinator] 2023-05-17 08:52:53,609 INFO [debezium-connector-oracle-poc|task-0] Snapshot step 6 - Persisting schema history (io.debezium.relational.RelationalSnapshotChangeEventSource) [debezium-oracleconnector-oracle.cytric-poc.-change-event-source-coordinator] 2023-05-17 08:52:53,609 INFO [debezium-connector-oracle-poc|task-0] Capturing structure of table ORCLPDB1.CYTRICQA.TLABEL_T (io.debezium.relational.RelationalSnapshotChangeEventSource) [debezium-oracleconnector-oracle.cytric-poc.-change-event-source-coordinator] 2023-05-17 08:52:53,611 ERROR [debezium-connector-oracle-poc|task-0] Error during snapshot (io.debezium.relational.RelationalSnapshotChangeEventSource) [debezium-oracleconnector-oracle.cytric-poc.-change-event-source-coordinator] java.lang.NullPointerException: Cannot invoke "io.debezium.relational.Table.id()" because "table" is null at io.debezium.connector.oracle.OracleSnapshotChangeEventSource.getCreateTableEvent(OracleSnapshotChangeEventSource.java:210) at io.debezium.relational.RelationalSnapshotChangeEventSource.createSchemaChangeEventsForTables(RelationalSnapshotChangeEventSource.java:352) at io.debezium.relational.RelationalSnapshotChangeEventSource.doExecute(RelationalSnapshotChangeEventSource.java:145) at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:76) at io.debezium.pipeline.ChangeEventSourceCoordinator.doSnapshot(ChangeEventSourceCoordinator.java:186) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:152) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:118) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at java.base/java.lang.Thread.run(Thread.java:833) 2023-05-17 08:52:53,614 INFO [debezium-connector-oracle-poc|task-0] Snapshot - Final stage (io.debezium.pipeline.source.AbstractSnapshotChangeEventSource) [debezium-oracleconnector-oracle.cytric-poc.-change-event-source-coordinator] 2023-05-17 08:52:53,619 WARN [debezium-connector-oracle-poc|task-0] Snapshot was not completed successfully, it will be re-executed upon connector restart (io.debezium.pipeline.source.AbstractSnapshotChangeEventSource) [debezium-oracleconnector-oracle.cytric-poc.-change-event-source-coordinator] 2023-05-17 08:52:53,619 ERROR [debezium-connector-oracle-poc|task-0] Producer failure (io.debezium.pipeline.ErrorHandler) [debezium-oracleconnector-oracle.cytric-poc.-change-event-source-coordinator] io.debezium.DebeziumException: java.lang.NullPointerException: Cannot invoke "io.debezium.relational.Table.id()" because "table" is null at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:85) at io.debezium.pipeline.ChangeEventSourceCoordinator.doSnapshot(ChangeEventSourceCoordinator.java:186) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:152) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:118) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at java.base/java.lang.Thread.run(Thread.java:833) Caused by: java.lang.NullPointerException: Cannot invoke "io.debezium.relational.Table.id()" because "table" is null at io.debezium.connector.oracle.OracleSnapshotChangeEventSource.getCreateTableEvent(OracleSnapshotChangeEventSource.java:210) at io.debezium.relational.RelationalSnapshotChangeEventSource.createSchemaChangeEventsForTables(RelationalSnapshotChangeEventSource.java:352) at io.debezium.relational.RelationalSnapshotChangeEventSource.doExecute(RelationalSnapshotChangeEventSource.java:145) at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:76) ... 8 more 2023-05-17 08:52:53,620 INFO [debezium-connector-oracle-poc|task-0] Connected metrics set to 'false' (io.debezium.pipeline.ChangeEventSourceCoordinator) [debezium-oracleconnector-oracle.cytric-poc.-change-event-source-coordinator] 2023-05-17 08:52:53,904 ERROR [debezium-connector-oracle-poc|task-0] WorkerSourceTask{id=debezium-connector-oracle-poc-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) [task-thread-debezium-connector-oracle-poc-0] 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:72) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:125) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at java.base/java.lang.Thread.run(Thread.java:833) Caused by: io.debezium.DebeziumException: java.lang.NullPointerException: Cannot invoke "io.debezium.relational.Table.id()" because "table" is null at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:85) at io.debezium.pipeline.ChangeEventSourceCoordinator.doSnapshot(ChangeEventSourceCoordinator.java:186) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:152) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:118) ... 5 more Caused by: java.lang.NullPointerException: Cannot invoke "io.debezium.relational.Table.id()" because "table" is null at io.debezium.connector.oracle.OracleSnapshotChangeEventSource.getCreateTableEvent(OracleSnapshotChangeEventSource.java:210) at io.debezium.relational.RelationalSnapshotChangeEventSource.createSchemaChangeEventsForTables(RelationalSnapshotChangeEventSource.java:352) at io.debezium.relational.RelationalSnapshotChangeEventSource.doExecute(RelationalSnapshotChangeEventSource.java:145) at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:76) ... 8 more 2023-05-17 08:52:53,906 INFO [debezium-connector-oracle-poc|task-0] Stopping down connector (io.debezium.connector.common.BaseSourceTask) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:53,908 INFO [debezium-connector-oracle-poc|task-0] SignalProcessor stopped (io.debezium.pipeline.signal.SignalProcessor) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:53,911 INFO [debezium-connector-oracle-poc|task-0] Connection gracefully closed (io.debezium.jdbc.JdbcConnection) [pool-16-thread-1] 2023-05-17 08:52:53,912 INFO [debezium-connector-oracle-poc|task-0] [Producer clientId=oracle.cytric-poc.-schemahistory] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:53,916 INFO [debezium-connector-oracle-poc|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:53,916 INFO [debezium-connector-oracle-poc|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:53,916 INFO [debezium-connector-oracle-poc|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:53,916 INFO [debezium-connector-oracle-poc|task-0] App info kafka.producer for oracle.cytric-poc.-schemahistory unregistered (org.apache.kafka.common.utils.AppInfoParser) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:53,917 INFO [debezium-connector-oracle-poc|task-0] [Producer clientId=connector-producer-debezium-connector-oracle-poc-0] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:53,921 INFO [debezium-connector-oracle-poc|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:53,921 INFO [debezium-connector-oracle-poc|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:53,921 INFO [debezium-connector-oracle-poc|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:53,921 INFO [debezium-connector-oracle-poc|task-0] App info kafka.producer for connector-producer-debezium-connector-oracle-poc-0 unregistered (org.apache.kafka.common.utils.AppInfoParser) [task-thread-debezium-connector-oracle-poc-0] 2023-05-17 08:52:58,046 INFO 10.130.6.1 - - [17/May/2023:08:52:58 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-20] 2023-05-17 08:52:58,046 INFO 10.130.6.1 - - [17/May/2023:08:52:58 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-19] 2023-05-17 08:53:08,045 INFO 10.130.6.1 - - [17/May/2023:08:53:08 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-22] 2023-05-17 08:53:08,045 INFO 10.130.6.1 - - [17/May/2023:08:53:08 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-21] 2023-05-17 08:53:18,045 INFO 10.130.6.1 - - [17/May/2023:08:53:18 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-19] 2023-05-17 08:53:18,045 INFO 10.130.6.1 - - [17/May/2023:08:53:18 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-20] 2023-05-17 08:53:28,044 INFO 10.130.6.1 - - [17/May/2023:08:53:28 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 2 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-25] 2023-05-17 08:53:28,045 INFO 10.130.6.1 - - [17/May/2023:08:53:28 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-23] 2023-05-17 08:53:38,046 INFO 10.130.6.1 - - [17/May/2023:08:53:38 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-24] 2023-05-17 08:53:38,046 INFO 10.130.6.1 - - [17/May/2023:08:53:38 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-21] 2023-05-17 08:53:48,045 INFO 10.130.6.1 - - [17/May/2023:08:53:48 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-22] 2023-05-17 08:53:48,046 INFO 10.130.6.1 - - [17/May/2023:08:53:48 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-25] 2023-05-17 08:53:58,043 INFO 10.130.6.1 - - [17/May/2023:08:53:58 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 1 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-23] 2023-05-17 08:53:58,044 INFO 10.130.6.1 - - [17/May/2023:08:53:58 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 2 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-20] 2023-05-17 08:54:08,046 INFO 10.130.6.1 - - [17/May/2023:08:54:08 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-22] 2023-05-17 08:54:08,046 INFO 10.130.6.1 - - [17/May/2023:08:54:08 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-24] 2023-05-17 08:54:18,044 INFO 10.130.6.1 - - [17/May/2023:08:54:18 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 2 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-25] 2023-05-17 08:54:18,046 INFO 10.130.6.1 - - [17/May/2023:08:54:18 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-19] 2023-05-17 08:54:28,046 INFO 10.130.6.1 - - [17/May/2023:08:54:28 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-20] 2023-05-17 08:54:28,046 INFO 10.130.6.1 - - [17/May/2023:08:54:28 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-23] 2023-05-17 08:54:38,046 INFO 10.130.6.1 - - [17/May/2023:08:54:38 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-20] 2023-05-17 08:54:38,046 INFO 10.130.6.1 - - [17/May/2023:08:54:38 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-24] 2023-05-17 08:54:46,343 INFO 10.129.3.16 - - [17/May/2023:08:54:46 +0000] "GET /admin/loggers/ HTTP/1.1" 200 142 "-" "-" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-24] 2023-05-17 08:54:46,343 INFO 10.129.3.16 - - [17/May/2023:08:54:46 +0000] "GET /connectors HTTP/1.1" 200 33 "-" "-" 5 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-21] 2023-05-17 08:54:46,343 INFO 10.129.3.16 - - [17/May/2023:08:54:46 +0000] "GET /connector-plugins HTTP/1.1" 200 406 "-" "-" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-20] 2023-05-17 08:54:46,351 INFO 10.129.3.16 - - [17/May/2023:08:54:46 +0000] "GET /connectors/debezium-connector-oracle-poc/config HTTP/1.1" 200 906 "-" "-" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-25] 2023-05-17 08:54:46,361 INFO 10.129.3.16 - - [17/May/2023:08:54:46 +0000] "GET /connectors/debezium-connector-oracle-poc/status HTTP/1.1" 200 2207 "-" "-" 5 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-22] 2023-05-17 08:54:46,373 INFO 10.129.3.16 - - [17/May/2023:08:54:46 +0000] "GET /connectors/debezium-connector-oracle-poc/status HTTP/1.1" 200 2207 "-" "-" 6 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-20] 2023-05-17 08:54:46,425 INFO 10.129.3.16 - - [17/May/2023:08:54:46 +0000] "GET /connectors/debezium-connector-oracle-poc/topics HTTP/1.1" 200 47 "-" "-" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-23] 2023-05-17 08:54:48,044 INFO 10.130.6.1 - - [17/May/2023:08:54:48 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 2 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-22] 2023-05-17 08:54:48,045 INFO 10.130.6.1 - - [17/May/2023:08:54:48 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-19] 2023-05-17 08:54:58,043 INFO 10.130.6.1 - - [17/May/2023:08:54:58 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 2 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-25] 2023-05-17 08:54:58,044 INFO 10.130.6.1 - - [17/May/2023:08:54:58 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-24] 2023-05-17 08:55:08,045 INFO 10.130.6.1 - - [17/May/2023:08:55:08 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-20] 2023-05-17 08:55:08,046 INFO 10.130.6.1 - - [17/May/2023:08:55:08 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-23] 2023-05-17 08:55:18,044 INFO 10.130.6.1 - - [17/May/2023:08:55:18 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 2 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-22] 2023-05-17 08:55:18,045 INFO 10.130.6.1 - - [17/May/2023:08:55:18 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-19] 2023-05-17 08:55:28,046 INFO 10.130.6.1 - - [17/May/2023:08:55:28 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-20] 2023-05-17 08:55:28,046 INFO 10.130.6.1 - - [17/May/2023:08:55:28 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-21] 2023-05-17 08:55:38,046 INFO 10.130.6.1 - - [17/May/2023:08:55:38 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-20] 2023-05-17 08:55:38,046 INFO 10.130.6.1 - - [17/May/2023:08:55:38 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.23" 4 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp944826636-23]