Preparing trust store certificates for internal communication Adding /etc/tls-sidecar/cluster-ca-certs/ca.crt to truststore /tmp/topic-operator/replication.truststore.p12 with alias ca Certificate was added to keystore Preparing trust store certificates for internal communication is completed Preparing key store certificates for internal communication Preparing key store certificates for internal communication is completed + exec /usr/bin/tini -w -e 143 -- java -Dlog4j2.configurationFile=file:/opt/topic-operator/custom-config/log4j2.properties -Dvertx.cacheDirBase=/tmp/vertx-cache -Djava.security.egd=file:/dev/./urandom --illegal-access=deny -classpath lib/io.strimzi.topic-operator-0.28.0-SNAPSHOT.jar:lib/io.fabric8.kubernetes-model-node-5.12.0.jar:lib/io.netty.netty-common-4.1.71.Final.jar:lib/io.prometheus.simpleclient_common-0.7.0.jar:lib/io.fabric8.kubernetes-model-certificates-5.12.0.jar:lib/io.fabric8.kubernetes-model-flowcontrol-5.12.0.jar:lib/org.apache.logging.log4j.log4j-slf4j-impl-2.17.1.jar:lib/io.apicurio.apicurio-registry-utils-streams-1.3.2.Final.jar:lib/io.fabric8.openshift-model-hive-5.12.0.jar:lib/io.fabric8.openshift-model-installer-5.12.0.jar:lib/io.netty.netty-buffer-4.1.71.Final.jar:lib/com.fasterxml.jackson.datatype.jackson-datatype-jsr310-2.13.1.jar:lib/com.101tec.zkclient-0.11.jar:lib/org.lz4.lz4-java-1.8.0.jar:lib/io.fabric8.openshift-model-console-5.12.0.jar:lib/io.vertx.vertx-core-4.2.4.jar:lib/com.squareup.okio.okio-1.15.0.jar:lib/io.apicurio.apicurio-registry-utils-kafka-1.3.2.Final.jar:lib/org.xerial.snappy.snappy-java-1.1.8.4.jar:lib/io.strimzi.certificate-manager-0.28.0-SNAPSHOT.jar:lib/io.netty.netty-codec-http2-4.1.71.Final.jar:lib/io.fabric8.openshift-model-machineconfig-5.12.0.jar:lib/io.fabric8.openshift-model-storageversionmigrator-5.12.0.jar:lib/io.fabric8.kubernetes-model-policy-5.12.0.jar:lib/io.fabric8.openshift-model-machine-5.12.0.jar:lib/jakarta.annotation.jakarta.annotation-api-1.3.5.jar:lib/org.hdrhistogram.HdrHistogram-2.1.11.jar:lib/com.fasterxml.jackson.core.jackson-databind-2.11.3.jar:lib/io.prometheus.simpleclient-0.7.0.jar:lib/io.fabric8.openshift-model-miscellaneous-5.12.0.jar:lib/io.fabric8.kubernetes-model-metrics-5.12.0.jar:lib/com.squareup.okhttp3.logging-interceptor-3.12.12.jar:lib/io.strimzi.api-0.28.0-SNAPSHOT.jar:lib/org.apache.yetus.audience-annotations-0.5.0.jar:lib/io.fabric8.openshift-model-operatorhub-5.12.0.jar:lib/com.fasterxml.jackson.core.jackson-annotations-2.11.3.jar:lib/io.fabric8.kubernetes-model-core-5.12.0.jar:lib/io.fabric8.openshift-model-operator-5.12.0.jar:lib/io.fabric8.openshift-model-5.12.0.jar:lib/org.apache.zookeeper.zookeeper-jute-3.6.3.jar:lib/io.netty.netty-handler-4.1.71.Final.jar:lib/io.micrometer.micrometer-core-1.3.1.jar:lib/io.fabric8.kubernetes-model-admissionregistration-5.12.0.jar:lib/io.fabric8.kubernetes-model-apps-5.12.0.jar:lib/io.netty.netty-codec-4.1.71.Final.jar:lib/org.apache.logging.log4j.log4j-core-2.17.1.jar:lib/org.apache.zookeeper.zookeeper-3.6.3.jar:lib/io.fabric8.kubernetes-model-extensions-5.12.0.jar:lib/com.fasterxml.jackson.dataformat.jackson-dataformat-yaml-2.10.5.jar:lib/io.fabric8.kubernetes-model-batch-5.12.0.jar:lib/io.netty.netty-codec-http-4.1.71.Final.jar:lib/com.squareup.okhttp3.okhttp-3.12.12.jar:lib/io.fabric8.kubernetes-model-scheduling-5.12.0.jar:lib/com.github.mifmif.generex-1.0.2.jar:lib/com.github.luben.zstd-jni-1.5.0-4.jar:lib/io.fabric8.openshift-model-clusterautoscaling-5.12.0.jar:lib/com.fasterxml.jackson.core.jackson-core-2.11.3.jar:lib/io.fabric8.kubernetes-model-common-5.12.0.jar:lib/io.fabric8.kubernetes-client-5.12.0.jar:lib/io.fabric8.kubernetes-model-autoscaling-5.12.0.jar:lib/io.fabric8.openshift-model-tuned-5.12.0.jar:lib/org.yaml.snakeyaml-1.26.jar:lib/io.fabric8.kubernetes-model-coordination-5.12.0.jar:lib/io.netty.netty-resolver-dns-4.1.71.Final.jar:lib/io.apicurio.apicurio-registry-common-1.3.2.Final.jar:lib/io.fabric8.kubernetes-model-events-5.12.0.jar:lib/io.fabric8.kubernetes-model-apiextensions-5.12.0.jar:lib/io.fabric8.kubernetes-model-discovery-5.12.0.jar:lib/io.fabric8.openshift-client-5.12.0.jar:lib/dk.brics.automaton.automaton-1.11-8.jar:lib/io.fabric8.openshift-model-whereabouts-5.12.0.jar:lib/io.netty.netty-codec-socks-4.1.71.Final.jar:lib/org.eclipse.microprofile.config.microprofile-config-api-1.4.jar:lib/io.netty.netty-handler-proxy-4.1.71.Final.jar:lib/io.fabric8.kubernetes-model-rbac-5.12.0.jar:lib/io.netty.netty-resolver-4.1.71.Final.jar:lib/io.strimzi.crd-annotations-0.28.0-SNAPSHOT.jar:lib/org.apache.logging.log4j.log4j-api-2.17.1.jar:lib/io.fabric8.zjsonpatch-0.3.0.jar:lib/io.netty.netty-transport-classes-epoll-4.1.71.Final.jar:lib/org.jboss.spec.javax.ws.rs.jboss-jaxrs-api_2.1_spec-2.0.1.Final.jar:lib/io.fabric8.kubernetes-model-storageclass-5.12.0.jar:lib/io.fabric8.kubernetes-model-networking-5.12.0.jar:lib/io.netty.netty-codec-dns-4.1.71.Final.jar:lib/io.fabric8.openshift-model-monitoring-5.12.0.jar:lib/org.apache.kafka.kafka-streams-3.1.0.jar:lib/org.slf4j.slf4j-api-1.7.25.jar:lib/io.netty.netty-transport-native-unix-common-4.1.71.Final.jar:lib/org.latencyutils.LatencyUtils-2.0.3.jar:lib/io.netty.netty-transport-native-epoll-4.1.71.Final.jar:lib/org.rocksdb.rocksdbjni-6.22.1.1.jar:lib/io.vertx.vertx-micrometer-metrics-4.2.4.jar:lib/io.netty.netty-tcnative-classes-2.0.46.Final.jar:lib/io.netty.netty-transport-4.1.71.Final.jar:lib/org.apache.kafka.kafka-clients-3.1.0.jar:lib/io.strimzi.operator-common-0.28.0-SNAPSHOT.jar:lib/io.micrometer.micrometer-registry-prometheus-1.3.1.jar io.strimzi.operator.topic.Main 2022-02-02 23:10:41,79105 INFO [main] Main:29 - TopicOperator 0.28.0-SNAPSHOT is starting 2022-02-02 23:10:42,38274 DEBUG [main] Config:540 - Trying to configure client from Kubernetes config... 2022-02-02 23:10:42,38347 DEBUG [main] Config:546 - Did not find Kubernetes config at: [/home/strimzi/.kube/config]. Ignoring. 2022-02-02 23:10:42,38376 DEBUG [main] Config:469 - Trying to configure client from service account... 2022-02-02 23:10:42,38416 DEBUG [main] Config:477 - Found service account host and port: 10.96.0.1:443 2022-02-02 23:10:42,38457 DEBUG [main] Config:483 - Found service account ca cert at: [/var/run/secrets/kubernetes.io/serviceaccount/ca.crt}]. 2022-02-02 23:10:42,38491 DEBUG [main] Config:490 - Found service account token at: [/var/run/secrets/kubernetes.io/serviceaccount/token]. 2022-02-02 23:10:42,38512 DEBUG [main] Config:747 - Trying to configure client namespace from Kubernetes service account namespace path... 2022-02-02 23:10:42,38543 DEBUG [main] Config:752 - Found service account namespace at: [/var/run/secrets/kubernetes.io/serviceaccount/namespace]. 2022-02-02 23:10:43,10071 DEBUG [main] LoggerFactory: - Using io.vertx.core.logging.SLF4JLogDelegateFactory 2022-02-02 23:10:43,20544 DEBUG [main] InternalLoggerFactory:61 - Using SLF4J as the default logging framework 2022-02-02 23:10:43,39225 DEBUG [main] InternalLoggerFactory:63 - Using SLF4J as the default logging framework 2022-02-02 23:10:43,39400 DEBUG [main] PlatformDependent0:460 - -Dio.netty.noUnsafe: false 2022-02-02 23:10:43,39416 DEBUG [main] PlatformDependent0:954 - Java version: 11 2022-02-02 23:10:43,39483 DEBUG [main] PlatformDependent0:135 - sun.misc.Unsafe.theUnsafe: available 2022-02-02 23:10:43,39517 DEBUG [main] PlatformDependent0:159 - sun.misc.Unsafe.copyMemory: available 2022-02-02 23:10:43,39543 DEBUG [main] PlatformDependent0:202 - java.nio.Buffer.address: available 2022-02-02 23:10:43,39572 DEBUG [main] PlatformDependent0:285 - direct buffer constructor: unavailable: Reflective setAccessible(true) disabled 2022-02-02 23:10:43,39605 DEBUG [main] PlatformDependent0:350 - java.nio.Bits.unaligned: available, true 2022-02-02 23:10:43,39671 DEBUG [main] PlatformDependent0:417 - jdk.internal.misc.Unsafe.allocateUninitializedArray(int): unavailable: class io.netty.util.internal.PlatformDependent0$6 cannot access class jdk.internal.misc.Unsafe (in module java.base) because module java.base does not export jdk.internal.misc to unnamed module @36ac8a63 2022-02-02 23:10:43,39718 DEBUG [main] PlatformDependent0:446 - java.nio.DirectByteBuffer.(long, int): unavailable 2022-02-02 23:10:43,39737 DEBUG [main] PlatformDependent:1116 - sun.misc.Unsafe: available 2022-02-02 23:10:43,39774 DEBUG [main] PlatformDependent:1218 - maxDirectMemory: 127729664 bytes (maybe) 2022-02-02 23:10:43,39789 DEBUG [main] PlatformDependent:1237 - -Dio.netty.tmpdir: /tmp (java.io.tmpdir) 2022-02-02 23:10:43,39806 DEBUG [main] PlatformDependent:1316 - -Dio.netty.bitMode: 64 (sun.arch.data.model) 2022-02-02 23:10:43,39848 DEBUG [main] PlatformDependent:178 - -Dio.netty.maxDirectMemory: -1 bytes 2022-02-02 23:10:43,39863 DEBUG [main] PlatformDependent:185 - -Dio.netty.uninitializedArrayAllocationThreshold: -1 2022-02-02 23:10:43,39917 DEBUG [main] CleanerJava9:71 - java.nio.ByteBuffer.cleaner(): available 2022-02-02 23:10:43,39934 DEBUG [main] PlatformDependent:205 - -Dio.netty.noPreferDirect: false 2022-02-02 23:10:43,40612 DEBUG [main] ResourceLeakDetector:129 - -Dio.netty.leakDetection.level: simple 2022-02-02 23:10:43,40629 DEBUG [main] ResourceLeakDetector:130 - -Dio.netty.leakDetection.targetRecords: 4 2022-02-02 23:10:43,49700 DEBUG [main] MultithreadEventLoopGroup:44 - -Dio.netty.eventLoopThreads: 2 2022-02-02 23:10:43,58966 DEBUG [main] InternalThreadLocalMap:83 - -Dio.netty.threadLocalMap.stringBuilder.initialSize: 1024 2022-02-02 23:10:43,58988 DEBUG [main] InternalThreadLocalMap:86 - -Dio.netty.threadLocalMap.stringBuilder.maxSize: 4096 2022-02-02 23:10:43,59499 DEBUG [main] NioEventLoop:109 - -Dio.netty.noKeySetOptimization: false 2022-02-02 23:10:43,59519 DEBUG [main] NioEventLoop:110 - -Dio.netty.selectorAutoRebuildThreshold: 512 2022-02-02 23:10:43,59886 DEBUG [main] PlatformDependent:967 - org.jctools-core.MpscChunkedArrayQueue: available 2022-02-02 23:10:43,79207 DEBUG [main] DefaultDnsServerAddressStreamProvider:80 - Default DNS servers: [/10.96.0.10:53] (sun.net.dns.ResolverConfiguration) 2022-02-02 23:10:43,79666 DEBUG [main] NetUtil:135 - -Djava.net.preferIPv4Stack: false 2022-02-02 23:10:43,79689 DEBUG [main] NetUtil:136 - -Djava.net.preferIPv6Addresses: false 2022-02-02 23:10:43,79816 DEBUG [main] NetUtilInitializations:129 - Loopback interface: lo (lo, 0:0:0:0:0:0:0:1%lo) 2022-02-02 23:10:43,79895 DEBUG [main] NetUtil:169 - /proc/sys/net/core/somaxconn: 128 2022-02-02 23:10:43,89321 INFO [main] Session:77 - Using config: STRIMZI_TRUSTSTORE_LOCATION: /tmp/topic-operator/replication.truststore.p12 STRIMZI_RESOURCE_LABELS: strimzi.io/cluster=my-cluster STRIMZI_SASL_MECHANISM: STRIMZI_SASL_USERNAME: STRIMZI_FULL_RECONCILIATION_INTERVAL_MS: 120000 STRIMZI_CLIENT_ID: strimzi-topic-operator-ab1ddee9-cb78-43ba-baf2-94b989aab241 STRIMZI_SECURITY_PROTOCOL: SSL STRIMZI_STALE_RESULT_TIMEOUT_MS: 5000 STRIMZI_TOPIC_METADATA_MAX_ATTEMPTS: 6 STRIMZI_KEYSTORE_LOCATION: /tmp/topic-operator/replication.keystore.p12 STRIMZI_REASSIGN_THROTTLE: 9223372036854775807 STRIMZI_USE_ZOOKEEPER_TOPIC_STORE: false STRIMZI_SASL_PASSWORD: ******** STRIMZI_KAFKA_BOOTSTRAP_SERVERS: my-cluster-kafka-bootstrap:9091 STRIMZI_SASL_ENABLED: false STRIMZI_SSL_ENDPOINT_IDENTIFICATION_ALGORITHM: HTTPS STRIMZI_NAMESPACE: myproject STRIMZI_APPLICATION_ID: __strimzi-topic-operator-kstreams STRIMZI_ZOOKEEPER_SESSION_TIMEOUT_MS: 18000 STRIMZI_TOPICS_PATH: /strimzi/topics STRIMZI_ZOOKEEPER_CONNECT: localhost:2181 STRIMZI_TLS_ENABLED: true STRIMZI_KEYSTORE_PASSWORD: ******** STRIMZI_STORE_NAME: topic-store STRIMZI_REASSIGN_VERIFY_INTERVAL_MS: 120000 TC_ZK_CONNECTION_TIMEOUT_MS: 18000 STRIMZI_TRUSTSTORE_PASSWORD: ******** STRIMZI_STORE_TOPIC: __strimzi_store_topic 2022-02-02 23:10:43,89965 INFO [vert.x-eventloop-thread-0] Session:155 - Starting 2022-02-02 23:10:44,59997 DEBUG [vert.x-eventloop-thread-0] DefaultSslEngineFactory:264 - Created SSL context with keystore SecurityStore(path=/tmp/topic-operator/replication.keystore.p12, modificationTime=Wed Feb 02 23:10:39 GMT 2022), truststore SecurityStore(path=/tmp/topic-operator/replication.truststore.p12, modificationTime=Wed Feb 02 23:10:39 GMT 2022), provider SunJSSE. 2022-02-02 23:10:44,69308 INFO [vert.x-eventloop-thread-0] AppInfoParser:119 - Kafka version: 3.1.0 2022-02-02 23:10:44,69327 INFO [vert.x-eventloop-thread-0] AppInfoParser:120 - Kafka commitId: 37edeed0777bacb3 2022-02-02 23:10:44,69336 INFO [vert.x-eventloop-thread-0] AppInfoParser:121 - Kafka startTimeMs: 1643843444692 2022-02-02 23:10:44,69427 DEBUG [vert.x-eventloop-thread-0] Session:161 - Using AdminClient org.apache.kafka.clients.admin.KafkaAdminClient@5572910d 2022-02-02 23:10:44,69501 DEBUG [vert.x-eventloop-thread-0] Session:163 - Using Kafka io.strimzi.operator.topic.KafkaImpl@46514f5d 2022-02-02 23:10:44,69513 DEBUG [vert.x-eventloop-thread-0] Session:167 - Using namespace myproject 2022-02-02 23:10:44,69789 DEBUG [vert.x-eventloop-thread-0] Session:169 - Using k8s io.strimzi.operator.topic.K8sImpl@35aa60a 2022-02-02 23:10:44,69803 DEBUG [vert.x-eventloop-thread-0] Session:172 - Using client-Id strimzi-topic-operator-ab1ddee9-cb78-43ba-baf2-94b989aab241 2022-02-02 23:10:44,79121 DEBUG [vert.x-worker-thread-0] ZkConnection:69 - Creating new ZookKeeper instance to connect to localhost:2181. 2022-02-02 23:10:44,79121 INFO [ZkClient-EventThread-20-localhost:2181] ZkEventThread:65 - Starting ZkClient event thread. 2022-02-02 23:10:44,79678 INFO [vert.x-worker-thread-0] ZooKeeper:98 - Client environment:zookeeper.version=3.6.3--6401e4ad2087061bc6b9f80dec2d69f2e3c8660a, built on 04/08/2021 16:35 GMT 2022-02-02 23:10:44,79694 INFO [vert.x-worker-thread-0] ZooKeeper:98 - Client environment:host.name=my-cluster-entity-operator-cfcf644cc-pq5bl 2022-02-02 23:10:44,79706 INFO [vert.x-worker-thread-0] ZooKeeper:98 - Client environment:java.version=11.0.14 2022-02-02 23:10:44,79717 INFO [vert.x-worker-thread-0] ZooKeeper:98 - Client environment:java.vendor=Red Hat, Inc. 2022-02-02 23:10:44,79726 INFO [vert.x-worker-thread-0] ZooKeeper:98 - Client environment:java.home=/usr/lib/jvm/java-11-openjdk-11.0.14.0.9-2.el8_5.x86_64 2022-02-02 23:10:44,79738 INFO [vert.x-worker-thread-0] ZooKeeper:98 - Client environment:java.class.path=lib/io.strimzi.topic-operator-0.28.0-SNAPSHOT.jar:lib/io.fabric8.kubernetes-model-node-5.12.0.jar:lib/io.netty.netty-common-4.1.71.Final.jar:lib/io.prometheus.simpleclient_common-0.7.0.jar:lib/io.fabric8.kubernetes-model-certificates-5.12.0.jar:lib/io.fabric8.kubernetes-model-flowcontrol-5.12.0.jar:lib/org.apache.logging.log4j.log4j-slf4j-impl-2.17.1.jar:lib/io.apicurio.apicurio-registry-utils-streams-1.3.2.Final.jar:lib/io.fabric8.openshift-model-hive-5.12.0.jar:lib/io.fabric8.openshift-model-installer-5.12.0.jar:lib/io.netty.netty-buffer-4.1.71.Final.jar:lib/com.fasterxml.jackson.datatype.jackson-datatype-jsr310-2.13.1.jar:lib/com.101tec.zkclient-0.11.jar:lib/org.lz4.lz4-java-1.8.0.jar:lib/io.fabric8.openshift-model-console-5.12.0.jar:lib/io.vertx.vertx-core-4.2.4.jar:lib/com.squareup.okio.okio-1.15.0.jar:lib/io.apicurio.apicurio-registry-utils-kafka-1.3.2.Final.jar:lib/org.xerial.snappy.snappy-java-1.1.8.4.jar:lib/io.strimzi.certificate-manager-0.28.0-SNAPSHOT.jar:lib/io.netty.netty-codec-http2-4.1.71.Final.jar:lib/io.fabric8.openshift-model-machineconfig-5.12.0.jar:lib/io.fabric8.openshift-model-storageversionmigrator-5.12.0.jar:lib/io.fabric8.kubernetes-model-policy-5.12.0.jar:lib/io.fabric8.openshift-model-machine-5.12.0.jar:lib/jakarta.annotation.jakarta.annotation-api-1.3.5.jar:lib/org.hdrhistogram.HdrHistogram-2.1.11.jar:lib/com.fasterxml.jackson.core.jackson-databind-2.11.3.jar:lib/io.prometheus.simpleclient-0.7.0.jar:lib/io.fabric8.openshift-model-miscellaneous-5.12.0.jar:lib/io.fabric8.kubernetes-model-metrics-5.12.0.jar:lib/com.squareup.okhttp3.logging-interceptor-3.12.12.jar:lib/io.strimzi.api-0.28.0-SNAPSHOT.jar:lib/org.apache.yetus.audience-annotations-0.5.0.jar:lib/io.fabric8.openshift-model-operatorhub-5.12.0.jar:lib/com.fasterxml.jackson.core.jackson-annotations-2.11.3.jar:lib/io.fabric8.kubernetes-model-core-5.12.0.jar:lib/io.fabric8.openshift-model-operator-5.12.0.jar:lib/io.fabric8.openshift-model-5.12.0.jar:lib/org.apache.zookeeper.zookeeper-jute-3.6.3.jar:lib/io.netty.netty-handler-4.1.71.Final.jar:lib/io.micrometer.micrometer-core-1.3.1.jar:lib/io.fabric8.kubernetes-model-admissionregistration-5.12.0.jar:lib/io.fabric8.kubernetes-model-apps-5.12.0.jar:lib/io.netty.netty-codec-4.1.71.Final.jar:lib/org.apache.logging.log4j.log4j-core-2.17.1.jar:lib/org.apache.zookeeper.zookeeper-3.6.3.jar:lib/io.fabric8.kubernetes-model-extensions-5.12.0.jar:lib/com.fasterxml.jackson.dataformat.jackson-dataformat-yaml-2.10.5.jar:lib/io.fabric8.kubernetes-model-batch-5.12.0.jar:lib/io.netty.netty-codec-http-4.1.71.Final.jar:lib/com.squareup.okhttp3.okhttp-3.12.12.jar:lib/io.fabric8.kubernetes-model-scheduling-5.12.0.jar:lib/com.github.mifmif.generex-1.0.2.jar:lib/com.github.luben.zstd-jni-1.5.0-4.jar:lib/io.fabric8.openshift-model-clusterautoscaling-5.12.0.jar:lib/com.fasterxml.jackson.core.jackson-core-2.11.3.jar:lib/io.fabric8.kubernetes-model-common-5.12.0.jar:lib/io.fabric8.kubernetes-client-5.12.0.jar:lib/io.fabric8.kubernetes-model-autoscaling-5.12.0.jar:lib/io.fabric8.openshift-model-tuned-5.12.0.jar:lib/org.yaml.snakeyaml-1.26.jar:lib/io.fabric8.kubernetes-model-coordination-5.12.0.jar:lib/io.netty.netty-resolver-dns-4.1.71.Final.jar:lib/io.apicurio.apicurio-registry-common-1.3.2.Final.jar:lib/io.fabric8.kubernetes-model-events-5.12.0.jar:lib/io.fabric8.kubernetes-model-apiextensions-5.12.0.jar:lib/io.fabric8.kubernetes-model-discovery-5.12.0.jar:lib/io.fabric8.openshift-client-5.12.0.jar:lib/dk.brics.automaton.automaton-1.11-8.jar:lib/io.fabric8.openshift-model-whereabouts-5.12.0.jar:lib/io.netty.netty-codec-socks-4.1.71.Final.jar:lib/org.eclipse.microprofile.config.microprofile-config-api-1.4.jar:lib/io.netty.netty-handler-proxy-4.1.71.Final.jar:lib/io.fabric8.kubernetes-model-rbac-5.12.0.jar:lib/io.netty.netty-resolver-4.1.71.Final.jar:lib/io.strimzi.crd-annotations-0.28.0-SNAPSHOT.jar:lib/org.apache.logging.log4j.log4j-api-2.17.1.jar:lib/io.fabric8.zjsonpatch-0.3.0.jar:lib/io.netty.netty-transport-classes-epoll-4.1.71.Final.jar:lib/org.jboss.spec.javax.ws.rs.jboss-jaxrs-api_2.1_spec-2.0.1.Final.jar:lib/io.fabric8.kubernetes-model-storageclass-5.12.0.jar:lib/io.fabric8.kubernetes-model-networking-5.12.0.jar:lib/io.netty.netty-codec-dns-4.1.71.Final.jar:lib/io.fabric8.openshift-model-monitoring-5.12.0.jar:lib/org.apache.kafka.kafka-streams-3.1.0.jar:lib/org.slf4j.slf4j-api-1.7.25.jar:lib/io.netty.netty-transport-native-unix-common-4.1.71.Final.jar:lib/org.latencyutils.LatencyUtils-2.0.3.jar:lib/io.netty.netty-transport-native-epoll-4.1.71.Final.jar:lib/org.rocksdb.rocksdbjni-6.22.1.1.jar:lib/io.vertx.vertx-micrometer-metrics-4.2.4.jar:lib/io.netty.netty-tcnative-classes-2.0.46.Final.jar:lib/io.netty.netty-transport-4.1.71.Final.jar:lib/org.apache.kafka.kafka-clients-3.1.0.jar:lib/io.strimzi.operator-common-0.28.0-SNAPSHOT.jar:lib/io.micrometer.micrometer-registry-prometheus-1.3.1.jar 2022-02-02 23:10:44,79751 INFO [vert.x-worker-thread-0] ZooKeeper:98 - Client environment:java.library.path=/usr/java/packages/lib:/usr/lib64:/lib64:/lib:/usr/lib 2022-02-02 23:10:44,79760 INFO [vert.x-worker-thread-0] ZooKeeper:98 - Client environment:java.io.tmpdir=/tmp 2022-02-02 23:10:44,79767 INFO [vert.x-worker-thread-0] ZooKeeper:98 - Client environment:java.compiler= 2022-02-02 23:10:44,79774 INFO [vert.x-worker-thread-0] ZooKeeper:98 - Client environment:os.name=Linux 2022-02-02 23:10:44,79782 INFO [vert.x-worker-thread-0] ZooKeeper:98 - Client environment:os.arch=amd64 2022-02-02 23:10:44,79789 INFO [vert.x-worker-thread-0] ZooKeeper:98 - Client environment:os.version=4.18.0-348.2.1.el8_5.x86_64 2022-02-02 23:10:44,79796 INFO [vert.x-worker-thread-0] ZooKeeper:98 - Client environment:user.name=strimzi 2022-02-02 23:10:44,79803 INFO [vert.x-worker-thread-0] ZooKeeper:98 - Client environment:user.home=/home/strimzi 2022-02-02 23:10:44,79810 INFO [vert.x-worker-thread-0] ZooKeeper:98 - Client environment:user.dir=/opt/strimzi 2022-02-02 23:10:44,79817 INFO [vert.x-worker-thread-0] ZooKeeper:98 - Client environment:os.memory.free=12MB 2022-02-02 23:10:44,79824 INFO [vert.x-worker-thread-0] ZooKeeper:98 - Client environment:os.memory.max=121MB 2022-02-02 23:10:44,79831 INFO [vert.x-worker-thread-0] ZooKeeper:98 - Client environment:os.memory.total=24MB 2022-02-02 23:10:44,79947 INFO [vert.x-worker-thread-0] ZooKeeper:1006 - Initiating client connection, connectString=localhost:2181 sessionTimeout=18000 watcher=org.I0Itec.zkclient.ZkClient@4ed11a50 2022-02-02 23:10:44,80150 INFO [vert.x-worker-thread-0] X509Util:77 - Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation 2022-02-02 23:10:44,88506 DEBUG [kafka-admin-client-thread | adminclient-1] Selector:531 - [AdminClient clientId=adminclient-1] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node -1 2022-02-02 23:10:44,88545 INFO [vert.x-worker-thread-0] ClientCnxnSocket:239 - jute.maxbuffer value is 1048575 Bytes 2022-02-02 23:10:44,88908 INFO [vert.x-worker-thread-0] ClientCnxn:1736 - zookeeper.request.timeout value is 0. feature enabled=false 2022-02-02 23:10:44,88950 DEBUG [vert.x-worker-thread-0] ZkClient:1230 - Awaiting connection to Zookeeper server 2022-02-02 23:10:44,88969 INFO [vert.x-worker-thread-0] ZkClient:936 - Waiting for keeper state SyncConnected 2022-02-02 23:10:44,89183 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] SaslServerPrincipal:86 - Canonicalized address to localhost 2022-02-02 23:10:44,98311 INFO [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:1181 - Opening socket connection to server localhost/127.0.0.1:2181. 2022-02-02 23:10:44,98339 INFO [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:1183 - SASL config status: Will not attempt to authenticate using SASL (unknown error) 2022-02-02 23:10:44,98388 INFO [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:1013 - Socket connection established, initiating session, client: /127.0.0.1:56722, server: localhost/127.0.0.1:2181 2022-02-02 23:10:44,98522 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:1103 - Session establishment request sent on localhost/127.0.0.1:2181 2022-02-02 23:10:45,00481 INFO [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:1448 - Session establishment complete on server localhost/127.0.0.1:2181, session id = 0x200b69b00d40002, negotiated timeout = 18000 2022-02-02 23:10:45,00643 DEBUG [vert.x-worker-thread-0-EventThread] ZkClient:615 - Received event: WatchedEvent state:SyncConnected type:None path:null 2022-02-02 23:10:45,00672 INFO [vert.x-worker-thread-0-EventThread] ZkClient:713 - zookeeper state changed (SyncConnected) 2022-02-02 23:10:45,00687 DEBUG [vert.x-worker-thread-0-EventThread] ZkClient:659 - Leaving process event 2022-02-02 23:10:45,00693 DEBUG [vert.x-worker-thread-0] ZkClient:950 - State is SyncConnected 2022-02-02 23:10:45,08363 DEBUG [vert.x-eventloop-thread-0] Session:183 - Using ZooKeeper io.strimzi.operator.topic.zk.ZkImpl@56036121 2022-02-02 23:10:45,08767 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:970 - Reading reply session id: 0x200b69b00d40002, packet:: clientPath:null serverPath:null finished:false header:: 1,3 replyHeader:: 1,4294967417,-101 request:: '/strimzi/topics,F response:: 2022-02-02 23:10:45,48722 DEBUG [vert.x-eventloop-thread-0] DefaultSslEngineFactory:264 - Created SSL context with keystore SecurityStore(path=/tmp/topic-operator/replication.keystore.p12, modificationTime=Wed Feb 02 23:10:39 GMT 2022), truststore SecurityStore(path=/tmp/topic-operator/replication.truststore.p12, modificationTime=Wed Feb 02 23:10:39 GMT 2022), provider SunJSSE. 2022-02-02 23:10:45,49051 INFO [vert.x-eventloop-thread-0] AppInfoParser:119 - Kafka version: 3.1.0 2022-02-02 23:10:45,49063 INFO [vert.x-eventloop-thread-0] AppInfoParser:120 - Kafka commitId: 37edeed0777bacb3 2022-02-02 23:10:45,49072 INFO [vert.x-eventloop-thread-0] AppInfoParser:121 - Kafka startTimeMs: 1643843445490 2022-02-02 23:10:45,49113 INFO [vert.x-eventloop-thread-0] KafkaStreamsTopicStoreService:52 - Starting ... 2022-02-02 23:10:45,49317 DEBUG [kafka-admin-client-thread | adminclient-2] Selector:531 - [AdminClient clientId=adminclient-2] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node -1 2022-02-02 23:10:46,28705 DEBUG [kafka-admin-client-thread | adminclient-2] SslTransportLayer:452 - [SslTransportLayer channelId=-1 key=channel=java.nio.channels.SocketChannel[connection-pending remote=my-cluster-kafka-bootstrap/10.102.90.72:9091], selector=sun.nio.ch.EPollSelectorImpl@65ade916, interestOps=8, readyOps=0] SSL handshake completed successfully with peerHost 'my-cluster-kafka-bootstrap' peerPort 9091 peerPrincipal 'CN=my-cluster-kafka, O=io.strimzi' cipherSuite 'TLS_AES_256_GCM_SHA384' 2022-02-02 23:10:46,28831 DEBUG [kafka-admin-client-thread | adminclient-2] Selector:560 - [AdminClient clientId=adminclient-2] Successfully authenticated with my-cluster-kafka-bootstrap/10.102.90.72 2022-02-02 23:10:46,29183 DEBUG [kafka-admin-client-thread | adminclient-1] SslTransportLayer:452 - [SslTransportLayer channelId=-1 key=channel=java.nio.channels.SocketChannel[connection-pending remote=my-cluster-kafka-bootstrap/10.102.90.72:9091], selector=sun.nio.ch.EPollSelectorImpl@4cb30181, interestOps=8, readyOps=0] SSL handshake completed successfully with peerHost 'my-cluster-kafka-bootstrap' peerPort 9091 peerPrincipal 'CN=my-cluster-kafka, O=io.strimzi' cipherSuite 'TLS_AES_256_GCM_SHA384' 2022-02-02 23:10:46,29226 DEBUG [kafka-admin-client-thread | adminclient-1] Selector:560 - [AdminClient clientId=adminclient-1] Successfully authenticated with my-cluster-kafka-bootstrap/10.102.90.72 2022-02-02 23:10:46,60080 DEBUG [kafka-admin-client-thread | adminclient-2] Selector:531 - [AdminClient clientId=adminclient-2] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 0 2022-02-02 23:10:46,70363 DEBUG [kafka-admin-client-thread | adminclient-2] SslTransportLayer:452 - [SslTransportLayer channelId=0 key=channel=java.nio.channels.SocketChannel[connection-pending remote=my-cluster-kafka-0.my-cluster-kafka-brokers.myproject.svc/172.16.94.144:9091], selector=sun.nio.ch.EPollSelectorImpl@65ade916, interestOps=8, readyOps=0] SSL handshake completed successfully with peerHost 'my-cluster-kafka-0.my-cluster-kafka-brokers.myproject.svc' peerPort 9091 peerPrincipal 'CN=my-cluster-kafka, O=io.strimzi' cipherSuite 'TLS_AES_256_GCM_SHA384' 2022-02-02 23:10:46,70387 DEBUG [kafka-admin-client-thread | adminclient-2] Selector:560 - [AdminClient clientId=adminclient-2] Successfully authenticated with my-cluster-kafka-0.my-cluster-kafka-brokers.myproject.svc/172.16.94.144 2022-02-02 23:10:46,79107 INFO [kafka-admin-client-thread | adminclient-2] KafkaStreamsTopicStoreService:135 - Creating new store topic: __strimzi_store_topic 2022-02-02 23:10:47,31061 INFO [kafka-admin-client-thread | adminclient-2] KafkaStreamsTopicStoreService:97 - Creating Kafka Streams, store name: topic-store 2022-02-02 23:10:47,49108 WARN [vertx-blocked-thread-checker] BlockedThreadChecker: - Thread Thread[vert.x-eventloop-thread-0,5,main] has been blocked for 2407 ms, time limit is 2000 ms 2022-02-02 23:10:47,69017 DEBUG [kafka-admin-client-thread | adminclient-2] DefaultSslEngineFactory:264 - Created SSL context with keystore SecurityStore(path=/tmp/topic-operator/replication.keystore.p12, modificationTime=Wed Feb 02 23:10:39 GMT 2022), truststore SecurityStore(path=/tmp/topic-operator/replication.truststore.p12, modificationTime=Wed Feb 02 23:10:39 GMT 2022), provider SunJSSE. 2022-02-02 23:10:47,70253 INFO [kafka-admin-client-thread | adminclient-2] AppInfoParser:119 - Kafka version: 3.1.0 2022-02-02 23:10:47,70272 INFO [kafka-admin-client-thread | adminclient-2] AppInfoParser:120 - Kafka commitId: 37edeed0777bacb3 2022-02-02 23:10:47,70284 INFO [kafka-admin-client-thread | adminclient-2] AppInfoParser:121 - Kafka startTimeMs: 1643843447702 2022-02-02 23:10:47,70680 DEBUG [kafka-admin-client-thread | __strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-admin] Selector:531 - [AdminClient clientId=__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-admin] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node -1 2022-02-02 23:10:47,89949 DEBUG [kafka-admin-client-thread | __strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-admin] SslTransportLayer:452 - [SslTransportLayer channelId=-1 key=channel=java.nio.channels.SocketChannel[connection-pending remote=my-cluster-kafka-bootstrap/10.102.90.72:9091], selector=sun.nio.ch.EPollSelectorImpl@4d0bf4cb, interestOps=8, readyOps=0] SSL handshake completed successfully with peerHost 'my-cluster-kafka-bootstrap' peerPort 9091 peerPrincipal 'CN=my-cluster-kafka, O=io.strimzi' cipherSuite 'TLS_AES_256_GCM_SHA384' 2022-02-02 23:10:47,89990 DEBUG [kafka-admin-client-thread | __strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-admin] Selector:560 - [AdminClient clientId=__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-admin] Successfully authenticated with my-cluster-kafka-bootstrap/10.102.90.72 2022-02-02 23:10:48,09329 DEBUG [kafka-admin-client-thread | adminclient-2] DefaultSslEngineFactory:264 - Created SSL context with keystore SecurityStore(path=/tmp/topic-operator/replication.keystore.p12, modificationTime=Wed Feb 02 23:10:39 GMT 2022), truststore SecurityStore(path=/tmp/topic-operator/replication.truststore.p12, modificationTime=Wed Feb 02 23:10:39 GMT 2022), provider SunJSSE. 2022-02-02 23:10:48,10558 INFO [kafka-admin-client-thread | adminclient-2] AppInfoParser:119 - Kafka version: 3.1.0 2022-02-02 23:10:48,10571 INFO [kafka-admin-client-thread | adminclient-2] AppInfoParser:120 - Kafka commitId: 37edeed0777bacb3 2022-02-02 23:10:48,10584 INFO [kafka-admin-client-thread | adminclient-2] AppInfoParser:121 - Kafka startTimeMs: 1643843448105 2022-02-02 23:10:48,39093 DEBUG [kafka-admin-client-thread | adminclient-2] DefaultSslEngineFactory:264 - Created SSL context with keystore SecurityStore(path=/tmp/topic-operator/replication.keystore.p12, modificationTime=Wed Feb 02 23:10:39 GMT 2022), truststore SecurityStore(path=/tmp/topic-operator/replication.truststore.p12, modificationTime=Wed Feb 02 23:10:39 GMT 2022), provider SunJSSE. 2022-02-02 23:10:48,39689 INFO [kafka-admin-client-thread | adminclient-2] AppInfoParser:119 - Kafka version: 3.1.0 2022-02-02 23:10:48,39715 INFO [kafka-admin-client-thread | adminclient-2] AppInfoParser:120 - Kafka commitId: 37edeed0777bacb3 2022-02-02 23:10:48,39726 INFO [kafka-admin-client-thread | adminclient-2] AppInfoParser:121 - Kafka startTimeMs: 1643843448396 2022-02-02 23:10:48,39866 DEBUG [kafka-producer-network-thread | __strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1-producer] Selector:531 - [Producer clientId=__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1-producer] Created socket with SO_RCVBUF = 32768, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node -1 2022-02-02 23:10:48,49064 WARN [vertx-blocked-thread-checker] BlockedThreadChecker: - Thread Thread[vert.x-eventloop-thread-0,5,main] has been blocked for 3407 ms, time limit is 2000 ms 2022-02-02 23:10:48,49244 DEBUG [kafka-producer-network-thread | __strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1-producer] SslTransportLayer:452 - [SslTransportLayer channelId=-1 key=channel=java.nio.channels.SocketChannel[connection-pending remote=my-cluster-kafka-bootstrap/10.102.90.72:9091], selector=sun.nio.ch.EPollSelectorImpl@18da44d4, interestOps=8, readyOps=0] SSL handshake completed successfully with peerHost 'my-cluster-kafka-bootstrap' peerPort 9091 peerPrincipal 'CN=my-cluster-kafka, O=io.strimzi' cipherSuite 'TLS_AES_256_GCM_SHA384' 2022-02-02 23:10:48,49275 DEBUG [kafka-producer-network-thread | __strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1-producer] Selector:560 - [Producer clientId=__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1-producer] Successfully authenticated with my-cluster-kafka-bootstrap/10.102.90.72 2022-02-02 23:10:48,68918 DEBUG [kafka-admin-client-thread | adminclient-2] DefaultSslEngineFactory:264 - Created SSL context with keystore SecurityStore(path=/tmp/topic-operator/replication.keystore.p12, modificationTime=Wed Feb 02 23:10:39 GMT 2022), truststore SecurityStore(path=/tmp/topic-operator/replication.truststore.p12, modificationTime=Wed Feb 02 23:10:39 GMT 2022), provider SunJSSE. 2022-02-02 23:10:48,78377 INFO [kafka-admin-client-thread | adminclient-2] AppInfoParser:119 - Kafka version: 3.1.0 2022-02-02 23:10:48,78389 INFO [kafka-admin-client-thread | adminclient-2] AppInfoParser:120 - Kafka commitId: 37edeed0777bacb3 2022-02-02 23:10:48,78396 INFO [kafka-admin-client-thread | adminclient-2] AppInfoParser:121 - Kafka startTimeMs: 1643843448783 2022-02-02 23:10:48,79517 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] Selector:531 - [Consumer clientId=__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1-consumer, groupId=__strimzi-topic-operator-kstreams] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node -1 2022-02-02 23:10:48,89298 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] SslTransportLayer:452 - [SslTransportLayer channelId=-1 key=channel=java.nio.channels.SocketChannel[connection-pending remote=my-cluster-kafka-bootstrap/10.102.90.72:9091], selector=sun.nio.ch.EPollSelectorImpl@1ff4cc6, interestOps=8, readyOps=0] SSL handshake completed successfully with peerHost 'my-cluster-kafka-bootstrap' peerPort 9091 peerPrincipal 'CN=my-cluster-kafka, O=io.strimzi' cipherSuite 'TLS_AES_256_GCM_SHA384' 2022-02-02 23:10:48,89330 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] Selector:560 - [Consumer clientId=__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1-consumer, groupId=__strimzi-topic-operator-kstreams] Successfully authenticated with my-cluster-kafka-bootstrap/10.102.90.72 2022-02-02 23:10:48,99385 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] Selector:531 - [Consumer clientId=__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1-consumer, groupId=__strimzi-topic-operator-kstreams] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 0 2022-02-02 23:10:49,01682 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] SslTransportLayer:452 - [SslTransportLayer channelId=0 key=channel=java.nio.channels.SocketChannel[connection-pending remote=my-cluster-kafka-0.my-cluster-kafka-brokers.myproject.svc/172.16.94.144:9091], selector=sun.nio.ch.EPollSelectorImpl@1ff4cc6, interestOps=8, readyOps=0] SSL handshake completed successfully with peerHost 'my-cluster-kafka-0.my-cluster-kafka-brokers.myproject.svc' peerPort 9091 peerPrincipal 'CN=my-cluster-kafka, O=io.strimzi' cipherSuite 'TLS_AES_256_GCM_SHA384' 2022-02-02 23:10:49,01708 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] Selector:560 - [Consumer clientId=__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1-consumer, groupId=__strimzi-topic-operator-kstreams] Successfully authenticated with my-cluster-kafka-0.my-cluster-kafka-brokers.myproject.svc/172.16.94.144 2022-02-02 23:10:49,49102 WARN [vertx-blocked-thread-checker] BlockedThreadChecker: - Thread Thread[vert.x-eventloop-thread-0,5,main] has been blocked for 4407 ms, time limit is 2000 ms 2022-02-02 23:10:50,21826 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] Selector:531 - [Consumer clientId=__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1-consumer, groupId=__strimzi-topic-operator-kstreams] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 2147483645 2022-02-02 23:10:50,30282 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] SslTransportLayer:452 - [SslTransportLayer channelId=2147483645 key=channel=java.nio.channels.SocketChannel[connection-pending remote=my-cluster-kafka-2.my-cluster-kafka-brokers.myproject.svc/172.16.94.169:9091], selector=sun.nio.ch.EPollSelectorImpl@1ff4cc6, interestOps=8, readyOps=0] SSL handshake completed successfully with peerHost 'my-cluster-kafka-2.my-cluster-kafka-brokers.myproject.svc' peerPort 9091 peerPrincipal 'CN=my-cluster-kafka, O=io.strimzi' cipherSuite 'TLS_AES_256_GCM_SHA384' 2022-02-02 23:10:50,30303 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] Selector:560 - [Consumer clientId=__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1-consumer, groupId=__strimzi-topic-operator-kstreams] Successfully authenticated with my-cluster-kafka-2.my-cluster-kafka-brokers.myproject.svc/172.16.94.169 2022-02-02 23:10:50,49064 WARN [vertx-blocked-thread-checker] BlockedThreadChecker: - Thread Thread[vert.x-eventloop-thread-0,5,main] has been blocked for 5406 ms, time limit is 2000 ms io.vertx.core.VertxException: Thread blocked at jdk.internal.misc.Unsafe.park(Native Method) ~[?:?] at java.util.concurrent.locks.LockSupport.park(LockSupport.java:194) ~[?:?] at java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1796) ~[?:?] at java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3128) ~[?:?] at java.util.concurrent.CompletableFuture.waitingGet(CompletableFuture.java:1823) ~[?:?] at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1998) ~[?:?] at io.apicurio.registry.utils.ConcurrentUtil.get(ConcurrentUtil.java:35) ~[io.apicurio.apicurio-registry-common-1.3.2.Final.jar:?] at io.apicurio.registry.utils.ConcurrentUtil.get(ConcurrentUtil.java:27) ~[io.apicurio.apicurio-registry-common-1.3.2.Final.jar:?] at io.apicurio.registry.utils.ConcurrentUtil.result(ConcurrentUtil.java:54) ~[io.apicurio.apicurio-registry-common-1.3.2.Final.jar:?] at io.strimzi.operator.topic.Session.lambda$start$9(Session.java:198) ~[io.strimzi.topic-operator-0.28.0-SNAPSHOT.jar:0.28.0-SNAPSHOT] at io.strimzi.operator.topic.Session$$Lambda$283/0x0000000840326c40.handle(Unknown Source) ~[?:?] at io.vertx.core.impl.future.FutureImpl$3.onSuccess(FutureImpl.java:141) ~[io.vertx.vertx-core-4.2.4.jar:4.2.4] at io.vertx.core.impl.future.FutureBase.lambda$emitSuccess$0(FutureBase.java:54) ~[io.vertx.vertx-core-4.2.4.jar:4.2.4] at io.vertx.core.impl.future.FutureBase$$Lambda$296/0x0000000840378440.run(Unknown Source) ~[?:?] at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164) ~[io.netty.netty-common-4.1.71.Final.jar:4.1.71.Final] at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:469) ~[io.netty.netty-common-4.1.71.Final.jar:4.1.71.Final] at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:503) ~[io.netty.netty-transport-4.1.71.Final.jar:4.1.71.Final] at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:986) ~[io.netty.netty-common-4.1.71.Final.jar:4.1.71.Final] at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[io.netty.netty-common-4.1.71.Final.jar:4.1.71.Final] at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[io.netty.netty-common-4.1.71.Final.jar:4.1.71.Final] at java.lang.Thread.run(Thread.java:829) ~[?:?] 2022-02-02 23:10:51,09273 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:890 - Got ping response for session id: 0x200b69b00d40002 after 0ms. 2022-02-02 23:10:51,49061 WARN [vertx-blocked-thread-checker] BlockedThreadChecker: - Thread Thread[vert.x-eventloop-thread-0,5,main] has been blocked for 6406 ms, time limit is 2000 ms io.vertx.core.VertxException: Thread blocked at jdk.internal.misc.Unsafe.park(Native Method) ~[?:?] at java.util.concurrent.locks.LockSupport.park(LockSupport.java:194) ~[?:?] at java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1796) ~[?:?] at java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3128) ~[?:?] at java.util.concurrent.CompletableFuture.waitingGet(CompletableFuture.java:1823) ~[?:?] at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1998) ~[?:?] at io.apicurio.registry.utils.ConcurrentUtil.get(ConcurrentUtil.java:35) ~[io.apicurio.apicurio-registry-common-1.3.2.Final.jar:?] at io.apicurio.registry.utils.ConcurrentUtil.get(ConcurrentUtil.java:27) ~[io.apicurio.apicurio-registry-common-1.3.2.Final.jar:?] at io.apicurio.registry.utils.ConcurrentUtil.result(ConcurrentUtil.java:54) ~[io.apicurio.apicurio-registry-common-1.3.2.Final.jar:?] at io.strimzi.operator.topic.Session.lambda$start$9(Session.java:198) ~[io.strimzi.topic-operator-0.28.0-SNAPSHOT.jar:0.28.0-SNAPSHOT] at io.strimzi.operator.topic.Session$$Lambda$283/0x0000000840326c40.handle(Unknown Source) ~[?:?] at io.vertx.core.impl.future.FutureImpl$3.onSuccess(FutureImpl.java:141) ~[io.vertx.vertx-core-4.2.4.jar:4.2.4] at io.vertx.core.impl.future.FutureBase.lambda$emitSuccess$0(FutureBase.java:54) ~[io.vertx.vertx-core-4.2.4.jar:4.2.4] at io.vertx.core.impl.future.FutureBase$$Lambda$296/0x0000000840378440.run(Unknown Source) ~[?:?] at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164) ~[io.netty.netty-common-4.1.71.Final.jar:4.1.71.Final] at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:469) ~[io.netty.netty-common-4.1.71.Final.jar:4.1.71.Final] at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:503) ~[io.netty.netty-transport-4.1.71.Final.jar:4.1.71.Final] at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:986) ~[io.netty.netty-common-4.1.71.Final.jar:4.1.71.Final] at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[io.netty.netty-common-4.1.71.Final.jar:4.1.71.Final] at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[io.netty.netty-common-4.1.71.Final.jar:4.1.71.Final] at java.lang.Thread.run(Thread.java:829) ~[?:?] 2022-02-02 23:10:52,49075 WARN [vertx-blocked-thread-checker] BlockedThreadChecker: - Thread Thread[vert.x-eventloop-thread-0,5,main] has been blocked for 7406 ms, time limit is 2000 ms io.vertx.core.VertxException: Thread blocked at jdk.internal.misc.Unsafe.park(Native Method) ~[?:?] at java.util.concurrent.locks.LockSupport.park(LockSupport.java:194) ~[?:?] at java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1796) ~[?:?] at java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3128) ~[?:?] at java.util.concurrent.CompletableFuture.waitingGet(CompletableFuture.java:1823) ~[?:?] at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1998) ~[?:?] at io.apicurio.registry.utils.ConcurrentUtil.get(ConcurrentUtil.java:35) ~[io.apicurio.apicurio-registry-common-1.3.2.Final.jar:?] at io.apicurio.registry.utils.ConcurrentUtil.get(ConcurrentUtil.java:27) ~[io.apicurio.apicurio-registry-common-1.3.2.Final.jar:?] at io.apicurio.registry.utils.ConcurrentUtil.result(ConcurrentUtil.java:54) ~[io.apicurio.apicurio-registry-common-1.3.2.Final.jar:?] at io.strimzi.operator.topic.Session.lambda$start$9(Session.java:198) ~[io.strimzi.topic-operator-0.28.0-SNAPSHOT.jar:0.28.0-SNAPSHOT] at io.strimzi.operator.topic.Session$$Lambda$283/0x0000000840326c40.handle(Unknown Source) ~[?:?] at io.vertx.core.impl.future.FutureImpl$3.onSuccess(FutureImpl.java:141) ~[io.vertx.vertx-core-4.2.4.jar:4.2.4] at io.vertx.core.impl.future.FutureBase.lambda$emitSuccess$0(FutureBase.java:54) ~[io.vertx.vertx-core-4.2.4.jar:4.2.4] at io.vertx.core.impl.future.FutureBase$$Lambda$296/0x0000000840378440.run(Unknown Source) ~[?:?] at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164) ~[io.netty.netty-common-4.1.71.Final.jar:4.1.71.Final] at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:469) ~[io.netty.netty-common-4.1.71.Final.jar:4.1.71.Final] at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:503) ~[io.netty.netty-transport-4.1.71.Final.jar:4.1.71.Final] at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:986) ~[io.netty.netty-common-4.1.71.Final.jar:4.1.71.Final] at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[io.netty.netty-common-4.1.71.Final.jar:4.1.71.Final] at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[io.netty.netty-common-4.1.71.Final.jar:4.1.71.Final] at java.lang.Thread.run(Thread.java:829) ~[?:?] 2022-02-02 23:10:53,33868 DEBUG [kafka-admin-client-thread | __strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-admin] Selector:531 - [AdminClient clientId=__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-admin] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 2 2022-02-02 23:10:53,38737 DEBUG [kafka-admin-client-thread | __strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-admin] SslTransportLayer:452 - [SslTransportLayer channelId=2 key=channel=java.nio.channels.SocketChannel[connection-pending remote=my-cluster-kafka-2.my-cluster-kafka-brokers.myproject.svc/172.16.94.169:9091], selector=sun.nio.ch.EPollSelectorImpl@4d0bf4cb, interestOps=8, readyOps=0] SSL handshake completed successfully with peerHost 'my-cluster-kafka-2.my-cluster-kafka-brokers.myproject.svc' peerPort 9091 peerPrincipal 'CN=my-cluster-kafka, O=io.strimzi' cipherSuite 'TLS_AES_256_GCM_SHA384' 2022-02-02 23:10:53,38763 DEBUG [kafka-admin-client-thread | __strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-admin] Selector:560 - [AdminClient clientId=__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-admin] Successfully authenticated with my-cluster-kafka-2.my-cluster-kafka-brokers.myproject.svc/172.16.94.169 2022-02-02 23:10:53,39496 DEBUG [kafka-admin-client-thread | __strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-admin] Selector:531 - [AdminClient clientId=__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-admin] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 0 2022-02-02 23:10:53,48372 DEBUG [kafka-admin-client-thread | __strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-admin] SslTransportLayer:452 - [SslTransportLayer channelId=0 key=channel=java.nio.channels.SocketChannel[connection-pending remote=my-cluster-kafka-0.my-cluster-kafka-brokers.myproject.svc/172.16.94.144:9091], selector=sun.nio.ch.EPollSelectorImpl@4d0bf4cb, interestOps=8, readyOps=0] SSL handshake completed successfully with peerHost 'my-cluster-kafka-0.my-cluster-kafka-brokers.myproject.svc' peerPort 9091 peerPrincipal 'CN=my-cluster-kafka, O=io.strimzi' cipherSuite 'TLS_AES_256_GCM_SHA384' 2022-02-02 23:10:53,48392 DEBUG [kafka-admin-client-thread | __strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-admin] Selector:560 - [AdminClient clientId=__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-admin] Successfully authenticated with my-cluster-kafka-0.my-cluster-kafka-brokers.myproject.svc/172.16.94.144 2022-02-02 23:10:53,49087 WARN [vertx-blocked-thread-checker] BlockedThreadChecker: - Thread Thread[vert.x-eventloop-thread-0,5,main] has been blocked for 8407 ms, time limit is 2000 ms io.vertx.core.VertxException: Thread blocked at jdk.internal.misc.Unsafe.park(Native Method) ~[?:?] at java.util.concurrent.locks.LockSupport.park(LockSupport.java:194) ~[?:?] at java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1796) ~[?:?] at java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3128) ~[?:?] at java.util.concurrent.CompletableFuture.waitingGet(CompletableFuture.java:1823) ~[?:?] at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1998) ~[?:?] at io.apicurio.registry.utils.ConcurrentUtil.get(ConcurrentUtil.java:35) ~[io.apicurio.apicurio-registry-common-1.3.2.Final.jar:?] at io.apicurio.registry.utils.ConcurrentUtil.get(ConcurrentUtil.java:27) ~[io.apicurio.apicurio-registry-common-1.3.2.Final.jar:?] at io.apicurio.registry.utils.ConcurrentUtil.result(ConcurrentUtil.java:54) ~[io.apicurio.apicurio-registry-common-1.3.2.Final.jar:?] at io.strimzi.operator.topic.Session.lambda$start$9(Session.java:198) ~[io.strimzi.topic-operator-0.28.0-SNAPSHOT.jar:0.28.0-SNAPSHOT] at io.strimzi.operator.topic.Session$$Lambda$283/0x0000000840326c40.handle(Unknown Source) ~[?:?] at io.vertx.core.impl.future.FutureImpl$3.onSuccess(FutureImpl.java:141) ~[io.vertx.vertx-core-4.2.4.jar:4.2.4] at io.vertx.core.impl.future.FutureBase.lambda$emitSuccess$0(FutureBase.java:54) ~[io.vertx.vertx-core-4.2.4.jar:4.2.4] at io.vertx.core.impl.future.FutureBase$$Lambda$296/0x0000000840378440.run(Unknown Source) ~[?:?] at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164) ~[io.netty.netty-common-4.1.71.Final.jar:4.1.71.Final] at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:469) ~[io.netty.netty-common-4.1.71.Final.jar:4.1.71.Final] at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:503) ~[io.netty.netty-transport-4.1.71.Final.jar:4.1.71.Final] at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:986) ~[io.netty.netty-common-4.1.71.Final.jar:4.1.71.Final] at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[io.netty.netty-common-4.1.71.Final.jar:4.1.71.Final] at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[io.netty.netty-common-4.1.71.Final.jar:4.1.71.Final] at java.lang.Thread.run(Thread.java:829) ~[?:?] 2022-02-02 23:10:53,79672 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] Selector:531 - [Consumer clientId=__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1-restore-consumer, groupId=null] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node -1 2022-02-02 23:10:53,88769 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] SslTransportLayer:452 - [SslTransportLayer channelId=-1 key=channel=java.nio.channels.SocketChannel[connection-pending remote=my-cluster-kafka-bootstrap/10.102.90.72:9091], selector=sun.nio.ch.EPollSelectorImpl@179476b2, interestOps=8, readyOps=0] SSL handshake completed successfully with peerHost 'my-cluster-kafka-bootstrap' peerPort 9091 peerPrincipal 'CN=my-cluster-kafka, O=io.strimzi' cipherSuite 'TLS_AES_256_GCM_SHA384' 2022-02-02 23:10:53,88795 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] Selector:560 - [Consumer clientId=__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1-restore-consumer, groupId=null] Successfully authenticated with my-cluster-kafka-bootstrap/10.102.90.72 2022-02-02 23:10:53,90972 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] Selector:531 - [Consumer clientId=__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1-restore-consumer, groupId=null] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 0 2022-02-02 23:10:53,98806 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] SslTransportLayer:452 - [SslTransportLayer channelId=0 key=channel=java.nio.channels.SocketChannel[connection-pending remote=my-cluster-kafka-0.my-cluster-kafka-brokers.myproject.svc/172.16.94.144:9091], selector=sun.nio.ch.EPollSelectorImpl@179476b2, interestOps=8, readyOps=0] SSL handshake completed successfully with peerHost 'my-cluster-kafka-0.my-cluster-kafka-brokers.myproject.svc' peerPort 9091 peerPrincipal 'CN=my-cluster-kafka, O=io.strimzi' cipherSuite 'TLS_AES_256_GCM_SHA384' 2022-02-02 23:10:53,98824 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] Selector:560 - [Consumer clientId=__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1-restore-consumer, groupId=null] Successfully authenticated with my-cluster-kafka-0.my-cluster-kafka-brokers.myproject.svc/172.16.94.144 2022-02-02 23:10:53,99596 INFO [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] LoggingStateRestoreListener:16 - restore start: topicPartition=__strimzi-topic-operator-kstreams-topic-store-changelog-0, storeName=topic-store, startingOffset=0, endingOffset=0 2022-02-02 23:10:54,09661 INFO [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] LoggingStateRestoreListener:27 - restore end: topicPartition=__strimzi-topic-operator-kstreams-topic-store-changelog-0, storeName=topic-store, totalRestored=0 2022-02-02 23:10:54,09781 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] Selector:531 - [Consumer clientId=__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1-consumer, groupId=__strimzi-topic-operator-kstreams] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 2 2022-02-02 23:10:54,10506 INFO [Thread-3] KafkaStreamsTopicStoreService:81 - Creating topic store ... 2022-02-02 23:10:54,10844 INFO [Thread-4] KafkaStreamsTopicStoreService:72 - Started. 2022-02-02 23:10:54,10901 INFO [kafka-admin-client-thread | adminclient-2] AppInfoParser:83 - App info kafka.admin.client for adminclient-2 unregistered 2022-02-02 23:10:54,18546 INFO [kafka-admin-client-thread | adminclient-2] Metrics:659 - Metrics scheduler closed 2022-02-02 23:10:54,18561 INFO [kafka-admin-client-thread | adminclient-2] Metrics:663 - Closing reporter org.apache.kafka.common.metrics.JmxReporter 2022-02-02 23:10:54,18570 INFO [kafka-admin-client-thread | adminclient-2] Metrics:669 - Metrics reporters closed 2022-02-02 23:10:54,18609 DEBUG [vert.x-eventloop-thread-0] Session:214 - Using TopicStore io.strimzi.operator.topic.KafkaStreamsTopicStore@7ea24173 2022-02-02 23:10:54,18813 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] SslTransportLayer:452 - [SslTransportLayer channelId=2 key=channel=java.nio.channels.SocketChannel[connection-pending remote=my-cluster-kafka-2.my-cluster-kafka-brokers.myproject.svc/172.16.94.169:9091], selector=sun.nio.ch.EPollSelectorImpl@1ff4cc6, interestOps=8, readyOps=0] SSL handshake completed successfully with peerHost 'my-cluster-kafka-2.my-cluster-kafka-brokers.myproject.svc' peerPort 9091 peerPrincipal 'CN=my-cluster-kafka, O=io.strimzi' cipherSuite 'TLS_AES_256_GCM_SHA384' 2022-02-02 23:10:54,18831 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] Selector:560 - [Consumer clientId=__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1-consumer, groupId=__strimzi-topic-operator-kstreams] Successfully authenticated with my-cluster-kafka-2.my-cluster-kafka-brokers.myproject.svc/172.16.94.169 2022-02-02 23:10:54,19566 DEBUG [vert.x-eventloop-thread-0] Session:217 - Using Operator io.strimzi.operator.topic.TopicOperator@29821132 2022-02-02 23:10:54,19629 DEBUG [vert.x-eventloop-thread-0] Session:220 - Using TopicConfigsWatcher io.strimzi.operator.topic.TopicConfigsWatcher@171184b5 2022-02-02 23:10:54,19655 DEBUG [vert.x-eventloop-thread-0] Session:222 - Using TopicWatcher io.strimzi.operator.topic.ZkTopicWatcher@5d3f1bb2 2022-02-02 23:10:54,19695 DEBUG [vert.x-eventloop-thread-0] Session:224 - Using TopicsWatcher io.strimzi.operator.topic.ZkTopicsWatcher@1c022cfe 2022-02-02 23:10:54,28444 DEBUG [vert.x-eventloop-thread-0] Session:230 - Starting watcher 2022-02-02 23:10:54,28470 DEBUG [vert.x-eventloop-thread-0] Session:351 - Watching KafkaTopics matching {strimzi.io/cluster=my-cluster} 2022-02-02 23:10:54,28637 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:970 - Reading reply session id: 0x200b69b00d40002, packet:: clientPath:null serverPath:null finished:false header:: 2,3 replyHeader:: 2,4294967533,0 request:: '/brokers/topics,T response:: s{4294967304,4294967304,1643843417992,1643843417992,0,3,0,0,0,3,4294967530} 2022-02-02 23:10:54,28937 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:970 - Reading reply session id: 0x200b69b00d40002, packet:: clientPath:null serverPath:null finished:false header:: 3,8 replyHeader:: 3,4294967533,0 request:: '/brokers/topics,T response:: v{'__strimzi_store_topic,'__strimzi-topic-operator-kstreams-topic-store-changelog,'__consumer_offsets} 2022-02-02 23:10:54,49092 WARN [vertx-blocked-thread-checker] BlockedThreadChecker: - Thread Thread[vert.x-eventloop-thread-0,5,main] has been blocked for 9407 ms, time limit is 2000 ms io.vertx.core.VertxException: Thread blocked at java.lang.ClassLoader.defineClass1(Native Method) ~[?:?] at java.lang.ClassLoader.defineClass(ClassLoader.java:1017) ~[?:?] at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:174) ~[?:?] at jdk.internal.loader.BuiltinClassLoader.defineClass(BuiltinClassLoader.java:800) ~[?:?] at jdk.internal.loader.BuiltinClassLoader.findClassOnClassPathOrNull(BuiltinClassLoader.java:698) ~[?:?] at jdk.internal.loader.BuiltinClassLoader.loadClassOrNull(BuiltinClassLoader.java:621) ~[?:?] at jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:579) ~[?:?] at jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:178) ~[?:?] at java.lang.ClassLoader.loadClass(ClassLoader.java:522) ~[?:?] at com.fasterxml.jackson.databind.DeserializationConfig.(DeserializationConfig.java:108) ~[com.fasterxml.jackson.core.jackson-databind-2.11.3.jar:2.11.3] at com.fasterxml.jackson.databind.ObjectMapper.(ObjectMapper.java:629) ~[com.fasterxml.jackson.core.jackson-databind-2.11.3.jar:2.11.3] at com.fasterxml.jackson.databind.ObjectMapper.(ObjectMapper.java:542) ~[com.fasterxml.jackson.core.jackson-databind-2.11.3.jar:2.11.3] at io.fabric8.kubernetes.client.utils.Serialization.(Serialization.java:51) ~[io.fabric8.kubernetes-client-5.12.0.jar:?] at io.fabric8.kubernetes.client.dsl.base.OperationSupport.(OperationSupport.java:63) ~[io.fabric8.kubernetes-client-5.12.0.jar:?] at io.fabric8.kubernetes.client.ResourceHandlerImpl.operation(ResourceHandlerImpl.java:77) ~[io.fabric8.kubernetes-client-5.12.0.jar:?] at io.fabric8.kubernetes.client.Handlers.getOperation(Handlers.java:137) ~[io.fabric8.kubernetes-client-5.12.0.jar:?] at io.fabric8.kubernetes.client.BaseKubernetesClient.resources(BaseKubernetesClient.java:439) ~[io.fabric8.kubernetes-client-5.12.0.jar:?] at io.fabric8.kubernetes.client.BaseKubernetesClient.resources(BaseKubernetesClient.java:128) ~[io.fabric8.kubernetes-client-5.12.0.jar:?] at io.strimzi.operator.topic.Session.startWatcher(Session.java:353) ~[io.strimzi.topic-operator-0.28.0-SNAPSHOT.jar:0.28.0-SNAPSHOT] at io.strimzi.operator.topic.Session.lambda$start$9(Session.java:231) ~[io.strimzi.topic-operator-0.28.0-SNAPSHOT.jar:0.28.0-SNAPSHOT] at io.strimzi.operator.topic.Session$$Lambda$283/0x0000000840326c40.handle(Unknown Source) ~[?:?] at io.vertx.core.impl.future.FutureImpl$3.onSuccess(FutureImpl.java:141) ~[io.vertx.vertx-core-4.2.4.jar:4.2.4] at io.vertx.core.impl.future.FutureBase.lambda$emitSuccess$0(FutureBase.java:54) ~[io.vertx.vertx-core-4.2.4.jar:4.2.4] at io.vertx.core.impl.future.FutureBase$$Lambda$296/0x0000000840378440.run(Unknown Source) ~[?:?] at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164) ~[io.netty.netty-common-4.1.71.Final.jar:4.1.71.Final] at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:469) ~[io.netty.netty-common-4.1.71.Final.jar:4.1.71.Final] at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:503) ~[io.netty.netty-transport-4.1.71.Final.jar:4.1.71.Final] at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:986) ~[io.netty.netty-common-4.1.71.Final.jar:4.1.71.Final] at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[io.netty.netty-common-4.1.71.Final.jar:4.1.71.Final] at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[io.netty.netty-common-4.1.71.Final.jar:4.1.71.Final] at java.lang.Thread.run(Thread.java:829) ~[?:?] 2022-02-02 23:10:54,69847 DEBUG [vert.x-eventloop-thread-0] AbstractWatchManager:222 - Watching https://10.96.0.1:443/apis/kafka.strimzi.io/v1beta2/namespaces/myproject/kafkatopics?labelSelector=strimzi.io%2Fcluster%3Dmy-cluster&allowWatchBookmarks=true&watch=true... 2022-02-02 23:10:54,88819 DEBUG [vert.x-eventloop-thread-0] Session:355 - Watching setup 2022-02-02 23:10:54,88819 DEBUG [OkHttp https://10.96.0.1/...] WatcherWebSocketListener:43 - WebSocket successfully opened 2022-02-02 23:10:54,88856 DEBUG [vert.x-eventloop-thread-0] Session:233 - Starting health server 2022-02-02 23:10:54,98830 DEBUG [vert.x-eventloop-thread-0] PooledByteBufAllocator:155 - -Dio.netty.allocator.numHeapArenas: 1 2022-02-02 23:10:54,98841 DEBUG [vert.x-eventloop-thread-0] PooledByteBufAllocator:156 - -Dio.netty.allocator.numDirectArenas: 1 2022-02-02 23:10:54,98850 DEBUG [vert.x-eventloop-thread-0] PooledByteBufAllocator:158 - -Dio.netty.allocator.pageSize: 8192 2022-02-02 23:10:54,98859 DEBUG [vert.x-eventloop-thread-0] PooledByteBufAllocator:163 - -Dio.netty.allocator.maxOrder: 11 2022-02-02 23:10:54,98868 DEBUG [vert.x-eventloop-thread-0] PooledByteBufAllocator:167 - -Dio.netty.allocator.chunkSize: 16777216 2022-02-02 23:10:54,98875 DEBUG [vert.x-eventloop-thread-0] PooledByteBufAllocator:168 - -Dio.netty.allocator.smallCacheSize: 256 2022-02-02 23:10:54,98881 DEBUG [vert.x-eventloop-thread-0] PooledByteBufAllocator:169 - -Dio.netty.allocator.normalCacheSize: 64 2022-02-02 23:10:54,98891 DEBUG [vert.x-eventloop-thread-0] PooledByteBufAllocator:170 - -Dio.netty.allocator.maxCachedBufferCapacity: 32768 2022-02-02 23:10:54,98900 DEBUG [vert.x-eventloop-thread-0] PooledByteBufAllocator:171 - -Dio.netty.allocator.cacheTrimInterval: 8192 2022-02-02 23:10:54,98911 DEBUG [vert.x-eventloop-thread-0] PooledByteBufAllocator:172 - -Dio.netty.allocator.cacheTrimIntervalMillis: 0 2022-02-02 23:10:54,98918 DEBUG [vert.x-eventloop-thread-0] PooledByteBufAllocator:173 - -Dio.netty.allocator.useCacheForAllThreads: true 2022-02-02 23:10:54,98928 DEBUG [vert.x-eventloop-thread-0] PooledByteBufAllocator:174 - -Dio.netty.allocator.maxCachedByteBuffersPerChunk: 1023 2022-02-02 23:10:55,00296 DEBUG [vert.x-eventloop-thread-0] DefaultChannelId:79 - -Dio.netty.processId: 30 (auto-detected) 2022-02-02 23:10:55,00394 DEBUG [vert.x-eventloop-thread-0] DefaultChannelId:101 - -Dio.netty.machineId: f6:98:6a:ff:fe:94:06:a1 (auto-detected) 2022-02-02 23:10:55,09885 DEBUG [vert.x-eventloop-thread-0] ByteBufUtil:87 - -Dio.netty.allocator.type: pooled 2022-02-02 23:10:55,09897 DEBUG [vert.x-eventloop-thread-0] ByteBufUtil:96 - -Dio.netty.threadLocalDirectBufferSize: 0 2022-02-02 23:10:55,09906 DEBUG [vert.x-eventloop-thread-0] ByteBufUtil:99 - -Dio.netty.maxThreadLocalCharBufferSize: 16384 2022-02-02 23:10:55,18786 INFO [vert.x-eventloop-thread-0] TopicOperator:1314 - Starting initial reconciliation 2022-02-02 23:10:55,18825 DEBUG [vert.x-eventloop-thread-0] KafkaImpl:127 - Listing topics 2022-02-02 23:10:55,18991 DEBUG [kafka-admin-client-thread | adminclient-1] Selector:531 - [AdminClient clientId=adminclient-1] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 0 2022-02-02 23:10:55,18994 INFO [vert.x-eventloop-thread-0] Session:262 - Started 2022-02-02 23:10:55,19134 INFO [vert.x-eventloop-thread-1] Main:53 - Session deployed 2022-02-02 23:10:55,19272 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:970 - Reading reply session id: 0x200b69b00d40002, packet:: clientPath:null serverPath:null finished:false header:: 4,8 replyHeader:: 4,4294967533,0 request:: '/brokers/topics,T response:: v{'__strimzi_store_topic,'__strimzi-topic-operator-kstreams-topic-store-changelog,'__consumer_offsets} 2022-02-02 23:10:55,19313 DEBUG [vert.x-eventloop-thread-0] ZkTopicsWatcher:72 - Setting initial children [__strimzi_store_topic, __strimzi-topic-operator-kstreams-topic-store-changelog, __consumer_offsets] 2022-02-02 23:10:55,28828 DEBUG [kafka-admin-client-thread | adminclient-1] SslTransportLayer:452 - [SslTransportLayer channelId=0 key=channel=java.nio.channels.SocketChannel[connection-pending remote=my-cluster-kafka-0.my-cluster-kafka-brokers.myproject.svc/172.16.94.144:9091], selector=sun.nio.ch.EPollSelectorImpl@4cb30181, interestOps=8, readyOps=0] SSL handshake completed successfully with peerHost 'my-cluster-kafka-0.my-cluster-kafka-brokers.myproject.svc' peerPort 9091 peerPrincipal 'CN=my-cluster-kafka, O=io.strimzi' cipherSuite 'TLS_AES_256_GCM_SHA384' 2022-02-02 23:10:55,28846 DEBUG [kafka-admin-client-thread | adminclient-1] Selector:560 - [AdminClient clientId=adminclient-1] Successfully authenticated with my-cluster-kafka-0.my-cluster-kafka-brokers.myproject.svc/172.16.94.144 2022-02-02 23:10:55,29447 DEBUG [vert.x-eventloop-thread-1] TopicOperator:1398 - Reconciling kafka topics [__strimzi_store_topic, __strimzi-topic-operator-kstreams-topic-store-changelog, __consumer_offsets] 2022-02-02 23:10:55,38272 DEBUG [vert.x-eventloop-thread-0] TopicConfigsWatcher:75 - Reconciliation #1(/config/topics =__strimzi_store_topic) KafkaTopic(myproject/__strimzi_store_topic): Watching znode /config/topics/__strimzi_store_topic for changes 2022-02-02 23:10:55,38412 DEBUG [vert.x-eventloop-thread-0] ZkTopicWatcher:75 - Reconciliation #3(/config/topics =__strimzi_store_topic) KafkaTopic(myproject/__strimzi_store_topic): Watching znode /brokers/topics/__strimzi_store_topic for changes 2022-02-02 23:10:55,38412 DEBUG [vert.x-eventloop-thread-1] TopicOperator:472 - Reconciliation #2(initial kafka __strimzi_store_topic) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): Queuing action reconcile-from-kafka on topic __strimzi_store_topic 2022-02-02 23:10:55,38440 DEBUG [vert.x-eventloop-thread-0] TopicConfigsWatcher:75 - Reconciliation #4(/config/topics =__strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/__strimzi-topic-operator-kstreams-topic-store-changelog): Watching znode /config/topics/__strimzi-topic-operator-kstreams-topic-store-changelog for changes 2022-02-02 23:10:55,38453 DEBUG [vert.x-eventloop-thread-1] TopicOperator:475 - Reconciliation #5(initial kafka __strimzi_store_topic) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): Adding first waiter reconcile-from-kafka 2022-02-02 23:10:55,38463 DEBUG [vert.x-eventloop-thread-0] ZkTopicWatcher:75 - Reconciliation #6(/config/topics =__strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/__strimzi-topic-operator-kstreams-topic-store-changelog): Watching znode /brokers/topics/__strimzi-topic-operator-kstreams-topic-store-changelog for changes 2022-02-02 23:10:55,38485 DEBUG [vert.x-eventloop-thread-0] TopicConfigsWatcher:75 - Reconciliation #7(/config/topics =__consumer_offsets) KafkaTopic(myproject/__consumer_offsets): Watching znode /config/topics/__consumer_offsets for changes 2022-02-02 23:10:55,38508 DEBUG [vert.x-eventloop-thread-0] ZkTopicWatcher:75 - Reconciliation #8(/config/topics =__consumer_offsets) KafkaTopic(myproject/__consumer_offsets): Watching znode /brokers/topics/__consumer_offsets for changes 2022-02-02 23:10:55,38618 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:970 - Reading reply session id: 0x200b69b00d40002, packet:: clientPath:null serverPath:null finished:false header:: 5,3 replyHeader:: 5,4294967533,0 request:: '/config/topics/__strimzi_store_topic,T response:: s{4294967419,4294967419,1643843446818,1643843446818,0,0,0,0,50,0,4294967419} 2022-02-02 23:10:55,38645 DEBUG [io.strimzi.operator.topic.zk.ZkImpl-2] ZkClient:196 - Subscribed data changes for /config/topics/__strimzi_store_topic 2022-02-02 23:10:55,38735 DEBUG [vert.x-eventloop-thread-1] TopicOperator:484 - Reconciliation #9(initial kafka __strimzi_store_topic) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): Lock acquired 2022-02-02 23:10:55,38748 DEBUG [vert.x-eventloop-thread-1] TopicOperator:485 - Reconciliation #10(initial kafka __strimzi_store_topic) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): Executing action reconcile-from-kafka on topic __strimzi_store_topic 2022-02-02 23:10:55,38851 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:970 - Reading reply session id: 0x200b69b00d40002, packet:: clientPath:null serverPath:null finished:false header:: 6,3 replyHeader:: 6,4294967533,0 request:: '/brokers/topics/__strimzi_store_topic,T response:: s{4294967420,4294967420,1643843446823,1643843446823,0,1,0,0,120,1,4294967421} 2022-02-02 23:10:55,38866 DEBUG [io.strimzi.operator.topic.zk.ZkImpl-2] ZkClient:196 - Subscribed data changes for /brokers/topics/__strimzi_store_topic 2022-02-02 23:10:55,39087 DEBUG [vert.x-eventloop-thread-1] TopicOperator:1415 - Reconciliation #11(initial kafka __strimzi_store_topic) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): No private topic for topic __strimzi_store_topic in Kafka -> undetermined 2022-02-02 23:10:55,39090 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:970 - Reading reply session id: 0x200b69b00d40002, packet:: clientPath:null serverPath:null finished:false header:: 7,3 replyHeader:: 7,4294967533,0 request:: '/config/topics/__strimzi-topic-operator-kstreams-topic-store-changelog,T response:: s{4294967529,4294967529,1643843453494,1643843453494,0,0,0,0,144,0,4294967529} 2022-02-02 23:10:55,39103 DEBUG [io.strimzi.operator.topic.zk.ZkImpl-2] ZkClient:196 - Subscribed data changes for /config/topics/__strimzi-topic-operator-kstreams-topic-store-changelog 2022-02-02 23:10:55,39168 DEBUG [vert.x-eventloop-thread-1] TopicOperator:487 - Reconciliation #12(initial kafka __strimzi_store_topic) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): Executing handler for action reconcile-from-kafka on topic __strimzi_store_topic 2022-02-02 23:10:55,39304 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:970 - Reading reply session id: 0x200b69b00d40002, packet:: clientPath:null serverPath:null finished:false header:: 8,3 replyHeader:: 8,4294967533,0 request:: '/brokers/topics/__strimzi-topic-operator-kstreams-topic-store-changelog,T response:: s{4294967530,4294967530,1643843453497,1643843453497,0,1,0,0,120,1,4294967531} 2022-02-02 23:10:55,39318 DEBUG [io.strimzi.operator.topic.zk.ZkImpl-2] ZkClient:196 - Subscribed data changes for /brokers/topics/__strimzi-topic-operator-kstreams-topic-store-changelog 2022-02-02 23:10:55,39346 DEBUG [vert.x-eventloop-thread-1] TopicOperator:1087 - Reconciliation #13(initial kafka __strimzi_store_topic) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): No KafkaTopic to set status 2022-02-02 23:10:55,39395 DEBUG [vert.x-eventloop-thread-1] TopicOperator:530 - Reconciliation #14(initial kafka __strimzi_store_topic) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): Lock released 2022-02-02 23:10:55,39404 DEBUG [vert.x-eventloop-thread-1] TopicOperator:461 - Reconciliation #15(initial kafka __strimzi_store_topic) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): Removing last waiter reconcile-from-kafka 2022-02-02 23:10:55,39425 DEBUG [vert.x-eventloop-thread-1] TopicOperator:472 - Reconciliation #16(initial kafka __strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): Queuing action reconcile-from-kafka on topic __strimzi-topic-operator-kstreams-topic-store-changelog 2022-02-02 23:10:55,39433 DEBUG [vert.x-eventloop-thread-1] TopicOperator:475 - Reconciliation #17(initial kafka __strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): Adding first waiter reconcile-from-kafka 2022-02-02 23:10:55,39444 DEBUG [vert.x-eventloop-thread-1] TopicOperator:484 - Reconciliation #18(initial kafka __strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): Lock acquired 2022-02-02 23:10:55,39451 DEBUG [vert.x-eventloop-thread-1] TopicOperator:485 - Reconciliation #19(initial kafka __strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): Executing action reconcile-from-kafka on topic __strimzi-topic-operator-kstreams-topic-store-changelog 2022-02-02 23:10:55,39467 DEBUG [vert.x-eventloop-thread-1] TopicOperator:1415 - Reconciliation #20(initial kafka __strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): No private topic for topic __strimzi-topic-operator-kstreams-topic-store-changelog in Kafka -> undetermined 2022-02-02 23:10:55,39476 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:970 - Reading reply session id: 0x200b69b00d40002, packet:: clientPath:null serverPath:null finished:false header:: 9,3 replyHeader:: 9,4294967533,0 request:: '/config/topics/__consumer_offsets,T response:: s{4294967425,4294967425,1643843448930,1643843448930,0,0,0,0,109,0,4294967425} 2022-02-02 23:10:55,39477 DEBUG [vert.x-eventloop-thread-1] TopicOperator:487 - Reconciliation #21(initial kafka __strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): Executing handler for action reconcile-from-kafka on topic __strimzi-topic-operator-kstreams-topic-store-changelog 2022-02-02 23:10:55,39486 DEBUG [io.strimzi.operator.topic.zk.ZkImpl-2] ZkClient:196 - Subscribed data changes for /config/topics/__consumer_offsets 2022-02-02 23:10:55,39528 DEBUG [vert.x-eventloop-thread-1] TopicOperator:1087 - Reconciliation #22(initial kafka __strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): No KafkaTopic to set status 2022-02-02 23:10:55,39536 DEBUG [vert.x-eventloop-thread-1] TopicOperator:530 - Reconciliation #23(initial kafka __strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): Lock released 2022-02-02 23:10:55,39543 DEBUG [vert.x-eventloop-thread-1] TopicOperator:461 - Reconciliation #24(initial kafka __strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): Removing last waiter reconcile-from-kafka 2022-02-02 23:10:55,39557 DEBUG [vert.x-eventloop-thread-1] TopicOperator:472 - Reconciliation #25(initial kafka __consumer_offsets) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): Queuing action reconcile-from-kafka on topic __consumer_offsets 2022-02-02 23:10:55,39565 DEBUG [vert.x-eventloop-thread-1] TopicOperator:475 - Reconciliation #26(initial kafka __consumer_offsets) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): Adding first waiter reconcile-from-kafka 2022-02-02 23:10:55,39577 DEBUG [vert.x-eventloop-thread-1] TopicOperator:484 - Reconciliation #27(initial kafka __consumer_offsets) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): Lock acquired 2022-02-02 23:10:55,39584 DEBUG [vert.x-eventloop-thread-1] TopicOperator:485 - Reconciliation #28(initial kafka __consumer_offsets) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): Executing action reconcile-from-kafka on topic __consumer_offsets 2022-02-02 23:10:55,39597 DEBUG [vert.x-eventloop-thread-1] TopicOperator:1415 - Reconciliation #29(initial kafka __consumer_offsets) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): No private topic for topic __consumer_offsets in Kafka -> undetermined 2022-02-02 23:10:55,39605 DEBUG [vert.x-eventloop-thread-1] TopicOperator:487 - Reconciliation #30(initial kafka __consumer_offsets) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): Executing handler for action reconcile-from-kafka on topic __consumer_offsets 2022-02-02 23:10:55,39618 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:970 - Reading reply session id: 0x200b69b00d40002, packet:: clientPath:null serverPath:null finished:false header:: 10,3 replyHeader:: 10,4294967533,0 request:: '/brokers/topics/__consumer_offsets,T response:: s{4294967426,4294967426,1643843448936,1643843448936,0,1,0,0,748,1,4294967427} 2022-02-02 23:10:55,39627 DEBUG [io.strimzi.operator.topic.zk.ZkImpl-2] ZkClient:196 - Subscribed data changes for /brokers/topics/__consumer_offsets 2022-02-02 23:10:55,39644 DEBUG [vert.x-eventloop-thread-1] TopicOperator:1087 - Reconciliation #31(initial kafka __consumer_offsets) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): No KafkaTopic to set status 2022-02-02 23:10:55,39655 DEBUG [vert.x-eventloop-thread-1] TopicOperator:530 - Reconciliation #32(initial kafka __consumer_offsets) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): Lock released 2022-02-02 23:10:55,39663 DEBUG [vert.x-eventloop-thread-1] TopicOperator:461 - Reconciliation #33(initial kafka __consumer_offsets) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): Removing last waiter reconcile-from-kafka 2022-02-02 23:10:55,48326 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:970 - Reading reply session id: 0x200b69b00d40002, packet:: clientPath:null serverPath:null finished:false header:: 11,4 replyHeader:: 11,4294967533,0 request:: '/config/topics/__strimzi_store_topic,T response:: #7b2276657273696f6e223a312c22636f6e666967223a7b226d696e2e696e73796e632e7265706c69636173223a2232227d7d,s{4294967419,4294967419,1643843446818,1643843446818,0,0,0,0,50,0,4294967419} 2022-02-02 23:10:55,48530 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:970 - Reading reply session id: 0x200b69b00d40002, packet:: clientPath:null serverPath:null finished:false header:: 12,4 replyHeader:: 12,4294967533,0 request:: '/brokers/topics/__strimzi_store_topic,T response:: #7b22706172746974696f6e73223a7b2230223a5b322c302c315d7d2c22746f7069635f6964223a2275695278702d4d2d546971754a6335797738424c5467222c22616464696e675f7265706c69636173223a7b7d2c2272656d6f76696e675f7265706c69636173223a7b7d2c2276657273696f6e223a337d,s{4294967420,4294967420,1643843446823,1643843446823,0,1,0,0,120,1,4294967421} 2022-02-02 23:10:55,48615 WARN [kubernetes-ops-pool-0] VersionUsageUtils:60 - The client is using resource type 'kafkatopics' with unstable version 'v1beta2' 2022-02-02 23:10:55,48715 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:970 - Reading reply session id: 0x200b69b00d40002, packet:: clientPath:null serverPath:null finished:false header:: 13,4 replyHeader:: 13,4294967533,0 request:: '/config/topics/__strimzi-topic-operator-kstreams-topic-store-changelog,T response:: #7b2276657273696f6e223a312c22636f6e666967223a7b22636c65616e75702e706f6c696379223a22636f6d70616374222c226d696e2e636f6d70616374696f6e2e6c61672e6d73223a2230222c226d6573736167652e74696d657374616d702e74797065223a2243726561746554696d65222c227365676d656e742e6279746573223a223637313038383634227d7d,s{4294967529,4294967529,1643843453494,1643843453494,0,0,0,0,144,0,4294967529} 2022-02-02 23:10:55,49149 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:970 - Reading reply session id: 0x200b69b00d40002, packet:: clientPath:null serverPath:null finished:false header:: 14,4 replyHeader:: 14,4294967533,0 request:: '/brokers/topics/__strimzi-topic-operator-kstreams-topic-store-changelog,T response:: #7b22706172746974696f6e73223a7b2230223a5b302c312c325d7d2c22746f7069635f6964223a222d6d52364d646a5851534731445f4676307a59533251222c22616464696e675f7265706c69636173223a7b7d2c2272656d6f76696e675f7265706c69636173223a7b7d2c2276657273696f6e223a337d,s{4294967530,4294967530,1643843453497,1643843453497,0,1,0,0,120,1,4294967531} 2022-02-02 23:10:55,49325 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:970 - Reading reply session id: 0x200b69b00d40002, packet:: clientPath:null serverPath:null finished:false header:: 15,4 replyHeader:: 15,4294967533,0 request:: '/config/topics/__consumer_offsets,T response:: #7b2276657273696f6e223a312c22636f6e666967223a7b22636f6d7072657373696f6e2e74797065223a2270726f6475636572222c22636c65616e75702e706f6c696379223a22636f6d70616374222c227365676d656e742e6279746573223a22313034383537363030227d7d,s{4294967425,4294967425,1643843448930,1643843448930,0,0,0,0,109,0,4294967425} 2022-02-02 23:10:55,49551 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:970 - Reading reply session id: 0x200b69b00d40002, packet:: clientPath:null serverPath:null finished:false header:: 16,4 replyHeader:: 16,4294967533,0 request:: '/brokers/topics/__consumer_offsets,T response:: #7b22706172746974696f6e73223a7b223434223a5b322c302c315d2c223435223a5b302c322c315d2c223436223a5b312c302c325d2c223437223a5b322c312c305d2c223438223a5b302c312c325d2c223439223a5b312c322c305d2c223130223a5b312c302c325d2c223131223a5b322c312c305d2c223132223a5b302c312c325d2c223133223a5b312c322c305d2c223134223a5b322c302c315d2c223135223a5b302c322c315d2c223136223a5b312c302c325d2c223137223a5b322c312c305d2c223138223a5b302c312c325d2c223139223a5b312c322c305d2c2230223a5b302c312c325d2c2231223a5b312c322c305d2c2232223a5b322c302c315d2c2233223a5b302c322c315d2c2234223a5b312c302c325d2c2235223a5b322c312c305d2c2236223a5b302c312c325d2c2237223a5b312c322c305d2c2238223a5b322c302c315d2c2239223a5b302c322c315d2c223230223a5b322c302c315d2c223231223a5b302c322c315d2c223232223a5b312c302c325d2c223233223a5b322c312c305d2c223234223a5b302c312c325d2c223235223a5b312c322c305d2c223236223a5b322c302c315d2c223237223a5b302c322c315d2c223238223a5b312c302c325d2c223239223a5b322c312c305d2c223330223a5b302c312c325d2c223331223a5b312c322c305d2c223332223a5b322c302c315d2c223333223a5b302c322c315d2c223334223a5b312c302c325d2c223335223a5b322c312c305d2c223336223a5b302c312c325d2c223337223a5b312c322c305d2c223338223a5b322c302c315d2c223339223a5b302c322c315d2c223430223a5b312c302c325d2c223431223a5b322c312c305d2c223432223a5b302c312c325d2c223433223a5b312c322c305d7d2c22746f7069635f6964223a224972577346396635534a6d4e316b4956485150614677222c22616464696e675f7265706c69636173223a7b7d2c2272656d6f76696e675f7265706c69636173223a7b7d2c2276657273696f6e223a337d,s{4294967426,4294967426,1643843448936,1643843448936,0,1,0,0,748,1,4294967427} 2022-02-02 23:10:55,89503 DEBUG [vert.x-eventloop-thread-1] TopicOperator:1007 - Reconciliation #34(initial -__strimzi_store_topic) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): Metric delete-remaining triggered 2022-02-02 23:10:55,89539 DEBUG [vert.x-eventloop-thread-1] TopicOperator:472 - Reconciliation #35(initial -__strimzi_store_topic) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): Queuing action delete-remaining on topic __strimzi_store_topic 2022-02-02 23:10:55,89552 DEBUG [vert.x-eventloop-thread-1] TopicOperator:475 - Reconciliation #36(initial -__strimzi_store_topic) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): Adding first waiter delete-remaining 2022-02-02 23:10:55,89571 DEBUG [vert.x-eventloop-thread-1] TopicOperator:484 - Reconciliation #37(initial -__strimzi_store_topic) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): Lock acquired 2022-02-02 23:10:55,89581 DEBUG [vert.x-eventloop-thread-1] TopicOperator:485 - Reconciliation #38(initial -__strimzi_store_topic) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): Executing action delete-remaining on topic __strimzi_store_topic 2022-02-02 23:10:55,89628 DEBUG [vert.x-eventloop-thread-1] KafkaImpl:108 - Reconciliation #39(initial -__strimzi_store_topic) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): Getting metadata for topic __strimzi_store_topic 2022-02-02 23:10:55,89845 DEBUG [vert.x-eventloop-thread-1] TopicOperator:1007 - Reconciliation #40(initial -__strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): Metric delete-remaining triggered 2022-02-02 23:10:55,89865 DEBUG [vert.x-eventloop-thread-1] TopicOperator:472 - Reconciliation #41(initial -__strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): Queuing action delete-remaining on topic __strimzi-topic-operator-kstreams-topic-store-changelog 2022-02-02 23:10:55,89877 DEBUG [vert.x-eventloop-thread-1] TopicOperator:475 - Reconciliation #42(initial -__strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): Adding first waiter delete-remaining 2022-02-02 23:10:55,89896 DEBUG [vert.x-eventloop-thread-1] TopicOperator:484 - Reconciliation #43(initial -__strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): Lock acquired 2022-02-02 23:10:55,89903 DEBUG [vert.x-eventloop-thread-1] TopicOperator:485 - Reconciliation #44(initial -__strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): Executing action delete-remaining on topic __strimzi-topic-operator-kstreams-topic-store-changelog 2022-02-02 23:10:55,89910 DEBUG [vert.x-eventloop-thread-1] KafkaImpl:108 - Reconciliation #45(initial -__strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): Getting metadata for topic __strimzi-topic-operator-kstreams-topic-store-changelog 2022-02-02 23:10:55,89936 DEBUG [vert.x-eventloop-thread-1] TopicOperator:1007 - Reconciliation #46(initial -__consumer_offsets) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): Metric delete-remaining triggered 2022-02-02 23:10:55,89948 DEBUG [vert.x-eventloop-thread-1] TopicOperator:472 - Reconciliation #47(initial -__consumer_offsets) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): Queuing action delete-remaining on topic __consumer_offsets 2022-02-02 23:10:55,89955 DEBUG [vert.x-eventloop-thread-1] TopicOperator:475 - Reconciliation #48(initial -__consumer_offsets) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): Adding first waiter delete-remaining 2022-02-02 23:10:55,89965 DEBUG [vert.x-eventloop-thread-1] TopicOperator:484 - Reconciliation #49(initial -__consumer_offsets) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): Lock acquired 2022-02-02 23:10:55,89978 DEBUG [vert.x-eventloop-thread-1] TopicOperator:485 - Reconciliation #50(initial -__consumer_offsets) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): Executing action delete-remaining on topic __consumer_offsets 2022-02-02 23:10:55,89988 DEBUG [vert.x-eventloop-thread-1] KafkaImpl:108 - Reconciliation #51(initial -__consumer_offsets) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): Getting metadata for topic __consumer_offsets 2022-02-02 23:10:55,98599 DEBUG [kafka-admin-client-thread | adminclient-1] Selector:531 - [AdminClient clientId=adminclient-1] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 1 2022-02-02 23:10:55,98781 DEBUG [kafka-admin-client-thread | adminclient-1] Selector:531 - [AdminClient clientId=adminclient-1] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 2 2022-02-02 23:10:56,08385 DEBUG [kafka-admin-client-thread | adminclient-1] SslTransportLayer:452 - [SslTransportLayer channelId=1 key=channel=java.nio.channels.SocketChannel[connection-pending remote=my-cluster-kafka-1.my-cluster-kafka-brokers.myproject.svc/172.16.94.175:9091], selector=sun.nio.ch.EPollSelectorImpl@4cb30181, interestOps=8, readyOps=0] SSL handshake completed successfully with peerHost 'my-cluster-kafka-1.my-cluster-kafka-brokers.myproject.svc' peerPort 9091 peerPrincipal 'CN=my-cluster-kafka, O=io.strimzi' cipherSuite 'TLS_AES_256_GCM_SHA384' 2022-02-02 23:10:56,08400 DEBUG [kafka-admin-client-thread | adminclient-1] Selector:560 - [AdminClient clientId=adminclient-1] Successfully authenticated with my-cluster-kafka-1.my-cluster-kafka-brokers.myproject.svc/172.16.94.175 2022-02-02 23:10:56,09006 DEBUG [kafka-admin-client-thread | adminclient-1] SslTransportLayer:452 - [SslTransportLayer channelId=2 key=channel=java.nio.channels.SocketChannel[connection-pending remote=my-cluster-kafka-2.my-cluster-kafka-brokers.myproject.svc/172.16.94.169:9091], selector=sun.nio.ch.EPollSelectorImpl@4cb30181, interestOps=8, readyOps=0] SSL handshake completed successfully with peerHost 'my-cluster-kafka-2.my-cluster-kafka-brokers.myproject.svc' peerPort 9091 peerPrincipal 'CN=my-cluster-kafka, O=io.strimzi' cipherSuite 'TLS_AES_256_GCM_SHA384' 2022-02-02 23:10:56,09027 DEBUG [kafka-admin-client-thread | adminclient-1] Selector:560 - [AdminClient clientId=adminclient-1] Successfully authenticated with my-cluster-kafka-2.my-cluster-kafka-brokers.myproject.svc/172.16.94.169 2022-02-02 23:10:56,09139 INFO [vert.x-eventloop-thread-1] TopicOperator:576 - Reconciliation #52(initial -__strimzi_store_topic) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): Reconciling topic __strimzi_store_topic, k8sTopic:null, kafkaTopic:nonnull, privateTopic:null 2022-02-02 23:10:56,09156 DEBUG [vert.x-eventloop-thread-1] TopicOperator:589 - Reconciliation #53(initial -__strimzi_store_topic) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): topic created in kafka, will create KafkaTopic in k8s and topicStore 2022-02-02 23:10:56,09244 DEBUG [vert.x-eventloop-thread-1] TopicOperator:819 - Reconciliation #54(initial -__strimzi_store_topic) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): Enqueuing event CreateResource(topicName=__strimzi_store_topic,ctx=9|initial -__strimzi_store_topic) 2022-02-02 23:10:56,10030 DEBUG [vert.x-eventloop-thread-1] CustomResource:172 - Calling CustomResource#setKind doesn't do anything because the Kind is computed and shouldn't be changed 2022-02-02 23:10:56,18316 INFO [vert.x-eventloop-thread-1] TopicOperator:576 - Reconciliation #55(initial -__consumer_offsets) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): Reconciling topic __consumer_offsets, k8sTopic:null, kafkaTopic:nonnull, privateTopic:null 2022-02-02 23:10:56,18347 DEBUG [vert.x-eventloop-thread-1] TopicOperator:589 - Reconciliation #56(initial -__consumer_offsets) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): topic created in kafka, will create KafkaTopic in k8s and topicStore 2022-02-02 23:10:56,18378 DEBUG [vert.x-eventloop-thread-1] TopicOperator:819 - Reconciliation #57(initial -__consumer_offsets) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): Enqueuing event CreateResource(topicName=__consumer_offsets,ctx=11|initial -__consumer_offsets) 2022-02-02 23:10:56,18405 INFO [vert.x-eventloop-thread-1] TopicOperator:576 - Reconciliation #58(initial -__strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): Reconciling topic __strimzi-topic-operator-kstreams-topic-store-changelog, k8sTopic:null, kafkaTopic:nonnull, privateTopic:null 2022-02-02 23:10:56,18416 DEBUG [vert.x-eventloop-thread-1] TopicOperator:589 - Reconciliation #59(initial -__strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): topic created in kafka, will create KafkaTopic in k8s and topicStore 2022-02-02 23:10:56,18430 DEBUG [vert.x-eventloop-thread-1] TopicOperator:819 - Reconciliation #60(initial -__strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): Enqueuing event CreateResource(topicName=__strimzi-topic-operator-kstreams-topic-store-changelog,ctx=10|initial -__strimzi-topic-operator-kstreams-topic-store-changelog) 2022-02-02 23:10:56,18470 DEBUG [vert.x-eventloop-thread-1] CustomResource:172 - Calling CustomResource#setKind doesn't do anything because the Kind is computed and shouldn't be changed 2022-02-02 23:10:56,18514 DEBUG [vert.x-eventloop-thread-1] CustomResource:172 - Calling CustomResource#setKind doesn't do anything because the Kind is computed and shouldn't be changed 2022-02-02 23:10:56,20143 DEBUG [vert.x-worker-thread-1] CustomResource:172 - Calling CustomResource#setKind doesn't do anything because the Kind is computed and shouldn't be changed 2022-02-02 23:10:56,20275 DEBUG [vert.x-worker-thread-1] K8sImpl:52 - KafkaTopic strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55 created with version null->7465591 2022-02-02 23:10:56,28426 DEBUG [vert.x-eventloop-thread-1] TopicOperator:819 - Reconciliation #61(initial -__strimzi_store_topic) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): Enqueuing event CreateInTopicStore(topicName=__strimzi_store_topic,ctx=9|initial -__strimzi_store_topic) 2022-02-02 23:10:56,28448 DEBUG [vert.x-eventloop-thread-1] TopicOperator:1218 - Reconciliation #62(initial -__strimzi_store_topic) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): Executing CreateInTopicStore(topicName=__strimzi_store_topic,ctx=9|initial -__strimzi_store_topic) 2022-02-02 23:10:56,28501 DEBUG [vert.x-eventloop-thread-1] KafkaStreamsTopicStore:82 - Handling topic command [CREATE]: __strimzi_store_topic 2022-02-02 23:10:56,28623 INFO [vert.x-eventloop-thread-1] AsyncProducer:85 - Creating new resilient producer. 2022-02-02 23:10:56,28789 DEBUG [vert.x-worker-thread-1] CustomResource:172 - Calling CustomResource#setKind doesn't do anything because the Kind is computed and shouldn't be changed 2022-02-02 23:10:56,28848 DEBUG [vert.x-worker-thread-1] K8sImpl:52 - KafkaTopic consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a created with version null->7465592 2022-02-02 23:10:56,28907 DEBUG [OkHttp https://10.96.0.1/...] CustomResource:172 - Calling CustomResource#setKind doesn't do anything because the Kind is computed and shouldn't be changed 2022-02-02 23:10:56,29205 DEBUG [OkHttp https://10.96.0.1/...] K8sTopicWatcher:43 - Reconciliation #63(kube +strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): Ignoring initial event for KafkaTopic strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55 during initial reconcile 2022-02-02 23:10:56,29284 DEBUG [OkHttp https://10.96.0.1/...] CustomResource:172 - Calling CustomResource#setKind doesn't do anything because the Kind is computed and shouldn't be changed 2022-02-02 23:10:56,29322 DEBUG [OkHttp https://10.96.0.1/...] K8sTopicWatcher:43 - Reconciliation #64(kube +consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): Ignoring initial event for KafkaTopic consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a during initial reconcile 2022-02-02 23:10:56,29347 DEBUG [vert.x-worker-thread-1] CustomResource:172 - Calling CustomResource#setKind doesn't do anything because the Kind is computed and shouldn't be changed 2022-02-02 23:10:56,29383 DEBUG [OkHttp https://10.96.0.1/...] CustomResource:172 - Calling CustomResource#setKind doesn't do anything because the Kind is computed and shouldn't be changed 2022-02-02 23:10:56,29400 DEBUG [vert.x-worker-thread-1] K8sImpl:52 - KafkaTopic strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b created with version null->7465593 2022-02-02 23:10:56,29415 DEBUG [OkHttp https://10.96.0.1/...] K8sTopicWatcher:43 - Reconciliation #65(kube +strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): Ignoring initial event for KafkaTopic strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b during initial reconcile 2022-02-02 23:10:56,49314 DEBUG [vert.x-eventloop-thread-1] DefaultSslEngineFactory:264 - Created SSL context with keystore SecurityStore(path=/tmp/topic-operator/replication.keystore.p12, modificationTime=Wed Feb 02 23:10:39 GMT 2022), truststore SecurityStore(path=/tmp/topic-operator/replication.truststore.p12, modificationTime=Wed Feb 02 23:10:39 GMT 2022), provider SunJSSE. 2022-02-02 23:10:56,49468 INFO [vert.x-eventloop-thread-1] AppInfoParser:119 - Kafka version: 3.1.0 2022-02-02 23:10:56,49475 INFO [vert.x-eventloop-thread-1] AppInfoParser:120 - Kafka commitId: 37edeed0777bacb3 2022-02-02 23:10:56,49480 INFO [vert.x-eventloop-thread-1] AppInfoParser:121 - Kafka startTimeMs: 1643843456494 2022-02-02 23:10:56,49568 DEBUG [kafka-producer-network-thread | producer-1] Selector:531 - [Producer clientId=producer-1] Created socket with SO_RCVBUF = 32768, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node -1 2022-02-02 23:10:56,51012 DEBUG [kafka-producer-network-thread | producer-1] SslTransportLayer:452 - [SslTransportLayer channelId=-1 key=channel=java.nio.channels.SocketChannel[connection-pending remote=my-cluster-kafka-bootstrap/10.102.90.72:9091], selector=sun.nio.ch.EPollSelectorImpl@54e7e86d, interestOps=8, readyOps=0] SSL handshake completed successfully with peerHost 'my-cluster-kafka-bootstrap' peerPort 9091 peerPrincipal 'CN=my-cluster-kafka, O=io.strimzi' cipherSuite 'TLS_AES_256_GCM_SHA384' 2022-02-02 23:10:56,51031 DEBUG [kafka-producer-network-thread | producer-1] Selector:560 - [Producer clientId=producer-1] Successfully authenticated with my-cluster-kafka-bootstrap/10.102.90.72 2022-02-02 23:10:56,52095 DEBUG [vert.x-eventloop-thread-1] TopicOperator:819 - Reconciliation #66(initial -__consumer_offsets) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): Enqueuing event CreateInTopicStore(topicName=__consumer_offsets,ctx=11|initial -__consumer_offsets) 2022-02-02 23:10:56,52103 DEBUG [kafka-producer-network-thread | producer-1] Selector:531 - [Producer clientId=producer-1] Created socket with SO_RCVBUF = 32768, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 2 2022-02-02 23:10:56,52110 DEBUG [vert.x-eventloop-thread-1] TopicOperator:819 - Reconciliation #67(initial -__strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): Enqueuing event CreateInTopicStore(topicName=__strimzi-topic-operator-kstreams-topic-store-changelog,ctx=10|initial -__strimzi-topic-operator-kstreams-topic-store-changelog) 2022-02-02 23:10:56,52119 DEBUG [vert.x-eventloop-thread-1] TopicOperator:1218 - Reconciliation #68(initial -__consumer_offsets) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): Executing CreateInTopicStore(topicName=__consumer_offsets,ctx=11|initial -__consumer_offsets) 2022-02-02 23:10:56,52127 DEBUG [vert.x-eventloop-thread-1] KafkaStreamsTopicStore:82 - Handling topic command [CREATE]: __consumer_offsets 2022-02-02 23:10:56,52170 DEBUG [vert.x-eventloop-thread-1] TopicOperator:1218 - Reconciliation #69(initial -__strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): Executing CreateInTopicStore(topicName=__strimzi-topic-operator-kstreams-topic-store-changelog,ctx=10|initial -__strimzi-topic-operator-kstreams-topic-store-changelog) 2022-02-02 23:10:56,52177 DEBUG [vert.x-eventloop-thread-1] KafkaStreamsTopicStore:82 - Handling topic command [CREATE]: __strimzi-topic-operator-kstreams-topic-store-changelog 2022-02-02 23:10:56,59345 DEBUG [kafka-producer-network-thread | producer-1] SslTransportLayer:452 - [SslTransportLayer channelId=2 key=channel=java.nio.channels.SocketChannel[connection-pending remote=my-cluster-kafka-2.my-cluster-kafka-brokers.myproject.svc/172.16.94.169:9091], selector=sun.nio.ch.EPollSelectorImpl@54e7e86d, interestOps=8, readyOps=0] SSL handshake completed successfully with peerHost 'my-cluster-kafka-2.my-cluster-kafka-brokers.myproject.svc' peerPort 9091 peerPrincipal 'CN=my-cluster-kafka, O=io.strimzi' cipherSuite 'TLS_AES_256_GCM_SHA384' 2022-02-02 23:10:56,59360 DEBUG [kafka-producer-network-thread | producer-1] Selector:560 - [Producer clientId=producer-1] Successfully authenticated with my-cluster-kafka-2.my-cluster-kafka-brokers.myproject.svc/172.16.94.169 2022-02-02 23:10:56,68407 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] TopicOperator:1220 - Reconciliation #70(initial -__strimzi_store_topic) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): Completing CreateInTopicStore(topicName=__strimzi_store_topic,ctx=9|initial -__strimzi_store_topic) 2022-02-02 23:10:56,68418 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] TopicOperator:1225 - Reconciliation #71(initial -__strimzi_store_topic) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): CreateInTopicStore(topicName=__strimzi_store_topic,ctx=9|initial -__strimzi_store_topic) succeeded 2022-02-02 23:10:56,68442 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] TopicOperator:1023 - Reconciliation #72(initial -__strimzi_store_topic) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): succeeded reconciliation delete-remaining 2022-02-02 23:10:56,68472 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] TopicOperator:1023 - Reconciliation #73(initial -__strimzi_store_topic) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): succeeded reconciliation delete-remaining 2022-02-02 23:10:56,68499 INFO [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] TopicOperator:1493 - Reconciliation #74(initial -__strimzi_store_topic) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): Success reconciling KafkaTopic null 2022-02-02 23:10:56,68506 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] TopicOperator:487 - Reconciliation #75(initial -__strimzi_store_topic) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): Executing handler for action delete-remaining on topic __strimzi_store_topic 2022-02-02 23:10:56,68578 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] TopicOperator:513 - Reconciliation #76(initial -__strimzi_store_topic) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): Updated metric strimzi.resource.state[tag(kind=KafkaTopic),tag(name=strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55),tag(reason=none),tag(resource-namespace=myproject)] = 1 2022-02-02 23:10:56,68592 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] TopicOperator:1050 - Reconciliation #77(initial -__strimzi_store_topic) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): There is a KafkaTopic to set status on, rv=7465591, generation=1 2022-02-02 23:10:56,69599 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] StatusDiff:47 - Status differs: {"op":"replace","path":"/","value":{"conditions":[{"type":"Ready","status":"True","lastTransitionTime":"2022-02-02T23:10:56.686888Z"}],"observedGeneration":1,"topicName":"__strimzi_store_topic"}} 2022-02-02 23:10:56,69617 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] StatusDiff:48 - Current Status path / has value 2022-02-02 23:10:56,69628 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] StatusDiff:49 - Desired Status path / has value 2022-02-02 23:10:56,69831 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] CustomResource:172 - Calling CustomResource#setKind doesn't do anything because the Kind is computed and shouldn't be changed 2022-02-02 23:10:56,70096 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] TopicOperator:1220 - Reconciliation #79(initial -__consumer_offsets) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): Completing CreateInTopicStore(topicName=__consumer_offsets,ctx=11|initial -__consumer_offsets) 2022-02-02 23:10:56,70110 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] TopicOperator:1225 - Reconciliation #80(initial -__consumer_offsets) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): CreateInTopicStore(topicName=__consumer_offsets,ctx=11|initial -__consumer_offsets) succeeded 2022-02-02 23:10:56,70136 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] TopicOperator:1023 - Reconciliation #81(initial -__consumer_offsets) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): succeeded reconciliation delete-remaining 2022-02-02 23:10:56,70150 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] TopicOperator:1023 - Reconciliation #82(initial -__consumer_offsets) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): succeeded reconciliation delete-remaining 2022-02-02 23:10:56,70160 INFO [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] TopicOperator:1493 - Reconciliation #83(initial -__consumer_offsets) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): Success reconciling KafkaTopic null 2022-02-02 23:10:56,70169 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] TopicOperator:487 - Reconciliation #84(initial -__consumer_offsets) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): Executing handler for action delete-remaining on topic __consumer_offsets 2022-02-02 23:10:56,70227 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] TopicOperator:513 - Reconciliation #85(initial -__consumer_offsets) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): Updated metric strimzi.resource.state[tag(kind=KafkaTopic),tag(name=consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a),tag(reason=none),tag(resource-namespace=myproject)] = 1 2022-02-02 23:10:56,70234 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] TopicOperator:1050 - Reconciliation #86(initial -__consumer_offsets) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): There is a KafkaTopic to set status on, rv=7465592, generation=1 2022-02-02 23:10:56,78287 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] StatusDiff:47 - Status differs: {"op":"replace","path":"/","value":{"conditions":[{"type":"Ready","status":"True","lastTransitionTime":"2022-02-02T23:10:56.702372Z"}],"observedGeneration":1,"topicName":"__consumer_offsets"}} 2022-02-02 23:10:56,78305 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] StatusDiff:48 - Current Status path / has value 2022-02-02 23:10:56,78311 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] StatusDiff:49 - Desired Status path / has value 2022-02-02 23:10:56,78331 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] CustomResource:172 - Calling CustomResource#setKind doesn't do anything because the Kind is computed and shouldn't be changed 2022-02-02 23:10:56,78451 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] TopicOperator:1220 - Reconciliation #88(initial -__strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): Completing CreateInTopicStore(topicName=__strimzi-topic-operator-kstreams-topic-store-changelog,ctx=10|initial -__strimzi-topic-operator-kstreams-topic-store-changelog) 2022-02-02 23:10:56,78465 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] TopicOperator:1225 - Reconciliation #89(initial -__strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): CreateInTopicStore(topicName=__strimzi-topic-operator-kstreams-topic-store-changelog,ctx=10|initial -__strimzi-topic-operator-kstreams-topic-store-changelog) succeeded 2022-02-02 23:10:56,78500 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] TopicOperator:1023 - Reconciliation #90(initial -__strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): succeeded reconciliation delete-remaining 2022-02-02 23:10:56,78521 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] TopicOperator:1023 - Reconciliation #91(initial -__strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): succeeded reconciliation delete-remaining 2022-02-02 23:10:56,78529 INFO [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] TopicOperator:1493 - Reconciliation #92(initial -__strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): Success reconciling KafkaTopic null 2022-02-02 23:10:56,78536 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] TopicOperator:487 - Reconciliation #93(initial -__strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): Executing handler for action delete-remaining on topic __strimzi-topic-operator-kstreams-topic-store-changelog 2022-02-02 23:10:56,78528 DEBUG [kubernetes-ops-pool-1] CustomResource:172 - Calling CustomResource#setKind doesn't do anything because the Kind is computed and shouldn't be changed 2022-02-02 23:10:56,78578 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] TopicOperator:513 - Reconciliation #94(initial -__strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): Updated metric strimzi.resource.state[tag(kind=KafkaTopic),tag(name=strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b),tag(reason=none),tag(resource-namespace=myproject)] = 1 2022-02-02 23:10:56,78585 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] TopicOperator:1050 - Reconciliation #95(initial -__strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): There is a KafkaTopic to set status on, rv=7465593, generation=1 2022-02-02 23:10:56,78612 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] StatusDiff:47 - Status differs: {"op":"replace","path":"/","value":{"conditions":[{"type":"Ready","status":"True","lastTransitionTime":"2022-02-02T23:10:56.785887Z"}],"observedGeneration":1,"topicName":"__strimzi-topic-operator-kstreams-topic-store-changelog"}} 2022-02-02 23:10:56,78632 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] StatusDiff:48 - Current Status path / has value 2022-02-02 23:10:56,78637 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] StatusDiff:49 - Desired Status path / has value 2022-02-02 23:10:56,78652 DEBUG [__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1] CustomResource:172 - Calling CustomResource#setKind doesn't do anything because the Kind is computed and shouldn't be changed 2022-02-02 23:10:56,79125 DEBUG [kubernetes-ops-pool-1] CustomResource:172 - Calling CustomResource#setKind doesn't do anything because the Kind is computed and shouldn't be changed 2022-02-02 23:10:56,79147 DEBUG [OkHttp https://10.96.0.1/...] CustomResource:172 - Calling CustomResource#setKind doesn't do anything because the Kind is computed and shouldn't be changed 2022-02-02 23:10:56,79203 DEBUG [OkHttp https://10.96.0.1/...] K8sTopicWatcher:43 - Reconciliation #97(kube =strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): Ignoring initial event for KafkaTopic strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55 during initial reconcile 2022-02-02 23:10:56,79223 INFO [kubernetes-ops-pool-1] CrdOperator:113 - Reconciliation #78(initial -__strimzi_store_topic) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): Status of KafkaTopic strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55 in namespace myproject has been updated 2022-02-02 23:10:56,79268 DEBUG [vert.x-eventloop-thread-0] TopicOperator:1074 - Reconciliation #98(initial -__strimzi_store_topic) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): status was set rv=7465595, generation=1, observedGeneration=1 2022-02-02 23:10:56,79294 DEBUG [vert.x-eventloop-thread-0] TopicOperator:530 - Reconciliation #99(initial -__strimzi_store_topic) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): Lock released 2022-02-02 23:10:56,79304 DEBUG [vert.x-eventloop-thread-0] TopicOperator:461 - Reconciliation #100(initial -__strimzi_store_topic) KafkaTopic(myproject/strimzi-store-topic---effb8e3e057afce1ecf67c3f5d8e4e3ff177fc55): Removing last waiter delete-remaining 2022-02-02 23:10:56,79366 DEBUG [kubernetes-ops-pool-1] CustomResource:172 - Calling CustomResource#setKind doesn't do anything because the Kind is computed and shouldn't be changed 2022-02-02 23:10:56,79747 DEBUG [kubernetes-ops-pool-1] CustomResource:172 - Calling CustomResource#setKind doesn't do anything because the Kind is computed and shouldn't be changed 2022-02-02 23:10:56,79762 DEBUG [OkHttp https://10.96.0.1/...] CustomResource:172 - Calling CustomResource#setKind doesn't do anything because the Kind is computed and shouldn't be changed 2022-02-02 23:10:56,79789 INFO [kubernetes-ops-pool-1] CrdOperator:113 - Reconciliation #87(initial -__consumer_offsets) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): Status of KafkaTopic consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a in namespace myproject has been updated 2022-02-02 23:10:56,79827 DEBUG [vert.x-eventloop-thread-0] TopicOperator:1074 - Reconciliation #101(initial -__consumer_offsets) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): status was set rv=7465596, generation=1, observedGeneration=1 2022-02-02 23:10:56,79846 DEBUG [vert.x-eventloop-thread-0] TopicOperator:530 - Reconciliation #102(initial -__consumer_offsets) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): Lock released 2022-02-02 23:10:56,79853 DEBUG [vert.x-eventloop-thread-0] TopicOperator:461 - Reconciliation #103(initial -__consumer_offsets) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): Removing last waiter delete-remaining 2022-02-02 23:10:56,79907 DEBUG [OkHttp https://10.96.0.1/...] K8sTopicWatcher:43 - Reconciliation #104(kube =consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a) KafkaTopic(myproject/consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a): Ignoring initial event for KafkaTopic consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a during initial reconcile 2022-02-02 23:10:56,79925 DEBUG [kubernetes-ops-pool-1] CustomResource:172 - Calling CustomResource#setKind doesn't do anything because the Kind is computed and shouldn't be changed 2022-02-02 23:10:56,80299 DEBUG [kubernetes-ops-pool-1] CustomResource:172 - Calling CustomResource#setKind doesn't do anything because the Kind is computed and shouldn't be changed 2022-02-02 23:10:56,80303 DEBUG [OkHttp https://10.96.0.1/...] CustomResource:172 - Calling CustomResource#setKind doesn't do anything because the Kind is computed and shouldn't be changed 2022-02-02 23:10:56,80336 DEBUG [OkHttp https://10.96.0.1/...] K8sTopicWatcher:43 - Reconciliation #105(kube =strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): Ignoring initial event for KafkaTopic strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b during initial reconcile 2022-02-02 23:10:56,80345 INFO [kubernetes-ops-pool-1] CrdOperator:113 - Reconciliation #96(initial -__strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): Status of KafkaTopic strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b in namespace myproject has been updated 2022-02-02 23:10:56,80375 DEBUG [vert.x-eventloop-thread-0] TopicOperator:1074 - Reconciliation #106(initial -__strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): status was set rv=7465597, generation=1, observedGeneration=1 2022-02-02 23:10:56,88348 DEBUG [vert.x-eventloop-thread-0] TopicOperator:530 - Reconciliation #107(initial -__strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): Lock released 2022-02-02 23:10:56,88367 DEBUG [vert.x-eventloop-thread-0] TopicOperator:461 - Reconciliation #108(initial -__strimzi-topic-operator-kstreams-topic-store-changelog) KafkaTopic(myproject/strimzi-topic-operator-kstreams-topic-store-changelog---b75e702040b99be8a9263134de3507fc0cc4017b): Removing last waiter delete-remaining 2022-02-02 23:10:57,24895 DEBUG [vert.x-eventloop-thread-0] Recycler:78 - -Dio.netty.recycler.maxCapacityPerThread: 4096 2022-02-02 23:10:57,24904 DEBUG [vert.x-eventloop-thread-0] Recycler:79 - -Dio.netty.recycler.ratio: 8 2022-02-02 23:10:57,24915 DEBUG [vert.x-eventloop-thread-0] Recycler:80 - -Dio.netty.recycler.chunkSize: 32 2022-02-02 23:10:57,25324 DEBUG [vert.x-eventloop-thread-0] AbstractByteBuf:63 - -Dio.netty.buffer.checkAccessible: true 2022-02-02 23:10:57,25334 DEBUG [vert.x-eventloop-thread-0] AbstractByteBuf:64 - -Dio.netty.buffer.checkBounds: true 2022-02-02 23:10:57,25385 DEBUG [vert.x-eventloop-thread-0] ResourceLeakDetectorFactory:196 - Loaded default ResourceLeakDetector: io.netty.util.ResourceLeakDetector@654186b2 2022-02-02 23:10:57,39094 DEBUG [vert.x-eventloop-thread-0] ZlibCodecFactory:39 - -Dio.netty.noJdkZlibDecoder: false 2022-02-02 23:10:57,39105 DEBUG [vert.x-eventloop-thread-0] ZlibCodecFactory:42 - -Dio.netty.noJdkZlibEncoder: false 2022-02-02 23:11:01,50169 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:890 - Got ping response for session id: 0x200b69b00d40002 after 0ms. 2022-02-02 23:11:07,50772 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:890 - Got ping response for session id: 0x200b69b00d40002 after 1ms. 2022-02-02 23:11:13,51373 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:890 - Got ping response for session id: 0x200b69b00d40002 after 0ms. 2022-02-02 23:11:19,52102 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:890 - Got ping response for session id: 0x200b69b00d40002 after 1ms. 2022-02-02 23:11:24,18614 DEBUG [kafka-producer-network-thread | __strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1-producer] Selector:531 - [Producer clientId=__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1-producer] Created socket with SO_RCVBUF = 32768, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 1 2022-02-02 23:11:24,19615 DEBUG [kafka-producer-network-thread | __strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1-producer] SslTransportLayer:452 - [SslTransportLayer channelId=1 key=channel=java.nio.channels.SocketChannel[connection-pending remote=my-cluster-kafka-1.my-cluster-kafka-brokers.myproject.svc/172.16.94.175:9091], selector=sun.nio.ch.EPollSelectorImpl@18da44d4, interestOps=8, readyOps=0] SSL handshake completed successfully with peerHost 'my-cluster-kafka-1.my-cluster-kafka-brokers.myproject.svc' peerPort 9091 peerPrincipal 'CN=my-cluster-kafka, O=io.strimzi' cipherSuite 'TLS_AES_256_GCM_SHA384' 2022-02-02 23:11:24,19638 DEBUG [kafka-producer-network-thread | __strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1-producer] Selector:560 - [Producer clientId=__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1-producer] Successfully authenticated with my-cluster-kafka-1.my-cluster-kafka-brokers.myproject.svc/172.16.94.175 2022-02-02 23:11:24,20222 DEBUG [kafka-producer-network-thread | __strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1-producer] Selector:531 - [Producer clientId=__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1-producer] Created socket with SO_RCVBUF = 32768, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 0 2022-02-02 23:11:24,21223 DEBUG [kafka-producer-network-thread | __strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1-producer] SslTransportLayer:452 - [SslTransportLayer channelId=0 key=channel=java.nio.channels.SocketChannel[connection-pending remote=my-cluster-kafka-0.my-cluster-kafka-brokers.myproject.svc/172.16.94.144:9091], selector=sun.nio.ch.EPollSelectorImpl@18da44d4, interestOps=8, readyOps=0] SSL handshake completed successfully with peerHost 'my-cluster-kafka-0.my-cluster-kafka-brokers.myproject.svc' peerPort 9091 peerPrincipal 'CN=my-cluster-kafka, O=io.strimzi' cipherSuite 'TLS_AES_256_GCM_SHA384' 2022-02-02 23:11:24,21242 DEBUG [kafka-producer-network-thread | __strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1-producer] Selector:560 - [Producer clientId=__strimzi-topic-operator-kstreams-8e2522c6-16dc-4c72-a3a6-b581ea2e7ef8-StreamThread-1-producer] Successfully authenticated with my-cluster-kafka-0.my-cluster-kafka-brokers.myproject.svc/172.16.94.144 2022-02-02 23:11:25,52652 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:890 - Got ping response for session id: 0x200b69b00d40002 after 0ms. 2022-02-02 23:11:31,53359 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:890 - Got ping response for session id: 0x200b69b00d40002 after 0ms. 2022-02-02 23:11:37,54074 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:890 - Got ping response for session id: 0x200b69b00d40002 after 0ms. 2022-02-02 23:11:43,54675 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:890 - Got ping response for session id: 0x200b69b00d40002 after 1ms. 2022-02-02 23:11:49,55298 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:890 - Got ping response for session id: 0x200b69b00d40002 after 1ms. 2022-02-02 23:11:55,52267 DEBUG [OkHttp https://10.96.0.1/...] CustomResource:172 - Calling CustomResource#setKind doesn't do anything because the Kind is computed and shouldn't be changed 2022-02-02 23:11:55,55861 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:890 - Got ping response for session id: 0x200b69b00d40002 after 0ms. 2022-02-02 23:12:01,56567 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:890 - Got ping response for session id: 0x200b69b00d40002 after 0ms. 2022-02-02 23:12:07,57270 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:890 - Got ping response for session id: 0x200b69b00d40002 after 0ms. 2022-02-02 23:12:13,57898 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:890 - Got ping response for session id: 0x200b69b00d40002 after 1ms. 2022-02-02 23:12:19,58471 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:890 - Got ping response for session id: 0x200b69b00d40002 after 0ms. 2022-02-02 23:12:25,59056 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:890 - Got ping response for session id: 0x200b69b00d40002 after 0ms. 2022-02-02 23:12:31,59752 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:890 - Got ping response for session id: 0x200b69b00d40002 after 0ms. 2022-02-02 23:12:37,60465 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:890 - Got ping response for session id: 0x200b69b00d40002 after 0ms. 2022-02-02 23:12:43,61161 DEBUG [vert.x-worker-thread-0-SendThread(localhost:2181)] ClientCnxn:890 - Got ping response for session id: 0x200b69b00d40002 after 0ms.