Waiting for the TLS sidecar to get ready
TLS sidecar is not ready yet, waiting for another 1 second
STRIMZI_BROKER_ID=2
Preparing truststore for replication listener
Adding /opt/kafka/cluster-ca-certs/ca.crt to truststore /tmp/kafka/cluster.truststore.p12 with alias ca
Certificate was added to keystore
Preparing truststore for replication listener is complete
Looking for the right CA
Found the right CA: /opt/kafka/cluster-ca-certs/ca.crt
Preparing keystore for replication and clienttls listener
Preparing keystore for replication and clienttls listener is complete
Preparing truststore for clienttls listener
Adding /opt/kafka/client-ca-certs/ca.crt to truststore /tmp/kafka/clients.truststore.p12 with alias ca
Certificate was added to keystore
Preparing truststore for clienttls listener is complete
Starting Kafka with configuration:
##############################
##############################
# This file is automatically generated by the Strimzi Cluster Operator
# Any changes to this file will be ignored and overwritten!
##############################
##############################
##########
# Broker ID
##########
broker.id=2
##########
# Zookeeper
##########
zookeeper.connect=localhost:2181
##########
# Kafka message logs configuration
##########
log.dirs=/var/lib/kafka/data/kafka-log2
##########
# Replication listener
##########
listener.name.replication-9091.ssl.keystore.location=/tmp/kafka/cluster.keystore.p12
listener.name.replication-9091.ssl.keystore.password=[hidden]
listener.name.replication-9091.ssl.keystore.type=PKCS12
listener.name.replication-9091.ssl.truststore.location=/tmp/kafka/cluster.truststore.p12
listener.name.replication-9091.ssl.truststore.password=[hidden]
listener.name.replication-9091.ssl.truststore.type=PKCS12
listener.name.replication-9091.ssl.client.auth=required
##########
# Plain listener
##########
##########
# TLS listener
##########
listener.name.tls-9093.ssl.keystore.location=/tmp/kafka/cluster.keystore.p12
listener.name.tls-9093.ssl.keystore.password=[hidden]
listener.name.tls-9093.ssl.keystore.type=PKCS12
##########
# Common listener configuration
##########
listeners=REPLICATION-9091://0.0.0.0:9091,PLAIN-9092://0.0.0.0:9092,TLS-9093://0.0.0.0:9093
advertised.listeners=REPLICATION-9091://my-cluster-kafka-2.my-cluster-kafka-brokers.topic-cluster-test.svc:9091,PLAIN-9092://my-cluster-kafka-2.my-cluster-kafka-brokers.topic-cluster-test.svc:9092,TLS-9093://my-cluster-kafka-2.my-cluster-kafka-brokers.topic-cluster-test.svc:9093
listener.security.protocol.map=REPLICATION-9091:SSL,PLAIN-9092:PLAINTEXT,TLS-9093:SSL
inter.broker.listener.name=REPLICATION-9091
sasl.enabled.mechanisms=
ssl.secure.random.implementation=SHA1PRNG
ssl.endpoint.identification.algorithm=HTTPS
##########
# User provided configuration
##########
log.message.format.version=2.4
offsets.topic.replication.factor=3
transaction.state.log.min.isr=2
transaction.state.log.replication.factor=3
OpenJDK 64-Bit Server VM warning: If the number of processors is expected to increase from one, then you should configure the number of parallel GC threads appropriately using -XX:ParallelGCThreads=N
2020-04-20 23:36:00,218 INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$) [main]
2020-04-20 23:36:01,340 DEBUG Metric kafka.server:type=KafkaServer,name=BrokerState added  (io.strimzi.kafka.agent.KafkaAgent) [main]
2020-04-20 23:36:01,346 INFO Registered signal handlers for TERM, INT, HUP (org.apache.kafka.common.utils.LoggingSignalHandler) [main]
2020-04-20 23:36:01,347 INFO starting (kafka.server.KafkaServer) [main]
2020-04-20 23:36:01,349 INFO Connecting to zookeeper on localhost:2181 (kafka.server.KafkaServer) [main]
2020-04-20 23:36:01,392 INFO [ZooKeeperClient Kafka server] Initializing a new session to localhost:2181. (kafka.zookeeper.ZooKeeperClient) [main]
2020-04-20 23:36:01,404 INFO Client environment:zookeeper.version=3.5.6-c11b7e26bc554b8523dc929761dd28808913f091, built on 10/08/2019 20:18 GMT (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:01,404 INFO Client environment:host.name=my-cluster-kafka-2.my-cluster-kafka-brokers.topic-cluster-test.svc.cluster.local (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:01,404 INFO Client environment:java.version=1.8.0_242 (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:01,404 INFO Client environment:java.vendor=Oracle Corporation (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:01,404 INFO Client environment:java.home=/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.242.b08-0.el7_7.x86_64/jre (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:01,404 INFO Client environment:java.class.path=/opt/kafka/bin/../libs/activation-1.1.1.jar:/opt/kafka/bin/../libs/annotations-13.0.jar:/opt/kafka/bin/../libs/aopalliance-repackaged-2.5.0.jar:/opt/kafka/bin/../libs/argparse4j-0.7.0.jar:/opt/kafka/bin/../libs/audience-annotations-0.5.0.jar:/opt/kafka/bin/../libs/bcpkix-jdk15on-1.60.jar:/opt/kafka/bin/../libs/bcprov-jdk15on-1.60.jar:/opt/kafka/bin/../libs/commons-cli-1.4.jar:/opt/kafka/bin/../libs/commons-lang-2.6.jar:/opt/kafka/bin/../libs/commons-lang3-3.8.1.jar:/opt/kafka/bin/../libs/connect-api-2.4.0.jar:/opt/kafka/bin/../libs/connect-basic-auth-extension-2.4.0.jar:/opt/kafka/bin/../libs/connect-file-2.4.0.jar:/opt/kafka/bin/../libs/connect-json-2.4.0.jar:/opt/kafka/bin/../libs/connect-mirror-2.4.0.jar:/opt/kafka/bin/../libs/connect-mirror-client-2.4.0.jar:/opt/kafka/bin/../libs/connect-runtime-2.4.0.jar:/opt/kafka/bin/../libs/connect-transforms-2.4.0.jar:/opt/kafka/bin/../libs/gson-2.8.6.jar:/opt/kafka/bin/../libs/guava-20.0.jar:/opt/kafka/bin/../libs/hk2-api-2.5.0.jar:/opt/kafka/bin/../libs/hk2-locator-2.5.0.jar:/opt/kafka/bin/../libs/hk2-utils-2.5.0.jar:/opt/kafka/bin/../libs/jackson-annotations-2.10.0.jar:/opt/kafka/bin/../libs/jackson-core-2.10.0.jar:/opt/kafka/bin/../libs/jackson-databind-2.10.0.jar:/opt/kafka/bin/../libs/jackson-dataformat-csv-2.10.0.jar:/opt/kafka/bin/../libs/jackson-datatype-jdk8-2.10.0.jar:/opt/kafka/bin/../libs/jackson-jaxrs-base-2.10.0.jar:/opt/kafka/bin/../libs/jackson-jaxrs-json-provider-2.10.0.jar:/opt/kafka/bin/../libs/jackson-module-jaxb-annotations-2.10.0.jar:/opt/kafka/bin/../libs/jackson-module-paranamer-2.10.0.jar:/opt/kafka/bin/../libs/jackson-module-scala_2.12-2.10.0.jar:/opt/kafka/bin/../libs/jaeger-client-1.1.0.jar:/opt/kafka/bin/../libs/jaeger-core-1.1.0.jar:/opt/kafka/bin/../libs/jaeger-thrift-1.1.0.jar:/opt/kafka/bin/../libs/jaeger-tracerresolver-1.1.0.jar:/opt/kafka/bin/../libs/jakarta.activation-api-1.2.1.jar:/opt/kafka/bin/../libs/jakarta.annotation-api-1.3.4.jar:/opt/kafka/bin/../libs/jakarta.inject-2.5.0.jar:/opt/kafka/bin/../libs/jakarta.ws.rs-api-2.1.5.jar:/opt/kafka/bin/../libs/jakarta.xml.bind-api-2.3.2.jar:/opt/kafka/bin/../libs/javassist-3.22.0-CR2.jar:/opt/kafka/bin/../libs/javax.servlet-api-3.1.0.jar:/opt/kafka/bin/../libs/javax.ws.rs-api-2.1.1.jar:/opt/kafka/bin/../libs/jaxb-api-2.3.0.jar:/opt/kafka/bin/../libs/jersey-client-2.28.jar:/opt/kafka/bin/../libs/jersey-common-2.28.jar:/opt/kafka/bin/../libs/jersey-container-servlet-2.28.jar:/opt/kafka/bin/../libs/jersey-container-servlet-core-2.28.jar:/opt/kafka/bin/../libs/jersey-hk2-2.28.jar:/opt/kafka/bin/../libs/jersey-media-jaxb-2.28.jar:/opt/kafka/bin/../libs/jersey-server-2.28.jar:/opt/kafka/bin/../libs/jetty-client-9.4.20.v20190813.jar:/opt/kafka/bin/../libs/jetty-continuation-9.4.20.v20190813.jar:/opt/kafka/bin/../libs/jetty-http-9.4.20.v20190813.jar:/opt/kafka/bin/../libs/jetty-io-9.4.20.v20190813.jar:/opt/kafka/bin/../libs/jetty-security-9.4.20.v20190813.jar:/opt/kafka/bin/../libs/jetty-server-9.4.20.v20190813.jar:/opt/kafka/bin/../libs/jetty-servlet-9.4.20.v20190813.jar:/opt/kafka/bin/../libs/jetty-servlets-9.4.20.v20190813.jar:/opt/kafka/bin/../libs/jetty-util-9.4.20.v20190813.jar:/opt/kafka/bin/../libs/jmx_prometheus_javaagent-0.12.0.jar:/opt/kafka/bin/../libs/jopt-simple-5.0.4.jar:/opt/kafka/bin/../libs/json-smart-1.1.1.jar:/opt/kafka/bin/../libs/jsonevent-layout-1.7.jar:/opt/kafka/bin/../libs/kafka-agent.jar:/opt/kafka/bin/../libs/kafka-clients-2.4.0.jar:/opt/kafka/bin/../libs/kafka-log4j-appender-2.4.0.jar:/opt/kafka/bin/../libs/kafka-oauth-client-0.4.0.jar:/opt/kafka/bin/../libs/kafka-oauth-common-0.4.0.jar:/opt/kafka/bin/../libs/kafka-oauth-keycloak-authorizer-0.4.0.jar:/opt/kafka/bin/../libs/kafka-oauth-server-0.4.0.jar:/opt/kafka/bin/../libs/kafka-streams-2.4.0.jar:/opt/kafka/bin/../libs/kafka-streams-examples-2.4.0.jar:/opt/kafka/bin/../libs/kafka-streams-scala_2.12-2.4.0.jar:/opt/kafka/bin/../libs/kafka-streams-test-utils-2.4.0.jar:/opt/kafka/bin/../libs/kafka-tools-2.4.0.jar:/opt/kafka/bin/../libs/kafka_2.12-2.4.0-sources.jar:/opt/kafka/bin/../libs/kafka_2.12-2.4.0.jar:/opt/kafka/bin/../libs/keycloak-common-7.0.0.jar:/opt/kafka/bin/../libs/keycloak-core-7.0.0.jar:/opt/kafka/bin/../libs/kotlin-stdlib-1.3.50.jar:/opt/kafka/bin/../libs/kotlin-stdlib-common-1.3.50.jar:/opt/kafka/bin/../libs/libthrift-0.13.0.jar:/opt/kafka/bin/../libs/log4j-1.2.17.jar:/opt/kafka/bin/../libs/lz4-java-1.6.0.jar:/opt/kafka/bin/../libs/maven-artifact-3.6.1.jar:/opt/kafka/bin/../libs/metrics-core-2.2.0.jar:/opt/kafka/bin/../libs/mirror-maker-agent.jar:/opt/kafka/bin/../libs/netty-buffer-4.1.42.Final.jar:/opt/kafka/bin/../libs/netty-codec-4.1.42.Final.jar:/opt/kafka/bin/../libs/netty-common-4.1.42.Final.jar:/opt/kafka/bin/../libs/netty-handler-4.1.42.Final.jar:/opt/kafka/bin/../libs/netty-resolver-4.1.42.Final.jar:/opt/kafka/bin/../libs/netty-transport-4.1.42.Final.jar:/opt/kafka/bin/../libs/netty-transport-native-epoll-4.1.42.Final.jar:/opt/kafka/bin/../libs/netty-transport-native-unix-common-4.1.42.Final.jar:/opt/kafka/bin/../libs/okhttp-4.2.2.jar:/opt/kafka/bin/../libs/okio-2.2.2.jar:/opt/kafka/bin/../libs/opentracing-api-0.33.0.jar:/opt/kafka/bin/../libs/opentracing-kafka-client-0.1.9.jar:/opt/kafka/bin/../libs/opentracing-noop-0.33.0.jar:/opt/kafka/bin/../libs/opentracing-tracerresolver-0.1.8.jar:/opt/kafka/bin/../libs/opentracing-util-0.33.0.jar:/opt/kafka/bin/../libs/osgi-resource-locator-1.0.1.jar:/opt/kafka/bin/../libs/paranamer-2.8.jar:/opt/kafka/bin/../libs/plexus-utils-3.2.0.jar:/opt/kafka/bin/../libs/reflections-0.9.11.jar:/opt/kafka/bin/../libs/rocksdbjni-5.18.3.jar:/opt/kafka/bin/../libs/scala-collection-compat_2.12-2.1.2.jar:/opt/kafka/bin/../libs/scala-java8-compat_2.12-0.9.0.jar:/opt/kafka/bin/../libs/scala-library-2.12.10.jar:/opt/kafka/bin/../libs/scala-logging_2.12-3.9.2.jar:/opt/kafka/bin/../libs/scala-reflect-2.12.10.jar:/opt/kafka/bin/../libs/slf4j-api-1.7.28.jar:/opt/kafka/bin/../libs/slf4j-log4j12-1.7.28.jar:/opt/kafka/bin/../libs/snappy-java-1.1.7.3.jar:/opt/kafka/bin/../libs/tracing-agent.jar:/opt/kafka/bin/../libs/validation-api-2.0.1.Final.jar:/opt/kafka/bin/../libs/zookeeper-3.5.6.jar:/opt/kafka/bin/../libs/zookeeper-jute-3.5.6.jar:/opt/kafka/bin/../libs/zstd-jni-1.4.3-1.jar:/opt/kafka/libs/kafka-agent.jar (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:01,404 INFO Client environment:java.library.path=/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:01,404 INFO Client environment:java.io.tmpdir=/tmp (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:01,404 INFO Client environment:java.compiler=<NA> (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:01,404 INFO Client environment:os.name=Linux (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:01,404 INFO Client environment:os.arch=amd64 (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:01,404 INFO Client environment:os.version=3.10.0-944.el7.x86_64 (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:01,404 INFO Client environment:user.name=? (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:01,404 INFO Client environment:user.home=? (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:01,404 INFO Client environment:user.dir=/opt/kafka (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:01,404 INFO Client environment:os.memory.free=118MB (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:01,404 INFO Client environment:os.memory.max=3972MB (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:01,404 INFO Client environment:os.memory.total=128MB (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:01,409 INFO Initiating client connection, connectString=localhost:2181 sessionTimeout=6000 watcher=kafka.zookeeper.ZooKeeperClient$ZooKeeperClientWatcher$@6c80d78a (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:01,415 INFO Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation (org.apache.zookeeper.common.X509Util) [main]
2020-04-20 23:36:01,423 INFO jute.maxbuffer value is 4194304 Bytes (org.apache.zookeeper.ClientCnxnSocket) [main]
2020-04-20 23:36:01,433 INFO zookeeper.request.timeout value is 0. feature enabled= (org.apache.zookeeper.ClientCnxn) [main]
2020-04-20 23:36:01,436 INFO Starting poller (io.strimzi.kafka.agent.KafkaAgent) [main]
2020-04-20 23:36:01,442 INFO [ZooKeeperClient Kafka server] Waiting until connected. (kafka.zookeeper.ZooKeeperClient) [main]
2020-04-20 23:36:01,443 DEBUG Metric kafka.server:type=SessionExpireListener,name=SessionState = CONNECTING (io.strimzi.kafka.agent.KafkaAgent) [KafkaAgentPoller]
2020-04-20 23:36:01,444 INFO Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn) [main-SendThread(localhost:2181)]
2020-04-20 23:36:01,452 INFO Socket error occurred: localhost/0:0:0:0:0:0:0:1:2181: Connection refused (org.apache.zookeeper.ClientCnxn) [main-SendThread(localhost:2181)]
2020-04-20 23:41:13,014 INFO Creating topic my-topic-575344098 with configuration {} and initial partition assignment Map(0 -> ArrayBuffer(0)) (kafka.zk.AdminZkClient) [data-plane-kafka-request-handler-4]
2020-04-20 23:41:13,130 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='my-topic-575344098', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition my-topic-575344098-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 6 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:41:17,547 INFO Creating topic __consumer_offsets with configuration {segment.bytes=104857600, compression.type=producer, cleanup.policy=compact} and initial partition assignment Map(23 -> ArrayBuffer(2, 0, 1), 32 -> ArrayBuffer(2, 1, 0), 41 -> ArrayBuffer(2, 0, 1), 17 -> ArrayBuffer(2, 0, 1), 8 -> ArrayBuffer(2, 1, 0), 35 -> ArrayBuffer(2, 0, 1), 44 -> ArrayBuffer(2, 1, 0), 26 -> ArrayBuffer(2, 1, 0), 11 -> ArrayBuffer(2, 0, 1), 29 -> ArrayBuffer(2, 0, 1), 38 -> ArrayBuffer(2, 1, 0), 47 -> ArrayBuffer(2, 0, 1), 20 -> ArrayBuffer(2, 1, 0), 2 -> ArrayBuffer(2, 1, 0), 5 -> ArrayBuffer(2, 0, 1), 14 -> ArrayBuffer(2, 1, 0), 46 -> ArrayBuffer(1, 2, 0), 49 -> ArrayBuffer(1, 0, 2), 40 -> ArrayBuffer(1, 2, 0), 13 -> ArrayBuffer(1, 0, 2), 4 -> ArrayBuffer(1, 2, 0), 22 -> ArrayBuffer(1, 2, 0), 31 -> ArrayBuffer(1, 0, 2), 16 -> ArrayBuffer(1, 2, 0), 7 -> ArrayBuffer(1, 0, 2), 43 -> ArrayBuffer(1, 0, 2), 25 -> ArrayBuffer(1, 0, 2), 34 -> ArrayBuffer(1, 2, 0), 10 -> ArrayBuffer(1, 2, 0), 37 -> ArrayBuffer(1, 0, 2), 1 -> ArrayBuffer(1, 0, 2), 19 -> ArrayBuffer(1, 0, 2), 28 -> ArrayBuffer(1, 2, 0), 45 -> ArrayBuffer(0, 1, 2), 27 -> ArrayBuffer(0, 1, 2), 36 -> ArrayBuffer(0, 2, 1), 18 -> ArrayBuffer(0, 2, 1), 9 -> ArrayBuffer(0, 1, 2), 21 -> ArrayBuffer(0, 1, 2), 48 -> ArrayBuffer(0, 2, 1), 3 -> ArrayBuffer(0, 1, 2), 12 -> ArrayBuffer(0, 2, 1), 30 -> ArrayBuffer(0, 2, 1), 39 -> ArrayBuffer(0, 1, 2), 15 -> ArrayBuffer(0, 1, 2), 42 -> ArrayBuffer(0, 2, 1), 24 -> ArrayBuffer(0, 2, 1), 6 -> ArrayBuffer(0, 2, 1), 33 -> ArrayBuffer(0, 1, 2), 0 -> ArrayBuffer(0, 2, 1)) (kafka.zk.AdminZkClient) [data-plane-kafka-request-handler-0]
2020-04-20 23:42:14,192 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example-new', partitionIndex=1, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2, 0, 1], zkVersion=0, replicas=[2, 0, 1], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 9 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:42:14,192 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example-new', partitionIndex=4, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2, 1, 0], zkVersion=0, replicas=[2, 1, 0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 9 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:42:14,214 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example-new', partitionIndex=3, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0, 2, 1], zkVersion=0, replicas=[0, 2, 1], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 9 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:42:14,214 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example-new', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0, 1, 2], zkVersion=0, replicas=[0, 1, 2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 9 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:42:14,214 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example-new', partitionIndex=2, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1, 2, 0], zkVersion=0, replicas=[1, 2, 0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 9 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:42:14,218 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 9 from controller 1 epoch 1 starting the become-leader transition for partition topic-example-new-4 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:42:14,218 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 9 from controller 1 epoch 1 starting the become-leader transition for partition topic-example-new-1 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:42:14,219 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example-new-4, topic-example-new-1) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-0]
2020-04-20 23:42:14,227 INFO [Log partition=topic-example-new-4, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-0]
2020-04-20 23:42:14,227 INFO [Log partition=topic-example-new-4, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 2 ms (kafka.log.Log) [data-plane-kafka-request-handler-0]
2020-04-20 23:42:14,228 INFO Created log for partition topic-example-new-4 in /var/lib/kafka/data/kafka-log2/topic-example-new-4 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 3, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-0]
2020-04-20 23:42:14,229 INFO [Partition topic-example-new-4 broker=2] No checkpointed highwatermark is found for partition topic-example-new-4 (kafka.cluster.Partition) [data-plane-kafka-request-handler-0]
2020-04-20 23:42:14,229 INFO [Partition topic-example-new-4 broker=2] Log loaded for partition topic-example-new-4 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-0]
2020-04-20 23:42:14,229 INFO [Partition topic-example-new-4 broker=2] topic-example-new-4 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-0]
2020-04-20 23:42:14,248 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 9 for partition topic-example-new-4 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:42:14,261 INFO [Log partition=topic-example-new-1, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-0]
2020-04-20 23:42:14,261 INFO [Log partition=topic-example-new-1, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 2 ms (kafka.log.Log) [data-plane-kafka-request-handler-0]
2020-04-20 23:42:14,262 INFO Created log for partition topic-example-new-1 in /var/lib/kafka/data/kafka-log2/topic-example-new-1 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 3, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-0]
2020-04-20 23:42:14,262 INFO [Partition topic-example-new-1 broker=2] No checkpointed highwatermark is found for partition topic-example-new-1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-0]
2020-04-20 23:42:14,262 INFO [Partition topic-example-new-1 broker=2] Log loaded for partition topic-example-new-1 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-0]
2020-04-20 23:42:14,262 INFO [Partition topic-example-new-1 broker=2] topic-example-new-1 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-0]
2020-04-20 23:42:34,775 TRACE [Broker id=2] Deleted partition topic-example-new-1 from metadata cache in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 11 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:42:34,775 TRACE [Broker id=2] Deleted partition topic-example-new-4 from metadata cache in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 11 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:42:34,775 TRACE [Broker id=2] Deleted partition topic-example-new-3 from metadata cache in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 11 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:42:34,775 TRACE [Broker id=2] Deleted partition topic-example-new-0 from metadata cache in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 11 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:42:34,775 TRACE [Broker id=2] Deleted partition topic-example-new-2 from metadata cache in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 11 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:42:34,775 INFO [GroupCoordinator 2]: Removed 0 offsets associated with deleted partitions: topic-example-new-1, topic-example-new-4, topic-example-new-3, topic-example-new-0, topic-example-new-2. (kafka.coordinator.group.GroupCoordinator) [data-plane-kafka-request-handler-2]
2020-04-20 23:42:34,844 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example-new-2, topic-example-new-3, topic-example-new-0, topic-example-new-1, topic-example-new-4) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-3]
2020-04-20 23:42:34,844 INFO [ReplicaAlterLogDirsManager on broker 2] Removed fetcher for partitions Set(topic-example-new-2, topic-example-new-3, topic-example-new-0, topic-example-new-1, topic-example-new-4) (kafka.server.ReplicaAlterLogDirsManager) [data-plane-kafka-request-handler-3]
2020-04-20 23:42:34,844 TRACE [Broker id=2] Handling stop replica (delete=false) for partition topic-example-new-2 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:42:34,844 TRACE [Broker id=2] Finished handling stop replica (delete=false) for partition topic-example-new-2 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:42:34,844 TRACE [Broker id=2] Handling stop replica (delete=false) for partition topic-example-new-3 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:42:34,844 TRACE [Broker id=2] Finished handling stop replica (delete=false) for partition topic-example-new-3 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:42:34,844 TRACE [Broker id=2] Handling stop replica (delete=false) for partition topic-example-new-0 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:42:34,844 TRACE [Broker id=2] Finished handling stop replica (delete=false) for partition topic-example-new-0 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:42:34,844 TRACE [Broker id=2] Handling stop replica (delete=false) for partition topic-example-new-1 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:42:34,844 TRACE [Broker id=2] Finished handling stop replica (delete=false) for partition topic-example-new-1 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:42:34,844 TRACE [Broker id=2] Handling stop replica (delete=false) for partition topic-example-new-4 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:42:34,844 TRACE [Broker id=2] Finished handling stop replica (delete=false) for partition topic-example-new-4 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:42:34,864 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example-new-2, topic-example-new-3, topic-example-new-0, topic-example-new-1, topic-example-new-4) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-6]
2020-04-20 23:42:34,865 INFO [ReplicaAlterLogDirsManager on broker 2] Removed fetcher for partitions Set(topic-example-new-2, topic-example-new-3, topic-example-new-0, topic-example-new-1, topic-example-new-4) (kafka.server.ReplicaAlterLogDirsManager) [data-plane-kafka-request-handler-6]
2020-04-20 23:42:34,865 TRACE [Broker id=2] Handling stop replica (delete=true) for partition topic-example-new-2 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:42:34,866 INFO The cleaning for partition topic-example-new-2 is aborted and paused (kafka.log.LogCleaner) [data-plane-kafka-request-handler-6]
2020-04-20 23:42:34,866 INFO The cleaning for partition topic-example-new-2 is aborted (kafka.log.LogCleaner) [data-plane-kafka-request-handler-6]
2020-04-20 23:42:34,878 INFO Log for partition topic-example-new-2 is renamed to /var/lib/kafka/data/kafka-log2/topic-example-new-2.4d335b4397d6470c8d1ee528d5ef3088-delete and is scheduled for deletion (kafka.log.LogManager) [data-plane-kafka-request-handler-6]
2020-04-20 23:42:34,878 TRACE [Broker id=2] Finished handling stop replica (delete=true) for partition topic-example-new-2 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:42:34,879 TRACE [Broker id=2] Handling stop replica (delete=true) for partition topic-example-new-3 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:42:34,880 INFO The cleaning for partition topic-example-new-3 is aborted and paused (kafka.log.LogCleaner) [data-plane-kafka-request-handler-6]
2020-04-20 23:42:34,880 INFO The cleaning for partition topic-example-new-3 is aborted (kafka.log.LogCleaner) [data-plane-kafka-request-handler-6]
2020-04-20 23:42:34,898 INFO Log for partition topic-example-new-3 is renamed to /var/lib/kafka/data/kafka-log2/topic-example-new-3.821728d138be4f589576c5e1f844f83e-delete and is scheduled for deletion (kafka.log.LogManager) [data-plane-kafka-request-handler-6]
2020-04-20 23:42:34,898 TRACE [Broker id=2] Finished handling stop replica (delete=true) for partition topic-example-new-3 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:42:34,898 TRACE [Broker id=2] Handling stop replica (delete=true) for partition topic-example-new-0 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:42:34,899 INFO The cleaning for partition topic-example-new-0 is aborted and paused (kafka.log.LogCleaner) [data-plane-kafka-request-handler-6]
2020-04-20 23:42:34,899 INFO The cleaning for partition topic-example-new-0 is aborted (kafka.log.LogCleaner) [data-plane-kafka-request-handler-6]
2020-04-20 23:42:34,936 INFO Log for partition topic-example-new-0 is renamed to /var/lib/kafka/data/kafka-log2/topic-example-new-0.576147f88ff547d9800021c8648344f7-delete and is scheduled for deletion (kafka.log.LogManager) [data-plane-kafka-request-handler-6]
2020-04-20 23:42:34,937 TRACE [Broker id=2] Finished handling stop replica (delete=true) for partition topic-example-new-0 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:42:34,937 TRACE [Broker id=2] Handling stop replica (delete=true) for partition topic-example-new-1 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:42:34,937 INFO The cleaning for partition topic-example-new-1 is aborted and paused (kafka.log.LogCleaner) [data-plane-kafka-request-handler-6]
2020-04-20 23:42:34,938 INFO The cleaning for partition topic-example-new-1 is aborted (kafka.log.LogCleaner) [data-plane-kafka-request-handler-6]
2020-04-20 23:42:34,960 INFO Log for partition topic-example-new-1 is renamed to /var/lib/kafka/data/kafka-log2/topic-example-new-1.a5287cddc38140b0be186b487ef2b76c-delete and is scheduled for deletion (kafka.log.LogManager) [data-plane-kafka-request-handler-6]
2020-04-20 23:42:59,605 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example0', partitionIndex=1, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 18 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:59,606 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 18 from controller 1 epoch 1 starting the become-leader transition for partition topic-example0-1 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:59,606 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example0-1) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:59,620 INFO [Log partition=topic-example0-1, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:59,620 INFO [Log partition=topic-example0-1, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 3 ms (kafka.log.Log) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:59,621 INFO Created log for partition topic-example0-1 in /var/lib/kafka/data/kafka-log2/topic-example0-1 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:59,626 INFO [Partition topic-example0-1 broker=2] No checkpointed highwatermark is found for partition topic-example0-1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:59,626 INFO [Partition topic-example0-1 broker=2] Log loaded for partition topic-example0-1 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:59,626 INFO [Partition topic-example0-1 broker=2] topic-example0-1 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:59,629 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 18 for partition topic-example0-1 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:59,629 TRACE [Broker id=2] Completed LeaderAndIsr request correlationId 18 from controller 1 epoch 1 for the become-leader transition for partition topic-example0-1 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:59,644 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example0', partitionIndex=2, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example0-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 19 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:42:59,646 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example0', partitionIndex=1, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example0-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 19 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:42:59,646 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example0', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example0-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 19 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:43:26,487 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 348 for partition topic-example170-0 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:43:26,487 TRACE [Broker id=2] Completed LeaderAndIsr request correlationId 348 from controller 1 epoch 1 for the become-leader transition for partition topic-example170-0 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:43:26,491 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example170', partitionIndex=0, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example170-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 349 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:43:26,491 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example170', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example170-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 349 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:43:26,491 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example170', partitionIndex=1, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example170-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 349 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:43:26,600 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example171', partitionIndex=2, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 350 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:43:26,601 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 350 from controller 1 epoch 1 starting the become-leader transition for partition topic-example171-2 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:43:26,601 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example171-2) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-1]
2020-04-20 23:43:26,639 INFO [Log partition=topic-example171-2, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-1]
2020-04-20 23:43:26,639 INFO [Log partition=topic-example171-2, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 2 ms (kafka.log.Log) [data-plane-kafka-request-handler-1]
2020-04-20 23:43:26,640 INFO Created log for partition topic-example171-2 in /var/lib/kafka/data/kafka-log2/topic-example171-2 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-1]
2020-04-20 23:43:26,640 INFO [Partition topic-example171-2 broker=2] No checkpointed highwatermark is found for partition topic-example171-2 (kafka.cluster.Partition) [data-plane-kafka-request-handler-1]
2020-04-20 23:43:26,641 INFO [Partition topic-example171-2 broker=2] Log loaded for partition topic-example171-2 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-1]
2020-04-20 23:43:26,641 INFO [Partition topic-example171-2 broker=2] topic-example171-2 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-1]
2020-04-20 23:43:26,642 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 350 for partition topic-example171-2 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:43:26,642 TRACE [Broker id=2] Completed LeaderAndIsr request correlationId 350 from controller 1 epoch 1 for the become-leader transition for partition topic-example171-2 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:43:26,647 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example171', partitionIndex=1, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example171-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 351 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:43:26,647 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example171', partitionIndex=0, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example171-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 351 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:43:26,647 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example171', partitionIndex=2, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example171-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 351 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:43:26,738 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example172', partitionIndex=1, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 352 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:43:26,739 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 352 from controller 1 epoch 1 starting the become-leader transition for partition topic-example172-1 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:43:26,739 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example172-1) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-0]
2020-04-20 23:43:26,752 INFO [Log partition=topic-example172-1, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-0]
2020-04-20 23:43:26,753 INFO [Log partition=topic-example172-1, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 2 ms (kafka.log.Log) [data-plane-kafka-request-handler-0]
2020-04-20 23:43:26,753 INFO Created log for partition topic-example172-1 in /var/lib/kafka/data/kafka-log2/topic-example172-1 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-0]
2020-04-20 23:43:26,755 INFO [Partition topic-example172-1 broker=2] No checkpointed highwatermark is found for partition topic-example172-1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-0]
2020-04-20 23:43:26,755 INFO [Partition topic-example172-1 broker=2] Log loaded for partition topic-example172-1 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-0]
2020-04-20 23:43:26,755 INFO [Partition topic-example172-1 broker=2] topic-example172-1 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-0]
2020-04-20 23:43:26,764 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 352 for partition topic-example172-1 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:43:26,764 TRACE [Broker id=2] Completed LeaderAndIsr request correlationId 352 from controller 1 epoch 1 for the become-leader transition for partition topic-example172-1 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:43:26,791 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example172', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example172-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 353 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:43:26,791 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example172', partitionIndex=2, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example172-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 353 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:43:26,791 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example172', partitionIndex=1, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example172-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 353 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:43:26,915 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example173', partitionIndex=2, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 354 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:43:26,916 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 354 from controller 1 epoch 1 starting the become-leader transition for partition topic-example173-2 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:43:26,916 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example173-2) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-3]
2020-04-20 23:43:26,924 INFO [Log partition=topic-example173-2, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-3]
2020-04-20 23:43:26,924 INFO [Log partition=topic-example173-2, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 3 ms (kafka.log.Log) [data-plane-kafka-request-handler-3]
2020-04-20 23:43:26,924 INFO Created log for partition topic-example173-2 in /var/lib/kafka/data/kafka-log2/topic-example173-2 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-3]
2020-04-20 23:43:26,925 INFO [Partition topic-example173-2 broker=2] No checkpointed highwatermark is found for partition topic-example173-2 (kafka.cluster.Partition) [data-plane-kafka-request-handler-3]
2020-04-20 23:43:26,925 INFO [Partition topic-example173-2 broker=2] Log loaded for partition topic-example173-2 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-3]
2020-04-20 23:43:26,925 INFO [Partition topic-example173-2 broker=2] topic-example173-2 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-3]
2020-04-20 23:43:26,927 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 354 for partition topic-example173-2 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:43:26,927 TRACE [Broker id=2] Completed LeaderAndIsr request correlationId 354 from controller 1 epoch 1 for the become-leader transition for partition topic-example173-2 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:43:26,935 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example173', partitionIndex=2, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example173-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 355 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:26,935 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example173', partitionIndex=1, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example173-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 355 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:26,935 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example173', partitionIndex=0, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example173-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 355 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:56,489 INFO Created log for partition topic-example394-2 in /var/lib/kafka/data/kafka-log2/topic-example394-2 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-7]
2020-04-20 23:43:56,490 INFO [Partition topic-example394-2 broker=2] No checkpointed highwatermark is found for partition topic-example394-2 (kafka.cluster.Partition) [data-plane-kafka-request-handler-7]
2020-04-20 23:43:56,490 INFO [Partition topic-example394-2 broker=2] Log loaded for partition topic-example394-2 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-7]
2020-04-20 23:43:56,490 INFO [Partition topic-example394-2 broker=2] topic-example394-2 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-7]
2020-04-20 23:43:56,493 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 790 for partition topic-example394-2 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:43:56,493 TRACE [Broker id=2] Completed LeaderAndIsr request correlationId 790 from controller 1 epoch 1 for the become-leader transition for partition topic-example394-2 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:43:56,497 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example394', partitionIndex=0, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example394-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 791 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:43:56,497 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example394', partitionIndex=2, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example394-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 791 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:43:56,497 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example394', partitionIndex=1, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example394-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 791 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:43:56,542 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example397', partitionIndex=1, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 792 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:56,543 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 792 from controller 1 epoch 1 starting the become-leader transition for partition topic-example397-1 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:56,543 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example397-1) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:56,557 INFO [Log partition=topic-example397-1, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:56,558 INFO [Log partition=topic-example397-1, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 2 ms (kafka.log.Log) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:56,558 INFO Created log for partition topic-example397-1 in /var/lib/kafka/data/kafka-log2/topic-example397-1 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:56,559 INFO [Partition topic-example397-1 broker=2] No checkpointed highwatermark is found for partition topic-example397-1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:56,559 INFO [Partition topic-example397-1 broker=2] Log loaded for partition topic-example397-1 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:56,560 INFO [Partition topic-example397-1 broker=2] topic-example397-1 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:56,563 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 792 for partition topic-example397-1 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:56,563 TRACE [Broker id=2] Completed LeaderAndIsr request correlationId 792 from controller 1 epoch 1 for the become-leader transition for partition topic-example397-1 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:56,578 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example397', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example397-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 793 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:43:56,578 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example397', partitionIndex=2, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example397-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 793 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:43:56,578 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example397', partitionIndex=1, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example397-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 793 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:43:56,745 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example396', partitionIndex=1, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 794 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:43:56,746 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 794 from controller 1 epoch 1 starting the become-leader transition for partition topic-example396-1 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:43:56,746 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example396-1) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-7]
2020-04-20 23:43:56,759 INFO [Log partition=topic-example396-1, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-7]
2020-04-20 23:43:56,759 INFO [Log partition=topic-example396-1, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 2 ms (kafka.log.Log) [data-plane-kafka-request-handler-7]
2020-04-20 23:43:56,760 INFO Created log for partition topic-example396-1 in /var/lib/kafka/data/kafka-log2/topic-example396-1 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-7]
2020-04-20 23:43:56,761 INFO [Partition topic-example396-1 broker=2] No checkpointed highwatermark is found for partition topic-example396-1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-7]
2020-04-20 23:43:56,761 INFO [Partition topic-example396-1 broker=2] Log loaded for partition topic-example396-1 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-7]
2020-04-20 23:43:56,761 INFO [Partition topic-example396-1 broker=2] topic-example396-1 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-7]
2020-04-20 23:43:56,769 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 794 for partition topic-example396-1 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:43:56,769 TRACE [Broker id=2] Completed LeaderAndIsr request correlationId 794 from controller 1 epoch 1 for the become-leader transition for partition topic-example396-1 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:43:56,777 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example396', partitionIndex=1, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example396-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 795 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:43:56,777 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example396', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example396-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 795 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:43:56,777 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example396', partitionIndex=2, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example396-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 795 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:43:56,855 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example398', partitionIndex=1, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 796 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:43:56,856 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 796 from controller 1 epoch 1 starting the become-leader transition for partition topic-example398-1 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:43:56,856 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example398-1) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-3]
2020-04-20 23:43:56,861 INFO [Log partition=topic-example398-1, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-3]
2020-04-20 23:43:56,862 INFO [Log partition=topic-example398-1, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 2 ms (kafka.log.Log) [data-plane-kafka-request-handler-3]
2020-04-20 23:43:56,862 INFO Created log for partition topic-example398-1 in /var/lib/kafka/data/kafka-log2/topic-example398-1 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-3]
2020-04-20 23:43:56,863 INFO [Partition topic-example398-1 broker=2] No checkpointed highwatermark is found for partition topic-example398-1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-3]
2020-04-20 23:43:56,863 INFO [Partition topic-example398-1 broker=2] Log loaded for partition topic-example398-1 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-3]
2020-04-20 23:43:56,863 INFO [Partition topic-example398-1 broker=2] topic-example398-1 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-3]
2020-04-20 23:43:56,865 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 796 for partition topic-example398-1 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:43:56,865 TRACE [Broker id=2] Completed LeaderAndIsr request correlationId 796 from controller 1 epoch 1 for the become-leader transition for partition topic-example398-1 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:43:56,903 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example398', partitionIndex=2, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example398-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 797 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:43:56,903 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example398', partitionIndex=1, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example398-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 797 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:43:56,904 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example398', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example398-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 797 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:43:57,038 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example399', partitionIndex=1, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 798 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:43:57,039 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 798 from controller 1 epoch 1 starting the become-leader transition for partition topic-example399-1 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:43:57,039 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example399-1) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-7]
2020-04-20 23:43:57,046 INFO [Log partition=topic-example399-1, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-7]
2020-04-20 23:43:57,046 INFO [Log partition=topic-example399-1, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 2 ms (kafka.log.Log) [data-plane-kafka-request-handler-7]
2020-04-20 23:43:57,046 INFO Created log for partition topic-example399-1 in /var/lib/kafka/data/kafka-log2/topic-example399-1 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-7]
2020-04-20 23:43:57,047 INFO [Partition topic-example399-1 broker=2] No checkpointed highwatermark is found for partition topic-example399-1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-7]
2020-04-20 23:43:57,047 INFO [Partition topic-example399-1 broker=2] Log loaded for partition topic-example399-1 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-7]
2020-04-20 23:43:57,047 INFO [Partition topic-example399-1 broker=2] topic-example399-1 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-7]
2020-04-20 23:44:26,498 INFO [Log partition=topic-example602-0, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-4]
2020-04-20 23:44:26,498 INFO [Log partition=topic-example602-0, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 2 ms (kafka.log.Log) [data-plane-kafka-request-handler-4]
2020-04-20 23:44:26,498 INFO Created log for partition topic-example602-0 in /var/lib/kafka/data/kafka-log2/topic-example602-0 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-4]
2020-04-20 23:44:26,500 INFO [Partition topic-example602-0 broker=2] No checkpointed highwatermark is found for partition topic-example602-0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-4]
2020-04-20 23:44:26,500 INFO [Partition topic-example602-0 broker=2] Log loaded for partition topic-example602-0 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-4]
2020-04-20 23:44:26,500 INFO [Partition topic-example602-0 broker=2] topic-example602-0 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-4]
2020-04-20 23:44:26,510 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 1208 for partition topic-example602-0 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:44:26,510 TRACE [Broker id=2] Completed LeaderAndIsr request correlationId 1208 from controller 1 epoch 1 for the become-leader transition for partition topic-example602-0 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:44:26,514 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example602', partitionIndex=0, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example602-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 1209 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:44:26,514 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example602', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example602-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 1209 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:44:26,514 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example602', partitionIndex=1, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example602-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 1209 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:44:26,704 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example603', partitionIndex=1, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 1210 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:44:26,704 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 1210 from controller 1 epoch 1 starting the become-leader transition for partition topic-example603-1 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:44:26,705 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example603-1) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-5]
2020-04-20 23:44:26,708 INFO [Log partition=topic-example603-1, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-5]
2020-04-20 23:44:26,709 INFO [Log partition=topic-example603-1, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 2 ms (kafka.log.Log) [data-plane-kafka-request-handler-5]
2020-04-20 23:44:26,709 INFO Created log for partition topic-example603-1 in /var/lib/kafka/data/kafka-log2/topic-example603-1 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-5]
2020-04-20 23:44:26,711 INFO [Partition topic-example603-1 broker=2] No checkpointed highwatermark is found for partition topic-example603-1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-5]
2020-04-20 23:44:26,711 INFO [Partition topic-example603-1 broker=2] Log loaded for partition topic-example603-1 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-5]
2020-04-20 23:44:26,711 INFO [Partition topic-example603-1 broker=2] topic-example603-1 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-5]
2020-04-20 23:44:26,719 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 1210 for partition topic-example603-1 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:44:26,719 TRACE [Broker id=2] Completed LeaderAndIsr request correlationId 1210 from controller 1 epoch 1 for the become-leader transition for partition topic-example603-1 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:44:26,725 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example603', partitionIndex=2, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example603-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 1211 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:44:26,725 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example603', partitionIndex=1, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example603-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 1211 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:44:26,725 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example603', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example603-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 1211 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:44:26,908 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example604', partitionIndex=1, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 1212 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:44:26,908 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 1212 from controller 1 epoch 1 starting the become-leader transition for partition topic-example604-1 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:44:26,908 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example604-1) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-2]
2020-04-20 23:44:26,924 INFO [Log partition=topic-example604-1, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-2]
2020-04-20 23:44:26,925 INFO [Log partition=topic-example604-1, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 2 ms (kafka.log.Log) [data-plane-kafka-request-handler-2]
2020-04-20 23:44:26,925 INFO Created log for partition topic-example604-1 in /var/lib/kafka/data/kafka-log2/topic-example604-1 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-2]
2020-04-20 23:44:26,926 INFO [Partition topic-example604-1 broker=2] No checkpointed highwatermark is found for partition topic-example604-1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-2]
2020-04-20 23:44:26,926 INFO [Partition topic-example604-1 broker=2] Log loaded for partition topic-example604-1 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-2]
2020-04-20 23:44:26,927 INFO [Partition topic-example604-1 broker=2] topic-example604-1 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-2]
2020-04-20 23:44:26,928 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 1212 for partition topic-example604-1 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:44:26,928 TRACE [Broker id=2] Completed LeaderAndIsr request correlationId 1212 from controller 1 epoch 1 for the become-leader transition for partition topic-example604-1 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:44:26,932 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example604', partitionIndex=1, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example604-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 1213 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:44:26,932 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example604', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example604-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 1213 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:44:26,932 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example604', partitionIndex=2, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example604-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 1213 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:44:56,515 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example817', partitionIndex=1, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 1628 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:44:56,516 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 1628 from controller 1 epoch 1 starting the become-leader transition for partition topic-example817-1 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:44:56,516 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example817-1) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-5]
2020-04-20 23:44:56,525 INFO [Log partition=topic-example817-1, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-5]
2020-04-20 23:44:56,526 INFO [Log partition=topic-example817-1, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 3 ms (kafka.log.Log) [data-plane-kafka-request-handler-5]
2020-04-20 23:44:56,526 INFO Created log for partition topic-example817-1 in /var/lib/kafka/data/kafka-log2/topic-example817-1 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-5]
2020-04-20 23:44:56,528 INFO [Partition topic-example817-1 broker=2] No checkpointed highwatermark is found for partition topic-example817-1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-5]
2020-04-20 23:44:56,528 INFO [Partition topic-example817-1 broker=2] Log loaded for partition topic-example817-1 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-5]
2020-04-20 23:44:56,528 INFO [Partition topic-example817-1 broker=2] topic-example817-1 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-5]
2020-04-20 23:44:56,529 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 1628 for partition topic-example817-1 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:44:56,529 TRACE [Broker id=2] Completed LeaderAndIsr request correlationId 1628 from controller 1 epoch 1 for the become-leader transition for partition topic-example817-1 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:44:56,565 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example817', partitionIndex=1, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example817-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 1629 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:44:56,565 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example817', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example817-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 1629 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:44:56,565 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example817', partitionIndex=2, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example817-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 1629 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:44:56,625 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example818', partitionIndex=2, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 1630 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:44:56,626 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 1630 from controller 1 epoch 1 starting the become-leader transition for partition topic-example818-2 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:44:56,626 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example818-2) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-1]
2020-04-20 23:44:56,629 INFO [Log partition=topic-example818-2, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-1]
2020-04-20 23:44:56,630 INFO [Log partition=topic-example818-2, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 2 ms (kafka.log.Log) [data-plane-kafka-request-handler-1]
2020-04-20 23:44:56,630 INFO Created log for partition topic-example818-2 in /var/lib/kafka/data/kafka-log2/topic-example818-2 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-1]
2020-04-20 23:44:56,631 INFO [Partition topic-example818-2 broker=2] No checkpointed highwatermark is found for partition topic-example818-2 (kafka.cluster.Partition) [data-plane-kafka-request-handler-1]
2020-04-20 23:44:56,631 INFO [Partition topic-example818-2 broker=2] Log loaded for partition topic-example818-2 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-1]
2020-04-20 23:44:56,631 INFO [Partition topic-example818-2 broker=2] topic-example818-2 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-1]
2020-04-20 23:44:56,633 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 1630 for partition topic-example818-2 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:44:56,633 TRACE [Broker id=2] Completed LeaderAndIsr request correlationId 1630 from controller 1 epoch 1 for the become-leader transition for partition topic-example818-2 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:44:56,643 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example818', partitionIndex=0, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example818-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 1631 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:44:56,643 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example818', partitionIndex=2, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example818-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 1631 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:44:56,643 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example818', partitionIndex=1, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example818-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 1631 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:45:26,246 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1272', partitionIndex=0, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 2006 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:45:26,247 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 2006 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1272-0 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:45:26,247 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example1272-0) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-7]
2020-04-20 23:45:26,281 INFO [Log partition=topic-example1272-0, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-7]
2020-04-20 23:45:26,281 INFO [Log partition=topic-example1272-0, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 1 ms (kafka.log.Log) [data-plane-kafka-request-handler-7]
2020-04-20 23:45:26,282 INFO Created log for partition topic-example1272-0 in /var/lib/kafka/data/kafka-log2/topic-example1272-0 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-7]
2020-04-20 23:45:26,307 INFO [Partition topic-example1272-0 broker=2] No checkpointed highwatermark is found for partition topic-example1272-0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-7]
2020-04-20 23:45:26,307 INFO [Partition topic-example1272-0 broker=2] Log loaded for partition topic-example1272-0 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-7]
2020-04-20 23:45:26,307 INFO [Partition topic-example1272-0 broker=2] topic-example1272-0 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-7]
2020-04-20 23:45:26,310 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 2006 for partition topic-example1272-0 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:45:26,310 TRACE [Broker id=2] Completed LeaderAndIsr request correlationId 2006 from controller 1 epoch 1 for the become-leader transition for partition topic-example1272-0 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:45:26,321 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1272', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example1272-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2007 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:45:26,321 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1272', partitionIndex=1, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example1272-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2007 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:45:26,321 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1272', partitionIndex=0, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example1272-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2007 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:45:26,373 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1277', partitionIndex=0, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 2008 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:45:26,374 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 2008 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1277-0 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:45:26,374 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example1277-0) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-4]
2020-04-20 23:45:26,392 INFO [Log partition=topic-example1277-0, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-4]
2020-04-20 23:45:26,392 INFO [Log partition=topic-example1277-0, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 1 ms (kafka.log.Log) [data-plane-kafka-request-handler-4]
2020-04-20 23:45:26,393 INFO Created log for partition topic-example1277-0 in /var/lib/kafka/data/kafka-log2/topic-example1277-0 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-4]
2020-04-20 23:45:26,394 INFO [Partition topic-example1277-0 broker=2] No checkpointed highwatermark is found for partition topic-example1277-0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-4]
2020-04-20 23:45:26,394 INFO [Partition topic-example1277-0 broker=2] Log loaded for partition topic-example1277-0 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-4]
2020-04-20 23:45:26,394 INFO [Partition topic-example1277-0 broker=2] topic-example1277-0 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-4]
2020-04-20 23:45:26,397 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 2008 for partition topic-example1277-0 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:45:26,397 TRACE [Broker id=2] Completed LeaderAndIsr request correlationId 2008 from controller 1 epoch 1 for the become-leader transition for partition topic-example1277-0 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:45:26,403 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1277', partitionIndex=0, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example1277-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2009 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:45:26,403 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1277', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example1277-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2009 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:45:26,403 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1277', partitionIndex=1, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example1277-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2009 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:45:26,669 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1285', partitionIndex=2, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 2010 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:45:26,669 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 2010 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1285-2 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:45:26,669 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example1285-2) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:26,571 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1142', partitionIndex=0, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 2572 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:47:26,571 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 2572 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1142-0 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:47:26,571 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example1142-0) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-6]
2020-04-20 23:47:26,574 INFO [Log partition=topic-example1142-0, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-6]
2020-04-20 23:47:26,574 INFO [Log partition=topic-example1142-0, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 1 ms (kafka.log.Log) [data-plane-kafka-request-handler-6]
2020-04-20 23:47:26,574 INFO Created log for partition topic-example1142-0 in /var/lib/kafka/data/kafka-log2/topic-example1142-0 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-6]
2020-04-20 23:47:26,576 INFO [Partition topic-example1142-0 broker=2] No checkpointed highwatermark is found for partition topic-example1142-0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-6]
2020-04-20 23:47:26,576 INFO [Partition topic-example1142-0 broker=2] Log loaded for partition topic-example1142-0 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-6]
2020-04-20 23:47:26,576 INFO [Partition topic-example1142-0 broker=2] topic-example1142-0 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-6]
2020-04-20 23:47:26,578 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 2572 for partition topic-example1142-0 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:47:26,578 TRACE [Broker id=2] Completed LeaderAndIsr request correlationId 2572 from controller 1 epoch 1 for the become-leader transition for partition topic-example1142-0 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:47:26,606 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1142', partitionIndex=0, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example1142-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2573 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:47:26,606 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1142', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example1142-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2573 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:47:26,606 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1142', partitionIndex=1, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example1142-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2573 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:47:26,679 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1143', partitionIndex=2, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 2574 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:47:26,679 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 2574 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1143-2 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:47:26,679 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example1143-2) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-4]
2020-04-20 23:47:26,695 INFO [Log partition=topic-example1143-2, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-4]
2020-04-20 23:47:26,696 INFO [Log partition=topic-example1143-2, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 1 ms (kafka.log.Log) [data-plane-kafka-request-handler-4]
2020-04-20 23:47:26,696 INFO Created log for partition topic-example1143-2 in /var/lib/kafka/data/kafka-log2/topic-example1143-2 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-4]
2020-04-20 23:47:26,702 INFO [Partition topic-example1143-2 broker=2] No checkpointed highwatermark is found for partition topic-example1143-2 (kafka.cluster.Partition) [data-plane-kafka-request-handler-4]
2020-04-20 23:47:26,702 INFO [Partition topic-example1143-2 broker=2] Log loaded for partition topic-example1143-2 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-4]
2020-04-20 23:47:26,702 INFO [Partition topic-example1143-2 broker=2] topic-example1143-2 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-4]
2020-04-20 23:47:26,716 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 2574 for partition topic-example1143-2 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:47:26,716 TRACE [Broker id=2] Completed LeaderAndIsr request correlationId 2574 from controller 1 epoch 1 for the become-leader transition for partition topic-example1143-2 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:47:26,723 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1143', partitionIndex=2, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example1143-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2575 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:47:26,723 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1143', partitionIndex=1, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example1143-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2575 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:47:26,723 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1143', partitionIndex=0, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example1143-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2575 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:47:26,769 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1144', partitionIndex=0, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 2576 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:26,770 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 2576 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1144-0 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:26,770 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example1144-0) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:26,782 INFO [Log partition=topic-example1144-0, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:26,782 INFO [Log partition=topic-example1144-0, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 2 ms (kafka.log.Log) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:26,783 INFO Created log for partition topic-example1144-0 in /var/lib/kafka/data/kafka-log2/topic-example1144-0 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:26,786 INFO [Partition topic-example1144-0 broker=2] No checkpointed highwatermark is found for partition topic-example1144-0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:26,786 INFO [Partition topic-example1144-0 broker=2] Log loaded for partition topic-example1144-0 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:26,786 INFO [Partition topic-example1144-0 broker=2] topic-example1144-0 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:26,789 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 2576 for partition topic-example1144-0 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:26,789 TRACE [Broker id=2] Completed LeaderAndIsr request correlationId 2576 from controller 1 epoch 1 for the become-leader transition for partition topic-example1144-0 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:26,804 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1144', partitionIndex=1, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example1144-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2577 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:26,804 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1144', partitionIndex=0, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example1144-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2577 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:26,804 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1144', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example1144-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2577 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:26,902 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1145', partitionIndex=0, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 2578 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:47:26,902 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 2578 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1145-0 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:47:26,902 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example1145-0) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-3]
2020-04-20 23:47:26,905 INFO [Log partition=topic-example1145-0, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-3]
2020-04-20 23:47:26,905 INFO [Log partition=topic-example1145-0, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 1 ms (kafka.log.Log) [data-plane-kafka-request-handler-3]
2020-04-20 23:47:26,906 INFO Created log for partition topic-example1145-0 in /var/lib/kafka/data/kafka-log2/topic-example1145-0 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-3]
2020-04-20 23:47:26,909 INFO [Partition topic-example1145-0 broker=2] No checkpointed highwatermark is found for partition topic-example1145-0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-3]
2020-04-20 23:47:26,909 INFO [Partition topic-example1145-0 broker=2] Log loaded for partition topic-example1145-0 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-3]
2020-04-20 23:47:26,909 INFO [Partition topic-example1145-0 broker=2] topic-example1145-0 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-3]
2020-04-20 23:47:26,912 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 2578 for partition topic-example1145-0 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:47:26,912 TRACE [Broker id=2] Completed LeaderAndIsr request correlationId 2578 from controller 1 epoch 1 for the become-leader transition for partition topic-example1145-0 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:47:26,918 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1145', partitionIndex=0, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example1145-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2579 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:26,918 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1145', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example1145-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2579 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:26,918 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1145', partitionIndex=1, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example1145-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2579 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:26,966 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1146', partitionIndex=1, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 2580 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:26,967 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 2580 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1146-1 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:26,967 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example1146-1) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:26,975 INFO [Log partition=topic-example1146-1, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:26,994 INFO [Log partition=topic-example1146-1, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 20 ms (kafka.log.Log) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:26,994 INFO Created log for partition topic-example1146-1 in /var/lib/kafka/data/kafka-log2/topic-example1146-1 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:27,007 INFO [Partition topic-example1146-1 broker=2] No checkpointed highwatermark is found for partition topic-example1146-1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:27,007 INFO [Partition topic-example1146-1 broker=2] Log loaded for partition topic-example1146-1 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:27,007 INFO [Partition topic-example1146-1 broker=2] topic-example1146-1 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:27,011 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 2580 for partition topic-example1146-1 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:27,011 TRACE [Broker id=2] Completed LeaderAndIsr request correlationId 2580 from controller 1 epoch 1 for the become-leader transition for partition topic-example1146-1 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:27,021 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1146', partitionIndex=2, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example1146-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2581 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:47:27,021 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1146', partitionIndex=1, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example1146-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2581 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:47:27,021 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1146', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example1146-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2581 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:47:27,067 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1147', partitionIndex=0, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 2582 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:27,068 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 2582 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1147-0 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:27,068 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example1147-0) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:27,088 INFO [Log partition=topic-example1147-0, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:27,088 INFO [Log partition=topic-example1147-0, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 2 ms (kafka.log.Log) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:27,088 INFO Created log for partition topic-example1147-0 in /var/lib/kafka/data/kafka-log2/topic-example1147-0 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:27,091 INFO [Partition topic-example1147-0 broker=2] No checkpointed highwatermark is found for partition topic-example1147-0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:27,091 INFO [Partition topic-example1147-0 broker=2] Log loaded for partition topic-example1147-0 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:27,091 INFO [Partition topic-example1147-0 broker=2] topic-example1147-0 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:27,099 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 2582 for partition topic-example1147-0 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:27,099 TRACE [Broker id=2] Completed LeaderAndIsr request correlationId 2582 from controller 1 epoch 1 for the become-leader transition for partition topic-example1147-0 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:27,108 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1147', partitionIndex=1, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example1147-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2583 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:27,108 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1147', partitionIndex=0, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example1147-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2583 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:27,108 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1147', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example1147-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2583 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:27,194 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1149', partitionIndex=0, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 2584 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:27,195 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 2584 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1149-0 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:27,195 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example1149-0) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:27,212 INFO [Log partition=topic-example1149-0, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:27,212 INFO [Log partition=topic-example1149-0, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 1 ms (kafka.log.Log) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:27,212 INFO Created log for partition topic-example1149-0 in /var/lib/kafka/data/kafka-log2/topic-example1149-0 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:27,214 INFO [Partition topic-example1149-0 broker=2] No checkpointed highwatermark is found for partition topic-example1149-0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:27,214 INFO [Partition topic-example1149-0 broker=2] Log loaded for partition topic-example1149-0 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:27,214 INFO [Partition topic-example1149-0 broker=2] topic-example1149-0 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:27,216 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 2584 for partition topic-example1149-0 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:27,216 TRACE [Broker id=2] Completed LeaderAndIsr request correlationId 2584 from controller 1 epoch 1 for the become-leader transition for partition topic-example1149-0 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:27,251 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1149', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example1149-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2585 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:27,251 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1149', partitionIndex=1, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example1149-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2585 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:27,251 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1149', partitionIndex=0, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example1149-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2585 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:56,534 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1345', partitionIndex=0, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 2922 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:56,535 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 2922 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1345-0 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:56,535 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example1345-0) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:56,550 INFO [Log partition=topic-example1345-0, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:56,550 INFO [Log partition=topic-example1345-0, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 1 ms (kafka.log.Log) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:56,550 INFO Created log for partition topic-example1345-0 in /var/lib/kafka/data/kafka-log2/topic-example1345-0 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:56,552 INFO [Partition topic-example1345-0 broker=2] No checkpointed highwatermark is found for partition topic-example1345-0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:56,552 INFO [Partition topic-example1345-0 broker=2] Log loaded for partition topic-example1345-0 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:56,552 INFO [Partition topic-example1345-0 broker=2] topic-example1345-0 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:56,574 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 2922 for partition topic-example1345-0 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:56,574 TRACE [Broker id=2] Completed LeaderAndIsr request correlationId 2922 from controller 1 epoch 1 for the become-leader transition for partition topic-example1345-0 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:56,588 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1345', partitionIndex=1, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example1345-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2923 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:56,588 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1345', partitionIndex=0, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example1345-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2923 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:56,588 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1345', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example1345-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2923 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:56,655 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1347', partitionIndex=1, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 2924 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:47:56,655 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 2924 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1347-1 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:47:56,655 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example1347-1) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-3]
2020-04-20 23:47:56,671 INFO [Log partition=topic-example1347-1, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-3]
2020-04-20 23:47:56,671 INFO [Log partition=topic-example1347-1, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 2 ms (kafka.log.Log) [data-plane-kafka-request-handler-3]
2020-04-20 23:47:56,671 INFO Created log for partition topic-example1347-1 in /var/lib/kafka/data/kafka-log2/topic-example1347-1 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-3]
2020-04-20 23:47:56,674 INFO [Partition topic-example1347-1 broker=2] No checkpointed highwatermark is found for partition topic-example1347-1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-3]
2020-04-20 23:47:56,674 INFO [Partition topic-example1347-1 broker=2] Log loaded for partition topic-example1347-1 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-3]
2020-04-20 23:47:56,674 INFO [Partition topic-example1347-1 broker=2] topic-example1347-1 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-3]
2020-04-20 23:47:56,676 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 2924 for partition topic-example1347-1 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:47:56,676 TRACE [Broker id=2] Completed LeaderAndIsr request correlationId 2924 from controller 1 epoch 1 for the become-leader transition for partition topic-example1347-1 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:47:56,690 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1347', partitionIndex=2, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example1347-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2925 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:47:56,690 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1347', partitionIndex=1, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example1347-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2925 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:47:56,690 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1347', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example1347-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2925 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:47:56,842 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1348', partitionIndex=0, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 2926 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:56,843 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 2926 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1348-0 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:56,843 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example1348-0) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:56,871 INFO [Log partition=topic-example1348-0, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:56,872 INFO [Log partition=topic-example1348-0, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 2 ms (kafka.log.Log) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:56,934 INFO Created log for partition topic-example1348-0 in /var/lib/kafka/data/kafka-log2/topic-example1348-0 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:56,937 INFO [Partition topic-example1348-0 broker=2] No checkpointed highwatermark is found for partition topic-example1348-0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:56,938 INFO [Partition topic-example1348-0 broker=2] Log loaded for partition topic-example1348-0 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:56,938 INFO [Partition topic-example1348-0 broker=2] topic-example1348-0 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:56,958 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 2926 for partition topic-example1348-0 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:56,958 TRACE [Broker id=2] Completed LeaderAndIsr request correlationId 2926 from controller 1 epoch 1 for the become-leader transition for partition topic-example1348-0 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:48:26,640 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1578', partitionIndex=2, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 3324 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:48:26,640 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 3324 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1578-2 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:48:26,640 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example1578-2) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-1]
2020-04-20 23:48:26,645 INFO [Log partition=topic-example1578-2, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-1]
2020-04-20 23:48:26,645 INFO [Log partition=topic-example1578-2, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 1 ms (kafka.log.Log) [data-plane-kafka-request-handler-1]
2020-04-20 23:48:26,646 INFO Created log for partition topic-example1578-2 in /var/lib/kafka/data/kafka-log2/topic-example1578-2 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-1]
2020-04-20 23:48:26,648 INFO [Partition topic-example1578-2 broker=2] No checkpointed highwatermark is found for partition topic-example1578-2 (kafka.cluster.Partition) [data-plane-kafka-request-handler-1]
2020-04-20 23:48:26,648 INFO [Partition topic-example1578-2 broker=2] Log loaded for partition topic-example1578-2 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-1]
2020-04-20 23:48:26,648 INFO [Partition topic-example1578-2 broker=2] topic-example1578-2 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-1]
2020-04-20 23:48:26,649 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 3324 for partition topic-example1578-2 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:48:26,649 TRACE [Broker id=2] Completed LeaderAndIsr request correlationId 3324 from controller 1 epoch 1 for the become-leader transition for partition topic-example1578-2 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:48:26,662 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1578', partitionIndex=1, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example1578-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 3325 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:48:26,662 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1578', partitionIndex=0, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example1578-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 3325 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:48:26,662 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1578', partitionIndex=2, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example1578-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 3325 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:48:26,796 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1579', partitionIndex=2, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 3326 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:48:26,796 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 3326 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1579-2 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:48:26,797 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example1579-2) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-2]
2020-04-20 23:48:26,800 INFO [Log partition=topic-example1579-2, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-2]
2020-04-20 23:48:26,800 INFO [Log partition=topic-example1579-2, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 1 ms (kafka.log.Log) [data-plane-kafka-request-handler-2]
2020-04-20 23:48:26,800 INFO Created log for partition topic-example1579-2 in /var/lib/kafka/data/kafka-log2/topic-example1579-2 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-2]
2020-04-20 23:48:26,844 INFO [Partition topic-example1579-2 broker=2] No checkpointed highwatermark is found for partition topic-example1579-2 (kafka.cluster.Partition) [data-plane-kafka-request-handler-2]
2020-04-20 23:48:26,844 INFO [Partition topic-example1579-2 broker=2] Log loaded for partition topic-example1579-2 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-2]
2020-04-20 23:48:26,844 INFO [Partition topic-example1579-2 broker=2] topic-example1579-2 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-2]
2020-04-20 23:48:26,858 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 3326 for partition topic-example1579-2 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:48:26,858 TRACE [Broker id=2] Completed LeaderAndIsr request correlationId 3326 from controller 1 epoch 1 for the become-leader transition for partition topic-example1579-2 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:48:26,883 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1579', partitionIndex=1, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example1579-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 3327 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:48:26,883 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1579', partitionIndex=0, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example1579-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 3327 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:48:26,883 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1579', partitionIndex=2, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example1579-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 3327 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:48:27,041 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1580', partitionIndex=1, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 3328 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:48:27,041 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 3328 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1580-1 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:48:27,041 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example1580-1) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-2]
2020-04-20 23:48:27,053 INFO [Log partition=topic-example1580-1, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-2]
2020-04-20 23:48:27,053 INFO [Log partition=topic-example1580-1, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 1 ms (kafka.log.Log) [data-plane-kafka-request-handler-2]
2020-04-20 23:48:27,054 INFO Created log for partition topic-example1580-1 in /var/lib/kafka/data/kafka-log2/topic-example1580-1 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-2]
2020-04-20 23:48:56,515 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1777', partitionIndex=0, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 3678 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:48:56,515 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 3678 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1777-0 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:48:56,515 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example1777-0) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-5]
2020-04-20 23:48:56,524 INFO [Log partition=topic-example1777-0, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-5]
2020-04-20 23:48:56,524 INFO [Log partition=topic-example1777-0, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 1 ms (kafka.log.Log) [data-plane-kafka-request-handler-5]
2020-04-20 23:48:56,525 INFO Created log for partition topic-example1777-0 in /var/lib/kafka/data/kafka-log2/topic-example1777-0 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-5]
2020-04-20 23:48:56,527 INFO [Partition topic-example1777-0 broker=2] No checkpointed highwatermark is found for partition topic-example1777-0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-5]
2020-04-20 23:48:56,527 INFO [Partition topic-example1777-0 broker=2] Log loaded for partition topic-example1777-0 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-5]
2020-04-20 23:48:56,527 INFO [Partition topic-example1777-0 broker=2] topic-example1777-0 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-5]
2020-04-20 23:48:56,536 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 3678 for partition topic-example1777-0 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:48:56,536 TRACE [Broker id=2] Completed LeaderAndIsr request correlationId 3678 from controller 1 epoch 1 for the become-leader transition for partition topic-example1777-0 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:48:56,547 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1777', partitionIndex=1, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example1777-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 3679 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:48:56,547 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1777', partitionIndex=0, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example1777-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 3679 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:48:56,547 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1777', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example1777-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 3679 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:48:56,633 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1778', partitionIndex=1, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 3680 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:48:56,634 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 3680 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1778-1 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:48:56,634 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example1778-1) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-3]
2020-04-20 23:48:56,644 INFO [Log partition=topic-example1778-1, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-3]
2020-04-20 23:48:56,645 INFO [Log partition=topic-example1778-1, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 2 ms (kafka.log.Log) [data-plane-kafka-request-handler-3]
2020-04-20 23:48:56,645 INFO Created log for partition topic-example1778-1 in /var/lib/kafka/data/kafka-log2/topic-example1778-1 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-3]
2020-04-20 23:48:56,660 INFO [Partition topic-example1778-1 broker=2] No checkpointed highwatermark is found for partition topic-example1778-1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-3]
2020-04-20 23:48:56,660 INFO [Partition topic-example1778-1 broker=2] Log loaded for partition topic-example1778-1 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-3]
2020-04-20 23:48:56,660 INFO [Partition topic-example1778-1 broker=2] topic-example1778-1 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-3]
2020-04-20 23:48:56,675 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 3680 for partition topic-example1778-1 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:48:56,675 TRACE [Broker id=2] Completed LeaderAndIsr request correlationId 3680 from controller 1 epoch 1 for the become-leader transition for partition topic-example1778-1 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:48:56,715 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1778', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example1778-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 3681 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:48:56,715 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1778', partitionIndex=2, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example1778-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 3681 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:48:56,715 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1778', partitionIndex=1, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example1778-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 3681 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:48:56,841 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1780', partitionIndex=0, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 3682 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:48:56,842 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 3682 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1780-0 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:48:56,842 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example1780-0) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-5]
2020-04-20 23:48:56,856 INFO [Log partition=topic-example1780-0, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-5]
2020-04-20 23:48:56,856 INFO [Log partition=topic-example1780-0, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 2 ms (kafka.log.Log) [data-plane-kafka-request-handler-5]
2020-04-20 23:48:56,857 INFO Created log for partition topic-example1780-0 in /var/lib/kafka/data/kafka-log2/topic-example1780-0 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-5]
2020-04-20 23:48:56,886 INFO [Partition topic-example1780-0 broker=2] No checkpointed highwatermark is found for partition topic-example1780-0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-5]
2020-04-20 23:48:56,886 INFO [Partition topic-example1780-0 broker=2] Log loaded for partition topic-example1780-0 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-5]
2020-04-20 23:48:56,886 INFO [Partition topic-example1780-0 broker=2] topic-example1780-0 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-5]
2020-04-20 23:48:56,917 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 3682 for partition topic-example1780-0 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:48:56,917 TRACE [Broker id=2] Completed LeaderAndIsr request correlationId 3682 from controller 1 epoch 1 for the become-leader transition for partition topic-example1780-0 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:48:56,946 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1780', partitionIndex=1, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example1780-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 3683 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:48:56,946 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1780', partitionIndex=0, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example1780-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 3683 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:48:56,946 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1780', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example1780-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 3683 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:48:56,987 TRACE [Broker id=2] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1781', partitionIndex=0, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 3684 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:48:56,988 TRACE [Broker id=2] Handling LeaderAndIsr request correlationId 3684 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1781-0 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:48:56,988 INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(topic-example1781-0) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-0]
2020-04-20 23:48:56,996 INFO [Log partition=topic-example1781-0, dir=/var/lib/kafka/data/kafka-log2] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-0]
2020-04-20 23:48:56,996 INFO [Log partition=topic-example1781-0, dir=/var/lib/kafka/data/kafka-log2] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 1 ms (kafka.log.Log) [data-plane-kafka-request-handler-0]
2020-04-20 23:48:56,997 INFO Created log for partition topic-example1781-0 in /var/lib/kafka/data/kafka-log2/topic-example1781-0 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> 7200000, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 60000, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 1000012, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager) [data-plane-kafka-request-handler-0]
2020-04-20 23:48:56,999 INFO [Partition topic-example1781-0 broker=2] No checkpointed highwatermark is found for partition topic-example1781-0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-0]
2020-04-20 23:48:56,999 INFO [Partition topic-example1781-0 broker=2] Log loaded for partition topic-example1781-0 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-0]
2020-04-20 23:48:56,999 INFO [Partition topic-example1781-0 broker=2] topic-example1781-0 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-0]
2020-04-20 23:48:57,001 TRACE [Broker id=2] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 3684 for partition topic-example1781-0 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:48:57,002 TRACE [Broker id=2] Completed LeaderAndIsr request correlationId 3684 from controller 1 epoch 1 for the become-leader transition for partition topic-example1781-0 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:48:57,014 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1781', partitionIndex=0, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example1781-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 3685 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:48:57,014 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1781', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example1781-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 3685 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:48:57,014 TRACE [Broker id=2] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1781', partitionIndex=1, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example1781-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 3685 (state.change.logger) [data-plane-kafka-request-handler-2]