+ shift + export MALLOC_ARENA_MAX=2 + MALLOC_ARENA_MAX=2 + JAVA_OPTS=' -Dlog4j2.configurationFile=file:/opt/user-operator/custom-config/log4j2.properties -Dvertx.cacheDirBase=/tmp -Djava.security.egd=file:/dev/./urandom' ++ get_gc_opts ++ '[' false == true ']' ++ echo '' + JAVA_OPTS=' -Dlog4j2.configurationFile=file:/opt/user-operator/custom-config/log4j2.properties -Dvertx.cacheDirBase=/tmp -Djava.security.egd=file:/dev/./urandom ' + exec /usr/bin/tini -w -e 143 -- java -Dlog4j2.configurationFile=file:/opt/user-operator/custom-config/log4j2.properties -Dvertx.cacheDirBase=/tmp -Djava.security.egd=file:/dev/./urandom -classpath lib/io.strimzi.user-operator-0.18.0-SNAPSHOT.jar:lib/io.prometheus.simpleclient_common-0.7.0.jar:lib/com.github.luben.zstd-jni-1.4.3-1.jar:lib/io.netty.netty-handler-4.1.45.Final.jar:lib/com.101tec.zkclient-0.11.jar:lib/io.netty.netty-codec-http-4.1.45.Final.jar:lib/io.strimzi.operator-common-0.18.0-SNAPSHOT.jar:lib/com.squareup.okio.okio-1.15.0.jar:lib/io.netty.netty-buffer-4.1.45.Final.jar:lib/org.yaml.snakeyaml-1.24.jar:lib/io.fabric8.openshift-client-4.6.4.jar:lib/io.strimzi.api-0.18.0-SNAPSHOT.jar:lib/io.netty.netty-common-4.1.45.Final.jar:lib/org.apache.logging.log4j.log4j-api-2.13.0.jar:lib/org.xerial.snappy.snappy-java-1.1.7.3.jar:lib/org.hdrhistogram.HdrHistogram-2.1.11.jar:lib/io.prometheus.simpleclient-0.7.0.jar:lib/org.apache.yetus.audience-annotations-0.5.0.jar:lib/com.fasterxml.jackson.dataformat.jackson-dataformat-yaml-2.10.2.jar:lib/io.strimzi.certificate-manager-0.18.0-SNAPSHOT.jar:lib/io.netty.netty-codec-4.1.45.Final.jar:lib/io.micrometer.micrometer-core-1.3.1.jar:lib/jakarta.activation.jakarta.activation-api-1.2.1.jar:lib/io.vertx.vertx-core-3.8.5.jar:lib/io.netty.netty-codec-dns-4.1.45.Final.jar:lib/io.fabric8.kubernetes-model-4.6.4.jar:lib/io.netty.netty-codec-socks-4.1.45.Final.jar:lib/com.github.mifmif.generex-1.0.2.jar:lib/io.netty.netty-resolver-4.1.45.Final.jar:lib/org.apache.zookeeper.zookeeper-jute-3.5.6.jar:lib/io.netty.netty-handler-proxy-4.1.45.Final.jar:lib/com.squareup.okhttp3.logging-interceptor-3.12.6.jar:lib/io.netty.netty-transport-native-unix-common-4.1.45.Final.jar:lib/org.apache.zookeeper.zookeeper-3.5.6.jar:lib/dk.brics.automaton.automaton-1.11-8.jar:lib/io.vertx.vertx-micrometer-metrics-3.8.5.jar:lib/com.fasterxml.jackson.core.jackson-core-2.10.2.jar:lib/io.netty.netty-transport-4.1.45.Final.jar:lib/io.netty.netty-transport-native-epoll-4.1.45.Final.jar:lib/jakarta.xml.bind.jakarta.xml.bind-api-2.3.2.jar:lib/org.apache.logging.log4j.log4j-slf4j-impl-2.13.0.jar:lib/com.fasterxml.jackson.core.jackson-annotations-2.10.2.jar:lib/org.lz4.lz4-java-1.6.0.jar:lib/io.fabric8.zjsonpatch-0.3.0.jar:lib/io.strimzi.crd-annotations-0.18.0-SNAPSHOT.jar:lib/io.fabric8.kubernetes-client-4.6.4.jar:lib/com.fasterxml.jackson.module.jackson-module-jaxb-annotations-2.10.2.jar:lib/com.squareup.okhttp3.okhttp-3.12.6.jar:lib/io.netty.netty-codec-http2-4.1.45.Final.jar:lib/org.apache.logging.log4j.log4j-core-2.13.0.jar:lib/io.fabric8.kubernetes-model-common-4.6.4.jar:lib/com.fasterxml.jackson.core.jackson-databind-2.10.2.jar:lib/io.netty.netty-resolver-dns-4.1.45.Final.jar:lib/org.slf4j.slf4j-api-1.7.25.jar:lib/org.latencyutils.LatencyUtils-2.0.3.jar:lib/org.apache.kafka.kafka-clients-2.4.0.jar:lib/io.micrometer.micrometer-registry-prometheus-1.3.1.jar io.strimzi.operator.user.Main [2020-04-20 23:36:25,176] INFO
[main ] Using config: PATH: /usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin STRIMZI_CA_RENEWAL: 30 MY_CLUSTER_KAFKA_BOOTSTRAP_PORT_9093_TCP_ADDR: 172.30.117.198 STRIMZI_LABELS: strimzi.io/cluster=my-cluster JAVA_OPTS: -Dlog4j2.configurationFile=file:/opt/user-operator/custom-config/log4j2.properties -Dvertx.cacheDirBase=/tmp -Djava.security.egd=file:/dev/./urandom MY_CLUSTER_KAFKA_BOOTSTRAP_PORT_9091_TCP_PROTO: tcp MY_CLUSTER_KAFKA_BOOTSTRAP_SERVICE_HOST: 172.30.117.198 MY_CLUSTER_KAFKA_BOOTSTRAP_SERVICE_PORT_TCP_CLIENTS: 9092 MY_CLUSTER_ZOOKEEPER_CLIENT_SERVICE_HOST: 172.30.125.227 STRIMZI_EO_KEY_SECRET_NAME: my-cluster-entity-operator-certs STRIMZI_GC_LOG_ENABLED: false STRIMZI_HOME: /opt/strimzi PWD: /opt/strimzi MY_CLUSTER_KAFKA_BOOTSTRAP_PORT_9093_TCP_PORT: 9093 KUBERNETES_PORT_443_TCP: tcp://172.30.0.1:443 JAVA_MAIN: io.strimzi.operator.user.Main STRIMZI_VERSION: 0.18.0-SNAPSHOT STRIMZI_KAFKA_BOOTSTRAP_SERVERS: my-cluster-kafka-bootstrap:9091 MY_CLUSTER_ZOOKEEPER_CLIENT_SERVICE_PORT: 2181 MY_CLUSTER_ZOOKEEPER_CLIENT_PORT_2181_TCP_PORT: 2181 STRIMZI_NAMESPACE: topic-cluster-test MY_CLUSTER_KAFKA_BOOTSTRAP_SERVICE_PORT: 9091 MY_CLUSTER_KAFKA_BOOTSTRAP_PORT_9092_TCP_PROTO: tcp STRIMZI_CA_VALIDITY: 365 STRIMZI_ZOOKEEPER_CONNECT: localhost:2181 MY_CLUSTER_ZOOKEEPER_CLIENT_PORT_2181_TCP_ADDR: 172.30.125.227 KUBERNETES_SERVICE_PORT_HTTPS: 443 MY_CLUSTER_KAFKA_BOOTSTRAP_SERVICE_PORT_TCP_REPLICATION: 9091 SHLVL: 0 TINI_SHA256: 12d20136605531b09a2c2dac02ccee85e1b874eb322ef6baf7561cd93f93c855 KUBERNETES_PORT: tcp://172.30.0.1:443 MY_CLUSTER_KAFKA_BOOTSTRAP_PORT_9091_TCP: tcp://172.30.117.198:9091 STRIMZI_FULL_RECONCILIATION_INTERVAL_MS: 120000 KUBERNETES_SERVICE_HOST: 172.30.0.1 JAVA_CLASSPATH: lib/io.strimzi.user-operator-0.18.0-SNAPSHOT.jar:lib/io.prometheus.simpleclient_common-0.7.0.jar:lib/com.github.luben.zstd-jni-1.4.3-1.jar:lib/io.netty.netty-handler-4.1.45.Final.jar:lib/com.101tec.zkclient-0.11.jar:lib/io.netty.netty-codec-http-4.1.45.Final.jar:lib/io.strimzi.operator-common-0.18.0-SNAPSHOT.jar:lib/com.squareup.okio.okio-1.15.0.jar:lib/io.netty.netty-buffer-4.1.45.Final.jar:lib/org.yaml.snakeyaml-1.24.jar:lib/io.fabric8.openshift-client-4.6.4.jar:lib/io.strimzi.api-0.18.0-SNAPSHOT.jar:lib/io.netty.netty-common-4.1.45.Final.jar:lib/org.apache.logging.log4j.log4j-api-2.13.0.jar:lib/org.xerial.snappy.snappy-java-1.1.7.3.jar:lib/org.hdrhistogram.HdrHistogram-2.1.11.jar:lib/io.prometheus.simpleclient-0.7.0.jar:lib/org.apache.yetus.audience-annotations-0.5.0.jar:lib/com.fasterxml.jackson.dataformat.jackson-dataformat-yaml-2.10.2.jar:lib/io.strimzi.certificate-manager-0.18.0-SNAPSHOT.jar:lib/io.netty.netty-codec-4.1.45.Final.jar:lib/io.micrometer.micrometer-core-1.3.1.jar:lib/jakarta.activation.jakarta.activation-api-1.2.1.jar:lib/io.vertx.vertx-core-3.8.5.jar:lib/io.netty.netty-codec-dns-4.1.45.Final.jar:lib/io.fabric8.kubernetes-model-4.6.4.jar:lib/io.netty.netty-codec-socks-4.1.45.Final.jar:lib/com.github.mifmif.generex-1.0.2.jar:lib/io.netty.netty-resolver-4.1.45.Final.jar:lib/org.apache.zookeeper.zookeeper-jute-3.5.6.jar:lib/io.netty.netty-handler-proxy-4.1.45.Final.jar:lib/com.squareup.okhttp3.logging-interceptor-3.12.6.jar:lib/io.netty.netty-transport-native-unix-common-4.1.45.Final.jar:lib/org.apache.zookeeper.zookeeper-3.5.6.jar:lib/dk.brics.automaton.automaton-1.11-8.jar:lib/io.vertx.vertx-micrometer-metrics-3.8.5.jar:lib/com.fasterxml.jackson.core.jackson-core-2.10.2.jar:lib/io.netty.netty-transport-4.1.45.Final.jar:lib/io.netty.netty-transport-native-epoll-4.1.45.Final.jar:lib/jakarta.xml.bind.jakarta.xml.bind-api-2.3.2.jar:lib/org.apache.logging.log4j.log4j-slf4j-impl-2.13.0.jar:lib/com.fasterxml.jackson.core.jackson-annotations-2.10.2.jar:lib/org.lz4.lz4-java-1.6.0.jar:lib/io.fabric8.zjsonpatch-0.3.0.jar:lib/io.strimzi.crd-annotations-0.18.0-SNAPSHOT.jar:lib/io.fabric8.kubernetes-client-4.6.4.jar:lib/com.fasterxml.jackson.module.jackson-module-jaxb-annotations-2.10.2.jar:lib/com.squareup.okhttp3.okhttp-3.12.6.jar:lib/io.netty.netty-codec-http2-4.1.45.Final.jar:lib/org.apache.logging.log4j.log4j-core-2.13.0.jar:lib/io.fabric8.kubernetes-model-common-4.6.4.jar:lib/com.fasterxml.jackson.core.jackson-databind-2.10.2.jar:lib/io.netty.netty-resolver-dns-4.1.45.Final.jar:lib/org.slf4j.slf4j-api-1.7.25.jar:lib/org.latencyutils.LatencyUtils-2.0.3.jar:lib/org.apache.kafka.kafka-clients-2.4.0.jar:lib/io.micrometer.micrometer-registry-prometheus-1.3.1.jar MY_CLUSTER_ZOOKEEPER_CLIENT_PORT: tcp://172.30.125.227:2181 MY_CLUSTER_KAFKA_BOOTSTRAP_PORT_9092_TCP: tcp://172.30.117.198:9092 STRIMZI_CLUSTER_CA_CERT_SECRET_NAME: my-cluster-cluster-ca-cert TINI_VERSION: v0.18.0 MY_CLUSTER_KAFKA_BOOTSTRAP_PORT_9092_TCP_ADDR: 172.30.117.198 KUBERNETES_PORT_443_TCP_ADDR: 172.30.0.1 MY_CLUSTER_KAFKA_BOOTSTRAP_SERVICE_PORT_TCP_CLIENTSTLS: 9093 MY_CLUSTER_KAFKA_BOOTSTRAP_PORT: tcp://172.30.117.198:9091 STRIMZI_ZOOKEEPER_SESSION_TIMEOUT_MS: 6000 MY_CLUSTER_ZOOKEEPER_CLIENT_PORT_2181_TCP: tcp://172.30.125.227:2181 MY_CLUSTER_KAFKA_BOOTSTRAP_PORT_9093_TCP: tcp://172.30.117.198:9093 KUBERNETES_PORT_443_TCP_PROTO: tcp MY_CLUSTER_KAFKA_BOOTSTRAP_PORT_9091_TCP_PORT: 9091 STRIMZI_CA_CERT_NAME: my-cluster-clients-ca-cert STRIMZI_CA_NAMESPACE: topic-cluster-test KUBERNETES_SERVICE_PORT: 443 MY_CLUSTER_ZOOKEEPER_CLIENT_PORT_2181_TCP_PROTO: tcp MY_CLUSTER_KAFKA_BOOTSTRAP_PORT_9091_TCP_ADDR: 172.30.117.198 MY_CLUSTER_KAFKA_BOOTSTRAP_PORT_9092_TCP_PORT: 9092 MY_CLUSTER_ZOOKEEPER_CLIENT_SERVICE_PORT_TCP_CLIENTS: 2181 HOSTNAME: my-cluster-entity-operator-cd8c8d56-t6t69 STRIMZI_CA_KEY_NAME: my-cluster-clients-ca KUBERNETES_PORT_443_TCP_PORT: 443 MY_CLUSTER_KAFKA_BOOTSTRAP_PORT_9093_TCP_PROTO: tcp HOME: / MALLOC_ARENA_MAX: 2 [2020-04-20 23:36:25,276] DEBUG [main ] Using SLF4J as the default logging framework [2020-04-20 23:36:26,143] INFO [oop-thread-0] AdminClientConfig values: bootstrap.servers = [my-cluster-kafka-bootstrap:9091] client.dns.lookup = default client.id = connections.max.idle.ms = 300000 metadata.max.age.ms = 30000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 120000 retries = 5 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = SSL security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = /tmp/io.strimzi.operator.common.DefaultAdminClientProvider6935729108067071837ts ssl.keystore.password = [hidden] ssl.keystore.type = PKCS12 ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = /tmp/io.strimzi.operator.common.DefaultAdminClientProvider8975426780047649513ts ssl.truststore.password = [hidden] ssl.truststore.type = PKCS12 [2020-04-20 23:36:26,183] DEBUG [oop-thread-0] [AdminClient clientId=adminclient-1] Setting bootstrap cluster metadata Cluster(id = null, nodes = [my-cluster-kafka-bootstrap:9091 (id: -1 rack: null)], partitions = [], controller = null). [2020-04-20 23:36:26,299] DEBUG [oop-thread-0] Created SSL context with keystore SecurityStore(path=/tmp/io.strimzi.operator.common.DefaultAdminClientProvider6935729108067071837ts, modificationTime=Mon Apr 20 23:36:26 UTC 2020), truststore SecurityStore(path=/tmp/io.strimzi.operator.common.DefaultAdminClientProvider8975426780047649513ts, modificationTime=Mon Apr 20 23:36:26 UTC 2020), provider SunJSSE. [2020-04-20 23:36:26,306] DEBUG [oop-thread-0] Added sensor with name connections-closed: [2020-04-20 23:36:26,308] DEBUG [oop-thread-0] Added sensor with name connections-created: [2020-04-20 23:36:26,309] DEBUG [oop-thread-0] Added sensor with name successful-authentication: [2020-04-20 23:36:26,309] DEBUG [oop-thread-0] Added sensor with name successful-reauthentication: [2020-04-20 23:36:26,310] DEBUG [oop-thread-0] Added sensor with name successful-authentication-no-reauth: [2020-04-20 23:36:26,310] DEBUG [oop-thread-0] Added sensor with name failed-authentication: [2020-04-20 23:36:26,310] DEBUG [oop-thread-0] Added sensor with name failed-reauthentication: [2020-04-20 23:36:26,311] DEBUG [oop-thread-0] Added sensor with name reauthentication-latency: [2020-04-20 23:36:26,312] DEBUG [oop-thread-0] Added sensor with name bytes-sent-received: [2020-04-20 23:36:26,313] DEBUG [oop-thread-0] Added sensor with name bytes-sent: [2020-04-20 23:36:26,314] DEBUG [oop-thread-0] Added sensor with name bytes-received: [2020-04-20 23:36:26,314] DEBUG [oop-thread-0] Added sensor with name select-time: [2020-04-20 23:36:26,315] DEBUG [oop-thread-0] Added sensor with name io-time: [2020-04-20 23:36:26,336] INFO [oop-thread-0] Kafka version: 2.4.0 [2020-04-20 23:36:26,337] INFO [oop-thread-0] Kafka commitId: 77a89fcf8d7fa018 [2020-04-20 23:36:26,337] INFO [oop-thread-0] Kafka startTimeMs: 1587425786334 [2020-04-20 23:36:26,343] DEBUG [oop-thread-0] [AdminClient clientId=adminclient-1] Kafka admin client initialized [2020-04-20 23:36:26,359] DEBUG [dminclient-1] [AdminClient clientId=adminclient-1] Initiating connection to node my-cluster-kafka-bootstrap:9091 (id: -1 rack: null) using address my-cluster-kafka-bootstrap/172.30.117.198 [2020-04-20 23:36:26,370] DEBUG [oop-thread-0] Creating new ZookKeeper instance to connect to localhost:2181. [2020-04-20 23:36:26,371] INFO [calhost:2181] Starting ZkClient event thread. [2020-04-20 23:36:26,377] INFO [oop-thread-0] Client environment:zookeeper.version=3.5.6-c11b7e26bc554b8523dc929761dd28808913f091, built on 10/08/2019 20:18 GMT [2020-04-20 23:36:26,377] INFO [oop-thread-0] Client environment:host.name=my-cluster-entity-operator-cd8c8d56-t6t69 [2020-04-20 23:36:26,377] INFO [oop-thread-0] Client environment:java.version=1.8.0_242 [2020-04-20 23:36:26,378] INFO [oop-thread-0] Client environment:java.vendor=Oracle Corporation [2020-04-20 23:36:26,378] INFO [oop-thread-0] Client environment:java.home=/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.242.b08-0.el7_7.x86_64/jre [2020-04-20 23:36:26,378] INFO [oop-thread-0] Client environment:java.class.path=lib/io.strimzi.user-operator-0.18.0-SNAPSHOT.jar:lib/io.prometheus.simpleclient_common-0.7.0.jar:lib/com.github.luben.zstd-jni-1.4.3-1.jar:lib/io.netty.netty-handler-4.1.45.Final.jar:lib/com.101tec.zkclient-0.11.jar:lib/io.netty.netty-codec-http-4.1.45.Final.jar:lib/io.strimzi.operator-common-0.18.0-SNAPSHOT.jar:lib/com.squareup.okio.okio-1.15.0.jar:lib/io.netty.netty-buffer-4.1.45.Final.jar:lib/org.yaml.snakeyaml-1.24.jar:lib/io.fabric8.openshift-client-4.6.4.jar:lib/io.strimzi.api-0.18.0-SNAPSHOT.jar:lib/io.netty.netty-common-4.1.45.Final.jar:lib/org.apache.logging.log4j.log4j-api-2.13.0.jar:lib/org.xerial.snappy.snappy-java-1.1.7.3.jar:lib/org.hdrhistogram.HdrHistogram-2.1.11.jar:lib/io.prometheus.simpleclient-0.7.0.jar:lib/org.apache.yetus.audience-annotations-0.5.0.jar:lib/com.fasterxml.jackson.dataformat.jackson-dataformat-yaml-2.10.2.jar:lib/io.strimzi.certificate-manager-0.18.0-SNAPSHOT.jar:lib/io.netty.netty-codec-4.1.45.Final.jar:lib/io.micrometer.micrometer-core-1.3.1.jar:lib/jakarta.activation.jakarta.activation-api-1.2.1.jar:lib/io.vertx.vertx-core-3.8.5.jar:lib/io.netty.netty-codec-dns-4.1.45.Final.jar:lib/io.fabric8.kubernetes-model-4.6.4.jar:lib/io.netty.netty-codec-socks-4.1.45.Final.jar:lib/com.github.mifmif.generex-1.0.2.jar:lib/io.netty.netty-resolver-4.1.45.Final.jar:lib/org.apache.zookeeper.zookeeper-jute-3.5.6.jar:lib/io.netty.netty-handler-proxy-4.1.45.Final.jar:lib/com.squareup.okhttp3.logging-interceptor-3.12.6.jar:lib/io.netty.netty-transport-native-unix-common-4.1.45.Final.jar:lib/org.apache.zookeeper.zookeeper-3.5.6.jar:lib/dk.brics.automaton.automaton-1.11-8.jar:lib/io.vertx.vertx-micrometer-metrics-3.8.5.jar:lib/com.fasterxml.jackson.core.jackson-core-2.10.2.jar:lib/io.netty.netty-transport-4.1.45.Final.jar:lib/io.netty.netty-transport-native-epoll-4.1.45.Final.jar:lib/jakarta.xml.bind.jakarta.xml.bind-api-2.3.2.jar:lib/org.apache.logging.log4j.log4j-slf4j-impl-2.13.0.jar:lib/com.fasterxml.jackson.core.jackson-annotations-2.10.2.jar:lib/org.lz4.lz4-java-1.6.0.jar:lib/io.fabric8.zjsonpatch-0.3.0.jar:lib/io.strimzi.crd-annotations-0.18.0-SNAPSHOT.jar:lib/io.fabric8.kubernetes-client-4.6.4.jar:lib/com.fasterxml.jackson.module.jackson-module-jaxb-annotations-2.10.2.jar:lib/com.squareup.okhttp3.okhttp-3.12.6.jar:lib/io.netty.netty-codec-http2-4.1.45.Final.jar:lib/org.apache.logging.log4j.log4j-core-2.13.0.jar:lib/io.fabric8.kubernetes-model-common-4.6.4.jar:lib/com.fasterxml.jackson.core.jackson-databind-2.10.2.jar:lib/io.netty.netty-resolver-dns-4.1.45.Final.jar:lib/org.slf4j.slf4j-api-1.7.25.jar:lib/org.latencyutils.LatencyUtils-2.0.3.jar:lib/org.apache.kafka.kafka-clients-2.4.0.jar:lib/io.micrometer.micrometer-registry-prometheus-1.3.1.jar [2020-04-20 23:36:26,378] INFO [oop-thread-0] Client environment:java.library.path=/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib [2020-04-20 23:36:26,378] INFO [oop-thread-0] Client environment:java.io.tmpdir=/tmp [2020-04-20 23:36:26,378] INFO [oop-thread-0] Client environment:java.compiler= [2020-04-20 23:36:26,378] INFO [oop-thread-0] Client environment:os.name=Linux [2020-04-20 23:36:26,378] INFO [oop-thread-0] Client environment:os.arch=amd64 [2020-04-20 23:36:26,378] INFO [oop-thread-0] Client environment:os.version=3.10.0-944.el7.x86_64 [2020-04-20 23:36:26,378] INFO [oop-thread-0] Client environment:user.name=? [2020-04-20 23:36:26,379] INFO [oop-thread-0] Client environment:user.home=? [2020-04-20 23:36:26,379] INFO [oop-thread-0] Client environment:user.dir=/opt/strimzi [2020-04-20 23:36:26,379] INFO [oop-thread-0] Client environment:os.memory.free=177MB [2020-04-20 23:36:26,379] INFO [oop-thread-0] Client environment:os.memory.max=3839MB [2020-04-20 23:36:26,379] INFO [oop-thread-0] Client environment:os.memory.total=241MB [2020-04-20 23:36:26,380] DEBUG [dminclient-1] Added sensor with name node--1.bytes-sent [2020-04-20 23:36:26,381] DEBUG [dminclient-1] Added sensor with name node--1.bytes-received [2020-04-20 23:36:26,381] INFO [oop-thread-0] Initiating client connection, connectString=localhost:2181 sessionTimeout=6000 watcher=org.I0Itec.zkclient.ZkClient@1d5c46f0 [2020-04-20 23:36:26,384] DEBUG [dminclient-1] Added sensor with name node--1.latency [2020-04-20 23:36:26,386] DEBUG [dminclient-1] [AdminClient clientId=adminclient-1] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node -1 [2020-04-20 23:36:26,387] INFO [oop-thread-0] Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation [2020-04-20 23:36:26,391] INFO [oop-thread-0] jute.maxbuffer value is 4194304 Bytes [2020-04-20 23:36:26,407] INFO [oop-thread-0] zookeeper.request.timeout value is 0. feature enabled= [2020-04-20 23:36:26,412] DEBUG [oop-thread-0] Awaiting connection to Zookeeper server [2020-04-20 23:36:26,413] INFO [oop-thread-0] Waiting for keeper state SyncConnected [2020-04-20 23:36:26,418] DEBUG [alhost:2181)] Canonicalized address to localhost [2020-04-20 23:36:26,420] INFO [alhost:2181)] Opening socket connection to server localhost/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error) [2020-04-20 23:36:26,421] INFO [alhost:2181)] Socket connection established, initiating session, client: /127.0.0.1:33394, server: localhost/127.0.0.1:2181 [2020-04-20 23:36:26,422] DEBUG [alhost:2181)] Session establishment request sent on localhost/127.0.0.1:2181 [2020-04-20 23:36:26,444] INFO [alhost:2181)] Session establishment complete on server localhost/127.0.0.1:2181, sessionid = 0x10000736c8c0004, negotiated timeout = 6000 [2020-04-20 23:36:26,446] DEBUG [-EventThread] Received event: WatchedEvent state:SyncConnected type:None path:null [2020-04-20 23:36:26,447] INFO [-EventThread] zookeeper state changed (SyncConnected) [2020-04-20 23:36:26,447] DEBUG [-EventThread] Leaving process event [2020-04-20 23:36:26,447] DEBUG [oop-thread-0] State is SyncConnected [2020-04-20 23:36:26,449] DEBUG [oop-thread-0] Creating new ZookKeeper instance to connect to localhost:2181. [2020-04-20 23:36:26,450] INFO [oop-thread-0] Initiating client connection, connectString=localhost:2181 sessionTimeout=6000 watcher=org.I0Itec.zkclient.ZkClient@e65cff6 [2020-04-20 23:36:26,450] INFO [calhost:2181] Starting ZkClient event thread. [2020-04-20 23:36:26,450] INFO [oop-thread-0] jute.maxbuffer value is 4194304 Bytes [2020-04-20 23:36:26,454] INFO [oop-thread-0] zookeeper.request.timeout value is 0. feature enabled= [2020-04-20 23:36:26,455] DEBUG [alhost:2181)] Canonicalized address to localhost [2020-04-20 23:36:26,455] INFO [alhost:2181)] Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2181. Will not attempt to authenticate using SASL (unknown error) [2020-04-20 23:36:26,456] INFO [alhost:2181)] Socket error occurred: localhost/0:0:0:0:0:0:0:1:2181: Connection refused [2020-04-20 23:36:26,461] DEBUG [oop-thread-0] Awaiting connection to Zookeeper server [2020-04-20 23:36:26,461] INFO [oop-thread-0] Waiting for keeper state SyncConnected [2020-04-20 23:36:26,456] DEBUG [alhost:2181)] Ignoring exception during shutdown input java.nio.channels.ClosedChannelException: null at sun.nio.ch.SocketChannelImpl.shutdownInput(SocketChannelImpl.java:777) ~[?:1.8.0_242] at sun.nio.ch.SocketAdaptor.shutdownInput(SocketAdaptor.java:412) ~[?:1.8.0_242] at org.apache.zookeeper.ClientCnxnSocketNIO.cleanup(ClientCnxnSocketNIO.java:198) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] at org.apache.zookeeper.ClientCnxn$SendThread.cleanup(ClientCnxn.java:1338) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] at org.apache.zookeeper.ClientCnxn$SendThread.cleanAndNotifyState(ClientCnxn.java:1276) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1254) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] [2020-04-20 23:36:26,462] DEBUG [alhost:2181)] Ignoring exception during shutdown output java.nio.channels.ClosedChannelException: null at sun.nio.ch.SocketChannelImpl.shutdownOutput(SocketChannelImpl.java:794) ~[?:1.8.0_242] at sun.nio.ch.SocketAdaptor.shutdownOutput(SocketAdaptor.java:420) ~[?:1.8.0_242] at org.apache.zookeeper.ClientCnxnSocketNIO.cleanup(ClientCnxnSocketNIO.java:205) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] at org.apache.zookeeper.ClientCnxn$SendThread.cleanup(ClientCnxn.java:1338) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] at org.apache.zookeeper.ClientCnxn$SendThread.cleanAndNotifyState(ClientCnxn.java:1276) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1254) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] [2020-04-20 23:36:26,623] DEBUG [dminclient-1] [AdminClient clientId=adminclient-1] Completed connection to node -1. Fetching API versions. [2020-04-20 23:36:26,710] DEBUG [dminclient-1] [SslTransportLayer channelId=-1 key=sun.nio.ch.SelectionKeyImpl@1f388c13] SSL handshake completed successfully with peerHost 'my-cluster-kafka-bootstrap' peerPort 9091 peerPrincipal 'CN=my-cluster-kafka, O=io.strimzi' cipherSuite 'TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA384' [2020-04-20 23:36:26,711] DEBUG [dminclient-1] [AdminClient clientId=adminclient-1] Successfully authenticated with my-cluster-kafka-bootstrap/172.30.117.198 [2020-04-20 23:36:26,712] DEBUG [dminclient-1] [AdminClient clientId=adminclient-1] Initiating API versions fetch from node -1. [2020-04-20 23:36:26,874] DEBUG [dminclient-1] [AdminClient clientId=adminclient-1] Recorded API versions for node -1: (Produce(0): 0 to 8 [usable: 8], Fetch(1): 0 to 11 [usable: 11], ListOffsets(2): 0 to 5 [usable: 5], Metadata(3): 0 to 9 [usable: 9], LeaderAndIsr(4): 0 to 4 [usable: 4], StopReplica(5): 0 to 2 [usable: 2], UpdateMetadata(6): 0 to 6 [usable: 6], ControlledShutdown(7): 0 to 3 [usable: 3], OffsetCommit(8): 0 to 8 [usable: 8], OffsetFetch(9): 0 to 6 [usable: 6], FindCoordinator(10): 0 to 3 [usable: 3], JoinGroup(11): 0 to 6 [usable: 6], Heartbeat(12): 0 to 4 [usable: 4], LeaveGroup(13): 0 to 4 [usable: 4], SyncGroup(14): 0 to 4 [usable: 4], DescribeGroups(15): 0 to 5 [usable: 5], ListGroups(16): 0 to 3 [usable: 3], SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 3 [usable: 3], CreateTopics(19): 0 to 5 [usable: 5], DeleteTopics(20): 0 to 4 [usable: 4], DeleteRecords(21): 0 to 1 [usable: 1], InitProducerId(22): 0 to 2 [usable: 2], OffsetForLeaderEpoch(23): 0 to 3 [usable: 3], AddPartitionsToTxn(24): 0 to 1 [usable: 1], AddOffsetsToTxn(25): 0 to 1 [usable: 1], EndTxn(26): 0 to 1 [usable: 1], WriteTxnMarkers(27): 0 [usable: 0], TxnOffsetCommit(28): 0 to 2 [usable: 2], DescribeAcls(29): 0 to 1 [usable: 1], CreateAcls(30): 0 to 1 [usable: 1], DeleteAcls(31): 0 to 1 [usable: 1], DescribeConfigs(32): 0 to 2 [usable: 2], AlterConfigs(33): 0 to 1 [usable: 1], AlterReplicaLogDirs(34): 0 to 1 [usable: 1], DescribeLogDirs(35): 0 to 1 [usable: 1], SaslAuthenticate(36): 0 to 1 [usable: 1], CreatePartitions(37): 0 to 1 [usable: 1], CreateDelegationToken(38): 0 to 2 [usable: 2], RenewDelegationToken(39): 0 to 1 [usable: 1], ExpireDelegationToken(40): 0 to 1 [usable: 1], DescribeDelegationToken(41): 0 to 1 [usable: 1], DeleteGroups(42): 0 to 2 [usable: 2], ElectLeaders(43): 0 to 2 [usable: 2], IncrementalAlterConfigs(44): 0 to 1 [usable: 1], AlterPartitionReassignments(45): 0 [usable: 0], ListPartitionReassignments(46): 0 [usable: 0], OffsetDelete(47): 0 [usable: 0]) [2020-04-20 23:36:26,890] DEBUG [dminclient-1] [AdminClient clientId=adminclient-1] Updating cluster metadata to Cluster(id = ekOAnyoiQqCRJryaE24oKQ, nodes = [my-cluster-kafka-2.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 2 rack: null), my-cluster-kafka-1.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 1 rack: null), my-cluster-kafka-0.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 0 rack: null)], partitions = [], controller = my-cluster-kafka-1.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 1 rack: null)) [2020-04-20 23:36:27,564] DEBUG [alhost:2181)] Canonicalized address to localhost [2020-04-20 23:36:27,565] INFO [alhost:2181)] Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2181. Will not attempt to authenticate using SASL (unknown error) [2020-04-20 23:36:27,565] INFO [alhost:2181)] Socket error occurred: localhost/0:0:0:0:0:0:0:1:2181: Connection refused [2020-04-20 23:36:27,566] DEBUG [alhost:2181)] Ignoring exception during shutdown input java.nio.channels.ClosedChannelException: null at sun.nio.ch.SocketChannelImpl.shutdownInput(SocketChannelImpl.java:777) ~[?:1.8.0_242] at sun.nio.ch.SocketAdaptor.shutdownInput(SocketAdaptor.java:412) ~[?:1.8.0_242] at org.apache.zookeeper.ClientCnxnSocketNIO.cleanup(ClientCnxnSocketNIO.java:198) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] at org.apache.zookeeper.ClientCnxn$SendThread.cleanup(ClientCnxn.java:1338) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] at org.apache.zookeeper.ClientCnxn$SendThread.cleanAndNotifyState(ClientCnxn.java:1276) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1254) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] [2020-04-20 23:36:27,566] DEBUG [alhost:2181)] Ignoring exception during shutdown output java.nio.channels.ClosedChannelException: null at sun.nio.ch.SocketChannelImpl.shutdownOutput(SocketChannelImpl.java:794) ~[?:1.8.0_242] at sun.nio.ch.SocketAdaptor.shutdownOutput(SocketAdaptor.java:420) ~[?:1.8.0_242] at org.apache.zookeeper.ClientCnxnSocketNIO.cleanup(ClientCnxnSocketNIO.java:205) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] at org.apache.zookeeper.ClientCnxn$SendThread.cleanup(ClientCnxn.java:1338) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] at org.apache.zookeeper.ClientCnxn$SendThread.cleanAndNotifyState(ClientCnxn.java:1276) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1254) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] [2020-04-20 23:36:28,433] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 4ms [2020-04-20 23:36:28,669] DEBUG [alhost:2181)] Canonicalized address to localhost [2020-04-20 23:36:28,669] INFO [alhost:2181)] Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2181. Will not attempt to authenticate using SASL (unknown error) [2020-04-20 23:36:28,670] INFO [alhost:2181)] Socket error occurred: localhost/0:0:0:0:0:0:0:1:2181: Connection refused [2020-04-20 23:36:28,670] DEBUG [alhost:2181)] Ignoring exception during shutdown input java.nio.channels.ClosedChannelException: null at sun.nio.ch.SocketChannelImpl.shutdownInput(SocketChannelImpl.java:777) ~[?:1.8.0_242] at sun.nio.ch.SocketAdaptor.shutdownInput(SocketAdaptor.java:412) ~[?:1.8.0_242] at org.apache.zookeeper.ClientCnxnSocketNIO.cleanup(ClientCnxnSocketNIO.java:198) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] at org.apache.zookeeper.ClientCnxn$SendThread.cleanup(ClientCnxn.java:1338) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] at org.apache.zookeeper.ClientCnxn$SendThread.cleanAndNotifyState(ClientCnxn.java:1276) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1254) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] [2020-04-20 23:36:28,671] DEBUG [alhost:2181)] Ignoring exception during shutdown output java.nio.channels.ClosedChannelException: null at sun.nio.ch.SocketChannelImpl.shutdownOutput(SocketChannelImpl.java:794) ~[?:1.8.0_242] at sun.nio.ch.SocketAdaptor.shutdownOutput(SocketAdaptor.java:420) ~[?:1.8.0_242] at org.apache.zookeeper.ClientCnxnSocketNIO.cleanup(ClientCnxnSocketNIO.java:205) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] at org.apache.zookeeper.ClientCnxn$SendThread.cleanup(ClientCnxn.java:1338) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] at org.apache.zookeeper.ClientCnxn$SendThread.cleanAndNotifyState(ClientCnxn.java:1276) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1254) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] Apr 20, 2020 11:36:28 PM io.vertx.core.impl.BlockedThreadChecker WARNING: Thread Thread[vert.x-eventloop-thread-0,5,main]=Thread[vert.x-eventloop-thread-0,5,main] has been blocked for 2707 ms, time limit is 2000 ms Apr 20, 2020 11:36:29 PM io.vertx.core.impl.BlockedThreadChecker WARNING: Thread Thread[vert.x-eventloop-thread-0,5,main]=Thread[vert.x-eventloop-thread-0,5,main] has been blocked for 3708 ms, time limit is 2000 ms [2020-04-20 23:36:29,772] DEBUG [alhost:2181)] Canonicalized address to localhost [2020-04-20 23:36:29,772] INFO [alhost:2181)] Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2181. Will not attempt to authenticate using SASL (unknown error) [2020-04-20 23:36:29,773] INFO [alhost:2181)] Socket error occurred: localhost/0:0:0:0:0:0:0:1:2181: Connection refused [2020-04-20 23:36:29,773] DEBUG [alhost:2181)] Ignoring exception during shutdown input java.nio.channels.ClosedChannelException: null at sun.nio.ch.SocketChannelImpl.shutdownInput(SocketChannelImpl.java:777) ~[?:1.8.0_242] at sun.nio.ch.SocketAdaptor.shutdownInput(SocketAdaptor.java:412) ~[?:1.8.0_242] at org.apache.zookeeper.ClientCnxnSocketNIO.cleanup(ClientCnxnSocketNIO.java:198) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] at org.apache.zookeeper.ClientCnxn$SendThread.cleanup(ClientCnxn.java:1338) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] at org.apache.zookeeper.ClientCnxn$SendThread.cleanAndNotifyState(ClientCnxn.java:1276) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1254) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] [2020-04-20 23:36:29,773] DEBUG [alhost:2181)] Ignoring exception during shutdown output java.nio.channels.ClosedChannelException: null at sun.nio.ch.SocketChannelImpl.shutdownOutput(SocketChannelImpl.java:794) ~[?:1.8.0_242] at sun.nio.ch.SocketAdaptor.shutdownOutput(SocketAdaptor.java:420) ~[?:1.8.0_242] at org.apache.zookeeper.ClientCnxnSocketNIO.cleanup(ClientCnxnSocketNIO.java:205) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] at org.apache.zookeeper.ClientCnxn$SendThread.cleanup(ClientCnxn.java:1338) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] at org.apache.zookeeper.ClientCnxn$SendThread.cleanAndNotifyState(ClientCnxn.java:1276) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1254) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] [2020-04-20 23:36:30,437] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 3ms Apr 20, 2020 11:36:30 PM io.vertx.core.impl.BlockedThreadChecker WARNING: Thread Thread[vert.x-eventloop-thread-0,5,main]=Thread[vert.x-eventloop-thread-0,5,main] has been blocked for 4708 ms, time limit is 2000 ms [2020-04-20 23:36:30,876] DEBUG [alhost:2181)] Canonicalized address to localhost [2020-04-20 23:36:30,876] INFO [alhost:2181)] Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2181. Will not attempt to authenticate using SASL (unknown error) [2020-04-20 23:36:30,877] INFO [alhost:2181)] Socket error occurred: localhost/0:0:0:0:0:0:0:1:2181: Connection refused [2020-04-20 23:36:30,877] DEBUG [alhost:2181)] Ignoring exception during shutdown input java.nio.channels.ClosedChannelException: null at sun.nio.ch.SocketChannelImpl.shutdownInput(SocketChannelImpl.java:777) ~[?:1.8.0_242] at sun.nio.ch.SocketAdaptor.shutdownInput(SocketAdaptor.java:412) ~[?:1.8.0_242] at org.apache.zookeeper.ClientCnxnSocketNIO.cleanup(ClientCnxnSocketNIO.java:198) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] at org.apache.zookeeper.ClientCnxn$SendThread.cleanup(ClientCnxn.java:1338) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] at org.apache.zookeeper.ClientCnxn$SendThread.cleanAndNotifyState(ClientCnxn.java:1276) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1254) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] [2020-04-20 23:36:30,877] DEBUG [alhost:2181)] Ignoring exception during shutdown output java.nio.channels.ClosedChannelException: null at sun.nio.ch.SocketChannelImpl.shutdownOutput(SocketChannelImpl.java:794) ~[?:1.8.0_242] at sun.nio.ch.SocketAdaptor.shutdownOutput(SocketAdaptor.java:420) ~[?:1.8.0_242] at org.apache.zookeeper.ClientCnxnSocketNIO.cleanup(ClientCnxnSocketNIO.java:205) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] at org.apache.zookeeper.ClientCnxn$SendThread.cleanup(ClientCnxn.java:1338) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] at org.apache.zookeeper.ClientCnxn$SendThread.cleanAndNotifyState(ClientCnxn.java:1276) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1254) [org.apache.zookeeper.zookeeper-3.5.6.jar:3.5.6] Apr 20, 2020 11:36:31 PM io.vertx.core.impl.BlockedThreadChecker WARNING: Thread Thread[vert.x-eventloop-thread-0,5,main]=Thread[vert.x-eventloop-thread-0,5,main] has been blocked for 5708 ms, time limit is 2000 ms io.vertx.core.VertxException: Thread blocked at sun.misc.Unsafe.park(Native Method) at java.util.concurrent.locks.LockSupport.parkUntil(LockSupport.java:256) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitUntil(AbstractQueuedSynchronizer.java:2120) at org.I0Itec.zkclient.ZkClient.waitForKeeperState(ZkClient.java:944) at org.I0Itec.zkclient.ZkClient.waitUntilConnected(ZkClient.java:926) at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:1231) at org.I0Itec.zkclient.ZkClient.(ZkClient.java:157) at org.I0Itec.zkclient.ZkClient.(ZkClient.java:131) at org.I0Itec.zkclient.ZkClient.(ZkClient.java:98) at io.strimzi.operator.user.operator.KafkaUserQuotasOperator.(KafkaUserQuotasOperator.java:35) at io.strimzi.operator.user.Main.lambda$run$2(Main.java:87) at io.strimzi.operator.user.Main$$Lambda$48/871160466.apply(Unknown Source) at io.vertx.core.Future.lambda$compose$3(Future.java:360) at io.vertx.core.Future$$Lambda$54/1787189503.handle(Unknown Source) at io.vertx.core.impl.FutureImpl.dispatch(FutureImpl.java:107) at io.vertx.core.impl.FutureImpl.tryComplete(FutureImpl.java:152) at io.vertx.core.impl.FutureImpl.complete(FutureImpl.java:113) at io.strimzi.operator.user.Main.lambda$createAdminClient$3(Main.java:134) at io.strimzi.operator.user.Main$$Lambda$47/944140566.handle(Unknown Source) at io.vertx.core.impl.FutureImpl.dispatch(FutureImpl.java:107) at io.vertx.core.impl.FutureImpl.tryComplete(FutureImpl.java:152) at io.vertx.core.impl.FutureImpl.complete(FutureImpl.java:113) at io.vertx.core.impl.FutureImpl.handle(FutureImpl.java:178) at io.vertx.core.impl.CompositeFutureImpl.doComplete(CompositeFutureImpl.java:252) at io.vertx.core.impl.CompositeFutureImpl.lambda$join$3(CompositeFutureImpl.java:110) at io.vertx.core.impl.CompositeFutureImpl$$Lambda$46/403170294.handle(Unknown Source) at io.vertx.core.impl.FutureImpl.dispatch(FutureImpl.java:107) at io.vertx.core.impl.FutureImpl.tryComplete(FutureImpl.java:152) at io.vertx.core.impl.FutureImpl.complete(FutureImpl.java:113) at io.vertx.core.impl.FutureImpl.handle(FutureImpl.java:178) at io.vertx.core.impl.FutureImpl.handle(FutureImpl.java:21) at io.vertx.core.impl.ContextImpl.lambda$null$0(ContextImpl.java:330) at io.vertx.core.impl.ContextImpl$$Lambda$66/1574074701.handle(Unknown Source) at io.vertx.core.impl.ContextImpl.executeTask(ContextImpl.java:369) at io.vertx.core.impl.EventLoopContext.lambda$executeAsync$0(EventLoopContext.java:38) at io.vertx.core.impl.EventLoopContext$$Lambda$67/1097288306.run(Unknown Source) at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164) at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.lang.Thread.run(Thread.java:748) [2020-04-20 23:36:31,978] DEBUG [alhost:2181)] Canonicalized address to localhost [2020-04-20 23:36:31,978] INFO [alhost:2181)] Opening socket connection to server localhost/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error) [2020-04-20 23:36:31,979] INFO [alhost:2181)] Socket connection established, initiating session, client: /127.0.0.1:33444, server: localhost/127.0.0.1:2181 [2020-04-20 23:36:31,979] DEBUG [alhost:2181)] Session establishment request sent on localhost/127.0.0.1:2181 [2020-04-20 23:36:31,991] INFO [alhost:2181)] Session establishment complete on server localhost/127.0.0.1:2181, sessionid = 0x10000736c8c0006, negotiated timeout = 6000 [2020-04-20 23:36:31,992] DEBUG [-EventThread] Received event: WatchedEvent state:SyncConnected type:None path:null [2020-04-20 23:36:31,992] INFO [-EventThread] zookeeper state changed (SyncConnected) [2020-04-20 23:36:31,992] DEBUG [-EventThread] Leaving process event [2020-04-20 23:36:31,993] DEBUG [oop-thread-0] State is SyncConnected [2020-04-20 23:36:32,003] INFO [oop-thread-0] Creating UserOperator for namespace topic-cluster-test [2020-04-20 23:36:32,041] INFO [oop-thread-1] Starting UserOperator for namespace topic-cluster-test [2020-04-20 23:36:32,060] DEBUG [ker-thread-0] Connecting websocket ... io.fabric8.kubernetes.client.dsl.internal.WatchConnectionManager@7eed6d84 [2020-04-20 23:36:32,124] DEBUG [2.30.0.1/...] WebSocket successfully opened [2020-04-20 23:36:32,127] INFO [oop-thread-1] Started operator for KafkaUser kind [2020-04-20 23:36:32,127] INFO [oop-thread-1] Setting up periodic reconciliation for namespace topic-cluster-test [2020-04-20 23:36:32,184] DEBUG [oop-thread-1] -Dio.netty.allocator.numHeapArenas: 2 [2020-04-20 23:36:32,184] DEBUG [oop-thread-1] -Dio.netty.allocator.numDirectArenas: 2 [2020-04-20 23:36:32,185] DEBUG [oop-thread-1] -Dio.netty.allocator.pageSize: 8192 [2020-04-20 23:36:32,185] DEBUG [oop-thread-1] -Dio.netty.allocator.maxOrder: 11 [2020-04-20 23:36:32,185] DEBUG [oop-thread-1] -Dio.netty.allocator.chunkSize: 16777216 [2020-04-20 23:36:32,185] DEBUG [oop-thread-1] -Dio.netty.allocator.tinyCacheSize: 512 [2020-04-20 23:36:32,185] DEBUG [oop-thread-1] -Dio.netty.allocator.smallCacheSize: 256 [2020-04-20 23:36:32,186] DEBUG [oop-thread-1] -Dio.netty.allocator.normalCacheSize: 64 [2020-04-20 23:36:32,186] DEBUG [oop-thread-1] -Dio.netty.allocator.maxCachedBufferCapacity: 32768 [2020-04-20 23:36:32,186] DEBUG [oop-thread-1] -Dio.netty.allocator.cacheTrimInterval: 8192 [2020-04-20 23:36:32,186] DEBUG [oop-thread-1] -Dio.netty.allocator.cacheTrimIntervalMillis: 0 [2020-04-20 23:36:32,186] DEBUG [oop-thread-1] -Dio.netty.allocator.useCacheForAllThreads: true [2020-04-20 23:36:32,186] DEBUG [oop-thread-1] -Dio.netty.allocator.maxCachedByteBuffersPerChunk: 1023 [2020-04-20 23:36:32,268] DEBUG [oop-thread-1] -Dio.netty.processId: 10 (auto-detected) [2020-04-20 23:36:32,270] DEBUG [oop-thread-1] -Dio.netty.machineId: 02:42:ac:ff:fe:11:00:10 (auto-detected) [2020-04-20 23:36:32,308] DEBUG [oop-thread-1] -Dio.netty.allocator.type: pooled [2020-04-20 23:36:32,308] DEBUG [oop-thread-1] -Dio.netty.threadLocalDirectBufferSize: 0 [2020-04-20 23:36:32,309] DEBUG [oop-thread-1] -Dio.netty.maxThreadLocalCharBufferSize: 16384 [2020-04-20 23:36:32,442] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:36:32,475] INFO [oop-thread-1] UserOperator is now ready (health server listening on 8081) [2020-04-20 23:36:32,477] INFO
[oop-thread-0] User Operator verticle started in namespace topic-cluster-test [2020-04-20 23:36:33,984] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:36:34,442] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:36:35,986] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:36:36,444] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:36:37,988] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:36:38,448] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 3ms [2020-04-20 23:36:38,472] DEBUG [oop-thread-1] -Dio.netty.recycler.maxCapacityPerThread: 4096 [2020-04-20 23:36:38,472] DEBUG [oop-thread-1] -Dio.netty.recycler.maxSharedCapacityFactor: 2 [2020-04-20 23:36:38,472] DEBUG [oop-thread-1] -Dio.netty.recycler.linkCapacity: 16 [2020-04-20 23:36:38,472] DEBUG [oop-thread-1] -Dio.netty.recycler.ratio: 8 [2020-04-20 23:36:38,481] DEBUG [oop-thread-1] -Dio.netty.buffer.checkAccessible: true [2020-04-20 23:36:38,482] DEBUG [oop-thread-1] -Dio.netty.buffer.checkBounds: true [2020-04-20 23:36:38,485] DEBUG [oop-thread-1] Loaded default ResourceLeakDetector: io.netty.util.ResourceLeakDetector@2b33503f [2020-04-20 23:36:38,570] DEBUG [oop-thread-1] -Dio.netty.noJdkZlibDecoder: false [2020-04-20 23:36:38,570] DEBUG [oop-thread-1] -Dio.netty.noJdkZlibEncoder: false [2020-04-20 23:36:39,988] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:36:40,449] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:36:41,993] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:36:42,450] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:36:43,996] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 3ms [2020-04-20 23:36:44,459] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 8ms [2020-04-20 23:36:56,015] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:36:56,469] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:36:56,925] DEBUG [dminclient-1] [AdminClient clientId=adminclient-1] Initiating connection to node my-cluster-kafka-0.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 0 rack: null) using address my-cluster-kafka-0.my-cluster-kafka-brokers.topic-cluster-test.svc/172.17.0.14 [2020-04-20 23:36:56,928] DEBUG [dminclient-1] Added sensor with name node-0.bytes-sent [2020-04-20 23:36:56,930] DEBUG [dminclient-1] Added sensor with name node-0.bytes-received [2020-04-20 23:36:56,930] DEBUG [dminclient-1] Added sensor with name node-0.latency [2020-04-20 23:36:56,931] DEBUG [dminclient-1] [AdminClient clientId=adminclient-1] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 0 [2020-04-20 23:36:56,935] DEBUG [dminclient-1] [AdminClient clientId=adminclient-1] Completed connection to node 0. Fetching API versions. [2020-04-20 23:36:56,994] DEBUG [dminclient-1] [SslTransportLayer channelId=0 key=sun.nio.ch.SelectionKeyImpl@421b3d91] SSL handshake completed successfully with peerHost 'my-cluster-kafka-0.my-cluster-kafka-brokers.topic-cluster-test.svc' peerPort 9091 peerPrincipal 'CN=my-cluster-kafka, O=io.strimzi' cipherSuite 'TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA384' [2020-04-20 23:36:56,995] DEBUG [dminclient-1] [AdminClient clientId=adminclient-1] Successfully authenticated with my-cluster-kafka-0.my-cluster-kafka-brokers.topic-cluster-test.svc/172.17.0.14 [2020-04-20 23:36:56,995] DEBUG [dminclient-1] [AdminClient clientId=adminclient-1] Initiating API versions fetch from node 0. [2020-04-20 23:36:57,011] DEBUG [dminclient-1] [AdminClient clientId=adminclient-1] Recorded API versions for node 0: (Produce(0): 0 to 8 [usable: 8], Fetch(1): 0 to 11 [usable: 11], ListOffsets(2): 0 to 5 [usable: 5], Metadata(3): 0 to 9 [usable: 9], LeaderAndIsr(4): 0 to 4 [usable: 4], StopReplica(5): 0 to 2 [usable: 2], UpdateMetadata(6): 0 to 6 [usable: 6], ControlledShutdown(7): 0 to 3 [usable: 3], OffsetCommit(8): 0 to 8 [usable: 8], OffsetFetch(9): 0 to 6 [usable: 6], FindCoordinator(10): 0 to 3 [usable: 3], JoinGroup(11): 0 to 6 [usable: 6], Heartbeat(12): 0 to 4 [usable: 4], LeaveGroup(13): 0 to 4 [usable: 4], SyncGroup(14): 0 to 4 [usable: 4], DescribeGroups(15): 0 to 5 [usable: 5], ListGroups(16): 0 to 3 [usable: 3], SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 3 [usable: 3], CreateTopics(19): 0 to 5 [usable: 5], DeleteTopics(20): 0 to 4 [usable: 4], DeleteRecords(21): 0 to 1 [usable: 1], InitProducerId(22): 0 to 2 [usable: 2], OffsetForLeaderEpoch(23): 0 to 3 [usable: 3], AddPartitionsToTxn(24): 0 to 1 [usable: 1], AddOffsetsToTxn(25): 0 to 1 [usable: 1], EndTxn(26): 0 to 1 [usable: 1], WriteTxnMarkers(27): 0 [usable: 0], TxnOffsetCommit(28): 0 to 2 [usable: 2], DescribeAcls(29): 0 to 1 [usable: 1], CreateAcls(30): 0 to 1 [usable: 1], DeleteAcls(31): 0 to 1 [usable: 1], DescribeConfigs(32): 0 to 2 [usable: 2], AlterConfigs(33): 0 to 1 [usable: 1], AlterReplicaLogDirs(34): 0 to 1 [usable: 1], DescribeLogDirs(35): 0 to 1 [usable: 1], SaslAuthenticate(36): 0 to 1 [usable: 1], CreatePartitions(37): 0 to 1 [usable: 1], CreateDelegationToken(38): 0 to 2 [usable: 2], RenewDelegationToken(39): 0 to 1 [usable: 1], ExpireDelegationToken(40): 0 to 1 [usable: 1], DescribeDelegationToken(41): 0 to 1 [usable: 1], DeleteGroups(42): 0 to 2 [usable: 2], ElectLeaders(43): 0 to 2 [usable: 2], IncrementalAlterConfigs(44): 0 to 1 [usable: 1], AlterPartitionReassignments(45): 0 [usable: 0], ListPartitionReassignments(46): 0 [usable: 0], OffsetDelete(47): 0 [usable: 0]) [2020-04-20 23:36:57,027] DEBUG [dminclient-1] [AdminClient clientId=adminclient-1] Updating cluster metadata to Cluster(id = ekOAnyoiQqCRJryaE24oKQ, nodes = [my-cluster-kafka-0.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 0 rack: null), my-cluster-kafka-1.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 1 rack: null), my-cluster-kafka-2.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 2 rack: null)], partitions = [], controller = my-cluster-kafka-1.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 1 rack: null)) [2020-04-20 23:36:58,017] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 3ms [2020-04-20 23:36:58,472] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:37:00,021] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 4ms [2020-04-20 23:37:00,473] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:37:02,033] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 12ms [2020-04-20 23:37:02,477] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:37:04,026] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:37:04,480] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 3ms [2020-04-20 23:37:06,029] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:37:06,482] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:37:08,032] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:37:08,484] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:37:10,035] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:37:10,486] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:37:12,044] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 8ms [2020-04-20 23:37:12,491] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 5ms [2020-04-20 23:37:14,047] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 8ms [2020-04-20 23:37:14,491] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:37:16,045] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:37:16,494] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:37:18,054] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 9ms [2020-04-20 23:37:18,499] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 5ms [2020-04-20 23:37:20,051] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:37:20,500] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:37:22,054] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:37:22,504] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:37:26,058] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:37:26,509] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:37:27,068] DEBUG [dminclient-1] [AdminClient clientId=adminclient-1] Updating cluster metadata to Cluster(id = ekOAnyoiQqCRJryaE24oKQ, nodes = [my-cluster-kafka-0.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 0 rack: null), my-cluster-kafka-1.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 1 rack: null), my-cluster-kafka-2.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 2 rack: null)], partitions = [], controller = my-cluster-kafka-1.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 1 rack: null)) [2020-04-20 23:37:28,060] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:37:28,510] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:37:30,063] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:37:30,512] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:37:32,070] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 4ms [2020-04-20 23:37:32,517] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 3ms [2020-04-20 23:37:34,069] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:37:34,518] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:37:36,072] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:37:36,520] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:37:38,074] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:37:38,522] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:37:40,076] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 3ms [2020-04-20 23:37:40,524] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:37:42,082] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 5ms [2020-04-20 23:37:42,527] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:37:56,098] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:37:56,544] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:37:57,109] DEBUG [dminclient-1] [AdminClient clientId=adminclient-1] Updating cluster metadata to Cluster(id = ekOAnyoiQqCRJryaE24oKQ, nodes = [my-cluster-kafka-0.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 0 rack: null), my-cluster-kafka-2.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 2 rack: null), my-cluster-kafka-1.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 1 rack: null)], partitions = [], controller = my-cluster-kafka-1.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 1 rack: null)) [2020-04-20 23:37:58,100] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:37:58,548] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 3ms [2020-04-20 23:38:00,105] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:38:00,550] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:38:02,106] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:38:02,553] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:38:04,108] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:38:04,559] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 4ms [2020-04-20 23:38:06,117] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 4ms [2020-04-20 23:38:06,560] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:38:08,124] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 6ms [2020-04-20 23:38:08,562] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:38:26,138] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:38:26,584] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:38:27,141] DEBUG [dminclient-1] [AdminClient clientId=adminclient-1] Updating cluster metadata to Cluster(id = ekOAnyoiQqCRJryaE24oKQ, nodes = [my-cluster-kafka-1.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 1 rack: null), my-cluster-kafka-0.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 0 rack: null), my-cluster-kafka-2.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 2 rack: null)], partitions = [], controller = my-cluster-kafka-1.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 1 rack: null)) [2020-04-20 23:38:28,140] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:38:28,586] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:38:30,143] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:38:30,591] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:38:32,132] INFO [oop-thread-1] Triggering periodic reconciliation for namespace topic-cluster-test... [2020-04-20 23:38:32,138] WARN [s-ops-tool-2] The client is using resource type 'kafkausers' with unstable version 'v1beta1' [2020-04-20 23:38:32,145] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:38:32,223] DEBUG [r-ops-pool-0] Searching for Users with any ACL rules [2020-04-20 23:38:32,242] DEBUG [r-ops-pool-0] [AdminClient clientId=adminclient-1] Queueing Call(callName=describeAcls, deadlineMs=1587426032240) with a timeout 120000 ms from now. [2020-04-20 23:38:32,278] DEBUG [alhost:2181)] Reading reply sessionid:0x10000736c8c0004, packet:: clientPath:null serverPath:null finished:false header:: 1,3 replyHeader:: 1,4294967391,0 request:: '/config/users,F response:: s{4294967317,4294967317,1587425761572,1587425761572,0,0,0,0,0,0,4294967317} [2020-04-20 23:38:32,279] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 9ms [2020-04-20 23:38:32,287] DEBUG [alhost:2181)] Reading reply sessionid:0x10000736c8c0004, packet:: clientPath:null serverPath:null finished:false header:: 2,8 replyHeader:: 2,4294967391,0 request:: '/config/users,F response:: v{} [2020-04-20 23:38:34,150] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 3ms [2020-04-20 23:38:34,289] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:38:36,152] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:38:36,292] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:38:38,154] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:38:38,293] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:38:40,157] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:38:40,295] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:38:42,157] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:38:42,297] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:38:44,161] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:38:44,299] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:38:46,162] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:38:46,300] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:38:56,174] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:38:56,312] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:38:57,157] DEBUG [dminclient-1] [AdminClient clientId=adminclient-1] Updating cluster metadata to Cluster(id = ekOAnyoiQqCRJryaE24oKQ, nodes = [my-cluster-kafka-1.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 1 rack: null), my-cluster-kafka-2.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 2 rack: null), my-cluster-kafka-0.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 0 rack: null)], partitions = [], controller = my-cluster-kafka-1.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 1 rack: null)) [2020-04-20 23:38:58,176] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:38:58,314] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:39:00,177] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:39:00,317] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:39:02,179] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:39:02,320] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:39:04,182] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:39:04,322] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:39:06,183] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:39:06,324] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:39:08,185] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:39:08,326] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:39:10,188] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:39:10,327] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:39:12,191] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:39:12,331] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:39:14,194] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:39:14,331] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:39:16,197] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:39:16,334] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:39:26,209] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:39:26,349] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:39:27,181] DEBUG [dminclient-1] [AdminClient clientId=adminclient-1] Updating cluster metadata to Cluster(id = ekOAnyoiQqCRJryaE24oKQ, nodes = [my-cluster-kafka-2.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 2 rack: null), my-cluster-kafka-0.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 0 rack: null), my-cluster-kafka-1.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 1 rack: null)], partitions = [], controller = my-cluster-kafka-1.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 1 rack: null)) [2020-04-20 23:39:28,211] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:39:28,351] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:39:30,215] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:39:30,354] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:39:32,217] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:39:32,358] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 3ms [2020-04-20 23:39:34,219] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:39:34,358] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:39:36,221] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:39:36,360] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:39:38,222] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:39:38,362] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:39:40,230] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 8ms [2020-04-20 23:39:40,364] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:39:42,225] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:39:42,368] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 3ms [2020-04-20 23:39:44,228] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:39:44,368] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:39:46,229] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:39:46,370] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:39:48,231] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:39:48,372] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:39:56,241] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:39:56,382] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:39:57,213] DEBUG [dminclient-1] [AdminClient clientId=adminclient-1] Updating cluster metadata to Cluster(id = ekOAnyoiQqCRJryaE24oKQ, nodes = [my-cluster-kafka-1.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 1 rack: null), my-cluster-kafka-0.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 0 rack: null), my-cluster-kafka-2.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 2 rack: null)], partitions = [], controller = my-cluster-kafka-1.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 1 rack: null)) [2020-04-20 23:39:58,245] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:39:58,384] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:40:00,247] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:40:00,389] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:40:02,248] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:40:02,390] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:40:04,250] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:40:04,392] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:40:06,252] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:40:06,394] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:40:08,255] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 3ms [2020-04-20 23:40:08,398] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:40:10,259] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 4ms [2020-04-20 23:40:10,398] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:40:12,258] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:40:12,401] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:40:14,259] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:40:14,404] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:40:16,262] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:40:16,407] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:40:26,282] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:40:26,419] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 4ms [2020-04-20 23:40:27,253] DEBUG [dminclient-1] [AdminClient clientId=adminclient-1] Updating cluster metadata to Cluster(id = ekOAnyoiQqCRJryaE24oKQ, nodes = [my-cluster-kafka-0.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 0 rack: null), my-cluster-kafka-2.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 2 rack: null), my-cluster-kafka-1.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 1 rack: null)], partitions = [], controller = my-cluster-kafka-1.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 1 rack: null)) [2020-04-20 23:40:28,286] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:40:28,419] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:40:30,287] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:40:30,423] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 3ms [2020-04-20 23:40:32,132] INFO [oop-thread-1] Triggering periodic reconciliation for namespace topic-cluster-test... [2020-04-20 23:40:32,145] DEBUG [r-ops-pool-1] Searching for Users with any ACL rules [2020-04-20 23:40:32,146] DEBUG [r-ops-pool-1] [AdminClient clientId=adminclient-1] Queueing Call(callName=describeAcls, deadlineMs=1587426152146) with a timeout 120000 ms from now. [2020-04-20 23:40:32,154] DEBUG [alhost:2181)] Reading reply sessionid:0x10000736c8c0004, packet:: clientPath:null serverPath:null finished:false header:: 3,3 replyHeader:: 3,4294967399,0 request:: '/config/users,F response:: s{4294967317,4294967317,1587425761572,1587425761572,0,0,0,0,0,0,4294967317} [2020-04-20 23:40:32,155] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 3ms [2020-04-20 23:40:32,155] DEBUG [alhost:2181)] Reading reply sessionid:0x10000736c8c0004, packet:: clientPath:null serverPath:null finished:false header:: 4,8 replyHeader:: 4,4294967399,0 request:: '/config/users,F response:: v{} [2020-04-20 23:40:32,290] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:40:34,158] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:40:34,294] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:40:36,162] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:40:36,295] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:40:38,163] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:40:38,298] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:40:40,167] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:40:40,298] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:40:42,169] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:40:42,300] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:40:44,171] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:40:44,304] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:40:46,174] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:40:46,308] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:40:48,175] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:40:48,310] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:40:50,179] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:40:50,312] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:40:52,182] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 3ms [2020-04-20 23:40:52,341] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 30ms [2020-04-20 23:40:54,183] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:40:54,317] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:40:56,186] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:40:56,318] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:40:57,282] DEBUG [dminclient-1] [AdminClient clientId=adminclient-1] Updating cluster metadata to Cluster(id = ekOAnyoiQqCRJryaE24oKQ, nodes = [my-cluster-kafka-0.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 0 rack: null), my-cluster-kafka-1.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 1 rack: null), my-cluster-kafka-2.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 2 rack: null)], partitions = [], controller = my-cluster-kafka-1.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 1 rack: null)) [2020-04-20 23:40:58,189] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:40:58,320] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:41:00,191] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:41:00,324] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:41:02,194] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:41:02,327] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:41:04,198] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:41:04,329] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:41:06,200] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:41:06,331] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:41:08,202] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:41:08,335] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 3ms [2020-04-20 23:41:10,203] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:41:10,334] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:41:12,208] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 3ms [2020-04-20 23:41:12,345] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 7ms [2020-04-20 23:41:14,208] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:41:14,341] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:41:16,210] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:41:16,345] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:41:26,223] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:41:26,381] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 5ms [2020-04-20 23:41:27,312] DEBUG [dminclient-1] [AdminClient clientId=adminclient-1] Node -1 disconnected. [2020-04-20 23:41:27,315] DEBUG [dminclient-1] [AdminClient clientId=adminclient-1] Requesting metadata update. [2020-04-20 23:41:27,333] DEBUG [dminclient-1] [AdminClient clientId=adminclient-1] Updating cluster metadata to Cluster(id = ekOAnyoiQqCRJryaE24oKQ, nodes = [my-cluster-kafka-1.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 1 rack: null), my-cluster-kafka-2.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 2 rack: null), my-cluster-kafka-0.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 0 rack: null)], partitions = [], controller = my-cluster-kafka-1.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 1 rack: null)) [2020-04-20 23:41:28,226] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:41:28,379] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:41:30,226] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:41:30,382] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:41:32,233] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 5ms [2020-04-20 23:41:32,384] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:41:34,230] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:41:34,386] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:41:36,233] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:41:36,388] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:41:38,236] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:41:38,391] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:41:40,240] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:41:40,394] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:41:42,240] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:41:42,394] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:41:44,244] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:41:44,399] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:41:46,244] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:41:46,398] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:41:48,250] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 6ms [2020-04-20 23:41:48,401] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:41:50,252] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 3ms [2020-04-20 23:41:50,410] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 5ms [2020-04-20 23:41:52,252] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:41:52,411] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 4ms [2020-04-20 23:41:54,254] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:41:54,413] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 3ms [2020-04-20 23:41:56,255] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:41:56,414] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:41:57,374] DEBUG [dminclient-1] [AdminClient clientId=adminclient-1] Updating cluster metadata to Cluster(id = ekOAnyoiQqCRJryaE24oKQ, nodes = [my-cluster-kafka-1.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 1 rack: null), my-cluster-kafka-0.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 0 rack: null), my-cluster-kafka-2.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 2 rack: null)], partitions = [], controller = my-cluster-kafka-1.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 1 rack: null)) [2020-04-20 23:41:58,261] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:41:58,416] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:42:00,263] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:42:00,419] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:42:02,269] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 4ms [2020-04-20 23:42:02,421] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:42:04,271] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:42:04,434] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 12ms [2020-04-20 23:42:06,272] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:42:06,425] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:42:08,275] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:42:08,428] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:42:10,277] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:42:10,431] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:42:12,280] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:42:12,432] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:42:14,289] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 8ms [2020-04-20 23:42:26,299] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:42:26,451] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 2ms [2020-04-20 23:42:27,418] DEBUG [dminclient-1] [AdminClient clientId=adminclient-1] Updating cluster metadata to Cluster(id = ekOAnyoiQqCRJryaE24oKQ, nodes = [my-cluster-kafka-0.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 0 rack: null), my-cluster-kafka-2.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 2 rack: null), my-cluster-kafka-1.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 1 rack: null)], partitions = [], controller = my-cluster-kafka-1.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 1 rack: null)) [2020-04-20 23:42:28,301] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:42:28,457] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 7ms [2020-04-20 23:42:30,303] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:42:30,452] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:42:32,131] INFO [oop-thread-1] Triggering periodic reconciliation for namespace topic-cluster-test... [2020-04-20 23:42:32,140] DEBUG [r-ops-pool-2] Searching for Users with any ACL rules [2020-04-20 23:42:32,141] DEBUG [r-ops-pool-2] [AdminClient clientId=adminclient-1] Queueing Call(callName=describeAcls, deadlineMs=1587426272141) with a timeout 120000 ms from now. [2020-04-20 23:42:32,149] DEBUG [alhost:2181)] Reading reply sessionid:0x10000736c8c0004, packet:: clientPath:null serverPath:null finished:false header:: 5,3 replyHeader:: 5,4294967543,0 request:: '/config/users,F response:: s{4294967317,4294967317,1587425761572,1587425761572,0,0,0,0,0,0,4294967317} [2020-04-20 23:42:32,149] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 2ms [2020-04-20 23:42:32,151] DEBUG [alhost:2181)] Reading reply sessionid:0x10000736c8c0004, packet:: clientPath:null serverPath:null finished:false header:: 6,8 replyHeader:: 6,4294967543,0 request:: '/config/users,F response:: v{} [2020-04-20 23:42:32,462] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:42:34,153] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:42:34,465] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:42:56,491] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:42:57,462] DEBUG [dminclient-1] [AdminClient clientId=adminclient-1] Updating cluster metadata to Cluster(id = ekOAnyoiQqCRJryaE24oKQ, nodes = [my-cluster-kafka-1.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 1 rack: null), my-cluster-kafka-0.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 0 rack: null), my-cluster-kafka-2.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 2 rack: null)], partitions = [], controller = my-cluster-kafka-1.my-cluster-kafka-brokers.topic-cluster-test.svc:9091 (id: 1 rack: null)) [2020-04-20 23:42:58,184] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 1ms [2020-04-20 23:42:58,494] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:43:26,537] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:43:56,596] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 14ms [2020-04-20 23:44:26,663] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 18ms [2020-04-20 23:44:56,704] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 7ms [2020-04-20 23:45:26,321] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0004 after 11ms [2020-04-20 23:47:26,975] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 6ms [2020-04-20 23:47:57,017] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 1ms [2020-04-20 23:48:27,077] DEBUG [alhost:2181)] Got ping response for sessionid: 0x10000736c8c0006 after 11ms