Waiting for the TLS sidecar to get ready
TLS sidecar is not ready yet, waiting for another 1 second
STRIMZI_BROKER_ID=0
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=0
##########
# Zookeeper
##########
zookeeper.connect=localhost:2181
##########
# Kafka message logs configuration
##########
log.dirs=/var/lib/kafka/data/kafka-log0
##########
# 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-0.my-cluster-kafka-brokers.topic-cluster-test.svc:9091,PLAIN-9092://my-cluster-kafka-0.my-cluster-kafka-brokers.topic-cluster-test.svc:9092,TLS-9093://my-cluster-kafka-0.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:35:59,805 INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$) [main]
2020-04-20 23:36:00,879 DEBUG Metric kafka.server:type=KafkaServer,name=BrokerState added  (io.strimzi.kafka.agent.KafkaAgent) [main]
2020-04-20 23:36:00,884 INFO Registered signal handlers for TERM, INT, HUP (org.apache.kafka.common.utils.LoggingSignalHandler) [main]
2020-04-20 23:36:00,886 INFO starting (kafka.server.KafkaServer) [main]
2020-04-20 23:36:00,888 INFO Connecting to zookeeper on localhost:2181 (kafka.server.KafkaServer) [main]
2020-04-20 23:36:00,934 INFO [ZooKeeperClient Kafka server] Initializing a new session to localhost:2181. (kafka.zookeeper.ZooKeeperClient) [main]
2020-04-20 23:36:00,943 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:00,943 INFO Client environment:host.name=my-cluster-kafka-0.my-cluster-kafka-brokers.topic-cluster-test.svc.cluster.local (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:00,943 INFO Client environment:java.version=1.8.0_242 (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:00,943 INFO Client environment:java.vendor=Oracle Corporation (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:00,943 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:00,943 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:00,943 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:00,943 INFO Client environment:java.io.tmpdir=/tmp (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:00,943 INFO Client environment:java.compiler=<NA> (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:00,943 INFO Client environment:os.name=Linux (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:00,943 INFO Client environment:os.arch=amd64 (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:00,943 INFO Client environment:os.version=3.10.0-944.el7.x86_64 (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:00,943 INFO Client environment:user.name=? (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:00,943 INFO Client environment:user.home=? (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:00,943 INFO Client environment:user.dir=/opt/kafka (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:00,943 INFO Client environment:os.memory.free=116MB (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:00,943 INFO Client environment:os.memory.max=3972MB (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:00,943 INFO Client environment:os.memory.total=128MB (org.apache.zookeeper.ZooKeeper) [main]
2020-04-20 23:36:00,947 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:00,951 INFO Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation (org.apache.zookeeper.common.X509Util) [main]
2020-04-20 23:36:00,958 INFO jute.maxbuffer value is 4194304 Bytes (org.apache.zookeeper.ClientCnxnSocket) [main]
2020-04-20 23:36:00,967 INFO zookeeper.request.timeout value is 0. feature enabled= (org.apache.zookeeper.ClientCnxn) [main]
2020-04-20 23:36:00,968 INFO Starting poller (io.strimzi.kafka.agent.KafkaAgent) [main]
2020-04-20 23:36:00,971 INFO [ZooKeeperClient Kafka server] Waiting until connected. (kafka.zookeeper.ZooKeeperClient) [main]
2020-04-20 23:36:00,973 DEBUG Metric kafka.server:type=SessionExpireListener,name=SessionState = CONNECTING (io.strimzi.kafka.agent.KafkaAgent) [KafkaAgentPoller]
2020-04-20 23:36:00,981 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:00,989 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:36:02,096 INFO Opening socket connection to server localhost/127.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:02,097 INFO Socket connection established, initiating session, client: /127.0.0.1:33242, server: localhost/127.0.0.1:2181 (org.apache.zookeeper.ClientCnxn) [main-SendThread(localhost:2181)]
2020-04-20 23:36:02,128 INFO Session establishment complete on server localhost/127.0.0.1:2181, sessionid = 0x10000736c8c0002, negotiated timeout = 6000 (org.apache.zookeeper.ClientCnxn) [main-SendThread(localhost:2181)]
2020-04-20 23:36:02,134 INFO [ZooKeeperClient Kafka server] Connected. (kafka.zookeeper.ZooKeeperClient) [main]
2020-04-20 23:41:13,129 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='my-topic-575344098', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 7 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:41:13,142 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 7 from controller 1 epoch 1 starting the become-leader transition for partition my-topic-575344098-0 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:41:13,144 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(my-topic-575344098-0) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-5]
2020-04-20 23:41:13,172 INFO [Log partition=my-topic-575344098-0, dir=/var/lib/kafka/data/kafka-log0] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-5]
2020-04-20 23:41:13,173 INFO [Log partition=my-topic-575344098-0, dir=/var/lib/kafka/data/kafka-log0] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 5 ms (kafka.log.Log) [data-plane-kafka-request-handler-5]
2020-04-20 23:41:13,178 INFO Created log for partition my-topic-575344098-0 in /var/lib/kafka/data/kafka-log0/my-topic-575344098-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 -> 604800000, 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:41:13,183 INFO [Partition my-topic-575344098-0 broker=0] No checkpointed highwatermark is found for partition my-topic-575344098-0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-5]
2020-04-20 23:41:13,184 INFO [Partition my-topic-575344098-0 broker=0] Log loaded for partition my-topic-575344098-0 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-5]
2020-04-20 23:41:13,186 INFO [Partition my-topic-575344098-0 broker=0] my-topic-575344098-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:41:13,215 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 7 for partition my-topic-575344098-0 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:41:13,216 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 7 from controller 1 epoch 1 for the become-leader transition for partition my-topic-575344098-0 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:41:13,227 TRACE [Broker id=0] 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 8 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:41:53,313 INFO [GroupCoordinator 0]: Member instance2063800538-f046c72c-80f2-4173-9592-611d587e589d in group my-consumer-group835085890 has failed, removing it from the group (kafka.coordinator.group.GroupCoordinator) [executor-Heartbeat]
2020-04-20 23:41:53,315 INFO [GroupCoordinator 0]: Preparing to rebalance group my-consumer-group835085890 in state PreparingRebalance with old generation 1 (__consumer_offsets-45) (reason: removing member instance2063800538-f046c72c-80f2-4173-9592-611d587e589d on heartbeat expiration) (kafka.coordinator.group.GroupCoordinator) [executor-Heartbeat]
2020-04-20 23:41:53,316 INFO [GroupCoordinator 0]: Group my-consumer-group835085890 with generation 2 is now empty (__consumer_offsets-45) (kafka.coordinator.group.GroupCoordinator) [executor-Heartbeat]
2020-04-20 23:42:14,198 TRACE [Broker id=0] 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 11 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:14,198 TRACE [Broker id=0] 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 11 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:14,198 TRACE [Broker id=0] 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 11 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:14,198 TRACE [Broker id=0] 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 11 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:14,198 TRACE [Broker id=0] 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 11 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:14,200 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 11 from controller 1 epoch 1 starting the become-leader transition for partition topic-example-new-3 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:14,200 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 11 from controller 1 epoch 1 starting the become-leader transition for partition topic-example-new-0 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:14,200 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example-new-3, topic-example-new-0) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:14,254 INFO [Log partition=topic-example-new-3, dir=/var/lib/kafka/data/kafka-log0] 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:14,254 INFO [Log partition=topic-example-new-3, dir=/var/lib/kafka/data/kafka-log0] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:14,255 INFO Created log for partition topic-example-new-3 in /var/lib/kafka/data/kafka-log0/topic-example-new-3 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-7]
2020-04-20 23:42:14,262 INFO [Partition topic-example-new-3 broker=0] No checkpointed highwatermark is found for partition topic-example-new-3 (kafka.cluster.Partition) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:14,262 INFO [Partition topic-example-new-3 broker=0] Log loaded for partition topic-example-new-3 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:14,262 INFO [Partition topic-example-new-3 broker=0] topic-example-new-3 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:14,282 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 11 for partition topic-example-new-3 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:14,297 INFO [Log partition=topic-example-new-0, dir=/var/lib/kafka/data/kafka-log0] 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:14,298 INFO [Log partition=topic-example-new-0, dir=/var/lib/kafka/data/kafka-log0] 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:14,299 INFO Created log for partition topic-example-new-0 in /var/lib/kafka/data/kafka-log0/topic-example-new-0 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-7]
2020-04-20 23:42:14,299 INFO [Partition topic-example-new-0 broker=0] No checkpointed highwatermark is found for partition topic-example-new-0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:14,299 INFO [Partition topic-example-new-0 broker=0] Log loaded for partition topic-example-new-0 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:14,299 INFO [Partition topic-example-new-0 broker=0] topic-example-new-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:42:14,300 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 11 for partition topic-example-new-0 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:14,300 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 11 from controller 1 epoch 1 for the become-leader transition for partition topic-example-new-3 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:14,300 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 11 from controller 1 epoch 1 for the become-leader transition for partition topic-example-new-0 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:14,300 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 11 from controller 1 epoch 1 starting the become-follower transition for partition topic-example-new-2 with leader 1 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:14,300 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 11 from controller 1 epoch 1 starting the become-follower transition for partition topic-example-new-4 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:14,300 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 11 from controller 1 epoch 1 starting the become-follower transition for partition topic-example-new-1 with leader 2 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:34,777 TRACE [Broker id=0] Deleted partition topic-example-new-1 from metadata cache in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 13 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:42:34,777 TRACE [Broker id=0] Deleted partition topic-example-new-4 from metadata cache in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 13 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:42:34,777 TRACE [Broker id=0] Deleted partition topic-example-new-3 from metadata cache in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 13 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:42:34,777 TRACE [Broker id=0] Deleted partition topic-example-new-0 from metadata cache in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 13 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:42:34,778 TRACE [Broker id=0] Deleted partition topic-example-new-2 from metadata cache in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 13 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:42:34,788 INFO [GroupCoordinator 0]: 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-1]
2020-04-20 23:42:34,844 INFO [ReplicaFetcherManager on broker 0] 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,845 INFO [ReplicaAlterLogDirsManager on broker 0] 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,845 TRACE [Broker id=0] 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,845 TRACE [Broker id=0] 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,845 TRACE [Broker id=0] 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,845 TRACE [Broker id=0] 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,845 TRACE [Broker id=0] 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,845 TRACE [Broker id=0] 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,845 TRACE [Broker id=0] 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,845 TRACE [Broker id=0] 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,845 TRACE [Broker id=0] 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,845 TRACE [Broker id=0] 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,852 INFO [ReplicaFetcherManager on broker 0] 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-7]
2020-04-20 23:42:34,852 INFO [ReplicaAlterLogDirsManager on broker 0] 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-7]
2020-04-20 23:42:34,852 TRACE [Broker id=0] Handling stop replica (delete=true) for partition topic-example-new-2 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:34,853 INFO The cleaning for partition topic-example-new-2 is aborted and paused (kafka.log.LogCleaner) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:34,853 INFO The cleaning for partition topic-example-new-2 is aborted (kafka.log.LogCleaner) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:34,867 INFO Log for partition topic-example-new-2 is renamed to /var/lib/kafka/data/kafka-log0/topic-example-new-2.9d5235b248e442119c2f948376bff213-delete and is scheduled for deletion (kafka.log.LogManager) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:34,867 TRACE [Broker id=0] Finished handling stop replica (delete=true) for partition topic-example-new-2 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:34,867 TRACE [Broker id=0] Handling stop replica (delete=true) for partition topic-example-new-3 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:34,868 INFO The cleaning for partition topic-example-new-3 is aborted and paused (kafka.log.LogCleaner) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:34,868 INFO The cleaning for partition topic-example-new-3 is aborted (kafka.log.LogCleaner) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:34,883 INFO Log for partition topic-example-new-3 is renamed to /var/lib/kafka/data/kafka-log0/topic-example-new-3.ff5010c8299945c1b2503c238fcd0aa7-delete and is scheduled for deletion (kafka.log.LogManager) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:34,883 TRACE [Broker id=0] Finished handling stop replica (delete=true) for partition topic-example-new-3 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:34,883 TRACE [Broker id=0] Handling stop replica (delete=true) for partition topic-example-new-0 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:34,883 INFO The cleaning for partition topic-example-new-0 is aborted and paused (kafka.log.LogCleaner) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:34,884 INFO The cleaning for partition topic-example-new-0 is aborted (kafka.log.LogCleaner) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:34,902 INFO Log for partition topic-example-new-0 is renamed to /var/lib/kafka/data/kafka-log0/topic-example-new-0.b2a1fe04267e4f7c884fe2c07b67f743-delete and is scheduled for deletion (kafka.log.LogManager) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:34,903 TRACE [Broker id=0] Finished handling stop replica (delete=true) for partition topic-example-new-0 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:34,903 TRACE [Broker id=0] Handling stop replica (delete=true) for partition topic-example-new-1 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:34,904 INFO The cleaning for partition topic-example-new-1 is aborted and paused (kafka.log.LogCleaner) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:34,904 INFO The cleaning for partition topic-example-new-1 is aborted (kafka.log.LogCleaner) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:34,911 INFO Log for partition topic-example-new-1 is renamed to /var/lib/kafka/data/kafka-log0/topic-example-new-1.44111d104dd74335bd7a7a8065e5ea2c-delete and is scheduled for deletion (kafka.log.LogManager) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:34,911 TRACE [Broker id=0] Finished handling stop replica (delete=true) for partition topic-example-new-1 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:34,911 TRACE [Broker id=0] Handling stop replica (delete=true) for partition topic-example-new-4 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:34,912 INFO The cleaning for partition topic-example-new-4 is aborted and paused (kafka.log.LogCleaner) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:34,912 INFO The cleaning for partition topic-example-new-4 is aborted (kafka.log.LogCleaner) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:34,920 INFO Log for partition topic-example-new-4 is renamed to /var/lib/kafka/data/kafka-log0/topic-example-new-4.5120c46b93384e3391dc2082bd444b1d-delete and is scheduled for deletion (kafka.log.LogManager) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:34,920 TRACE [Broker id=0] Finished handling stop replica (delete=true) for partition topic-example-new-4 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:42:59,605 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example0', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 20 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:42:59,606 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 20 from controller 1 epoch 1 starting the become-leader transition for partition topic-example0-0 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:42:59,606 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example0-0) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-3]
2020-04-20 23:42:59,616 INFO [Log partition=topic-example0-0, dir=/var/lib/kafka/data/kafka-log0] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-3]
2020-04-20 23:42:59,617 INFO [Log partition=topic-example0-0, dir=/var/lib/kafka/data/kafka-log0] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 4 ms (kafka.log.Log) [data-plane-kafka-request-handler-3]
2020-04-20 23:42:59,618 INFO Created log for partition topic-example0-0 in /var/lib/kafka/data/kafka-log0/topic-example0-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:42:59,619 INFO [Partition topic-example0-0 broker=0] No checkpointed highwatermark is found for partition topic-example0-0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-3]
2020-04-20 23:42:59,619 INFO [Partition topic-example0-0 broker=0] Log loaded for partition topic-example0-0 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-3]
2020-04-20 23:42:59,619 INFO [Partition topic-example0-0 broker=0] topic-example0-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:42:59,627 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 20 for partition topic-example0-0 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:42:59,627 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 20 from controller 1 epoch 1 for the become-leader transition for partition topic-example0-0 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:42:59,638 TRACE [Broker id=0] 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 21 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:42:59,638 TRACE [Broker id=0] 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 21 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:42:59,638 TRACE [Broker id=0] 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 21 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:42:59,750 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example2', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 22 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:26,473 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example170', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 350 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:43:26,473 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 350 from controller 1 epoch 1 starting the become-leader transition for partition topic-example170-2 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:43:26,474 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example170-2) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-5]
2020-04-20 23:43:26,485 INFO [Log partition=topic-example170-2, dir=/var/lib/kafka/data/kafka-log0] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-5]
2020-04-20 23:43:26,486 INFO [Log partition=topic-example170-2, dir=/var/lib/kafka/data/kafka-log0] 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:43:26,494 INFO Created log for partition topic-example170-2 in /var/lib/kafka/data/kafka-log0/topic-example170-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-5]
2020-04-20 23:43:26,494 INFO [Partition topic-example170-2 broker=0] No checkpointed highwatermark is found for partition topic-example170-2 (kafka.cluster.Partition) [data-plane-kafka-request-handler-5]
2020-04-20 23:43:26,495 INFO [Partition topic-example170-2 broker=0] Log loaded for partition topic-example170-2 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-5]
2020-04-20 23:43:26,495 INFO [Partition topic-example170-2 broker=0] topic-example170-2 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:43:26,498 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 350 for partition topic-example170-2 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:43:26,498 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 350 from controller 1 epoch 1 for the become-leader transition for partition topic-example170-2 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:43:26,504 TRACE [Broker id=0] 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 351 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:43:26,504 TRACE [Broker id=0] 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 351 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:43:26,504 TRACE [Broker id=0] 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 351 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:43:26,600 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example171', partitionIndex=1, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 352 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:26,601 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 352 from controller 1 epoch 1 starting the become-leader transition for partition topic-example171-1 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:26,601 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example171-1) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:26,606 INFO [Log partition=topic-example171-1, dir=/var/lib/kafka/data/kafka-log0] 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:26,606 INFO [Log partition=topic-example171-1, dir=/var/lib/kafka/data/kafka-log0] 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:26,607 INFO Created log for partition topic-example171-1 in /var/lib/kafka/data/kafka-log0/topic-example171-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:26,607 INFO [Partition topic-example171-1 broker=0] No checkpointed highwatermark is found for partition topic-example171-1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:26,607 INFO [Partition topic-example171-1 broker=0] Log loaded for partition topic-example171-1 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:26,607 INFO [Partition topic-example171-1 broker=0] topic-example171-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:26,610 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 352 for partition topic-example171-1 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:26,610 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 352 from controller 1 epoch 1 for the become-leader transition for partition topic-example171-1 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:26,614 TRACE [Broker id=0] 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 353 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:43:26,614 TRACE [Broker id=0] 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 353 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:43:26,614 TRACE [Broker id=0] 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 353 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:43:26,740 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example172', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 354 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:43:26,741 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 354 from controller 1 epoch 1 starting the become-leader transition for partition topic-example172-0 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:43:26,741 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example172-0) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-2]
2020-04-20 23:43:26,752 INFO [Log partition=topic-example172-0, dir=/var/lib/kafka/data/kafka-log0] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-2]
2020-04-20 23:43:26,753 INFO [Log partition=topic-example172-0, dir=/var/lib/kafka/data/kafka-log0] 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:43:26,753 INFO Created log for partition topic-example172-0 in /var/lib/kafka/data/kafka-log0/topic-example172-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-2]
2020-04-20 23:43:26,754 INFO [Partition topic-example172-0 broker=0] No checkpointed highwatermark is found for partition topic-example172-0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-2]
2020-04-20 23:43:26,754 INFO [Partition topic-example172-0 broker=0] Log loaded for partition topic-example172-0 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-2]
2020-04-20 23:43:26,754 INFO [Partition topic-example172-0 broker=0] topic-example172-0 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:43:26,757 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 354 for partition topic-example172-0 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:43:26,757 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 354 from controller 1 epoch 1 for the become-leader transition for partition topic-example172-0 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:43:26,763 TRACE [Broker id=0] 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 355 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:43:26,763 TRACE [Broker id=0] 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 355 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:43:26,763 TRACE [Broker id=0] 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 355 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:43:26,910 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example173', partitionIndex=1, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 356 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:26,911 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 356 from controller 1 epoch 1 starting the become-leader transition for partition topic-example173-1 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:26,911 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example173-1) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:26,922 INFO [Log partition=topic-example173-1, dir=/var/lib/kafka/data/kafka-log0] 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:26,923 INFO [Log partition=topic-example173-1, dir=/var/lib/kafka/data/kafka-log0] 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:26,923 INFO Created log for partition topic-example173-1 in /var/lib/kafka/data/kafka-log0/topic-example173-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:26,924 INFO [Partition topic-example173-1 broker=0] No checkpointed highwatermark is found for partition topic-example173-1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:26,924 INFO [Partition topic-example173-1 broker=0] Log loaded for partition topic-example173-1 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:26,924 INFO [Partition topic-example173-1 broker=0] topic-example173-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:26,933 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 356 for partition topic-example173-1 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:26,933 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 356 from controller 1 epoch 1 for the become-leader transition for partition topic-example173-1 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:56,540 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example397', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 794 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:56,540 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 794 from controller 1 epoch 1 starting the become-leader transition for partition topic-example397-0 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:56,540 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example397-0) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:56,567 INFO [Log partition=topic-example397-0, dir=/var/lib/kafka/data/kafka-log0] 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,568 INFO [Log partition=topic-example397-0, dir=/var/lib/kafka/data/kafka-log0] 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,568 INFO Created log for partition topic-example397-0 in /var/lib/kafka/data/kafka-log0/topic-example397-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:43:56,569 INFO [Partition topic-example397-0 broker=0] No checkpointed highwatermark is found for partition topic-example397-0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:56,569 INFO [Partition topic-example397-0 broker=0] Log loaded for partition topic-example397-0 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:56,569 INFO [Partition topic-example397-0 broker=0] topic-example397-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:43:56,601 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 794 for partition topic-example397-0 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:56,601 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 794 from controller 1 epoch 1 for the become-leader transition for partition topic-example397-0 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:43:56,605 TRACE [Broker id=0] 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 795 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:43:56,605 TRACE [Broker id=0] 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 795 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:43:56,605 TRACE [Broker id=0] 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 795 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:43:56,742 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example396', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 796 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:43:56,743 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 796 from controller 1 epoch 1 starting the become-leader transition for partition topic-example396-0 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:43:56,743 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example396-0) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-2]
2020-04-20 23:43:56,749 INFO [Log partition=topic-example396-0, dir=/var/lib/kafka/data/kafka-log0] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-2]
2020-04-20 23:43:56,750 INFO [Log partition=topic-example396-0, dir=/var/lib/kafka/data/kafka-log0] 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-2]
2020-04-20 23:43:56,750 INFO Created log for partition topic-example396-0 in /var/lib/kafka/data/kafka-log0/topic-example396-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-2]
2020-04-20 23:43:56,751 INFO [Partition topic-example396-0 broker=0] No checkpointed highwatermark is found for partition topic-example396-0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-2]
2020-04-20 23:43:56,751 INFO [Partition topic-example396-0 broker=0] Log loaded for partition topic-example396-0 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-2]
2020-04-20 23:43:56,751 INFO [Partition topic-example396-0 broker=0] topic-example396-0 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:43:56,753 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 796 for partition topic-example396-0 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:43:56,753 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 796 from controller 1 epoch 1 for the become-leader transition for partition topic-example396-0 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:43:56,758 TRACE [Broker id=0] 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 797 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:43:56,758 TRACE [Broker id=0] 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 797 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:43:56,758 TRACE [Broker id=0] 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 797 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:43:56,846 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example398', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 798 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:43:56,847 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 798 from controller 1 epoch 1 starting the become-leader transition for partition topic-example398-0 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:43:56,847 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example398-0) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-1]
2020-04-20 23:43:56,859 INFO [Log partition=topic-example398-0, dir=/var/lib/kafka/data/kafka-log0] 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:56,859 INFO [Log partition=topic-example398-0, dir=/var/lib/kafka/data/kafka-log0] 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:56,860 INFO Created log for partition topic-example398-0 in /var/lib/kafka/data/kafka-log0/topic-example398-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:43:56,878 INFO [Partition topic-example398-0 broker=0] No checkpointed highwatermark is found for partition topic-example398-0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-1]
2020-04-20 23:43:56,878 INFO [Partition topic-example398-0 broker=0] Log loaded for partition topic-example398-0 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-1]
2020-04-20 23:43:56,879 INFO [Partition topic-example398-0 broker=0] topic-example398-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:43:56,881 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 798 for partition topic-example398-0 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:43:56,881 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 798 from controller 1 epoch 1 for the become-leader transition for partition topic-example398-0 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:43:56,904 TRACE [Broker id=0] 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 799 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:43:56,904 TRACE [Broker id=0] 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 799 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:43:56,904 TRACE [Broker id=0] 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 799 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:43:57,024 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example399', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 800 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:43:57,024 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 800 from controller 1 epoch 1 starting the become-leader transition for partition topic-example399-0 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:43:57,024 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example399-0) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-3]
2020-04-20 23:44:26,492 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example602', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 1210 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:44:26,493 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 1210 from controller 1 epoch 1 starting the become-leader transition for partition topic-example602-2 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:44:26,493 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example602-2) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-0]
2020-04-20 23:44:26,525 INFO [Log partition=topic-example602-2, dir=/var/lib/kafka/data/kafka-log0] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-0]
2020-04-20 23:44:26,526 INFO [Log partition=topic-example602-2, dir=/var/lib/kafka/data/kafka-log0] 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:44:26,526 INFO Created log for partition topic-example602-2 in /var/lib/kafka/data/kafka-log0/topic-example602-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-0]
2020-04-20 23:44:26,527 INFO [Partition topic-example602-2 broker=0] No checkpointed highwatermark is found for partition topic-example602-2 (kafka.cluster.Partition) [data-plane-kafka-request-handler-0]
2020-04-20 23:44:26,527 INFO [Partition topic-example602-2 broker=0] Log loaded for partition topic-example602-2 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-0]
2020-04-20 23:44:26,527 INFO [Partition topic-example602-2 broker=0] topic-example602-2 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:44:26,534 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 1210 for partition topic-example602-2 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:44:26,534 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 1210 from controller 1 epoch 1 for the become-leader transition for partition topic-example602-2 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:44:26,539 TRACE [Broker id=0] 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 1211 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:44:26,539 TRACE [Broker id=0] 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 1211 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:44:26,539 TRACE [Broker id=0] 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 1211 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:44:26,707 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example603', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 1212 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:44:26,707 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 1212 from controller 1 epoch 1 starting the become-leader transition for partition topic-example603-0 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:44:26,707 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example603-0) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-1]
2020-04-20 23:44:26,729 INFO [Log partition=topic-example603-0, dir=/var/lib/kafka/data/kafka-log0] 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:26,729 INFO [Log partition=topic-example603-0, dir=/var/lib/kafka/data/kafka-log0] 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:44:26,730 INFO Created log for partition topic-example603-0 in /var/lib/kafka/data/kafka-log0/topic-example603-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:44:26,731 INFO [Partition topic-example603-0 broker=0] No checkpointed highwatermark is found for partition topic-example603-0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-1]
2020-04-20 23:44:26,731 INFO [Partition topic-example603-0 broker=0] Log loaded for partition topic-example603-0 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-1]
2020-04-20 23:44:26,731 INFO [Partition topic-example603-0 broker=0] topic-example603-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:44:26,782 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 1212 for partition topic-example603-0 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:44:26,782 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 1212 from controller 1 epoch 1 for the become-leader transition for partition topic-example603-0 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:44:26,801 TRACE [Broker id=0] 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 1213 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:44:26,801 TRACE [Broker id=0] 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 1213 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:44:26,802 TRACE [Broker id=0] 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 1213 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:44:26,909 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example604', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 1214 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:44:26,909 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 1214 from controller 1 epoch 1 starting the become-leader transition for partition topic-example604-0 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:44:26,909 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example604-0) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-6]
2020-04-20 23:44:26,930 INFO [Log partition=topic-example604-0, dir=/var/lib/kafka/data/kafka-log0] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-6]
2020-04-20 23:44:26,930 INFO [Log partition=topic-example604-0, dir=/var/lib/kafka/data/kafka-log0] 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-6]
2020-04-20 23:44:26,930 INFO Created log for partition topic-example604-0 in /var/lib/kafka/data/kafka-log0/topic-example604-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:44:26,931 INFO [Partition topic-example604-0 broker=0] No checkpointed highwatermark is found for partition topic-example604-0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-6]
2020-04-20 23:44:26,931 INFO [Partition topic-example604-0 broker=0] Log loaded for partition topic-example604-0 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-6]
2020-04-20 23:44:26,931 INFO [Partition topic-example604-0 broker=0] topic-example604-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:44:26,943 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 1214 for partition topic-example604-0 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:44:26,943 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 1214 from controller 1 epoch 1 for the become-leader transition for partition topic-example604-0 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:44:26,948 TRACE [Broker id=0] 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 1215 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:44:26,949 TRACE [Broker id=0] 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 1215 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:44:26,949 TRACE [Broker id=0] 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 1215 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:44:56,512 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example817', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 1630 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:44:56,512 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 1630 from controller 1 epoch 1 starting the become-leader transition for partition topic-example817-0 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:44:56,513 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example817-0) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-7]
2020-04-20 23:44:56,518 INFO [Log partition=topic-example817-0, dir=/var/lib/kafka/data/kafka-log0] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-7]
2020-04-20 23:44:56,519 INFO [Log partition=topic-example817-0, dir=/var/lib/kafka/data/kafka-log0] 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:44:56,519 INFO Created log for partition topic-example817-0 in /var/lib/kafka/data/kafka-log0/topic-example817-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:44:56,520 INFO [Partition topic-example817-0 broker=0] No checkpointed highwatermark is found for partition topic-example817-0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-7]
2020-04-20 23:44:56,520 INFO [Partition topic-example817-0 broker=0] Log loaded for partition topic-example817-0 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-7]
2020-04-20 23:44:56,521 INFO [Partition topic-example817-0 broker=0] topic-example817-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:44:56,522 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 1630 for partition topic-example817-0 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:44:56,522 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 1630 from controller 1 epoch 1 for the become-leader transition for partition topic-example817-0 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:44:56,536 TRACE [Broker id=0] 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 1631 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:44:56,536 TRACE [Broker id=0] 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 1631 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:44:56,536 TRACE [Broker id=0] 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 1631 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:44:56,623 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example818', partitionIndex=1, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 1632 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:44:56,624 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 1632 from controller 1 epoch 1 starting the become-leader transition for partition topic-example818-1 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:44:56,624 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example818-1) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-6]
2020-04-20 23:44:56,632 INFO [Log partition=topic-example818-1, dir=/var/lib/kafka/data/kafka-log0] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-6]
2020-04-20 23:44:56,633 INFO [Log partition=topic-example818-1, dir=/var/lib/kafka/data/kafka-log0] 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-6]
2020-04-20 23:44:56,633 INFO Created log for partition topic-example818-1 in /var/lib/kafka/data/kafka-log0/topic-example818-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-6]
2020-04-20 23:44:56,634 INFO [Partition topic-example818-1 broker=0] No checkpointed highwatermark is found for partition topic-example818-1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-6]
2020-04-20 23:44:56,634 INFO [Partition topic-example818-1 broker=0] Log loaded for partition topic-example818-1 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-6]
2020-04-20 23:44:56,634 INFO [Partition topic-example818-1 broker=0] topic-example818-1 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:44:56,636 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 1632 for partition topic-example818-1 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:44:56,636 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 1632 from controller 1 epoch 1 for the become-leader transition for partition topic-example818-1 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:44:56,641 TRACE [Broker id=0] 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 1633 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:44:56,641 TRACE [Broker id=0] 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 1633 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:44:56,641 TRACE [Broker id=0] 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 1633 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:44:56,761 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example819', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 1634 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:44:56,761 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 1634 from controller 1 epoch 1 starting the become-leader transition for partition topic-example819-2 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:44:56,761 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example819-2) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-3]
2020-04-20 23:44:56,766 INFO [Log partition=topic-example819-2, dir=/var/lib/kafka/data/kafka-log0] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-3]
2020-04-20 23:44:56,766 INFO [Log partition=topic-example819-2, dir=/var/lib/kafka/data/kafka-log0] 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:44:56,767 INFO Created log for partition topic-example819-2 in /var/lib/kafka/data/kafka-log0/topic-example819-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:44:56,768 INFO [Partition topic-example819-2 broker=0] No checkpointed highwatermark is found for partition topic-example819-2 (kafka.cluster.Partition) [data-plane-kafka-request-handler-3]
2020-04-20 23:44:56,769 INFO [Partition topic-example819-2 broker=0] Log loaded for partition topic-example819-2 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-3]
2020-04-20 23:44:56,769 INFO [Partition topic-example819-2 broker=0] topic-example819-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:44:56,786 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 1634 for partition topic-example819-2 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:44:56,786 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 1634 from controller 1 epoch 1 for the become-leader transition for partition topic-example819-2 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:44:56,792 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='topic-example819', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example819-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 1635 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:44:56,792 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='topic-example819', partitionIndex=1, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example819-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 1635 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:44:56,792 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='topic-example819', partitionIndex=0, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example819-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 1635 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:44:56,921 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example821', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 1636 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:44:56,922 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 1636 from controller 1 epoch 1 starting the become-leader transition for partition topic-example821-2 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:44:56,922 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example821-2) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-6]
2020-04-20 23:44:56,941 INFO [Log partition=topic-example821-2, dir=/var/lib/kafka/data/kafka-log0] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-6]
2020-04-20 23:44:56,971 INFO [Log partition=topic-example821-2, dir=/var/lib/kafka/data/kafka-log0] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 31 ms (kafka.log.Log) [data-plane-kafka-request-handler-6]
2020-04-20 23:44:56,971 INFO Created log for partition topic-example821-2 in /var/lib/kafka/data/kafka-log0/topic-example821-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-6]
2020-04-20 23:44:56,973 INFO [Partition topic-example821-2 broker=0] No checkpointed highwatermark is found for partition topic-example821-2 (kafka.cluster.Partition) [data-plane-kafka-request-handler-6]
2020-04-20 23:44:56,973 INFO [Partition topic-example821-2 broker=0] Log loaded for partition topic-example821-2 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-6]
2020-04-20 23:44:56,973 INFO [Partition topic-example821-2 broker=0] topic-example821-2 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:44:56,982 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 1636 for partition topic-example821-2 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:44:56,982 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 1636 from controller 1 epoch 1 for the become-leader transition for partition topic-example821-2 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:44:57,005 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='topic-example821', partitionIndex=0, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example821-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 1637 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:44:57,005 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='topic-example821', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example821-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 1637 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:44:57,005 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='topic-example821', partitionIndex=1, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example821-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 1637 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:45:26,370 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1277', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 2010 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:45:26,370 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 2010 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1277-2 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:45:26,370 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example1277-2) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-1]
2020-04-20 23:45:26,384 INFO [Log partition=topic-example1277-2, dir=/var/lib/kafka/data/kafka-log0] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-1]
2020-04-20 23:45:26,384 INFO [Log partition=topic-example1277-2, dir=/var/lib/kafka/data/kafka-log0] 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:45:26,385 INFO Created log for partition topic-example1277-2 in /var/lib/kafka/data/kafka-log0/topic-example1277-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:45:26,386 INFO [Partition topic-example1277-2 broker=0] No checkpointed highwatermark is found for partition topic-example1277-2 (kafka.cluster.Partition) [data-plane-kafka-request-handler-1]
2020-04-20 23:45:26,386 INFO [Partition topic-example1277-2 broker=0] Log loaded for partition topic-example1277-2 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-1]
2020-04-20 23:45:26,386 INFO [Partition topic-example1277-2 broker=0] topic-example1277-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:45:26,400 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 2010 for partition topic-example1277-2 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:45:26,400 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 2010 from controller 1 epoch 1 for the become-leader transition for partition topic-example1277-2 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:45:26,424 TRACE [Broker id=0] 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 2011 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:45:26,424 TRACE [Broker id=0] 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 2011 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:45:26,424 TRACE [Broker id=0] 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 2011 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:45:26,685 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1285', partitionIndex=1, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 2012 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:45:26,685 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 2012 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1285-1 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:45:26,685 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example1285-1) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-5]
2020-04-20 23:45:26,706 INFO [Log partition=topic-example1285-1, dir=/var/lib/kafka/data/kafka-log0] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-5]
2020-04-20 23:45:26,706 INFO [Log partition=topic-example1285-1, dir=/var/lib/kafka/data/kafka-log0] 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:45:26,707 INFO Created log for partition topic-example1285-1 in /var/lib/kafka/data/kafka-log0/topic-example1285-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:45:26,709 INFO [Partition topic-example1285-1 broker=0] No checkpointed highwatermark is found for partition topic-example1285-1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-5]
2020-04-20 23:45:26,709 INFO [Partition topic-example1285-1 broker=0] Log loaded for partition topic-example1285-1 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-5]
2020-04-20 23:45:26,709 INFO [Partition topic-example1285-1 broker=0] topic-example1285-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:45:26,757 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 2012 for partition topic-example1285-1 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:45:26,757 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 2012 from controller 1 epoch 1 for the become-leader transition for partition topic-example1285-1 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:45:26,833 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1285', partitionIndex=1, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example1285-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2013 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:45:26,833 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1285', partitionIndex=0, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example1285-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2013 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:45:26,833 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1285', partitionIndex=2, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example1285-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2013 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:45:26,963 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1314', partitionIndex=1, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 2014 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:45:26,963 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1300', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 2014 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:45:26,963 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1294', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 2014 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:45:26,964 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 2014 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1314-1 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:45:26,964 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 2014 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1300-2 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:45:26,964 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 2014 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1294-0 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:45:26,964 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example1314-1, topic-example1300-2, topic-example1294-0) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-6]
2020-04-20 23:45:27,046 INFO [Log partition=topic-example1314-1, dir=/var/lib/kafka/data/kafka-log0] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-6]
2020-04-20 23:45:27,047 INFO [Log partition=topic-example1314-1, dir=/var/lib/kafka/data/kafka-log0] 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-6]
2020-04-20 23:45:27,047 INFO Created log for partition topic-example1314-1 in /var/lib/kafka/data/kafka-log0/topic-example1314-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-6]
2020-04-20 23:45:27,049 INFO [Partition topic-example1314-1 broker=0] No checkpointed highwatermark is found for partition topic-example1314-1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-6]
2020-04-20 23:45:27,049 INFO [Partition topic-example1314-1 broker=0] Log loaded for partition topic-example1314-1 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-6]
2020-04-20 23:45:27,049 INFO [Partition topic-example1314-1 broker=0] topic-example1314-1 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:45:27,091 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 2014 for partition topic-example1314-1 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:45:27,115 INFO [Log partition=topic-example1300-2, dir=/var/lib/kafka/data/kafka-log0] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-6]
2020-04-20 23:45:27,119 INFO [Log partition=topic-example1300-2, dir=/var/lib/kafka/data/kafka-log0] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 5 ms (kafka.log.Log) [data-plane-kafka-request-handler-6]
2020-04-20 23:45:27,122 INFO Created log for partition topic-example1300-2 in /var/lib/kafka/data/kafka-log0/topic-example1300-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-6]
2020-04-20 23:45:27,153 INFO [Partition topic-example1300-2 broker=0] No checkpointed highwatermark is found for partition topic-example1300-2 (kafka.cluster.Partition) [data-plane-kafka-request-handler-6]
2020-04-20 23:45:27,153 INFO [Partition topic-example1300-2 broker=0] Log loaded for partition topic-example1300-2 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-6]
2020-04-20 23:45:27,153 INFO [Partition topic-example1300-2 broker=0] topic-example1300-2 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:45:27,184 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 2014 for partition topic-example1300-2 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:47:26,616 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1142', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 2574 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:47:26,616 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 2574 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1142-2 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:47:26,616 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example1142-2) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-6]
2020-04-20 23:47:26,630 INFO [Log partition=topic-example1142-2, dir=/var/lib/kafka/data/kafka-log0] 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,630 INFO [Log partition=topic-example1142-2, dir=/var/lib/kafka/data/kafka-log0] 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,630 INFO Created log for partition topic-example1142-2 in /var/lib/kafka/data/kafka-log0/topic-example1142-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-6]
2020-04-20 23:47:26,633 INFO [Partition topic-example1142-2 broker=0] No checkpointed highwatermark is found for partition topic-example1142-2 (kafka.cluster.Partition) [data-plane-kafka-request-handler-6]
2020-04-20 23:47:26,633 INFO [Partition topic-example1142-2 broker=0] Log loaded for partition topic-example1142-2 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-6]
2020-04-20 23:47:26,633 INFO [Partition topic-example1142-2 broker=0] topic-example1142-2 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,657 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 2574 for partition topic-example1142-2 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:47:26,657 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 2574 from controller 1 epoch 1 for the become-leader transition for partition topic-example1142-2 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:47:26,676 TRACE [Broker id=0] 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 2575 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:47:26,676 TRACE [Broker id=0] 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 2575 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:47:26,676 TRACE [Broker id=0] 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 2575 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:47:26,684 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1143', partitionIndex=1, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 2576 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:26,685 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 2576 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1143-1 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:26,685 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example1143-1) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:26,690 INFO [Log partition=topic-example1143-1, dir=/var/lib/kafka/data/kafka-log0] 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,691 INFO [Log partition=topic-example1143-1, dir=/var/lib/kafka/data/kafka-log0] 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:47:26,691 INFO Created log for partition topic-example1143-1 in /var/lib/kafka/data/kafka-log0/topic-example1143-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:26,694 INFO [Partition topic-example1143-1 broker=0] No checkpointed highwatermark is found for partition topic-example1143-1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:26,694 INFO [Partition topic-example1143-1 broker=0] Log loaded for partition topic-example1143-1 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:26,694 INFO [Partition topic-example1143-1 broker=0] topic-example1143-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:26,721 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 2576 for partition topic-example1143-1 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:26,721 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 2576 from controller 1 epoch 1 for the become-leader transition for partition topic-example1143-1 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:26,738 TRACE [Broker id=0] 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 2577 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:47:26,738 TRACE [Broker id=0] 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 2577 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:47:26,738 TRACE [Broker id=0] 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 2577 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:47:26,771 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1144', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 2578 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:26,771 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 2578 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1144-2 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:26,771 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example1144-2) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:26,786 INFO [Log partition=topic-example1144-2, dir=/var/lib/kafka/data/kafka-log0] 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:26,786 INFO [Log partition=topic-example1144-2, dir=/var/lib/kafka/data/kafka-log0] 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:26,787 INFO Created log for partition topic-example1144-2 in /var/lib/kafka/data/kafka-log0/topic-example1144-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:47:26,790 INFO [Partition topic-example1144-2 broker=0] No checkpointed highwatermark is found for partition topic-example1144-2 (kafka.cluster.Partition) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:26,790 INFO [Partition topic-example1144-2 broker=0] Log loaded for partition topic-example1144-2 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:26,790 INFO [Partition topic-example1144-2 broker=0] topic-example1144-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:47:26,801 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 2578 for partition topic-example1144-2 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:26,801 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 2578 from controller 1 epoch 1 for the become-leader transition for partition topic-example1144-2 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:26,816 TRACE [Broker id=0] 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 2579 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:26,817 TRACE [Broker id=0] 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 2579 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:26,817 TRACE [Broker id=0] 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 2579 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:26,869 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1145', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 2580 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:47:26,869 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 2580 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1145-2 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:47:26,869 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example1145-2) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-2]
2020-04-20 23:47:26,875 INFO [Log partition=topic-example1145-2, dir=/var/lib/kafka/data/kafka-log0] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-2]
2020-04-20 23:47:26,876 INFO [Log partition=topic-example1145-2, dir=/var/lib/kafka/data/kafka-log0] 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:47:26,876 INFO Created log for partition topic-example1145-2 in /var/lib/kafka/data/kafka-log0/topic-example1145-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:47:26,879 INFO [Partition topic-example1145-2 broker=0] No checkpointed highwatermark is found for partition topic-example1145-2 (kafka.cluster.Partition) [data-plane-kafka-request-handler-2]
2020-04-20 23:47:26,879 INFO [Partition topic-example1145-2 broker=0] Log loaded for partition topic-example1145-2 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-2]
2020-04-20 23:47:26,879 INFO [Partition topic-example1145-2 broker=0] topic-example1145-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:47:26,886 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 2580 for partition topic-example1145-2 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:47:26,886 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 2580 from controller 1 epoch 1 for the become-leader transition for partition topic-example1145-2 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:47:26,922 TRACE [Broker id=0] 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 2581 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:47:26,922 TRACE [Broker id=0] 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 2581 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:47:26,922 TRACE [Broker id=0] 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 2581 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:47:27,003 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1146', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 2582 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:27,003 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 2582 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1146-0 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:27,003 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example1146-0) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:27,007 INFO [Log partition=topic-example1146-0, dir=/var/lib/kafka/data/kafka-log0] 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:27,007 INFO [Log partition=topic-example1146-0, dir=/var/lib/kafka/data/kafka-log0] 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:27,008 INFO Created log for partition topic-example1146-0 in /var/lib/kafka/data/kafka-log0/topic-example1146-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:27,017 INFO [Partition topic-example1146-0 broker=0] No checkpointed highwatermark is found for partition topic-example1146-0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:27,017 INFO [Partition topic-example1146-0 broker=0] Log loaded for partition topic-example1146-0 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:27,017 INFO [Partition topic-example1146-0 broker=0] topic-example1146-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:27,026 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 2582 for partition topic-example1146-0 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:27,026 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 2582 from controller 1 epoch 1 for the become-leader transition for partition topic-example1146-0 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:27,034 TRACE [Broker id=0] 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 2583 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:47:27,034 TRACE [Broker id=0] 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 2583 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:47:27,034 TRACE [Broker id=0] 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 2583 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:47:27,067 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1147', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 2584 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:47:27,067 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 2584 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1147-2 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:47:27,067 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example1147-2) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-5]
2020-04-20 23:47:27,078 INFO [Log partition=topic-example1147-2, dir=/var/lib/kafka/data/kafka-log0] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-5]
2020-04-20 23:47:27,078 INFO [Log partition=topic-example1147-2, dir=/var/lib/kafka/data/kafka-log0] 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:47:27,079 INFO Created log for partition topic-example1147-2 in /var/lib/kafka/data/kafka-log0/topic-example1147-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-5]
2020-04-20 23:47:27,082 INFO [Partition topic-example1147-2 broker=0] No checkpointed highwatermark is found for partition topic-example1147-2 (kafka.cluster.Partition) [data-plane-kafka-request-handler-5]
2020-04-20 23:47:27,083 INFO [Partition topic-example1147-2 broker=0] Log loaded for partition topic-example1147-2 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-5]
2020-04-20 23:47:27,083 INFO [Partition topic-example1147-2 broker=0] topic-example1147-2 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:47:27,088 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 2584 for partition topic-example1147-2 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:47:27,088 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 2584 from controller 1 epoch 1 for the become-leader transition for partition topic-example1147-2 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:47:27,096 TRACE [Broker id=0] 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 2585 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:47:27,096 TRACE [Broker id=0] 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 2585 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:47:27,096 TRACE [Broker id=0] 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 2585 (state.change.logger) [data-plane-kafka-request-handler-6]
2020-04-20 23:47:27,183 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1149', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 2586 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:47:27,184 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 2586 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1149-2 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:47:27,184 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example1149-2) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-5]
2020-04-20 23:47:27,189 INFO [Log partition=topic-example1149-2, dir=/var/lib/kafka/data/kafka-log0] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-5]
2020-04-20 23:47:27,189 INFO [Log partition=topic-example1149-2, dir=/var/lib/kafka/data/kafka-log0] 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:47:27,189 INFO Created log for partition topic-example1149-2 in /var/lib/kafka/data/kafka-log0/topic-example1149-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-5]
2020-04-20 23:47:27,191 INFO [Partition topic-example1149-2 broker=0] No checkpointed highwatermark is found for partition topic-example1149-2 (kafka.cluster.Partition) [data-plane-kafka-request-handler-5]
2020-04-20 23:47:27,191 INFO [Partition topic-example1149-2 broker=0] Log loaded for partition topic-example1149-2 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-5]
2020-04-20 23:47:27,191 INFO [Partition topic-example1149-2 broker=0] topic-example1149-2 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:47:56,572 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1345', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 2924 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:56,572 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 2924 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1345-2 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:56,572 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example1345-2) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:56,582 INFO [Log partition=topic-example1345-2, dir=/var/lib/kafka/data/kafka-log0] 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:56,582 INFO [Log partition=topic-example1345-2, dir=/var/lib/kafka/data/kafka-log0] 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:47:56,583 INFO Created log for partition topic-example1345-2 in /var/lib/kafka/data/kafka-log0/topic-example1345-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:47:56,584 INFO [Partition topic-example1345-2 broker=0] No checkpointed highwatermark is found for partition topic-example1345-2 (kafka.cluster.Partition) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:56,584 INFO [Partition topic-example1345-2 broker=0] Log loaded for partition topic-example1345-2 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:56,584 INFO [Partition topic-example1345-2 broker=0] topic-example1345-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:47:56,588 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 2924 for partition topic-example1345-2 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:56,588 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 2924 from controller 1 epoch 1 for the become-leader transition for partition topic-example1345-2 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:56,596 TRACE [Broker id=0] 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 2925 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:47:56,596 TRACE [Broker id=0] 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 2925 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:47:56,596 TRACE [Broker id=0] 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 2925 (state.change.logger) [data-plane-kafka-request-handler-5]
2020-04-20 23:47:56,656 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1347', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], 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,657 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 2926 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1347-0 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:56,657 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example1347-0) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:56,661 INFO [Log partition=topic-example1347-0, dir=/var/lib/kafka/data/kafka-log0] 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,662 INFO [Log partition=topic-example1347-0, dir=/var/lib/kafka/data/kafka-log0] 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,662 INFO Created log for partition topic-example1347-0 in /var/lib/kafka/data/kafka-log0/topic-example1347-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,697 INFO [Partition topic-example1347-0 broker=0] No checkpointed highwatermark is found for partition topic-example1347-0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:56,697 INFO [Partition topic-example1347-0 broker=0] Log loaded for partition topic-example1347-0 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:56,697 INFO [Partition topic-example1347-0 broker=0] topic-example1347-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,699 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 2926 for partition topic-example1347-0 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:56,699 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 2926 from controller 1 epoch 1 for the become-leader transition for partition topic-example1347-0 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:47:56,707 TRACE [Broker id=0] 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 2927 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:47:56,707 TRACE [Broker id=0] 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 2927 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:47:56,707 TRACE [Broker id=0] 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 2927 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:47:56,842 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1348', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 2928 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:47:56,843 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 2928 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1348-2 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:47:56,843 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example1348-2) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-4]
2020-04-20 23:47:56,849 INFO [Log partition=topic-example1348-2, dir=/var/lib/kafka/data/kafka-log0] 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:56,849 INFO [Log partition=topic-example1348-2, dir=/var/lib/kafka/data/kafka-log0] 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:56,850 INFO Created log for partition topic-example1348-2 in /var/lib/kafka/data/kafka-log0/topic-example1348-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:56,853 INFO [Partition topic-example1348-2 broker=0] No checkpointed highwatermark is found for partition topic-example1348-2 (kafka.cluster.Partition) [data-plane-kafka-request-handler-4]
2020-04-20 23:47:56,853 INFO [Partition topic-example1348-2 broker=0] Log loaded for partition topic-example1348-2 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-4]
2020-04-20 23:47:56,853 INFO [Partition topic-example1348-2 broker=0] topic-example1348-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:56,856 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 2928 for partition topic-example1348-2 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:47:56,856 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 2928 from controller 1 epoch 1 for the become-leader transition for partition topic-example1348-2 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:47:56,867 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1348', partitionIndex=1, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example1348-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2929 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:56,867 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1348', partitionIndex=0, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example1348-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2929 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:56,867 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1348', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example1348-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2929 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:56,981 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1349', partitionIndex=1, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 2930 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:56,982 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 2930 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1349-1 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:56,982 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example1349-1) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:56,991 INFO [Log partition=topic-example1349-1, dir=/var/lib/kafka/data/kafka-log0] 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:56,991 INFO [Log partition=topic-example1349-1, dir=/var/lib/kafka/data/kafka-log0] 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:47:56,992 INFO Created log for partition topic-example1349-1 in /var/lib/kafka/data/kafka-log0/topic-example1349-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:47:56,995 INFO [Partition topic-example1349-1 broker=0] No checkpointed highwatermark is found for partition topic-example1349-1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:56,995 INFO [Partition topic-example1349-1 broker=0] Log loaded for partition topic-example1349-1 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:56,995 INFO [Partition topic-example1349-1 broker=0] topic-example1349-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:47:57,001 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 2930 for partition topic-example1349-1 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:57,001 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 2930 from controller 1 epoch 1 for the become-leader transition for partition topic-example1349-1 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:47:57,020 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1349', partitionIndex=0, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example1349-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2931 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:57,020 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1349', partitionIndex=2, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example1349-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2931 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:47:57,020 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1349', partitionIndex=1, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example1349-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 2931 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:48:26,566 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1578', partitionIndex=1, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 3326 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:48:26,566 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 3326 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1578-1 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:48:26,566 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example1578-1) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-4]
2020-04-20 23:48:26,581 INFO [Log partition=topic-example1578-1, dir=/var/lib/kafka/data/kafka-log0] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-4]
2020-04-20 23:48:26,581 INFO [Log partition=topic-example1578-1, dir=/var/lib/kafka/data/kafka-log0] 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:48:26,581 INFO Created log for partition topic-example1578-1 in /var/lib/kafka/data/kafka-log0/topic-example1578-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:48:26,586 INFO [Partition topic-example1578-1 broker=0] No checkpointed highwatermark is found for partition topic-example1578-1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-4]
2020-04-20 23:48:26,586 INFO [Partition topic-example1578-1 broker=0] Log loaded for partition topic-example1578-1 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-4]
2020-04-20 23:48:26,586 INFO [Partition topic-example1578-1 broker=0] topic-example1578-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:48:26,588 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 3326 for partition topic-example1578-1 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:48:26,588 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 3326 from controller 1 epoch 1 for the become-leader transition for partition topic-example1578-1 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:48:26,640 TRACE [Broker id=0] 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 3327 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:48:26,640 TRACE [Broker id=0] 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 3327 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:48:26,640 TRACE [Broker id=0] 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 3327 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:48:26,796 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1579', partitionIndex=1, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 3328 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:48:26,797 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 3328 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1579-1 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:48:26,797 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example1579-1) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-4]
2020-04-20 23:48:26,825 INFO [Log partition=topic-example1579-1, dir=/var/lib/kafka/data/kafka-log0] Loading producer state till offset 0 with message format version 2 (kafka.log.Log) [data-plane-kafka-request-handler-4]
2020-04-20 23:48:26,825 INFO [Log partition=topic-example1579-1, dir=/var/lib/kafka/data/kafka-log0] 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:48:26,825 INFO Created log for partition topic-example1579-1 in /var/lib/kafka/data/kafka-log0/topic-example1579-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:48:26,830 INFO [Partition topic-example1579-1 broker=0] No checkpointed highwatermark is found for partition topic-example1579-1 (kafka.cluster.Partition) [data-plane-kafka-request-handler-4]
2020-04-20 23:48:26,831 INFO [Partition topic-example1579-1 broker=0] Log loaded for partition topic-example1579-1 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-4]
2020-04-20 23:48:26,831 INFO [Partition topic-example1579-1 broker=0] topic-example1579-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:48:26,839 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 3328 for partition topic-example1579-1 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:48:26,839 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 3328 from controller 1 epoch 1 for the become-leader transition for partition topic-example1579-1 (state.change.logger) [data-plane-kafka-request-handler-4]
2020-04-20 23:48:26,857 TRACE [Broker id=0] 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 3329 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:48:26,857 TRACE [Broker id=0] 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 3329 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:48:26,857 TRACE [Broker id=0] 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 3329 (state.change.logger) [data-plane-kafka-request-handler-0]
2020-04-20 23:48:27,033 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1580', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 3330 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:48:27,034 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 3330 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1580-0 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:48:27,034 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example1580-0) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-1]
2020-04-20 23:48:27,037 INFO [Log partition=topic-example1580-0, dir=/var/lib/kafka/data/kafka-log0] 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:27,038 INFO [Log partition=topic-example1580-0, dir=/var/lib/kafka/data/kafka-log0] 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:48:27,038 INFO Created log for partition topic-example1580-0 in /var/lib/kafka/data/kafka-log0/topic-example1580-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:48:27,040 INFO [Partition topic-example1580-0 broker=0] No checkpointed highwatermark is found for partition topic-example1580-0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-1]
2020-04-20 23:48:27,040 INFO [Partition topic-example1580-0 broker=0] Log loaded for partition topic-example1580-0 with initial high watermark 0 (kafka.cluster.Partition) [data-plane-kafka-request-handler-1]
2020-04-20 23:48:27,040 INFO [Partition topic-example1580-0 broker=0] topic-example1580-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:48:27,042 TRACE [Broker id=0] Stopped fetchers as part of become-leader request from controller 1 epoch 1 with correlation id 3330 for partition topic-example1580-0 (last update controller epoch 1) (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:48:27,042 TRACE [Broker id=0] Completed LeaderAndIsr request correlationId 3330 from controller 1 epoch 1 for the become-leader transition for partition topic-example1580-0 (state.change.logger) [data-plane-kafka-request-handler-1]
2020-04-20 23:48:27,058 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1580', partitionIndex=0, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], offlineReplicas=[]) for partition topic-example1580-0 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 3331 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:48:27,058 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1580', partitionIndex=2, controllerEpoch=1, leader=1, leaderEpoch=0, isr=[1], zkVersion=0, replicas=[1], offlineReplicas=[]) for partition topic-example1580-2 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 3331 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:48:27,058 TRACE [Broker id=0] Cached leader info UpdateMetadataPartitionState(topicName='topic-example1580', partitionIndex=1, controllerEpoch=1, leader=2, leaderEpoch=0, isr=[2], zkVersion=0, replicas=[2], offlineReplicas=[]) for partition topic-example1580-1 in response to UpdateMetadata request sent by controller 1 epoch 1 with correlation id 3331 (state.change.logger) [data-plane-kafka-request-handler-2]
2020-04-20 23:48:27,144 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1582', partitionIndex=1, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 3332 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:48:27,144 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 3332 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1582-1 (state.change.logger) [data-plane-kafka-request-handler-3]
2020-04-20 23:48:27,144 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example1582-1) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-3]
2020-04-20 23:48:27,147 INFO [Log partition=topic-example1582-1, dir=/var/lib/kafka/data/kafka-log0] 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:27,148 INFO [Log partition=topic-example1582-1, dir=/var/lib/kafka/data/kafka-log0] 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:27,148 INFO Created log for partition topic-example1582-1 in /var/lib/kafka/data/kafka-log0/topic-example1582-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,587 TRACE [Broker id=0] Received LeaderAndIsr request LeaderAndIsrPartitionState(topicName='topic-example1777', partitionIndex=2, controllerEpoch=1, leader=0, leaderEpoch=0, isr=[0], zkVersion=0, replicas=[0], addingReplicas=[], removingReplicas=[], isNew=true) correlation id 3680 from controller 1 epoch 1 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:48:56,588 TRACE [Broker id=0] Handling LeaderAndIsr request correlationId 3680 from controller 1 epoch 1 starting the become-leader transition for partition topic-example1777-2 (state.change.logger) [data-plane-kafka-request-handler-7]
2020-04-20 23:48:56,588 INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(topic-example1777-2) (kafka.server.ReplicaFetcherManager) [data-plane-kafka-request-handler-7]