2024-04-22T14:34:57.632979164Z kafka 14:34:57.62 
2024-04-22T14:34:57.635652910Z kafka 14:34:57.62 Welcome to the Bitnami kafka container
2024-04-22T14:34:57.645976799Z kafka 14:34:57.64 Subscribe to project updates by watching https://github.com/bitnami/containers
2024-04-22T14:34:57.653056496Z kafka 14:34:57.64 Submit issues and feature requests at https://github.com/bitnami/containers/issues
2024-04-22T14:34:57.654820168Z kafka 14:34:57.65 
2024-04-22T14:34:57.662979195Z kafka 14:34:57.66 INFO  ==> ** Starting Kafka setup **
2024-04-22T14:34:57.851274593Z kafka 14:34:57.85 INFO  ==> Initializing KRaft storage metadata
2024-04-22T14:34:57.854082356Z kafka 14:34:57.85 INFO  ==> Adding KRaft SCRAM users at storage bootstrap
2024-04-22T14:34:57.874242304Z kafka 14:34:57.87 INFO  ==> Formatting storage directories to add metadata...
2024-04-22T14:35:04.546151095Z Formatting /bitnami/kafka/data with metadata.version 3.5-IV2.
2024-04-22T14:35:04.948650846Z kafka 14:35:04.94 INFO  ==> ** Kafka setup finished! **
2024-04-22T14:35:04.948659016Z 
2024-04-22T14:35:04.978044283Z kafka 14:35:04.97 INFO  ==> ** Starting Kafka **
2024-04-22T14:35:08.620090665Z [2024-04-22 14:35:08,619] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
2024-04-22T14:35:09.260900597Z [2024-04-22 14:35:09,260] INFO Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation (org.apache.zookeeper.common.X509Util)
2024-04-22T14:35:09.718322026Z [2024-04-22 14:35:09,718] INFO Registered signal handlers for TERM, INT, HUP (org.apache.kafka.common.utils.LoggingSignalHandler)
2024-04-22T14:35:09.723559779Z [2024-04-22 14:35:09,723] INFO [ControllerServer id=2] Starting controller (kafka.server.ControllerServer)
2024-04-22T14:35:10.438114279Z [2024-04-22 14:35:10,437] INFO Updated connection-accept-rate max connection creation rate to 2147483647 (kafka.network.ConnectionQuotas)
2024-04-22T14:35:10.652421486Z [2024-04-22 14:35:10,643] INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin)
2024-04-22T14:35:10.684425148Z [2024-04-22 14:35:10,682] INFO [SocketServer listenerType=CONTROLLER, nodeId=2] Created data-plane acceptor and processors for endpoint : ListenerName(CONTROLLER) (kafka.network.SocketServer)
2024-04-22T14:35:10.689326264Z [2024-04-22 14:35:10,688] INFO [SharedServer id=2] Starting SharedServer (kafka.server.SharedServer)
2024-04-22T14:35:10.788948769Z [2024-04-22 14:35:10,782] INFO [LogLoader partition=__cluster_metadata-0, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:35:10.788962087Z [2024-04-22 14:35:10,783] INFO [LogLoader partition=__cluster_metadata-0, dir=/bitnami/kafka/data] Reloading from producer snapshot and rebuilding producer state from offset 0 (kafka.log.UnifiedLog$)
2024-04-22T14:35:10.788966173Z [2024-04-22 14:35:10,784] INFO [LogLoader partition=__cluster_metadata-0, dir=/bitnami/kafka/data] Producer state recovery took 1ms for snapshot load and 0ms for segment recovery from offset 0 (kafka.log.UnifiedLog$)
2024-04-22T14:35:10.850155839Z [2024-04-22 14:35:10,846] INFO Initialized snapshots with IDs Set() from /bitnami/kafka/data/__cluster_metadata-0 (kafka.raft.KafkaMetadataLog$)
2024-04-22T14:35:10.887151899Z [2024-04-22 14:35:10,885] INFO [raft-expiration-reaper]: Starting (kafka.raft.TimingWheelExpirationService$ExpiredOperationReaper)
2024-04-22T14:35:11.830827328Z [2024-04-22 14:35:11,830] INFO [RaftManager id=2] Completed transition to Unattached(epoch=0, voters=[0, 1, 2], electionTimeoutMs=1759) from null (org.apache.kafka.raft.QuorumState)
2024-04-22T14:35:11.854239506Z [2024-04-22 14:35:11,854] INFO [kafka-2-raft-outbound-request-thread]: Starting (kafka.raft.RaftSendThread)
2024-04-22T14:35:11.854991930Z [2024-04-22 14:35:11,854] INFO [kafka-2-raft-io-thread]: Starting (kafka.raft.KafkaRaftManager$RaftIoThread)
2024-04-22T14:35:11.993569443Z [2024-04-22 14:35:11,993] INFO [RaftManager id=2] Registered the listener org.apache.kafka.image.loader.MetadataLoader@823878874 (org.apache.kafka.raft.KafkaRaftClient)
2024-04-22T14:35:12.005075293Z [2024-04-22 14:35:12,002] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader)
2024-04-22T14:35:12.065277370Z [2024-04-22 14:35:12,060] INFO [ControllerServer id=2] Waiting for controller quorum voters future (kafka.server.ControllerServer)
2024-04-22T14:35:12.065306777Z [2024-04-22 14:35:12,061] INFO [ControllerServer id=2] Finished waiting for controller quorum voters future (kafka.server.ControllerServer)
2024-04-22T14:35:12.105287527Z [2024-04-22 14:35:12,105] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader)
2024-04-22T14:35:12.207818524Z [2024-04-22 14:35:12,207] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader)
2024-04-22T14:35:12.309244782Z [2024-04-22 14:35:12,309] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader)
2024-04-22T14:35:12.317270825Z [2024-04-22 14:35:12,314] INFO [QuorumController id=2] Creating new QuorumController with clusterId 63UaSEiq0cP7wK9P7VSYwQ, authorizer Optional.empty. (org.apache.kafka.controller.QuorumController)
2024-04-22T14:35:12.317288560Z [2024-04-22 14:35:12,315] INFO [RaftManager id=2] Registered the listener org.apache.kafka.controller.QuorumController$QuorumMetaLogListener@877920684 (org.apache.kafka.raft.KafkaRaftClient)
2024-04-22T14:35:12.338615490Z [2024-04-22 14:35:12,337] INFO [controller-2-ThrottledChannelReaper-Fetch]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
2024-04-22T14:35:12.343221244Z [2024-04-22 14:35:12,341] INFO [controller-2-ThrottledChannelReaper-Produce]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
2024-04-22T14:35:12.345778759Z [2024-04-22 14:35:12,345] INFO [controller-2-ThrottledChannelReaper-Request]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
2024-04-22T14:35:12.370045390Z [2024-04-22 14:35:12,356] INFO [controller-2-ThrottledChannelReaper-ControllerMutation]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
2024-04-22T14:35:12.409597352Z [2024-04-22 14:35:12,409] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader)
2024-04-22T14:35:12.424285930Z [2024-04-22 14:35:12,424] INFO [ExpirationReaper-2-AlterAcls]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
2024-04-22T14:35:12.503003979Z [2024-04-22 14:35:12,502] INFO [SocketServer listenerType=CONTROLLER, nodeId=2] Enabling request processing. (kafka.network.SocketServer)
2024-04-22T14:35:12.517196074Z [2024-04-22 14:35:12,509] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader)
2024-04-22T14:35:12.542318827Z [2024-04-22 14:35:12,541] INFO Awaiting socket connections on 0.0.0.0:9093. (kafka.network.DataPlaneAcceptor)
2024-04-22T14:35:12.610313115Z [2024-04-22 14:35:12,610] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader)
2024-04-22T14:35:12.709877508Z [2024-04-22 14:35:12,709] INFO [ControllerServer id=2] Waiting for all of the authorizer futures to be completed (kafka.server.ControllerServer)
2024-04-22T14:35:12.709897014Z [2024-04-22 14:35:12,709] INFO [ControllerServer id=2] Finished waiting for all of the authorizer futures to be completed (kafka.server.ControllerServer)
2024-04-22T14:35:12.710688449Z [2024-04-22 14:35:12,709] INFO [ControllerServer id=2] Waiting for all of the SocketServer Acceptors to be started (kafka.server.ControllerServer)
2024-04-22T14:35:12.717043872Z [2024-04-22 14:35:12,710] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader)
2024-04-22T14:35:12.717075236Z [2024-04-22 14:35:12,714] INFO [ControllerServer id=2] Finished waiting for all of the SocketServer Acceptors to be started (kafka.server.ControllerServer)
2024-04-22T14:35:12.722007294Z [2024-04-22 14:35:12,721] INFO [RaftManager id=2] Completed transition to CandidateState(localId=2, epoch=1, retries=1, voteStates={0=UNRECORDED, 1=UNRECORDED, 2=GRANTED}, highWatermark=Optional.empty, electionTimeoutMs=1031) from Unattached(epoch=0, voters=[0, 1, 2], electionTimeoutMs=1759) (org.apache.kafka.raft.QuorumState)
2024-04-22T14:35:12.732737582Z [2024-04-22 14:35:12,728] INFO [QuorumController id=2] In the new epoch 1, the leader is (none). (org.apache.kafka.controller.QuorumController)
2024-04-22T14:35:12.740944351Z [2024-04-22 14:35:12,740] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader)
2024-04-22T14:35:12.742396756Z [2024-04-22 14:35:12,740] INFO [ControllerServer id=2] Waiting for the controller metadata publishers to be installed (kafka.server.ControllerServer)
2024-04-22T14:35:12.742468032Z [2024-04-22 14:35:12,742] INFO [ControllerServer id=2] Finished waiting for the controller metadata publishers to be installed (kafka.server.ControllerServer)
2024-04-22T14:35:12.749288831Z [2024-04-22 14:35:12,748] INFO [BrokerServer id=2] Transition from SHUTDOWN to STARTING (kafka.server.BrokerServer)
2024-04-22T14:35:12.749303106Z [2024-04-22 14:35:12,748] INFO [BrokerServer id=2] Starting broker (kafka.server.BrokerServer)
2024-04-22T14:35:12.851937228Z [2024-04-22 14:35:12,850] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader)
2024-04-22T14:35:12.880229626Z [2024-04-22 14:35:12,880] INFO [broker-2-ThrottledChannelReaper-Fetch]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
2024-04-22T14:35:12.893333728Z [2024-04-22 14:35:12,893] INFO [broker-2-ThrottledChannelReaper-Produce]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
2024-04-22T14:35:12.894756300Z [2024-04-22 14:35:12,894] INFO [broker-2-ThrottledChannelReaper-Request]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
2024-04-22T14:35:12.943159681Z [2024-04-22 14:35:12,905] WARN [RaftManager id=2] Error connecting to node kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9093 (id: 0 rack: null) (org.apache.kafka.clients.NetworkClient)
2024-04-22T14:35:12.943217279Z java.net.UnknownHostException: kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local
2024-04-22T14:35:12.943239458Z 	at java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:801)
2024-04-22T14:35:12.943242838Z 	at java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1533)
2024-04-22T14:35:12.943246018Z 	at java.base/java.net.InetAddress.getAllByName(InetAddress.java:1385)
2024-04-22T14:35:12.943249232Z 	at java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)
2024-04-22T14:35:12.943253054Z 	at org.apache.kafka.clients.DefaultHostResolver.resolve(DefaultHostResolver.java:27)
2024-04-22T14:35:12.943256148Z 	at org.apache.kafka.clients.ClientUtils.resolve(ClientUtils.java:110)
2024-04-22T14:35:12.943259641Z 	at org.apache.kafka.clients.ClusterConnectionStates$NodeConnectionState.currentAddress(ClusterConnectionStates.java:510)
2024-04-22T14:35:12.943262763Z 	at org.apache.kafka.clients.ClusterConnectionStates$NodeConnectionState.access$200(ClusterConnectionStates.java:467)
2024-04-22T14:35:12.943265861Z 	at org.apache.kafka.clients.ClusterConnectionStates.currentAddress(ClusterConnectionStates.java:173)
2024-04-22T14:35:12.943268937Z 	at org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:1030)
2024-04-22T14:35:12.943272164Z 	at org.apache.kafka.clients.NetworkClient.ready(NetworkClient.java:301)
2024-04-22T14:35:12.943315252Z 	at kafka.common.InterBrokerSendThread.$anonfun$sendRequests$1(InterBrokerSendThread.scala:107)
2024-04-22T14:35:12.943322414Z 	at kafka.common.InterBrokerSendThread.$anonfun$sendRequests$1$adapted(InterBrokerSendThread.scala:103)
2024-04-22T14:35:12.943326233Z 	at scala.collection.Iterator.foreach(Iterator.scala:943)
2024-04-22T14:35:12.943329449Z 	at scala.collection.Iterator.foreach$(Iterator.scala:943)
2024-04-22T14:35:12.943332446Z 	at scala.collection.AbstractIterator.foreach(Iterator.scala:1431)
2024-04-22T14:35:12.943335500Z 	at scala.collection.IterableLike.foreach(IterableLike.scala:74)
2024-04-22T14:35:12.943338609Z 	at scala.collection.IterableLike.foreach$(IterableLike.scala:73)
2024-04-22T14:35:12.943342370Z 	at scala.collection.AbstractIterable.foreach(Iterable.scala:56)
2024-04-22T14:35:12.943345515Z 	at kafka.common.InterBrokerSendThread.sendRequests(InterBrokerSendThread.scala:103)
2024-04-22T14:35:12.943348592Z 	at kafka.common.InterBrokerSendThread.pollOnce(InterBrokerSendThread.scala:77)
2024-04-22T14:35:12.943351649Z 	at kafka.common.InterBrokerSendThread.doWork(InterBrokerSendThread.scala:98)
2024-04-22T14:35:12.943354644Z 	at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:127)
2024-04-22T14:35:12.953078556Z [2024-04-22 14:35:12,952] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader)
2024-04-22T14:35:12.960891582Z [2024-04-22 14:35:12,912] INFO [broker-2-ThrottledChannelReaper-ControllerMutation]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
2024-04-22T14:35:13.061531331Z [2024-04-22 14:35:13,061] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader)
2024-04-22T14:35:13.193887335Z [2024-04-22 14:35:13,193] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader)
2024-04-22T14:35:13.253000439Z [2024-04-22 14:35:13,250] INFO [RaftManager id=2] Completed transition to Unattached(epoch=2, voters=[0, 1, 2], electionTimeoutMs=510) from CandidateState(localId=2, epoch=1, retries=1, voteStates={0=UNRECORDED, 1=UNRECORDED, 2=GRANTED}, highWatermark=Optional.empty, electionTimeoutMs=1031) (org.apache.kafka.raft.QuorumState)
2024-04-22T14:35:13.256954953Z [2024-04-22 14:35:13,253] INFO [QuorumController id=2] In the new epoch 2, the leader is (none). (org.apache.kafka.controller.QuorumController)
2024-04-22T14:35:13.281079114Z [2024-04-22 14:35:13,280] INFO [BrokerServer id=2] Waiting for controller quorum voters future (kafka.server.BrokerServer)
2024-04-22T14:35:13.281092026Z [2024-04-22 14:35:13,280] INFO [BrokerServer id=2] Finished waiting for controller quorum voters future (kafka.server.BrokerServer)
2024-04-22T14:35:13.296967950Z [2024-04-22 14:35:13,294] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader)
2024-04-22T14:35:13.337439916Z [2024-04-22 14:35:13,337] INFO [broker-2-to-controller-forwarding-channel-manager]: Starting (kafka.server.BrokerToControllerRequestThread)
2024-04-22T14:35:13.405356691Z [2024-04-22 14:35:13,405] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader)
2024-04-22T14:35:13.453722773Z [2024-04-22 14:35:13,453] INFO [RaftManager id=2] Completed transition to Unattached(epoch=3, voters=[0, 1, 2], electionTimeoutMs=306) from Unattached(epoch=2, voters=[0, 1, 2], electionTimeoutMs=510) (org.apache.kafka.raft.QuorumState)
2024-04-22T14:35:13.453797797Z [2024-04-22 14:35:13,453] INFO [QuorumController id=2] In the new epoch 3, the leader is (none). (org.apache.kafka.controller.QuorumController)
2024-04-22T14:35:13.488998498Z [2024-04-22 14:35:13,488] INFO [RaftManager id=2] Completed transition to Voted(epoch=3, votedId=1, voters=[0, 1, 2], electionTimeoutMs=1833) from Unattached(epoch=3, voters=[0, 1, 2], electionTimeoutMs=306) (org.apache.kafka.raft.QuorumState)
2024-04-22T14:35:13.508993815Z [2024-04-22 14:35:13,505] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader)
2024-04-22T14:35:13.521168971Z [2024-04-22 14:35:13,520] INFO [RaftManager id=2] Vote request VoteRequestData(clusterId='63UaSEiq0cP7wK9P7VSYwQ', topics=[TopicData(topicName='__cluster_metadata', partitions=[PartitionData(partitionIndex=0, candidateEpoch=3, candidateId=1, lastOffsetEpoch=0, lastOffset=0)])]) with epoch 3 is granted (org.apache.kafka.raft.KafkaRaftClient)
2024-04-22T14:35:13.605864143Z [2024-04-22 14:35:13,605] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader)
2024-04-22T14:35:13.665013011Z [2024-04-22 14:35:13,661] INFO Updated connection-accept-rate max connection creation rate to 2147483647 (kafka.network.ConnectionQuotas)
2024-04-22T14:35:13.710147308Z [2024-04-22 14:35:13,709] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader)
2024-04-22T14:35:13.733010823Z [2024-04-22 14:35:13,730] INFO [SocketServer listenerType=BROKER, nodeId=2] Created data-plane acceptor and processors for endpoint : ListenerName(CLIENT) (kafka.network.SocketServer)
2024-04-22T14:35:13.733025791Z [2024-04-22 14:35:13,730] INFO Updated connection-accept-rate max connection creation rate to 2147483647 (kafka.network.ConnectionQuotas)
2024-04-22T14:35:13.761011439Z [2024-04-22 14:35:13,758] INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin)
2024-04-22T14:35:13.778792017Z [2024-04-22 14:35:13,777] INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin)
2024-04-22T14:35:13.816318900Z [2024-04-22 14:35:13,809] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader)
2024-04-22T14:35:13.821754633Z [2024-04-22 14:35:13,817] INFO [SocketServer listenerType=BROKER, nodeId=2] Created data-plane acceptor and processors for endpoint : ListenerName(INTERNAL) (kafka.network.SocketServer)
2024-04-22T14:35:13.830313609Z [2024-04-22 14:35:13,824] INFO [broker-2-to-controller-alter-partition-channel-manager]: Starting (kafka.server.BrokerToControllerRequestThread)
2024-04-22T14:35:13.837187476Z [2024-04-22 14:35:13,837] INFO [ExpirationReaper-2-Produce]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
2024-04-22T14:35:13.889710757Z [2024-04-22 14:35:13,886] INFO [ExpirationReaper-2-Fetch]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
2024-04-22T14:35:13.907193461Z [2024-04-22 14:35:13,896] INFO [ExpirationReaper-2-DeleteRecords]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
2024-04-22T14:35:13.907205101Z [2024-04-22 14:35:13,897] INFO [ExpirationReaper-2-ElectLeader]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
2024-04-22T14:35:14.109017327Z [2024-04-22 14:35:14,098] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader)
2024-04-22T14:35:14.167000794Z [2024-04-22 14:35:14,163] INFO [RaftManager id=2] Completed transition to FollowerState(fetchTimeoutMs=2000, epoch=3, leaderId=1, voters=[0, 1, 2], highWatermark=Optional.empty, fetchingSnapshot=Optional.empty) from Voted(epoch=3, votedId=1, voters=[0, 1, 2], electionTimeoutMs=1833) (org.apache.kafka.raft.QuorumState)
2024-04-22T14:35:14.167016299Z [2024-04-22 14:35:14,165] INFO [QuorumController id=2] In the new epoch 3, the leader is 1. (org.apache.kafka.controller.QuorumController)
2024-04-22T14:35:14.169287274Z [2024-04-22 14:35:14,168] INFO [ExpirationReaper-2-Heartbeat]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
2024-04-22T14:35:14.237331501Z [2024-04-22 14:35:14,233] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader)
2024-04-22T14:35:14.237349799Z [2024-04-22 14:35:14,234] INFO [broker-2-to-controller-forwarding-channel-manager]: Recorded new controller, from now on will use node kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9093 (id: 1 rack: null) (kafka.server.BrokerToControllerRequestThread)
2024-04-22T14:35:14.237354414Z [2024-04-22 14:35:14,234] INFO [broker-2-to-controller-alter-partition-channel-manager]: Recorded new controller, from now on will use node kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9093 (id: 1 rack: null) (kafka.server.BrokerToControllerRequestThread)
2024-04-22T14:35:14.244085682Z [2024-04-22 14:35:14,241] INFO [ExpirationReaper-2-Rebalance]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
2024-04-22T14:35:14.348528047Z [2024-04-22 14:35:14,344] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader)
2024-04-22T14:35:14.414812331Z [2024-04-22 14:35:14,414] INFO [BrokerLifecycleManager id=2] Incarnation h1C7o5D8SviPj1AgemRrnA of broker 2 in cluster 63UaSEiq0cP7wK9P7VSYwQ is now STARTING. (kafka.server.BrokerLifecycleManager)
2024-04-22T14:35:14.415922457Z [2024-04-22 14:35:14,414] INFO [broker-2-to-controller-heartbeat-channel-manager]: Starting (kafka.server.BrokerToControllerRequestThread)
2024-04-22T14:35:14.415929373Z [2024-04-22 14:35:14,415] INFO [broker-2-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9093 (id: 1 rack: null) (kafka.server.BrokerToControllerRequestThread)
2024-04-22T14:35:14.448448879Z [2024-04-22 14:35:14,448] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader)
2024-04-22T14:35:14.451040903Z [2024-04-22 14:35:14,450] INFO [ExpirationReaper-2-AlterAcls]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
2024-04-22T14:35:14.513095952Z [2024-04-22 14:35:14,511] INFO [RaftManager id=2] High watermark set to Optional[LogOffsetMetadata(offset=7, metadata=Optional.empty)] for the first time for epoch 3 (org.apache.kafka.raft.FollowerState)
2024-04-22T14:35:14.529023661Z [2024-04-22 14:35:14,524] INFO [QuorumController id=2] Setting metadata version to 3.5-IV2 (org.apache.kafka.controller.FeatureControlManager)
2024-04-22T14:35:14.529039136Z [2024-04-22 14:35:14,527] INFO [QuorumController id=2] Created new SCRAM credential for user with mechanism SCRAM_SHA_256. (org.apache.kafka.controller.ScramControlManager)
2024-04-22T14:35:14.529043119Z [2024-04-22 14:35:14,527] INFO [QuorumController id=2] Created new SCRAM credential for user with mechanism SCRAM_SHA_512. (org.apache.kafka.controller.ScramControlManager)
2024-04-22T14:35:14.529047588Z [2024-04-22 14:35:14,528] INFO [QuorumController id=2] Transitioning ZK migration state from NONE to NONE (org.apache.kafka.controller.FeatureControlManager)
2024-04-22T14:35:14.536349091Z [2024-04-22 14:35:14,530] INFO [MetadataLoader id=2] initializeNewPublishers: The loader is still catching up because we have loaded up to offset -1, but the high water mark is 7 (org.apache.kafka.image.loader.MetadataLoader)
2024-04-22T14:35:14.536359904Z [2024-04-22 14:35:14,530] INFO [BrokerServer id=2] Waiting for the broker metadata publishers to be installed (kafka.server.BrokerServer)
2024-04-22T14:35:14.536364285Z [2024-04-22 14:35:14,533] INFO [BrokerServer id=2] Finished waiting for the broker metadata publishers to be installed (kafka.server.BrokerServer)
2024-04-22T14:35:14.536367936Z [2024-04-22 14:35:14,533] INFO [BrokerServer id=2] Waiting for the controller to acknowledge that we are caught up (kafka.server.BrokerServer)
2024-04-22T14:35:14.540541159Z [2024-04-22 14:35:14,539] INFO [QuorumController id=2] Registered new broker: RegisterBrokerRecord(brokerId=1, isMigratingZkBroker=false, incarnationId=dgZuq5j3TAig6VLkDCcKLg, brokerEpoch=4, endPoints=[BrokerEndpoint(name='CLIENT', host='kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local', port=9092, securityProtocol=0), BrokerEndpoint(name='INTERNAL', host='kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local', port=9094, securityProtocol=2)], features=[BrokerFeature(name='metadata.version', minSupportedVersion=1, maxSupportedVersion=11)], rack=null, fenced=true, inControlledShutdown=false) (org.apache.kafka.controller.ClusterControlManager)
2024-04-22T14:35:14.553569855Z [2024-04-22 14:35:14,552] INFO [BrokerLifecycleManager id=2] Successfully registered broker 2 with broker epoch 7 (kafka.server.BrokerLifecycleManager)
2024-04-22T14:35:14.559708890Z [2024-04-22 14:35:14,556] INFO [MetadataLoader id=2] handleCommit: The loader finished catching up to the current high water mark of 7 (org.apache.kafka.image.loader.MetadataLoader)
2024-04-22T14:35:14.637074770Z [2024-04-22 14:35:14,633] INFO [MetadataLoader id=2] InitializeNewPublishers: initializing SnapshotGenerator with a snapshot at offset 6 (org.apache.kafka.image.loader.MetadataLoader)
2024-04-22T14:35:14.637088439Z [2024-04-22 14:35:14,634] INFO [MetadataLoader id=2] InitializeNewPublishers: initializing DynamicConfigPublisher controller id=2 with a snapshot at offset 6 (org.apache.kafka.image.loader.MetadataLoader)
2024-04-22T14:35:14.637092938Z [2024-04-22 14:35:14,635] INFO [MetadataLoader id=2] InitializeNewPublishers: initializing DynamicClientQuotaPublisher controller id=2 with a snapshot at offset 6 (org.apache.kafka.image.loader.MetadataLoader)
2024-04-22T14:35:14.637101279Z [2024-04-22 14:35:14,635] INFO [MetadataLoader id=2] InitializeNewPublishers: initializing ScramPublisher controller id=2 with a snapshot at offset 6 (org.apache.kafka.image.loader.MetadataLoader)
2024-04-22T14:35:14.637105475Z [2024-04-22 14:35:14,636] INFO [MetadataLoader id=2] InitializeNewPublishers: initializing ControllerMetadataMetricsPublisher with a snapshot at offset 6 (org.apache.kafka.image.loader.MetadataLoader)
2024-04-22T14:35:14.639975402Z [2024-04-22 14:35:14,639] INFO [MetadataLoader id=2] InitializeNewPublishers: initializing BrokerMetadataPublisher with a snapshot at offset 6 (org.apache.kafka.image.loader.MetadataLoader)
2024-04-22T14:35:14.640952411Z [2024-04-22 14:35:14,640] INFO [BrokerMetadataPublisher id=2] Publishing initial metadata at offset OffsetAndEpoch(offset=6, epoch=3) with metadata.version 3.5-IV2. (kafka.server.metadata.BrokerMetadataPublisher)
2024-04-22T14:35:14.652963170Z [2024-04-22 14:35:14,645] INFO Loading logs from log dirs ArrayBuffer(/bitnami/kafka/data) (kafka.log.LogManager)
2024-04-22T14:35:14.654904482Z [2024-04-22 14:35:14,654] INFO No logs found to be loaded in /bitnami/kafka/data (kafka.log.LogManager)
2024-04-22T14:35:14.658138697Z [2024-04-22 14:35:14,657] INFO [QuorumController id=2] Registered new broker: RegisterBrokerRecord(brokerId=2, isMigratingZkBroker=false, incarnationId=h1C7o5D8SviPj1AgemRrnA, brokerEpoch=7, endPoints=[BrokerEndpoint(name='CLIENT', host='kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local', port=9092, securityProtocol=0), BrokerEndpoint(name='INTERNAL', host='kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local', port=9094, securityProtocol=2)], features=[BrokerFeature(name='metadata.version', minSupportedVersion=1, maxSupportedVersion=11)], rack=null, fenced=true, inControlledShutdown=false) (org.apache.kafka.controller.ClusterControlManager)
2024-04-22T14:35:14.711866895Z [2024-04-22 14:35:14,708] INFO Loaded 0 logs in 62ms (kafka.log.LogManager)
2024-04-22T14:35:14.720661430Z [2024-04-22 14:35:14,708] INFO Starting log cleanup with a period of 300000 ms. (kafka.log.LogManager)
2024-04-22T14:35:14.763019677Z [2024-04-22 14:35:14,761] INFO Starting log flusher with a default period of 9223372036854775807 ms. (kafka.log.LogManager)
2024-04-22T14:35:14.844991691Z [2024-04-22 14:35:14,844] INFO Starting the log cleaner (kafka.log.LogCleaner)
2024-04-22T14:35:15.113040931Z [2024-04-22 14:35:15,110] INFO [kafka-log-cleaner-thread-0]: Starting (kafka.log.LogCleaner$CleanerThread)
2024-04-22T14:35:15.153994856Z [2024-04-22 14:35:15,147] INFO [GroupCoordinator 2]: Starting up. (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:35:15.154009200Z [2024-04-22 14:35:15,149] INFO [LogDirFailureHandler]: Starting (kafka.server.ReplicaManager$LogDirFailureHandler)
2024-04-22T14:35:15.154013047Z [2024-04-22 14:35:15,149] INFO [GroupCoordinator 2]: Startup complete. (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:35:15.154016522Z [2024-04-22 14:35:15,149] INFO [TransactionCoordinator id=2] Starting up. (kafka.coordinator.transaction.TransactionCoordinator)
2024-04-22T14:35:15.154427323Z [2024-04-22 14:35:15,154] INFO [TransactionCoordinator id=2] Startup complete. (kafka.coordinator.transaction.TransactionCoordinator)
2024-04-22T14:35:15.156271823Z [2024-04-22 14:35:15,155] INFO [BrokerMetadataPublisher id=2] Updating metadata.version to 11 at offset OffsetAndEpoch(offset=6, epoch=3). (kafka.server.metadata.BrokerMetadataPublisher)
2024-04-22T14:35:15.197146117Z [2024-04-22 14:35:15,195] INFO [TxnMarkerSenderThread-2]: Starting (kafka.coordinator.transaction.TransactionMarkerChannelManager)
2024-04-22T14:35:15.350346414Z [2024-04-22 14:35:15,349] INFO [BrokerLifecycleManager id=2] The broker has caught up. Transitioning from STARTING to RECOVERY. (kafka.server.BrokerLifecycleManager)
2024-04-22T14:35:15.351546671Z [2024-04-22 14:35:15,351] INFO [BrokerServer id=2] Finished waiting for the controller to acknowledge that we are caught up (kafka.server.BrokerServer)
2024-04-22T14:35:15.351557859Z [2024-04-22 14:35:15,351] INFO [BrokerServer id=2] Waiting for the initial broker metadata update to be published (kafka.server.BrokerServer)
2024-04-22T14:35:15.354395539Z [2024-04-22 14:35:15,351] INFO [BrokerServer id=2] Finished waiting for the initial broker metadata update to be published (kafka.server.BrokerServer)
2024-04-22T14:35:15.360298691Z [2024-04-22 14:35:15,358] INFO KafkaConfig values: 
2024-04-22T14:35:15.360315839Z 	advertised.listeners = CLIENT://kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9092,INTERNAL://kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094
2024-04-22T14:35:15.360320295Z 	alter.config.policy.class.name = null
2024-04-22T14:35:15.360323210Z 	alter.log.dirs.replication.quota.window.num = 11
2024-04-22T14:35:15.360326151Z 	alter.log.dirs.replication.quota.window.size.seconds = 1
2024-04-22T14:35:15.360329706Z 	authorizer.class.name = 
2024-04-22T14:35:15.360332612Z 	auto.create.topics.enable = true
2024-04-22T14:35:15.360335487Z 	auto.include.jmx.reporter = true
2024-04-22T14:35:15.360338468Z 	auto.leader.rebalance.enable = true
2024-04-22T14:35:15.360341657Z 	background.threads = 10
2024-04-22T14:35:15.360344484Z 	broker.heartbeat.interval.ms = 2000
2024-04-22T14:35:15.360347384Z 	broker.id = 2
2024-04-22T14:35:15.360350218Z 	broker.id.generation.enable = true
2024-04-22T14:35:15.360352985Z 	broker.rack = null
2024-04-22T14:35:15.360355783Z 	broker.session.timeout.ms = 9000
2024-04-22T14:35:15.360358634Z 	client.quota.callback.class = null
2024-04-22T14:35:15.360361408Z 	compression.type = producer
2024-04-22T14:35:15.360364170Z 	connection.failed.authentication.delay.ms = 100
2024-04-22T14:35:15.360366926Z 	connections.max.idle.ms = 600000
2024-04-22T14:35:15.360369835Z 	connections.max.reauth.ms = 0
2024-04-22T14:35:15.360372583Z 	control.plane.listener.name = null
2024-04-22T14:35:15.360375332Z 	controlled.shutdown.enable = true
2024-04-22T14:35:15.360378212Z 	controlled.shutdown.max.retries = 3
2024-04-22T14:35:15.360381058Z 	controlled.shutdown.retry.backoff.ms = 5000
2024-04-22T14:35:15.360383858Z 	controller.listener.names = CONTROLLER
2024-04-22T14:35:15.360386602Z 	controller.quorum.append.linger.ms = 25
2024-04-22T14:35:15.360389381Z 	controller.quorum.election.backoff.max.ms = 1000
2024-04-22T14:35:15.360392205Z 	controller.quorum.election.timeout.ms = 1000
2024-04-22T14:35:15.360394941Z 	controller.quorum.fetch.timeout.ms = 2000
2024-04-22T14:35:15.360397678Z 	controller.quorum.request.timeout.ms = 2000
2024-04-22T14:35:15.360400421Z 	controller.quorum.retry.backoff.ms = 20
2024-04-22T14:35:15.360404054Z 	controller.quorum.voters = [0@kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9093, 1@kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9093, 2@kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9093]
2024-04-22T14:35:15.360406842Z 	controller.quota.window.num = 11
2024-04-22T14:35:15.360409592Z 	controller.quota.window.size.seconds = 1
2024-04-22T14:35:15.360412331Z 	controller.socket.timeout.ms = 30000
2024-04-22T14:35:15.360415386Z 	create.topic.policy.class.name = null
2024-04-22T14:35:15.360418234Z 	default.replication.factor = 1
2024-04-22T14:35:15.360421009Z 	delegation.token.expiry.check.interval.ms = 3600000
2024-04-22T14:35:15.360423745Z 	delegation.token.expiry.time.ms = 86400000
2024-04-22T14:35:15.360431524Z 	delegation.token.master.key = null
2024-04-22T14:35:15.360434392Z 	delegation.token.max.lifetime.ms = 604800000
2024-04-22T14:35:15.360437182Z 	delegation.token.secret.key = null
2024-04-22T14:35:15.360440108Z 	delete.records.purgatory.purge.interval.requests = 1
2024-04-22T14:35:15.360447407Z 	delete.topic.enable = true
2024-04-22T14:35:15.360450347Z 	early.start.listeners = null
2024-04-22T14:35:15.360453455Z 	fetch.max.bytes = 57671680
2024-04-22T14:35:15.360456245Z 	fetch.purgatory.purge.interval.requests = 1000
2024-04-22T14:35:15.360458991Z 	group.consumer.assignors = []
2024-04-22T14:35:15.360461787Z 	group.consumer.heartbeat.interval.ms = 5000
2024-04-22T14:35:15.360464690Z 	group.consumer.max.heartbeat.interval.ms = 15000
2024-04-22T14:35:15.360467456Z 	group.consumer.max.session.timeout.ms = 60000
2024-04-22T14:35:15.360470225Z 	group.consumer.max.size = 2147483647
2024-04-22T14:35:15.360473078Z 	group.consumer.min.heartbeat.interval.ms = 5000
2024-04-22T14:35:15.360475837Z 	group.consumer.min.session.timeout.ms = 45000
2024-04-22T14:35:15.360478591Z 	group.consumer.session.timeout.ms = 45000
2024-04-22T14:35:15.360481447Z 	group.coordinator.new.enable = false
2024-04-22T14:35:15.360484289Z 	group.coordinator.threads = 1
2024-04-22T14:35:15.360487089Z 	group.initial.rebalance.delay.ms = 3000
2024-04-22T14:35:15.360489814Z 	group.max.session.timeout.ms = 1800000
2024-04-22T14:35:15.360492683Z 	group.max.size = 2147483647
2024-04-22T14:35:15.360495454Z 	group.min.session.timeout.ms = 6000
2024-04-22T14:35:15.360498219Z 	initial.broker.registration.timeout.ms = 60000
2024-04-22T14:35:15.360500972Z 	inter.broker.listener.name = INTERNAL
2024-04-22T14:35:15.360503778Z 	inter.broker.protocol.version = 3.5-IV2
2024-04-22T14:35:15.360506988Z 	kafka.metrics.polling.interval.secs = 10
2024-04-22T14:35:15.360509823Z 	kafka.metrics.reporters = []
2024-04-22T14:35:15.360512561Z 	leader.imbalance.check.interval.seconds = 300
2024-04-22T14:35:15.360517629Z 	leader.imbalance.per.broker.percentage = 10
2024-04-22T14:35:15.360521323Z 	listener.security.protocol.map = CLIENT:PLAINTEXT,INTERNAL:SASL_PLAINTEXT,CONTROLLER:SASL_PLAINTEXT
2024-04-22T14:35:15.360524430Z 	listeners = CLIENT://:9092,INTERNAL://:9094,CONTROLLER://:9093
2024-04-22T14:35:15.360527238Z 	log.cleaner.backoff.ms = 15000
2024-04-22T14:35:15.360530075Z 	log.cleaner.dedupe.buffer.size = 134217728
2024-04-22T14:35:15.360532841Z 	log.cleaner.delete.retention.ms = 86400000
2024-04-22T14:35:15.360535691Z 	log.cleaner.enable = true
2024-04-22T14:35:15.360538471Z 	log.cleaner.io.buffer.load.factor = 0.9
2024-04-22T14:35:15.360541332Z 	log.cleaner.io.buffer.size = 524288
2024-04-22T14:35:15.360544082Z 	log.cleaner.io.max.bytes.per.second = 1.7976931348623157E308
2024-04-22T14:35:15.360546861Z 	log.cleaner.max.compaction.lag.ms = 9223372036854775807
2024-04-22T14:35:15.360549628Z 	log.cleaner.min.cleanable.ratio = 0.5
2024-04-22T14:35:15.360552492Z 	log.cleaner.min.compaction.lag.ms = 0
2024-04-22T14:35:15.360555303Z 	log.cleaner.threads = 1
2024-04-22T14:35:15.360558046Z 	log.cleanup.policy = [delete]
2024-04-22T14:35:15.360560904Z 	log.dir = /bitnami/kafka/data
2024-04-22T14:35:15.360563806Z 	log.dirs = null
2024-04-22T14:35:15.360566606Z 	log.flush.interval.messages = 9223372036854775807
2024-04-22T14:35:15.360569418Z 	log.flush.interval.ms = null
2024-04-22T14:35:15.360572270Z 	log.flush.offset.checkpoint.interval.ms = 60000
2024-04-22T14:35:15.360575024Z 	log.flush.scheduler.interval.ms = 9223372036854775807
2024-04-22T14:35:15.360577834Z 	log.flush.start.offset.checkpoint.interval.ms = 60000
2024-04-22T14:35:15.360584234Z 	log.index.interval.bytes = 4096
2024-04-22T14:35:15.360587167Z 	log.index.size.max.bytes = 10485760
2024-04-22T14:35:15.360590029Z 	log.message.downconversion.enable = true
2024-04-22T14:35:15.360594595Z 	log.message.format.version = 3.0-IV1
2024-04-22T14:35:15.360597877Z 	log.message.timestamp.difference.max.ms = 9223372036854775807
2024-04-22T14:35:15.360600756Z 	log.message.timestamp.type = CreateTime
2024-04-22T14:35:15.360603663Z 	log.preallocate = false
2024-04-22T14:35:15.360606568Z 	log.retention.bytes = -1
2024-04-22T14:35:15.360609445Z 	log.retention.check.interval.ms = 300000
2024-04-22T14:35:15.360612408Z 	log.retention.hours = 168
2024-04-22T14:35:15.360615326Z 	log.retention.minutes = null
2024-04-22T14:35:15.360618191Z 	log.retention.ms = null
2024-04-22T14:35:15.360621107Z 	log.roll.hours = 168
2024-04-22T14:35:15.360624349Z 	log.roll.jitter.hours = 0
2024-04-22T14:35:15.360627327Z 	log.roll.jitter.ms = null
2024-04-22T14:35:15.360630296Z 	log.roll.ms = null
2024-04-22T14:35:15.360633231Z 	log.segment.bytes = 1073741824
2024-04-22T14:35:15.360636135Z 	log.segment.delete.delay.ms = 60000
2024-04-22T14:35:15.360639026Z 	max.connection.creation.rate = 2147483647
2024-04-22T14:35:15.360641989Z 	max.connections = 2147483647
2024-04-22T14:35:15.360644870Z 	max.connections.per.ip = 2147483647
2024-04-22T14:35:15.360647744Z 	max.connections.per.ip.overrides = 
2024-04-22T14:35:15.360650761Z 	max.incremental.fetch.session.cache.slots = 1000
2024-04-22T14:35:15.360653804Z 	message.max.bytes = 1048588
2024-04-22T14:35:15.360656816Z 	metadata.log.dir = null
2024-04-22T14:35:15.360659712Z 	metadata.log.max.record.bytes.between.snapshots = 20971520
2024-04-22T14:35:15.360662610Z 	metadata.log.max.snapshot.interval.ms = 3600000
2024-04-22T14:35:15.360665610Z 	metadata.log.segment.bytes = 1073741824
2024-04-22T14:35:15.360668491Z 	metadata.log.segment.min.bytes = 8388608
2024-04-22T14:35:15.360671395Z 	metadata.log.segment.ms = 604800000
2024-04-22T14:35:15.360674314Z 	metadata.max.idle.interval.ms = 500
2024-04-22T14:35:15.360677314Z 	metadata.max.retention.bytes = 104857600
2024-04-22T14:35:15.360680176Z 	metadata.max.retention.ms = 604800000
2024-04-22T14:35:15.360683165Z 	metric.reporters = []
2024-04-22T14:35:15.360686065Z 	metrics.num.samples = 2
2024-04-22T14:35:15.360689045Z 	metrics.recording.level = INFO
2024-04-22T14:35:15.360691943Z 	metrics.sample.window.ms = 30000
2024-04-22T14:35:15.360694848Z 	min.insync.replicas = 1
2024-04-22T14:35:15.360697886Z 	node.id = 2
2024-04-22T14:35:15.360700805Z 	num.io.threads = 8
2024-04-22T14:35:15.360703702Z 	num.network.threads = 3
2024-04-22T14:35:15.360706571Z 	num.partitions = 1
2024-04-22T14:35:15.360709479Z 	num.recovery.threads.per.data.dir = 1
2024-04-22T14:35:15.360712374Z 	num.replica.alter.log.dirs.threads = null
2024-04-22T14:35:15.360715317Z 	num.replica.fetchers = 1
2024-04-22T14:35:15.360718194Z 	offset.metadata.max.bytes = 4096
2024-04-22T14:35:15.360721110Z 	offsets.commit.required.acks = -1
2024-04-22T14:35:15.360724008Z 	offsets.commit.timeout.ms = 5000
2024-04-22T14:35:15.360726880Z 	offsets.load.buffer.size = 5242880
2024-04-22T14:35:15.360729739Z 	offsets.retention.check.interval.ms = 600000
2024-04-22T14:35:15.360732605Z 	offsets.retention.minutes = 10080
2024-04-22T14:35:15.360735469Z 	offsets.topic.compression.codec = 0
2024-04-22T14:35:15.360738338Z 	offsets.topic.num.partitions = 50
2024-04-22T14:35:15.360741205Z 	offsets.topic.replication.factor = 3
2024-04-22T14:35:15.360744086Z 	offsets.topic.segment.bytes = 104857600
2024-04-22T14:35:15.360752406Z 	password.encoder.cipher.algorithm = AES/CBC/PKCS5Padding
2024-04-22T14:35:15.360755456Z 	password.encoder.iterations = 4096
2024-04-22T14:35:15.360758237Z 	password.encoder.key.length = 128
2024-04-22T14:35:15.360761021Z 	password.encoder.keyfactory.algorithm = null
2024-04-22T14:35:15.360763850Z 	password.encoder.old.secret = null
2024-04-22T14:35:15.360766661Z 	password.encoder.secret = null
2024-04-22T14:35:15.360769531Z 	principal.builder.class = class org.apache.kafka.common.security.authenticator.DefaultKafkaPrincipalBuilder
2024-04-22T14:35:15.360772367Z 	process.roles = [controller, broker]
2024-04-22T14:35:15.360775227Z 	producer.id.expiration.check.interval.ms = 600000
2024-04-22T14:35:15.360778048Z 	producer.id.expiration.ms = 86400000
2024-04-22T14:35:15.360780882Z 	producer.purgatory.purge.interval.requests = 1000
2024-04-22T14:35:15.360783710Z 	queued.max.request.bytes = -1
2024-04-22T14:35:15.360786644Z 	queued.max.requests = 500
2024-04-22T14:35:15.360789459Z 	quota.window.num = 11
2024-04-22T14:35:15.360792310Z 	quota.window.size.seconds = 1
2024-04-22T14:35:15.360795158Z 	remote.log.index.file.cache.total.size.bytes = 1073741824
2024-04-22T14:35:15.360797984Z 	remote.log.manager.task.interval.ms = 30000
2024-04-22T14:35:15.360800833Z 	remote.log.manager.task.retry.backoff.max.ms = 30000
2024-04-22T14:35:15.360803620Z 	remote.log.manager.task.retry.backoff.ms = 500
2024-04-22T14:35:15.360806423Z 	remote.log.manager.task.retry.jitter = 0.2
2024-04-22T14:35:15.360809219Z 	remote.log.manager.thread.pool.size = 10
2024-04-22T14:35:15.360812021Z 	remote.log.metadata.manager.class.name = null
2024-04-22T14:35:15.360814815Z 	remote.log.metadata.manager.class.path = null
2024-04-22T14:35:15.360817617Z 	remote.log.metadata.manager.impl.prefix = null
2024-04-22T14:35:15.360820464Z 	remote.log.metadata.manager.listener.name = null
2024-04-22T14:35:15.360823293Z 	remote.log.reader.max.pending.tasks = 100
2024-04-22T14:35:15.360826100Z 	remote.log.reader.threads = 10
2024-04-22T14:35:15.360829064Z 	remote.log.storage.manager.class.name = null
2024-04-22T14:35:15.360842482Z 	remote.log.storage.manager.class.path = null
2024-04-22T14:35:15.360845285Z 	remote.log.storage.manager.impl.prefix = null
2024-04-22T14:35:15.360848073Z 	remote.log.storage.system.enable = false
2024-04-22T14:35:15.360850883Z 	replica.fetch.backoff.ms = 1000
2024-04-22T14:35:15.360853708Z 	replica.fetch.max.bytes = 1048576
2024-04-22T14:35:15.360856502Z 	replica.fetch.min.bytes = 1
2024-04-22T14:35:15.360876504Z 	replica.fetch.response.max.bytes = 10485760
2024-04-22T14:35:15.360879779Z 	replica.fetch.wait.max.ms = 500
2024-04-22T14:35:15.360882829Z 	replica.high.watermark.checkpoint.interval.ms = 5000
2024-04-22T14:35:15.360885803Z 	replica.lag.time.max.ms = 30000
2024-04-22T14:35:15.360899473Z 	replica.selector.class = null
2024-04-22T14:35:15.360903798Z 	replica.socket.receive.buffer.bytes = 65536
2024-04-22T14:35:15.360906786Z 	replica.socket.timeout.ms = 30000
2024-04-22T14:35:15.360909771Z 	replication.quota.window.num = 11
2024-04-22T14:35:15.360912686Z 	replication.quota.window.size.seconds = 1
2024-04-22T14:35:15.360915628Z 	request.timeout.ms = 30000
2024-04-22T14:35:15.360918575Z 	reserved.broker.max.id = 1000
2024-04-22T14:35:15.360921503Z 	sasl.client.callback.handler.class = null
2024-04-22T14:35:15.360924519Z 	sasl.enabled.mechanisms = [PLAIN, SCRAM-SHA-256, SCRAM-SHA-512]
2024-04-22T14:35:15.360927492Z 	sasl.jaas.config = null
2024-04-22T14:35:15.360930460Z 	sasl.kerberos.kinit.cmd = /usr/bin/kinit
2024-04-22T14:35:15.360933685Z 	sasl.kerberos.min.time.before.relogin = 60000
2024-04-22T14:35:15.360941310Z 	sasl.kerberos.principal.to.local.rules = [DEFAULT]
2024-04-22T14:35:15.360944402Z 	sasl.kerberos.service.name = null
2024-04-22T14:35:15.360947327Z 	sasl.kerberos.ticket.renew.jitter = 0.05
2024-04-22T14:35:15.360950296Z 	sasl.kerberos.ticket.renew.window.factor = 0.8
2024-04-22T14:35:15.360955002Z 	sasl.login.callback.handler.class = null
2024-04-22T14:35:15.360963410Z 	sasl.login.class = null
2024-04-22T14:35:15.360966867Z 	sasl.login.connect.timeout.ms = null
2024-04-22T14:35:15.360969844Z 	sasl.login.read.timeout.ms = null
2024-04-22T14:35:15.360972789Z 	sasl.login.refresh.buffer.seconds = 300
2024-04-22T14:35:15.360975791Z 	sasl.login.refresh.min.period.seconds = 60
2024-04-22T14:35:15.360978755Z 	sasl.login.refresh.window.factor = 0.8
2024-04-22T14:35:15.360981729Z 	sasl.login.refresh.window.jitter = 0.05
2024-04-22T14:35:15.360984684Z 	sasl.login.retry.backoff.max.ms = 10000
2024-04-22T14:35:15.360987616Z 	sasl.login.retry.backoff.ms = 100
2024-04-22T14:35:15.360990578Z 	sasl.mechanism.controller.protocol = PLAIN
2024-04-22T14:35:15.360993520Z 	sasl.mechanism.inter.broker.protocol = PLAIN
2024-04-22T14:35:15.360996487Z 	sasl.oauthbearer.clock.skew.seconds = 30
2024-04-22T14:35:15.360999445Z 	sasl.oauthbearer.expected.audience = null
2024-04-22T14:35:15.361002529Z 	sasl.oauthbearer.expected.issuer = null
2024-04-22T14:35:15.361005483Z 	sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
2024-04-22T14:35:15.361008410Z 	sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
2024-04-22T14:35:15.361011365Z 	sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
2024-04-22T14:35:15.361014286Z 	sasl.oauthbearer.jwks.endpoint.url = null
2024-04-22T14:35:15.361017221Z 	sasl.oauthbearer.scope.claim.name = scope
2024-04-22T14:35:15.361020164Z 	sasl.oauthbearer.sub.claim.name = sub
2024-04-22T14:35:15.361023093Z 	sasl.oauthbearer.token.endpoint.url = null
2024-04-22T14:35:15.361026049Z 	sasl.server.callback.handler.class = null
2024-04-22T14:35:15.361028990Z 	sasl.server.max.receive.size = 524288
2024-04-22T14:35:15.361031929Z 	security.inter.broker.protocol = PLAINTEXT
2024-04-22T14:35:15.361034885Z 	security.providers = null
2024-04-22T14:35:15.361037833Z 	server.max.startup.time.ms = 9223372036854775807
2024-04-22T14:35:15.361040750Z 	socket.connection.setup.timeout.max.ms = 30000
2024-04-22T14:35:15.361043704Z 	socket.connection.setup.timeout.ms = 10000
2024-04-22T14:35:15.361046663Z 	socket.listen.backlog.size = 50
2024-04-22T14:35:15.361049632Z 	socket.receive.buffer.bytes = 102400
2024-04-22T14:35:15.361052576Z 	socket.request.max.bytes = 104857600
2024-04-22T14:35:15.361055510Z 	socket.send.buffer.bytes = 102400
2024-04-22T14:35:15.361058465Z 	ssl.cipher.suites = []
2024-04-22T14:35:15.361061442Z 	ssl.client.auth = none
2024-04-22T14:35:15.361064631Z 	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
2024-04-22T14:35:15.361067568Z 	ssl.endpoint.identification.algorithm = https
2024-04-22T14:35:15.361070504Z 	ssl.engine.factory.class = null
2024-04-22T14:35:15.361073562Z 	ssl.key.password = null
2024-04-22T14:35:15.361076519Z 	ssl.keymanager.algorithm = SunX509
2024-04-22T14:35:15.361079457Z 	ssl.keystore.certificate.chain = null
2024-04-22T14:35:15.361082393Z 	ssl.keystore.key = null
2024-04-22T14:35:15.361085444Z 	ssl.keystore.location = null
2024-04-22T14:35:15.361088403Z 	ssl.keystore.password = null
2024-04-22T14:35:15.361091364Z 	ssl.keystore.type = JKS
2024-04-22T14:35:15.361094398Z 	ssl.principal.mapping.rules = DEFAULT
2024-04-22T14:35:15.361097361Z 	ssl.protocol = TLSv1.3
2024-04-22T14:35:15.361100328Z 	ssl.provider = null
2024-04-22T14:35:15.361107335Z 	ssl.secure.random.implementation = null
2024-04-22T14:35:15.361110683Z 	ssl.trustmanager.algorithm = PKIX
2024-04-22T14:35:15.361113755Z 	ssl.truststore.certificates = null
2024-04-22T14:35:15.361116845Z 	ssl.truststore.location = null
2024-04-22T14:35:15.361120050Z 	ssl.truststore.password = null
2024-04-22T14:35:15.361123231Z 	ssl.truststore.type = JKS
2024-04-22T14:35:15.361127007Z 	transaction.abort.timed.out.transaction.cleanup.interval.ms = 10000
2024-04-22T14:35:15.361130139Z 	transaction.max.timeout.ms = 900000
2024-04-22T14:35:15.361133357Z 	transaction.remove.expired.transaction.cleanup.interval.ms = 3600000
2024-04-22T14:35:15.361136554Z 	transaction.state.log.load.buffer.size = 5242880
2024-04-22T14:35:15.361140691Z 	transaction.state.log.min.isr = 2
2024-04-22T14:35:15.361143933Z 	transaction.state.log.num.partitions = 50
2024-04-22T14:35:15.361147122Z 	transaction.state.log.replication.factor = 3
2024-04-22T14:35:15.361150191Z 	transaction.state.log.segment.bytes = 104857600
2024-04-22T14:35:15.361153286Z 	transactional.id.expiration.ms = 604800000
2024-04-22T14:35:15.361156382Z 	unclean.leader.election.enable = false
2024-04-22T14:35:15.361159448Z 	unstable.api.versions.enable = false
2024-04-22T14:35:15.361162517Z 	zookeeper.clientCnxnSocket = null
2024-04-22T14:35:15.361165657Z 	zookeeper.connect = null
2024-04-22T14:35:15.361168822Z 	zookeeper.connection.timeout.ms = null
2024-04-22T14:35:15.361171893Z 	zookeeper.max.in.flight.requests = 10
2024-04-22T14:35:15.361174995Z 	zookeeper.metadata.migration.enable = false
2024-04-22T14:35:15.361178052Z 	zookeeper.session.timeout.ms = 18000
2024-04-22T14:35:15.361368717Z 	zookeeper.set.acl = false
2024-04-22T14:35:15.361373373Z 	zookeeper.ssl.cipher.suites = null
2024-04-22T14:35:15.361376640Z 	zookeeper.ssl.client.enable = false
2024-04-22T14:35:15.361379825Z 	zookeeper.ssl.crl.enable = false
2024-04-22T14:35:15.361383005Z 	zookeeper.ssl.enabled.protocols = null
2024-04-22T14:35:15.361386283Z 	zookeeper.ssl.endpoint.identification.algorithm = HTTPS
2024-04-22T14:35:15.361389554Z 	zookeeper.ssl.keystore.location = null
2024-04-22T14:35:15.361392769Z 	zookeeper.ssl.keystore.password = null
2024-04-22T14:35:15.361395959Z 	zookeeper.ssl.keystore.type = null
2024-04-22T14:35:15.361399220Z 	zookeeper.ssl.ocsp.enable = false
2024-04-22T14:35:15.361402410Z 	zookeeper.ssl.protocol = TLSv1.2
2024-04-22T14:35:15.361405652Z 	zookeeper.ssl.truststore.location = null
2024-04-22T14:35:15.361408815Z 	zookeeper.ssl.truststore.password = null
2024-04-22T14:35:15.361412083Z 	zookeeper.ssl.truststore.type = null
2024-04-22T14:35:15.361415381Z  (kafka.server.KafkaConfig)
2024-04-22T14:35:15.400961587Z [2024-04-22 14:35:15,393] INFO [BrokerServer id=2] Waiting for the broker to be unfenced (kafka.server.BrokerServer)
2024-04-22T14:35:15.419605035Z [2024-04-22 14:35:15,416] INFO [BrokerLifecycleManager id=2] The broker is in RECOVERY. (kafka.server.BrokerLifecycleManager)
2024-04-22T14:35:15.532608931Z [2024-04-22 14:35:15,529] INFO [BrokerLifecycleManager id=2] The broker has been unfenced. Transitioning from RECOVERY to RUNNING. (kafka.server.BrokerLifecycleManager)
2024-04-22T14:35:15.534873506Z [2024-04-22 14:35:15,532] INFO [BrokerServer id=2] Finished waiting for the broker to be unfenced (kafka.server.BrokerServer)
2024-04-22T14:35:15.534884550Z [2024-04-22 14:35:15,532] INFO [SocketServer listenerType=BROKER, nodeId=2] Enabling request processing. (kafka.network.SocketServer)
2024-04-22T14:35:15.534888996Z [2024-04-22 14:35:15,533] INFO Awaiting socket connections on 0.0.0.0:9092. (kafka.network.DataPlaneAcceptor)
2024-04-22T14:35:15.556982204Z [2024-04-22 14:35:15,555] INFO Awaiting socket connections on 0.0.0.0:9094. (kafka.network.DataPlaneAcceptor)
2024-04-22T14:35:15.612165287Z [2024-04-22 14:35:15,611] INFO [BrokerServer id=2] Waiting for all of the authorizer futures to be completed (kafka.server.BrokerServer)
2024-04-22T14:35:15.623532973Z [2024-04-22 14:35:15,623] INFO [BrokerServer id=2] Finished waiting for all of the authorizer futures to be completed (kafka.server.BrokerServer)
2024-04-22T14:35:15.625113260Z [2024-04-22 14:35:15,624] INFO [BrokerServer id=2] Waiting for all of the SocketServer Acceptors to be started (kafka.server.BrokerServer)
2024-04-22T14:35:15.625266195Z [2024-04-22 14:35:15,625] INFO [BrokerServer id=2] Finished waiting for all of the SocketServer Acceptors to be started (kafka.server.BrokerServer)
2024-04-22T14:35:15.625424937Z [2024-04-22 14:35:15,625] INFO [BrokerServer id=2] Transition from STARTING to STARTED (kafka.server.BrokerServer)
2024-04-22T14:35:15.629028294Z [2024-04-22 14:35:15,627] INFO Kafka version: 3.5.1 (org.apache.kafka.common.utils.AppInfoParser)
2024-04-22T14:35:15.629043193Z [2024-04-22 14:35:15,627] INFO Kafka commitId: 2c6fb6c54472e90a (org.apache.kafka.common.utils.AppInfoParser)
2024-04-22T14:35:15.629061001Z [2024-04-22 14:35:15,627] INFO Kafka startTimeMs: 1713796515625 (org.apache.kafka.common.utils.AppInfoParser)
2024-04-22T14:35:15.638156564Z [2024-04-22 14:35:15,635] INFO [KafkaRaftServer nodeId=2] Kafka Server started (kafka.server.KafkaRaftServer)
2024-04-22T14:36:04.511542350Z [2024-04-22 14:36:04,511] INFO [QuorumController id=2] Registered new broker: RegisterBrokerRecord(brokerId=0, isMigratingZkBroker=false, incarnationId=IWRyGaR2T0-q5xLO0YyBfw, brokerEpoch=109, endPoints=[BrokerEndpoint(name='CLIENT', host='kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local', port=9092, securityProtocol=0), BrokerEndpoint(name='INTERNAL', host='kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local', port=9094, securityProtocol=2)], features=[BrokerFeature(name='metadata.version', minSupportedVersion=1, maxSupportedVersion=11)], rack=null, fenced=true, inControlledShutdown=false) (org.apache.kafka.controller.ClusterControlManager)
2024-04-22T14:36:26.664617967Z [2024-04-22 14:36:26,662] INFO [QuorumController id=2] Created topic vim_account with topic ID gUhmt1oUQxql5U5QUXheFA. (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:26.664675533Z [2024-04-22 14:36:26,663] INFO [QuorumController id=2] Created partition vim_account-0 with topic ID gUhmt1oUQxql5U5QUXheFA and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:26.671782089Z [2024-04-22 14:36:26,671] INFO Sent auto-creation request for Set(vim_account) to the active controller. (kafka.server.DefaultAutoTopicCreationManager)
2024-04-22T14:36:27.477899542Z [2024-04-22 14:36:27,477] INFO Sent auto-creation request for Set(wim_account) to the active controller. (kafka.server.DefaultAutoTopicCreationManager)
2024-04-22T14:36:27.718975425Z [2024-04-22 14:36:27,707] INFO [QuorumController id=2] Created topic wim_account with topic ID apGb5OJmTTyL-xasl2b1CQ. (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:27.718997554Z [2024-04-22 14:36:27,707] INFO [QuorumController id=2] Created partition wim_account-0 with topic ID apGb5OJmTTyL-xasl2b1CQ and PartitionRegistration(replicas=[2], isr=[2], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:27.719001985Z [2024-04-22 14:36:27,709] INFO [Broker id=2] Transitioning 1 partition(s) to local leaders. (state.change.logger)
2024-04-22T14:36:27.719006189Z [2024-04-22 14:36:27,711] INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(wim_account-0) (kafka.server.ReplicaFetcherManager)
2024-04-22T14:36:27.719020207Z [2024-04-22 14:36:27,714] INFO [Broker id=2] Creating new partition wim_account-0 with topic id apGb5OJmTTyL-xasl2b1CQ. (state.change.logger)
2024-04-22T14:36:27.770116933Z [2024-04-22 14:36:27,769] INFO [LogLoader partition=wim_account-0, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:36:27.782779429Z [2024-04-22 14:36:27,774] INFO Created log for partition wim_account-0 in /bitnami/kafka/data/wim_account-0 with properties {} (kafka.log.LogManager)
2024-04-22T14:36:27.782790379Z [2024-04-22 14:36:27,777] INFO [Partition wim_account-0 broker=2] No checkpointed highwatermark is found for partition wim_account-0 (kafka.cluster.Partition)
2024-04-22T14:36:27.782793764Z [2024-04-22 14:36:27,779] INFO [Partition wim_account-0 broker=2] Log loaded for partition wim_account-0 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:36:27.783923573Z [2024-04-22 14:36:27,783] INFO [Broker id=2] Leader wim_account-0 with topic id Some(apGb5OJmTTyL-xasl2b1CQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:36:28.180249669Z [2024-04-22 14:36:28,179] INFO [QuorumController id=2] Created topic sdn with topic ID O_nzGhGlTRWAPuS5WrA87w. (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:28.180261091Z [2024-04-22 14:36:28,180] INFO [QuorumController id=2] Created partition sdn-0 with topic ID O_nzGhGlTRWAPuS5WrA87w and PartitionRegistration(replicas=[0], isr=[0], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:32.689838418Z [2024-04-22 14:36:32,687] INFO [QuorumController id=2] Created topic admin with topic ID fjiMEqz9T9W2vCrlT2e8Mw. (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:32.689864951Z [2024-04-22 14:36:32,688] INFO [QuorumController id=2] Created partition admin-0 with topic ID fjiMEqz9T9W2vCrlT2e8Mw and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:32.886738450Z [2024-04-22 14:36:32,886] INFO Sent auto-creation request for Set(ns) to the active controller. (kafka.server.DefaultAutoTopicCreationManager)
2024-04-22T14:36:33.182376438Z [2024-04-22 14:36:33,177] INFO [QuorumController id=2] Created topic ns with topic ID h_99DsLwQmmeqYkrds3_cg. (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:33.183167955Z [2024-04-22 14:36:33,182] INFO [QuorumController id=2] Created partition ns-0 with topic ID h_99DsLwQmmeqYkrds3_cg and PartitionRegistration(replicas=[0], isr=[0], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:33.656201676Z [2024-04-22 14:36:33,655] INFO Sent auto-creation request for Set(nsi) to the active controller. (kafka.server.DefaultAutoTopicCreationManager)
2024-04-22T14:36:33.671727413Z [2024-04-22 14:36:33,670] INFO [QuorumController id=2] Created topic nsi with topic ID lGc3sMx4T8-_29u1na-W_g. (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:33.671745050Z [2024-04-22 14:36:33,671] INFO [QuorumController id=2] Created partition nsi-0 with topic ID lGc3sMx4T8-_29u1na-W_g and PartitionRegistration(replicas=[2], isr=[2], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:33.671764443Z [2024-04-22 14:36:33,671] INFO [Broker id=2] Transitioning 1 partition(s) to local leaders. (state.change.logger)
2024-04-22T14:36:33.671768411Z [2024-04-22 14:36:33,671] INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(nsi-0) (kafka.server.ReplicaFetcherManager)
2024-04-22T14:36:33.671781395Z [2024-04-22 14:36:33,671] INFO [Broker id=2] Creating new partition nsi-0 with topic id lGc3sMx4T8-_29u1na-W_g. (state.change.logger)
2024-04-22T14:36:33.678298185Z [2024-04-22 14:36:33,678] INFO [LogLoader partition=nsi-0, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:36:33.685242262Z [2024-04-22 14:36:33,684] INFO Created log for partition nsi-0 in /bitnami/kafka/data/nsi-0 with properties {} (kafka.log.LogManager)
2024-04-22T14:36:33.686385927Z [2024-04-22 14:36:33,684] INFO [Partition nsi-0 broker=2] No checkpointed highwatermark is found for partition nsi-0 (kafka.cluster.Partition)
2024-04-22T14:36:33.686391283Z [2024-04-22 14:36:33,685] INFO [Partition nsi-0 broker=2] Log loaded for partition nsi-0 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:36:33.686406904Z [2024-04-22 14:36:33,685] INFO [Broker id=2] Leader nsi-0 with topic id Some(lGc3sMx4T8-_29u1na-W_g) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:36:33.967411264Z [2024-04-22 14:36:33,966] INFO Sent auto-creation request for Set(vnf) to the active controller. (kafka.server.DefaultAutoTopicCreationManager)
2024-04-22T14:36:34.175043280Z [2024-04-22 14:36:34,171] INFO [QuorumController id=2] Created topic vnf with topic ID MVKdfYcZTu2TuQMP_gcGlw. (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:34.175053079Z [2024-04-22 14:36:34,171] INFO [QuorumController id=2] Created partition vnf-0 with topic ID MVKdfYcZTu2TuQMP_gcGlw and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:53.596958113Z [2024-04-22 14:36:53,591] INFO [QuorumController id=2] Created topic alarm_request with topic ID 9ZMWBBlNSLyuS-Zhk3gSsw. (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:53.596972562Z [2024-04-22 14:36:53,591] INFO [QuorumController id=2] Created partition alarm_request-0 with topic ID 9ZMWBBlNSLyuS-Zhk3gSsw and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.028701587Z [2024-04-22 14:36:55,028] INFO [QuorumController id=2] Created topic users with topic ID MsDSas28TH-O9_cw8W50zw. (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.061272318Z [2024-04-22 14:36:55,060] INFO [QuorumController id=2] Created partition users-0 with topic ID MsDSas28TH-O9_cw8W50zw and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.300335391Z [2024-04-22 14:36:55,300] INFO [QuorumController id=2] Created topic __consumer_offsets with topic ID ytEnAvpXSiu4qCS_b1Zxag. (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.301765306Z [2024-04-22 14:36:55,300] INFO [QuorumController id=2] ConfigResource(type=TOPIC, name='__consumer_offsets'): set configuration compression.type to producer (org.apache.kafka.controller.ConfigurationControlManager)
2024-04-22T14:36:55.301779795Z [2024-04-22 14:36:55,300] INFO [QuorumController id=2] ConfigResource(type=TOPIC, name='__consumer_offsets'): set configuration cleanup.policy to compact (org.apache.kafka.controller.ConfigurationControlManager)
2024-04-22T14:36:55.301783131Z [2024-04-22 14:36:55,300] INFO [QuorumController id=2] ConfigResource(type=TOPIC, name='__consumer_offsets'): set configuration segment.bytes to 104857600 (org.apache.kafka.controller.ConfigurationControlManager)
2024-04-22T14:36:55.302215605Z [2024-04-22 14:36:55,300] INFO [QuorumController id=2] Created partition __consumer_offsets-0 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[1, 2, 0], isr=[1, 2, 0], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.302220761Z [2024-04-22 14:36:55,301] INFO [QuorumController id=2] Created partition __consumer_offsets-1 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[2, 0, 1], isr=[2, 0, 1], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.302223807Z [2024-04-22 14:36:55,301] INFO [QuorumController id=2] Created partition __consumer_offsets-2 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[0, 1, 2], isr=[0, 1, 2], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.302226828Z [2024-04-22 14:36:55,301] INFO [QuorumController id=2] Created partition __consumer_offsets-3 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[0, 1, 2], isr=[0, 1, 2], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.302229891Z [2024-04-22 14:36:55,301] INFO [QuorumController id=2] Created partition __consumer_offsets-4 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[1, 2, 0], isr=[1, 2, 0], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.302232810Z [2024-04-22 14:36:55,301] INFO [QuorumController id=2] Created partition __consumer_offsets-5 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[2, 0, 1], isr=[2, 0, 1], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.302239938Z [2024-04-22 14:36:55,301] INFO [QuorumController id=2] Created partition __consumer_offsets-6 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[2, 0, 1], isr=[2, 0, 1], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.302257065Z [2024-04-22 14:36:55,301] INFO [QuorumController id=2] Created partition __consumer_offsets-7 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[0, 1, 2], isr=[0, 1, 2], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.302260454Z [2024-04-22 14:36:55,301] INFO [QuorumController id=2] Created partition __consumer_offsets-8 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[1, 2, 0], isr=[1, 2, 0], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.302272217Z [2024-04-22 14:36:55,301] INFO [QuorumController id=2] Created partition __consumer_offsets-9 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[1, 0, 2], isr=[1, 0, 2], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.302275440Z [2024-04-22 14:36:55,301] INFO [QuorumController id=2] Created partition __consumer_offsets-10 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[0, 2, 1], isr=[0, 2, 1], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.302280381Z [2024-04-22 14:36:55,301] INFO [QuorumController id=2] Created partition __consumer_offsets-11 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[2, 1, 0], isr=[2, 1, 0], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.302287070Z [2024-04-22 14:36:55,301] INFO [QuorumController id=2] Created partition __consumer_offsets-12 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[2, 0, 1], isr=[2, 0, 1], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.303130741Z [2024-04-22 14:36:55,302] INFO [QuorumController id=2] Created partition __consumer_offsets-13 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[0, 1, 2], isr=[0, 1, 2], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305046059Z [2024-04-22 14:36:55,302] INFO [QuorumController id=2] Created partition __consumer_offsets-14 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[1, 2, 0], isr=[1, 2, 0], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305062642Z [2024-04-22 14:36:55,302] INFO [QuorumController id=2] Created partition __consumer_offsets-15 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[1, 0, 2], isr=[1, 0, 2], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305066211Z [2024-04-22 14:36:55,302] INFO [QuorumController id=2] Created partition __consumer_offsets-16 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[0, 2, 1], isr=[0, 2, 1], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305069256Z [2024-04-22 14:36:55,302] INFO [QuorumController id=2] Created partition __consumer_offsets-17 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[2, 1, 0], isr=[2, 1, 0], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305072313Z [2024-04-22 14:36:55,302] INFO [QuorumController id=2] Created partition __consumer_offsets-18 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[0, 1, 2], isr=[0, 1, 2], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305140905Z [2024-04-22 14:36:55,302] INFO [QuorumController id=2] Created partition __consumer_offsets-19 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[1, 2, 0], isr=[1, 2, 0], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305144836Z [2024-04-22 14:36:55,303] INFO [QuorumController id=2] Created partition __consumer_offsets-20 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[2, 0, 1], isr=[2, 0, 1], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305147895Z [2024-04-22 14:36:55,303] INFO [QuorumController id=2] Created partition __consumer_offsets-21 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[2, 0, 1], isr=[2, 0, 1], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305154346Z [2024-04-22 14:36:55,303] INFO [QuorumController id=2] Created partition __consumer_offsets-22 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[0, 1, 2], isr=[0, 1, 2], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305157256Z [2024-04-22 14:36:55,303] INFO [QuorumController id=2] Created partition __consumer_offsets-23 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[1, 2, 0], isr=[1, 2, 0], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305160223Z [2024-04-22 14:36:55,303] INFO [QuorumController id=2] Created partition __consumer_offsets-24 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[0, 1, 2], isr=[0, 1, 2], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305217125Z [2024-04-22 14:36:55,303] INFO [QuorumController id=2] Created partition __consumer_offsets-25 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[1, 2, 0], isr=[1, 2, 0], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305221088Z [2024-04-22 14:36:55,303] INFO [QuorumController id=2] Created partition __consumer_offsets-26 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[2, 0, 1], isr=[2, 0, 1], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305224025Z [2024-04-22 14:36:55,303] INFO [QuorumController id=2] Created partition __consumer_offsets-27 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[2, 0, 1], isr=[2, 0, 1], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305226886Z [2024-04-22 14:36:55,303] INFO [QuorumController id=2] Created partition __consumer_offsets-28 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[0, 1, 2], isr=[0, 1, 2], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305229850Z [2024-04-22 14:36:55,303] INFO [QuorumController id=2] Created partition __consumer_offsets-29 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[1, 2, 0], isr=[1, 2, 0], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305256231Z [2024-04-22 14:36:55,303] INFO [QuorumController id=2] Created partition __consumer_offsets-30 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[0, 1, 2], isr=[0, 1, 2], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305259995Z [2024-04-22 14:36:55,303] INFO [QuorumController id=2] Created partition __consumer_offsets-31 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[1, 2, 0], isr=[1, 2, 0], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305262843Z [2024-04-22 14:36:55,303] INFO [QuorumController id=2] Created partition __consumer_offsets-32 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[2, 0, 1], isr=[2, 0, 1], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305265673Z [2024-04-22 14:36:55,303] INFO [QuorumController id=2] Created partition __consumer_offsets-33 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[1, 2, 0], isr=[1, 2, 0], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305268840Z [2024-04-22 14:36:55,303] INFO [QuorumController id=2] Created partition __consumer_offsets-34 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[2, 0, 1], isr=[2, 0, 1], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305271944Z [2024-04-22 14:36:55,304] INFO [QuorumController id=2] Created partition __consumer_offsets-35 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[0, 1, 2], isr=[0, 1, 2], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305278236Z [2024-04-22 14:36:55,304] INFO [QuorumController id=2] Created partition __consumer_offsets-36 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[0, 2, 1], isr=[0, 2, 1], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305281343Z [2024-04-22 14:36:55,304] INFO [QuorumController id=2] Created partition __consumer_offsets-37 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[2, 1, 0], isr=[2, 1, 0], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305284222Z [2024-04-22 14:36:55,304] INFO [QuorumController id=2] Created partition __consumer_offsets-38 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[1, 0, 2], isr=[1, 0, 2], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305287099Z [2024-04-22 14:36:55,304] INFO [QuorumController id=2] Created partition __consumer_offsets-39 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[0, 1, 2], isr=[0, 1, 2], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305296678Z [2024-04-22 14:36:55,304] INFO [QuorumController id=2] Created partition __consumer_offsets-40 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[1, 2, 0], isr=[1, 2, 0], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305299698Z [2024-04-22 14:36:55,304] INFO [QuorumController id=2] Created partition __consumer_offsets-41 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[2, 0, 1], isr=[2, 0, 1], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305302547Z [2024-04-22 14:36:55,304] INFO [QuorumController id=2] Created partition __consumer_offsets-42 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[1, 2, 0], isr=[1, 2, 0], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305305385Z [2024-04-22 14:36:55,304] INFO [QuorumController id=2] Created partition __consumer_offsets-43 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[2, 0, 1], isr=[2, 0, 1], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305308238Z [2024-04-22 14:36:55,304] INFO [QuorumController id=2] Created partition __consumer_offsets-44 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[0, 1, 2], isr=[0, 1, 2], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305311144Z [2024-04-22 14:36:55,304] INFO [QuorumController id=2] Created partition __consumer_offsets-45 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[0, 1, 2], isr=[0, 1, 2], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305314124Z [2024-04-22 14:36:55,304] INFO [QuorumController id=2] Created partition __consumer_offsets-46 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[1, 2, 0], isr=[1, 2, 0], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.305318097Z [2024-04-22 14:36:55,304] INFO [QuorumController id=2] Created partition __consumer_offsets-47 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[2, 0, 1], isr=[2, 0, 1], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.320011352Z [2024-04-22 14:36:55,312] INFO [QuorumController id=2] Created partition __consumer_offsets-48 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[0, 2, 1], isr=[0, 2, 1], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.320026447Z [2024-04-22 14:36:55,312] INFO [QuorumController id=2] Created partition __consumer_offsets-49 with topic ID ytEnAvpXSiu4qCS_b1Zxag and PartitionRegistration(replicas=[2, 1, 0], isr=[2, 1, 0], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.447547633Z [2024-04-22 14:36:55,447] INFO [Broker id=2] Transitioning 17 partition(s) to local leaders. (state.change.logger)
2024-04-22T14:36:55.447654869Z [2024-04-22 14:36:55,447] INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(__consumer_offsets-47, __consumer_offsets-11, __consumer_offsets-43, __consumer_offsets-12, __consumer_offsets-41, __consumer_offsets-21, __consumer_offsets-20, __consumer_offsets-17, __consumer_offsets-49, __consumer_offsets-32, __consumer_offsets-27, __consumer_offsets-26, __consumer_offsets-5, __consumer_offsets-37, __consumer_offsets-6, __consumer_offsets-1, __consumer_offsets-34) (kafka.server.ReplicaFetcherManager)
2024-04-22T14:36:55.447721342Z [2024-04-22 14:36:55,447] INFO [Broker id=2] Creating new partition __consumer_offsets-47 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:36:55.472532001Z [2024-04-22 14:36:55,472] INFO [LogLoader partition=__consumer_offsets-47, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:36:55.480708238Z [2024-04-22 14:36:55,479] INFO Created log for partition __consumer_offsets-47 in /bitnami/kafka/data/__consumer_offsets-47 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:36:55.480720130Z [2024-04-22 14:36:55,479] INFO [Partition __consumer_offsets-47 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-47 (kafka.cluster.Partition)
2024-04-22T14:36:55.480723448Z [2024-04-22 14:36:55,480] INFO [Partition __consumer_offsets-47 broker=2] Log loaded for partition __consumer_offsets-47 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:36:55.480733629Z [2024-04-22 14:36:55,480] INFO [Broker id=2] Leader __consumer_offsets-47 with topic id Some(ytEnAvpXSiu4qCS_b1Zxag) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,0,1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:36:55.527499845Z [2024-04-22 14:36:55,527] INFO [QuorumController id=2] Created topic project with topic ID eerqGcvSQeS9o_pDfVdxGw. (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.530119621Z [2024-04-22 14:36:55,527] INFO [QuorumController id=2] Created partition project-0 with topic ID eerqGcvSQeS9o_pDfVdxGw and PartitionRegistration(replicas=[0], isr=[0], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:36:55.559186424Z [2024-04-22 14:36:55,558] INFO [Broker id=2] Creating new partition __consumer_offsets-11 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:36:55.600463334Z [2024-04-22 14:36:55,599] INFO [LogLoader partition=__consumer_offsets-11, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:36:55.600479770Z [2024-04-22 14:36:55,599] INFO Created log for partition __consumer_offsets-11 in /bitnami/kafka/data/__consumer_offsets-11 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:36:55.600483849Z [2024-04-22 14:36:55,600] INFO [Partition __consumer_offsets-11 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-11 (kafka.cluster.Partition)
2024-04-22T14:36:55.600487210Z [2024-04-22 14:36:55,600] INFO [Partition __consumer_offsets-11 broker=2] Log loaded for partition __consumer_offsets-11 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:36:55.600498400Z [2024-04-22 14:36:55,600] INFO [Broker id=2] Leader __consumer_offsets-11 with topic id Some(ytEnAvpXSiu4qCS_b1Zxag) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,1,0], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:36:55.626637024Z [2024-04-22 14:36:55,626] INFO [Broker id=2] Creating new partition __consumer_offsets-43 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:36:55.637046120Z [2024-04-22 14:36:55,636] INFO [LogLoader partition=__consumer_offsets-43, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:36:55.650651982Z [2024-04-22 14:36:55,650] INFO Created log for partition __consumer_offsets-43 in /bitnami/kafka/data/__consumer_offsets-43 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:36:55.667864907Z [2024-04-22 14:36:55,667] INFO [Partition __consumer_offsets-43 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-43 (kafka.cluster.Partition)
2024-04-22T14:36:55.667962144Z [2024-04-22 14:36:55,667] INFO [Partition __consumer_offsets-43 broker=2] Log loaded for partition __consumer_offsets-43 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:36:55.672351018Z [2024-04-22 14:36:55,672] INFO [Broker id=2] Leader __consumer_offsets-43 with topic id Some(ytEnAvpXSiu4qCS_b1Zxag) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,0,1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:36:55.693081028Z [2024-04-22 14:36:55,692] INFO [Broker id=2] Creating new partition __consumer_offsets-12 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:36:55.731527372Z [2024-04-22 14:36:55,731] INFO [LogLoader partition=__consumer_offsets-12, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:36:55.748219049Z [2024-04-22 14:36:55,741] INFO Created log for partition __consumer_offsets-12 in /bitnami/kafka/data/__consumer_offsets-12 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:36:55.748229283Z [2024-04-22 14:36:55,747] INFO [Partition __consumer_offsets-12 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-12 (kafka.cluster.Partition)
2024-04-22T14:36:55.748232445Z [2024-04-22 14:36:55,747] INFO [Partition __consumer_offsets-12 broker=2] Log loaded for partition __consumer_offsets-12 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:36:55.748236729Z [2024-04-22 14:36:55,747] INFO [Broker id=2] Leader __consumer_offsets-12 with topic id Some(ytEnAvpXSiu4qCS_b1Zxag) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,0,1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:36:55.757016097Z [2024-04-22 14:36:55,751] INFO [Broker id=2] Creating new partition __consumer_offsets-41 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:36:55.786370223Z [2024-04-22 14:36:55,783] INFO [LogLoader partition=__consumer_offsets-41, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:36:55.802077316Z [2024-04-22 14:36:55,801] INFO Created log for partition __consumer_offsets-41 in /bitnami/kafka/data/__consumer_offsets-41 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:36:55.812188811Z [2024-04-22 14:36:55,811] INFO [Partition __consumer_offsets-41 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-41 (kafka.cluster.Partition)
2024-04-22T14:36:55.812512046Z [2024-04-22 14:36:55,811] INFO [Partition __consumer_offsets-41 broker=2] Log loaded for partition __consumer_offsets-41 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:36:55.812519237Z [2024-04-22 14:36:55,811] INFO [Broker id=2] Leader __consumer_offsets-41 with topic id Some(ytEnAvpXSiu4qCS_b1Zxag) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,0,1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:36:55.832078804Z [2024-04-22 14:36:55,831] INFO [Broker id=2] Creating new partition __consumer_offsets-21 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:36:55.873501218Z [2024-04-22 14:36:55,872] INFO [LogLoader partition=__consumer_offsets-21, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:36:55.876708860Z [2024-04-22 14:36:55,876] INFO Created log for partition __consumer_offsets-21 in /bitnami/kafka/data/__consumer_offsets-21 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:36:55.876718402Z [2024-04-22 14:36:55,876] INFO [Partition __consumer_offsets-21 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-21 (kafka.cluster.Partition)
2024-04-22T14:36:55.876721762Z [2024-04-22 14:36:55,876] INFO [Partition __consumer_offsets-21 broker=2] Log loaded for partition __consumer_offsets-21 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:36:55.876725550Z [2024-04-22 14:36:55,876] INFO [Broker id=2] Leader __consumer_offsets-21 with topic id Some(ytEnAvpXSiu4qCS_b1Zxag) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,0,1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:36:55.891548546Z [2024-04-22 14:36:55,890] INFO [Broker id=2] Creating new partition __consumer_offsets-20 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:36:55.919719387Z [2024-04-22 14:36:55,919] INFO [LogLoader partition=__consumer_offsets-20, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:36:55.921237819Z [2024-04-22 14:36:55,921] INFO Created log for partition __consumer_offsets-20 in /bitnami/kafka/data/__consumer_offsets-20 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:36:55.926096207Z [2024-04-22 14:36:55,925] INFO [Partition __consumer_offsets-20 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-20 (kafka.cluster.Partition)
2024-04-22T14:36:55.927878241Z [2024-04-22 14:36:55,927] INFO [Partition __consumer_offsets-20 broker=2] Log loaded for partition __consumer_offsets-20 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:36:55.933243915Z [2024-04-22 14:36:55,930] INFO [Broker id=2] Leader __consumer_offsets-20 with topic id Some(ytEnAvpXSiu4qCS_b1Zxag) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,0,1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:36:55.952511171Z [2024-04-22 14:36:55,951] INFO [Broker id=2] Creating new partition __consumer_offsets-17 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:36:56.008153381Z [2024-04-22 14:36:56,008] INFO [LogLoader partition=__consumer_offsets-17, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:36:56.011306238Z [2024-04-22 14:36:56,011] INFO Created log for partition __consumer_offsets-17 in /bitnami/kafka/data/__consumer_offsets-17 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:36:56.122227484Z [2024-04-22 14:36:56,018] INFO [Partition __consumer_offsets-17 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-17 (kafka.cluster.Partition)
2024-04-22T14:36:56.122245148Z [2024-04-22 14:36:56,121] INFO [Partition __consumer_offsets-17 broker=2] Log loaded for partition __consumer_offsets-17 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:36:56.122248968Z [2024-04-22 14:36:56,121] INFO [Broker id=2] Leader __consumer_offsets-17 with topic id Some(ytEnAvpXSiu4qCS_b1Zxag) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,1,0], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:36:56.150562213Z [2024-04-22 14:36:56,149] INFO [Broker id=2] Creating new partition __consumer_offsets-49 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:36:56.281923985Z [2024-04-22 14:36:56,281] INFO [LogLoader partition=__consumer_offsets-49, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:36:56.285492938Z [2024-04-22 14:36:56,285] INFO Created log for partition __consumer_offsets-49 in /bitnami/kafka/data/__consumer_offsets-49 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:36:56.296967529Z [2024-04-22 14:36:56,296] INFO [Partition __consumer_offsets-49 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-49 (kafka.cluster.Partition)
2024-04-22T14:36:56.297760618Z [2024-04-22 14:36:56,297] INFO [Partition __consumer_offsets-49 broker=2] Log loaded for partition __consumer_offsets-49 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:36:56.298303460Z [2024-04-22 14:36:56,298] INFO [Broker id=2] Leader __consumer_offsets-49 with topic id Some(ytEnAvpXSiu4qCS_b1Zxag) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,1,0], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:36:56.308430728Z [2024-04-22 14:36:56,308] INFO [Broker id=2] Creating new partition __consumer_offsets-32 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:36:56.331568546Z [2024-04-22 14:36:56,331] INFO [LogLoader partition=__consumer_offsets-32, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:36:56.333788403Z [2024-04-22 14:36:56,333] INFO Created log for partition __consumer_offsets-32 in /bitnami/kafka/data/__consumer_offsets-32 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:36:56.432893359Z [2024-04-22 14:36:56,431] INFO [Partition __consumer_offsets-32 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-32 (kafka.cluster.Partition)
2024-04-22T14:36:56.441998896Z [2024-04-22 14:36:56,440] INFO [Partition __consumer_offsets-32 broker=2] Log loaded for partition __consumer_offsets-32 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:36:56.447146136Z [2024-04-22 14:36:56,447] INFO [Broker id=2] Leader __consumer_offsets-32 with topic id Some(ytEnAvpXSiu4qCS_b1Zxag) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,0,1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:36:56.473253646Z [2024-04-22 14:36:56,473] INFO [Broker id=2] Creating new partition __consumer_offsets-27 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:36:56.593023366Z [2024-04-22 14:36:56,589] INFO [LogLoader partition=__consumer_offsets-27, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:36:56.593041803Z [2024-04-22 14:36:56,590] INFO Created log for partition __consumer_offsets-27 in /bitnami/kafka/data/__consumer_offsets-27 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:36:56.593046306Z [2024-04-22 14:36:56,590] INFO [Partition __consumer_offsets-27 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-27 (kafka.cluster.Partition)
2024-04-22T14:36:56.593049794Z [2024-04-22 14:36:56,590] INFO [Partition __consumer_offsets-27 broker=2] Log loaded for partition __consumer_offsets-27 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:36:56.593054215Z [2024-04-22 14:36:56,590] INFO [Broker id=2] Leader __consumer_offsets-27 with topic id Some(ytEnAvpXSiu4qCS_b1Zxag) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,0,1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:36:56.666142756Z [2024-04-22 14:36:56,665] INFO [Broker id=2] Creating new partition __consumer_offsets-26 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:36:56.696958834Z [2024-04-22 14:36:56,689] INFO [LogLoader partition=__consumer_offsets-26, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:36:56.784953679Z [2024-04-22 14:36:56,740] INFO Created log for partition __consumer_offsets-26 in /bitnami/kafka/data/__consumer_offsets-26 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:36:56.797389752Z [2024-04-22 14:36:56,797] INFO [Partition __consumer_offsets-26 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-26 (kafka.cluster.Partition)
2024-04-22T14:36:56.831134340Z [2024-04-22 14:36:56,830] INFO [Partition __consumer_offsets-26 broker=2] Log loaded for partition __consumer_offsets-26 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:36:56.831267043Z [2024-04-22 14:36:56,831] INFO [Broker id=2] Leader __consumer_offsets-26 with topic id Some(ytEnAvpXSiu4qCS_b1Zxag) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,0,1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:36:56.861777629Z [2024-04-22 14:36:56,861] INFO [Broker id=2] Creating new partition __consumer_offsets-5 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:36:57.028429877Z [2024-04-22 14:36:57,020] INFO [LogLoader partition=__consumer_offsets-5, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:36:57.082646188Z [2024-04-22 14:36:57,082] INFO Created log for partition __consumer_offsets-5 in /bitnami/kafka/data/__consumer_offsets-5 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:36:57.082666428Z [2024-04-22 14:36:57,082] INFO [Partition __consumer_offsets-5 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-5 (kafka.cluster.Partition)
2024-04-22T14:36:57.082781213Z [2024-04-22 14:36:57,082] INFO [Partition __consumer_offsets-5 broker=2] Log loaded for partition __consumer_offsets-5 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:36:57.082912551Z [2024-04-22 14:36:57,082] INFO [Broker id=2] Leader __consumer_offsets-5 with topic id Some(ytEnAvpXSiu4qCS_b1Zxag) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,0,1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:36:57.116649218Z [2024-04-22 14:36:57,115] INFO [Broker id=2] Creating new partition __consumer_offsets-37 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:36:57.119883737Z [2024-04-22 14:36:57,119] INFO [LogLoader partition=__consumer_offsets-37, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:36:57.120519499Z [2024-04-22 14:36:57,120] INFO Created log for partition __consumer_offsets-37 in /bitnami/kafka/data/__consumer_offsets-37 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:36:57.120582770Z [2024-04-22 14:36:57,120] INFO [Partition __consumer_offsets-37 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-37 (kafka.cluster.Partition)
2024-04-22T14:36:57.120590611Z [2024-04-22 14:36:57,120] INFO [Partition __consumer_offsets-37 broker=2] Log loaded for partition __consumer_offsets-37 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:36:57.120760800Z [2024-04-22 14:36:57,120] INFO [Broker id=2] Leader __consumer_offsets-37 with topic id Some(ytEnAvpXSiu4qCS_b1Zxag) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,1,0], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:36:57.363533576Z [2024-04-22 14:36:57,363] INFO [Broker id=2] Creating new partition __consumer_offsets-6 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:36:57.374924445Z [2024-04-22 14:36:57,374] INFO [LogLoader partition=__consumer_offsets-6, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:36:57.376417663Z [2024-04-22 14:36:57,376] INFO Created log for partition __consumer_offsets-6 in /bitnami/kafka/data/__consumer_offsets-6 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:36:57.376434748Z [2024-04-22 14:36:57,376] INFO [Partition __consumer_offsets-6 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-6 (kafka.cluster.Partition)
2024-04-22T14:36:57.376482893Z [2024-04-22 14:36:57,376] INFO [Partition __consumer_offsets-6 broker=2] Log loaded for partition __consumer_offsets-6 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:36:57.376642307Z [2024-04-22 14:36:57,376] INFO [Broker id=2] Leader __consumer_offsets-6 with topic id Some(ytEnAvpXSiu4qCS_b1Zxag) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,0,1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:36:57.409880995Z [2024-04-22 14:36:57,388] INFO [Broker id=2] Creating new partition __consumer_offsets-1 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:36:57.412939519Z [2024-04-22 14:36:57,411] INFO [LogLoader partition=__consumer_offsets-1, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:36:57.412954663Z [2024-04-22 14:36:57,412] INFO Created log for partition __consumer_offsets-1 in /bitnami/kafka/data/__consumer_offsets-1 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:36:57.412958880Z [2024-04-22 14:36:57,412] INFO [Partition __consumer_offsets-1 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-1 (kafka.cluster.Partition)
2024-04-22T14:36:57.412978726Z [2024-04-22 14:36:57,412] INFO [Partition __consumer_offsets-1 broker=2] Log loaded for partition __consumer_offsets-1 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:36:57.412983522Z [2024-04-22 14:36:57,412] INFO [Broker id=2] Leader __consumer_offsets-1 with topic id Some(ytEnAvpXSiu4qCS_b1Zxag) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,0,1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:36:57.421574681Z [2024-04-22 14:36:57,419] INFO [Broker id=2] Creating new partition __consumer_offsets-34 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:36:57.436548767Z [2024-04-22 14:36:57,436] INFO [LogLoader partition=__consumer_offsets-34, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:36:57.463303200Z [2024-04-22 14:36:57,462] INFO Created log for partition __consumer_offsets-34 in /bitnami/kafka/data/__consumer_offsets-34 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:36:57.463319731Z [2024-04-22 14:36:57,463] INFO [Partition __consumer_offsets-34 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-34 (kafka.cluster.Partition)
2024-04-22T14:36:57.463323982Z [2024-04-22 14:36:57,463] INFO [Partition __consumer_offsets-34 broker=2] Log loaded for partition __consumer_offsets-34 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:36:57.465514993Z [2024-04-22 14:36:57,464] INFO [Broker id=2] Leader __consumer_offsets-34 with topic id Some(ytEnAvpXSiu4qCS_b1Zxag) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,0,1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:36:57.708982560Z [2024-04-22 14:36:57,705] INFO [Broker id=2] Transitioning 33 partition(s) to local followers. (state.change.logger)
2024-04-22T14:36:57.984768945Z [2024-04-22 14:36:57,984] INFO [Broker id=2] Creating new partition __consumer_offsets-15 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:36:58.165174905Z [2024-04-22 14:36:58,156] INFO [LogLoader partition=__consumer_offsets-15, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:36:58.165188914Z [2024-04-22 14:36:58,156] INFO Created log for partition __consumer_offsets-15 in /bitnami/kafka/data/__consumer_offsets-15 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:36:58.165192950Z [2024-04-22 14:36:58,156] INFO [Partition __consumer_offsets-15 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-15 (kafka.cluster.Partition)
2024-04-22T14:36:58.165196408Z [2024-04-22 14:36:58,156] INFO [Partition __consumer_offsets-15 broker=2] Log loaded for partition __consumer_offsets-15 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:36:58.207792653Z [2024-04-22 14:36:58,207] INFO [Broker id=2] Follower __consumer_offsets-15 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:36:58.335343331Z [2024-04-22 14:36:58,334] INFO [Broker id=2] Creating new partition __consumer_offsets-48 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:36:58.349144266Z [2024-04-22 14:36:58,344] INFO [LogLoader partition=__consumer_offsets-48, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:36:58.349163512Z [2024-04-22 14:36:58,345] INFO Created log for partition __consumer_offsets-48 in /bitnami/kafka/data/__consumer_offsets-48 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:36:58.349168028Z [2024-04-22 14:36:58,345] INFO [Partition __consumer_offsets-48 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-48 (kafka.cluster.Partition)
2024-04-22T14:36:58.349171310Z [2024-04-22 14:36:58,345] INFO [Partition __consumer_offsets-48 broker=2] Log loaded for partition __consumer_offsets-48 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:36:58.349175079Z [2024-04-22 14:36:58,346] INFO [Broker id=2] Follower __consumer_offsets-48 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:36:58.349178755Z [2024-04-22 14:36:58,346] INFO [Broker id=2] Creating new partition __consumer_offsets-13 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:36:58.372140990Z [2024-04-22 14:36:58,371] INFO [LogLoader partition=__consumer_offsets-13, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:36:58.376363552Z [2024-04-22 14:36:58,375] INFO Created log for partition __consumer_offsets-13 in /bitnami/kafka/data/__consumer_offsets-13 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:36:58.376374034Z [2024-04-22 14:36:58,375] INFO [Partition __consumer_offsets-13 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-13 (kafka.cluster.Partition)
2024-04-22T14:36:58.376377061Z [2024-04-22 14:36:58,375] INFO [Partition __consumer_offsets-13 broker=2] Log loaded for partition __consumer_offsets-13 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:36:58.376382331Z [2024-04-22 14:36:58,375] INFO [Broker id=2] Follower __consumer_offsets-13 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:36:58.376385588Z [2024-04-22 14:36:58,375] INFO [Broker id=2] Creating new partition __consumer_offsets-46 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:36:58.379692912Z [2024-04-22 14:36:58,379] INFO [LogLoader partition=__consumer_offsets-46, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:36:58.386285951Z [2024-04-22 14:36:58,385] INFO Created log for partition __consumer_offsets-46 in /bitnami/kafka/data/__consumer_offsets-46 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:36:58.386299562Z [2024-04-22 14:36:58,385] INFO [Partition __consumer_offsets-46 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-46 (kafka.cluster.Partition)
2024-04-22T14:36:58.386303023Z [2024-04-22 14:36:58,385] INFO [Partition __consumer_offsets-46 broker=2] Log loaded for partition __consumer_offsets-46 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:36:58.386306715Z [2024-04-22 14:36:58,385] INFO [Broker id=2] Follower __consumer_offsets-46 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:36:58.386310205Z [2024-04-22 14:36:58,386] INFO [Broker id=2] Creating new partition __consumer_offsets-44 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:36:58.727519132Z [2024-04-22 14:36:58,725] INFO [LogLoader partition=__consumer_offsets-44, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:36:58.727545016Z [2024-04-22 14:36:58,726] INFO Created log for partition __consumer_offsets-44 in /bitnami/kafka/data/__consumer_offsets-44 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:36:58.727548953Z [2024-04-22 14:36:58,726] INFO [Partition __consumer_offsets-44 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-44 (kafka.cluster.Partition)
2024-04-22T14:36:58.727551807Z [2024-04-22 14:36:58,726] INFO [Partition __consumer_offsets-44 broker=2] Log loaded for partition __consumer_offsets-44 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:36:58.727555287Z [2024-04-22 14:36:58,726] INFO [Broker id=2] Follower __consumer_offsets-44 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:36:58.727558558Z [2024-04-22 14:36:58,726] INFO [Broker id=2] Creating new partition __consumer_offsets-9 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:36:59.451933230Z [2024-04-22 14:36:59,451] INFO [LogLoader partition=__consumer_offsets-9, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:36:59.460680619Z [2024-04-22 14:36:59,460] INFO Created log for partition __consumer_offsets-9 in /bitnami/kafka/data/__consumer_offsets-9 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:36:59.481218340Z [2024-04-22 14:36:59,480] INFO [Partition __consumer_offsets-9 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-9 (kafka.cluster.Partition)
2024-04-22T14:36:59.481233877Z [2024-04-22 14:36:59,480] INFO [Partition __consumer_offsets-9 broker=2] Log loaded for partition __consumer_offsets-9 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:36:59.483369796Z [2024-04-22 14:36:59,482] INFO [Broker id=2] Follower __consumer_offsets-9 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:36:59.491078689Z [2024-04-22 14:36:59,490] INFO [Broker id=2] Creating new partition __consumer_offsets-42 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:36:59.700160322Z [2024-04-22 14:36:59,699] INFO [LogLoader partition=__consumer_offsets-42, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:36:59.706942925Z [2024-04-22 14:36:59,706] INFO Created log for partition __consumer_offsets-42 in /bitnami/kafka/data/__consumer_offsets-42 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:36:59.706958775Z [2024-04-22 14:36:59,706] INFO [Partition __consumer_offsets-42 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-42 (kafka.cluster.Partition)
2024-04-22T14:36:59.706962181Z [2024-04-22 14:36:59,706] INFO [Partition __consumer_offsets-42 broker=2] Log loaded for partition __consumer_offsets-42 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:36:59.706966276Z [2024-04-22 14:36:59,706] INFO [Broker id=2] Follower __consumer_offsets-42 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:36:59.712056239Z [2024-04-22 14:36:59,711] INFO [Broker id=2] Creating new partition __consumer_offsets-23 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:37:00.013546001Z [2024-04-22 14:36:59,964] INFO [LogLoader partition=__consumer_offsets-23, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:37:00.014391489Z [2024-04-22 14:37:00,014] INFO Created log for partition __consumer_offsets-23 in /bitnami/kafka/data/__consumer_offsets-23 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:37:00.014396573Z [2024-04-22 14:37:00,014] INFO [Partition __consumer_offsets-23 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-23 (kafka.cluster.Partition)
2024-04-22T14:37:00.014427069Z [2024-04-22 14:37:00,014] INFO [Partition __consumer_offsets-23 broker=2] Log loaded for partition __consumer_offsets-23 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:37:00.014522597Z [2024-04-22 14:37:00,014] INFO [Broker id=2] Follower __consumer_offsets-23 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:37:00.021023408Z [2024-04-22 14:37:00,020] INFO [Broker id=2] Creating new partition __consumer_offsets-19 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:37:00.033082310Z [2024-04-22 14:37:00,032] INFO [LogLoader partition=__consumer_offsets-19, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:37:00.049804258Z [2024-04-22 14:37:00,049] INFO Created log for partition __consumer_offsets-19 in /bitnami/kafka/data/__consumer_offsets-19 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:37:00.049820761Z [2024-04-22 14:37:00,049] INFO [Partition __consumer_offsets-19 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-19 (kafka.cluster.Partition)
2024-04-22T14:37:00.050050033Z [2024-04-22 14:37:00,049] INFO [Partition __consumer_offsets-19 broker=2] Log loaded for partition __consumer_offsets-19 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:37:00.050057050Z [2024-04-22 14:37:00,049] INFO [Broker id=2] Follower __consumer_offsets-19 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:37:00.050061196Z [2024-04-22 14:37:00,049] INFO [Broker id=2] Creating new partition __consumer_offsets-30 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:37:00.089657531Z [2024-04-22 14:37:00,089] INFO [LogLoader partition=__consumer_offsets-30, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:37:00.090261937Z [2024-04-22 14:37:00,090] INFO Created log for partition __consumer_offsets-30 in /bitnami/kafka/data/__consumer_offsets-30 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:37:00.090276040Z [2024-04-22 14:37:00,090] INFO [Partition __consumer_offsets-30 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-30 (kafka.cluster.Partition)
2024-04-22T14:37:00.090481764Z [2024-04-22 14:37:00,090] INFO [Partition __consumer_offsets-30 broker=2] Log loaded for partition __consumer_offsets-30 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:37:00.090488668Z [2024-04-22 14:37:00,090] INFO [Broker id=2] Follower __consumer_offsets-30 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:37:00.090492801Z [2024-04-22 14:37:00,090] INFO [Broker id=2] Creating new partition __consumer_offsets-28 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:37:00.095469820Z [2024-04-22 14:37:00,092] INFO [LogLoader partition=__consumer_offsets-28, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:37:00.289029431Z [2024-04-22 14:37:00,284] INFO Created log for partition __consumer_offsets-28 in /bitnami/kafka/data/__consumer_offsets-28 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:37:00.289048695Z [2024-04-22 14:37:00,284] INFO [Partition __consumer_offsets-28 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-28 (kafka.cluster.Partition)
2024-04-22T14:37:00.289052194Z [2024-04-22 14:37:00,284] INFO [Partition __consumer_offsets-28 broker=2] Log loaded for partition __consumer_offsets-28 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:37:00.289073888Z [2024-04-22 14:37:00,284] INFO [Broker id=2] Follower __consumer_offsets-28 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:37:00.289078667Z [2024-04-22 14:37:00,284] INFO [Broker id=2] Creating new partition __consumer_offsets-7 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:37:00.289082665Z [2024-04-22 14:37:00,287] INFO [LogLoader partition=__consumer_offsets-7, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:37:00.289085963Z [2024-04-22 14:37:00,288] INFO Created log for partition __consumer_offsets-7 in /bitnami/kafka/data/__consumer_offsets-7 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:37:00.289089293Z [2024-04-22 14:37:00,288] INFO [Partition __consumer_offsets-7 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-7 (kafka.cluster.Partition)
2024-04-22T14:37:00.289092432Z [2024-04-22 14:37:00,288] INFO [Partition __consumer_offsets-7 broker=2] Log loaded for partition __consumer_offsets-7 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:37:00.289095434Z [2024-04-22 14:37:00,288] INFO [Broker id=2] Follower __consumer_offsets-7 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:37:00.289098511Z [2024-04-22 14:37:00,288] INFO [Broker id=2] Creating new partition __consumer_offsets-40 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:37:00.544515660Z [2024-04-22 14:37:00,542] INFO [LogLoader partition=__consumer_offsets-40, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:37:00.544533330Z [2024-04-22 14:37:00,543] INFO Created log for partition __consumer_offsets-40 in /bitnami/kafka/data/__consumer_offsets-40 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:37:00.544545466Z [2024-04-22 14:37:00,543] INFO [Partition __consumer_offsets-40 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-40 (kafka.cluster.Partition)
2024-04-22T14:37:00.544549033Z [2024-04-22 14:37:00,543] INFO [Partition __consumer_offsets-40 broker=2] Log loaded for partition __consumer_offsets-40 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:37:00.544552767Z [2024-04-22 14:37:00,543] INFO [Broker id=2] Follower __consumer_offsets-40 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:37:00.545117750Z [2024-04-22 14:37:00,544] INFO [Broker id=2] Creating new partition __consumer_offsets-38 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:37:00.560004646Z [2024-04-22 14:37:00,559] INFO [LogLoader partition=__consumer_offsets-38, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:37:00.568534945Z [2024-04-22 14:37:00,560] INFO Created log for partition __consumer_offsets-38 in /bitnami/kafka/data/__consumer_offsets-38 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:37:00.568544550Z [2024-04-22 14:37:00,560] INFO [Partition __consumer_offsets-38 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-38 (kafka.cluster.Partition)
2024-04-22T14:37:00.568548966Z [2024-04-22 14:37:00,567] INFO [Partition __consumer_offsets-38 broker=2] Log loaded for partition __consumer_offsets-38 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:37:00.568553426Z [2024-04-22 14:37:00,567] INFO [Broker id=2] Follower __consumer_offsets-38 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:37:00.568558797Z [2024-04-22 14:37:00,567] INFO [Broker id=2] Creating new partition __consumer_offsets-3 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:37:00.580437068Z [2024-04-22 14:37:00,579] INFO [LogLoader partition=__consumer_offsets-3, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:37:00.585412465Z [2024-04-22 14:37:00,583] INFO Created log for partition __consumer_offsets-3 in /bitnami/kafka/data/__consumer_offsets-3 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:37:00.587295062Z [2024-04-22 14:37:00,586] INFO [Partition __consumer_offsets-3 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-3 (kafka.cluster.Partition)
2024-04-22T14:37:00.587318784Z [2024-04-22 14:37:00,586] INFO [Partition __consumer_offsets-3 broker=2] Log loaded for partition __consumer_offsets-3 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:37:00.587322879Z [2024-04-22 14:37:00,587] INFO [Broker id=2] Follower __consumer_offsets-3 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:37:00.587326983Z [2024-04-22 14:37:00,587] INFO [Broker id=2] Creating new partition __consumer_offsets-36 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:37:00.604186386Z [2024-04-22 14:37:00,599] INFO [LogLoader partition=__consumer_offsets-36, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:37:00.604194157Z [2024-04-22 14:37:00,601] INFO Created log for partition __consumer_offsets-36 in /bitnami/kafka/data/__consumer_offsets-36 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:37:00.604197697Z [2024-04-22 14:37:00,601] INFO [Partition __consumer_offsets-36 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-36 (kafka.cluster.Partition)
2024-04-22T14:37:00.604200895Z [2024-04-22 14:37:00,601] INFO [Partition __consumer_offsets-36 broker=2] Log loaded for partition __consumer_offsets-36 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:37:00.604203905Z [2024-04-22 14:37:00,601] INFO [Broker id=2] Follower __consumer_offsets-36 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:37:00.604222619Z [2024-04-22 14:37:00,602] INFO [Broker id=2] Creating new partition __consumer_offsets-16 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:37:00.611257282Z [2024-04-22 14:37:00,610] INFO [LogLoader partition=__consumer_offsets-16, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:37:00.616027461Z [2024-04-22 14:37:00,615] INFO Created log for partition __consumer_offsets-16 in /bitnami/kafka/data/__consumer_offsets-16 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:37:00.616125846Z [2024-04-22 14:37:00,615] INFO [Partition __consumer_offsets-16 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-16 (kafka.cluster.Partition)
2024-04-22T14:37:00.616129440Z [2024-04-22 14:37:00,615] INFO [Partition __consumer_offsets-16 broker=2] Log loaded for partition __consumer_offsets-16 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:37:00.616133047Z [2024-04-22 14:37:00,615] INFO [Broker id=2] Follower __consumer_offsets-16 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:37:00.616636254Z [2024-04-22 14:37:00,616] INFO [Broker id=2] Creating new partition __consumer_offsets-45 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:37:00.629046053Z [2024-04-22 14:37:00,623] INFO [LogLoader partition=__consumer_offsets-45, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:37:00.629065665Z [2024-04-22 14:37:00,624] INFO Created log for partition __consumer_offsets-45 in /bitnami/kafka/data/__consumer_offsets-45 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:37:00.629070050Z [2024-04-22 14:37:00,624] INFO [Partition __consumer_offsets-45 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-45 (kafka.cluster.Partition)
2024-04-22T14:37:00.629073600Z [2024-04-22 14:37:00,624] INFO [Partition __consumer_offsets-45 broker=2] Log loaded for partition __consumer_offsets-45 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:37:00.629077853Z [2024-04-22 14:37:00,625] INFO [Broker id=2] Follower __consumer_offsets-45 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:37:00.629081666Z [2024-04-22 14:37:00,625] INFO [Broker id=2] Creating new partition __consumer_offsets-14 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:37:00.635352662Z [2024-04-22 14:37:00,634] INFO [LogLoader partition=__consumer_offsets-14, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:37:00.638489228Z [2024-04-22 14:37:00,637] INFO Created log for partition __consumer_offsets-14 in /bitnami/kafka/data/__consumer_offsets-14 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:37:00.640048957Z [2024-04-22 14:37:00,637] INFO [Partition __consumer_offsets-14 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-14 (kafka.cluster.Partition)
2024-04-22T14:37:00.640055301Z [2024-04-22 14:37:00,637] INFO [Partition __consumer_offsets-14 broker=2] Log loaded for partition __consumer_offsets-14 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:37:00.640081363Z [2024-04-22 14:37:00,637] INFO [Broker id=2] Follower __consumer_offsets-14 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:37:00.640085164Z [2024-04-22 14:37:00,637] INFO [Broker id=2] Creating new partition __consumer_offsets-10 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:37:00.644397536Z [2024-04-22 14:37:00,644] INFO [LogLoader partition=__consumer_offsets-10, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:37:00.663129960Z [2024-04-22 14:37:00,654] INFO Created log for partition __consumer_offsets-10 in /bitnami/kafka/data/__consumer_offsets-10 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:37:00.664165510Z [2024-04-22 14:37:00,655] INFO [Partition __consumer_offsets-10 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-10 (kafka.cluster.Partition)
2024-04-22T14:37:00.664176910Z [2024-04-22 14:37:00,655] INFO [Partition __consumer_offsets-10 broker=2] Log loaded for partition __consumer_offsets-10 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:37:00.664186622Z [2024-04-22 14:37:00,655] INFO [Broker id=2] Follower __consumer_offsets-10 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:37:00.664194611Z [2024-04-22 14:37:00,655] INFO [Broker id=2] Creating new partition __consumer_offsets-24 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:37:00.763674805Z [2024-04-22 14:37:00,763] INFO [LogLoader partition=__consumer_offsets-24, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:37:00.765549878Z [2024-04-22 14:37:00,764] INFO Created log for partition __consumer_offsets-24 in /bitnami/kafka/data/__consumer_offsets-24 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:37:00.765570251Z [2024-04-22 14:37:00,764] INFO [Partition __consumer_offsets-24 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-24 (kafka.cluster.Partition)
2024-04-22T14:37:00.765574272Z [2024-04-22 14:37:00,764] INFO [Partition __consumer_offsets-24 broker=2] Log loaded for partition __consumer_offsets-24 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:37:00.765578527Z [2024-04-22 14:37:00,764] INFO [Broker id=2] Follower __consumer_offsets-24 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:37:00.765582509Z [2024-04-22 14:37:00,764] INFO [Broker id=2] Creating new partition __consumer_offsets-22 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:37:00.975393973Z [2024-04-22 14:37:00,963] INFO [LogLoader partition=__consumer_offsets-22, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:37:00.975403522Z [2024-04-22 14:37:00,964] INFO Created log for partition __consumer_offsets-22 in /bitnami/kafka/data/__consumer_offsets-22 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:37:01.083962949Z [2024-04-22 14:37:01,001] INFO [Partition __consumer_offsets-22 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-22 (kafka.cluster.Partition)
2024-04-22T14:37:01.088228209Z [2024-04-22 14:37:01,084] INFO [Partition __consumer_offsets-22 broker=2] Log loaded for partition __consumer_offsets-22 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:37:01.088243770Z [2024-04-22 14:37:01,084] INFO [Broker id=2] Follower __consumer_offsets-22 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:37:01.088247722Z [2024-04-22 14:37:01,084] INFO [Broker id=2] Creating new partition __consumer_offsets-18 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:37:01.164802616Z [2024-04-22 14:37:01,164] INFO [LogLoader partition=__consumer_offsets-18, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:37:01.173178758Z [2024-04-22 14:37:01,171] INFO Created log for partition __consumer_offsets-18 in /bitnami/kafka/data/__consumer_offsets-18 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:37:01.188521601Z [2024-04-22 14:37:01,171] INFO [Partition __consumer_offsets-18 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-18 (kafka.cluster.Partition)
2024-04-22T14:37:01.188530782Z [2024-04-22 14:37:01,171] INFO [Partition __consumer_offsets-18 broker=2] Log loaded for partition __consumer_offsets-18 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:37:01.188535045Z [2024-04-22 14:37:01,172] INFO [Broker id=2] Follower __consumer_offsets-18 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:37:01.188539089Z [2024-04-22 14:37:01,172] INFO [Broker id=2] Creating new partition __consumer_offsets-31 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:37:01.334015284Z [2024-04-22 14:37:01,333] INFO [LogLoader partition=__consumer_offsets-31, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:37:01.336022854Z [2024-04-22 14:37:01,335] INFO Created log for partition __consumer_offsets-31 in /bitnami/kafka/data/__consumer_offsets-31 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:37:01.337037491Z [2024-04-22 14:37:01,336] INFO [Partition __consumer_offsets-31 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-31 (kafka.cluster.Partition)
2024-04-22T14:37:01.337196843Z [2024-04-22 14:37:01,337] INFO [Partition __consumer_offsets-31 broker=2] Log loaded for partition __consumer_offsets-31 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:37:01.337201134Z [2024-04-22 14:37:01,337] INFO [Broker id=2] Follower __consumer_offsets-31 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:37:01.337257788Z [2024-04-22 14:37:01,337] INFO [Broker id=2] Creating new partition __consumer_offsets-0 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:37:01.497331900Z [2024-04-22 14:37:01,496] INFO [LogLoader partition=__consumer_offsets-0, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:37:01.534362859Z [2024-04-22 14:37:01,534] INFO Created log for partition __consumer_offsets-0 in /bitnami/kafka/data/__consumer_offsets-0 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:37:01.550250280Z [2024-04-22 14:37:01,550] INFO [Partition __consumer_offsets-0 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-0 (kafka.cluster.Partition)
2024-04-22T14:37:01.553536264Z [2024-04-22 14:37:01,550] INFO [Partition __consumer_offsets-0 broker=2] Log loaded for partition __consumer_offsets-0 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:37:01.553547837Z [2024-04-22 14:37:01,550] INFO [Broker id=2] Follower __consumer_offsets-0 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:37:01.553552133Z [2024-04-22 14:37:01,550] INFO [Broker id=2] Creating new partition __consumer_offsets-29 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:37:01.626228450Z [2024-04-22 14:37:01,625] INFO [LogLoader partition=__consumer_offsets-29, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:37:01.640928585Z [2024-04-22 14:37:01,637] INFO Created log for partition __consumer_offsets-29 in /bitnami/kafka/data/__consumer_offsets-29 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:37:01.640949270Z [2024-04-22 14:37:01,638] INFO [Partition __consumer_offsets-29 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-29 (kafka.cluster.Partition)
2024-04-22T14:37:01.640952909Z [2024-04-22 14:37:01,638] INFO [Partition __consumer_offsets-29 broker=2] Log loaded for partition __consumer_offsets-29 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:37:01.640956667Z [2024-04-22 14:37:01,638] INFO [Broker id=2] Follower __consumer_offsets-29 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:37:01.640960203Z [2024-04-22 14:37:01,638] INFO [Broker id=2] Creating new partition __consumer_offsets-25 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:37:01.778535129Z [2024-04-22 14:37:01,778] INFO [LogLoader partition=__consumer_offsets-25, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:37:01.797728539Z [2024-04-22 14:37:01,790] INFO Created log for partition __consumer_offsets-25 in /bitnami/kafka/data/__consumer_offsets-25 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:37:01.797760275Z [2024-04-22 14:37:01,790] INFO [Partition __consumer_offsets-25 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-25 (kafka.cluster.Partition)
2024-04-22T14:37:01.797764358Z [2024-04-22 14:37:01,795] INFO [Partition __consumer_offsets-25 broker=2] Log loaded for partition __consumer_offsets-25 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:37:01.799005184Z [2024-04-22 14:37:01,798] INFO [Broker id=2] Follower __consumer_offsets-25 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:37:01.799293808Z [2024-04-22 14:37:01,799] INFO [Broker id=2] Creating new partition __consumer_offsets-39 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:37:01.805038954Z [2024-04-22 14:37:01,802] INFO [LogLoader partition=__consumer_offsets-39, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:37:01.805074248Z [2024-04-22 14:37:01,803] INFO Created log for partition __consumer_offsets-39 in /bitnami/kafka/data/__consumer_offsets-39 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:37:01.805089051Z [2024-04-22 14:37:01,803] INFO [Partition __consumer_offsets-39 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-39 (kafka.cluster.Partition)
2024-04-22T14:37:01.805092592Z [2024-04-22 14:37:01,803] INFO [Partition __consumer_offsets-39 broker=2] Log loaded for partition __consumer_offsets-39 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:37:01.805096338Z [2024-04-22 14:37:01,803] INFO [Broker id=2] Follower __consumer_offsets-39 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:37:01.805100240Z [2024-04-22 14:37:01,803] INFO [Broker id=2] Creating new partition __consumer_offsets-8 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:37:01.821117532Z [2024-04-22 14:37:01,812] INFO [LogLoader partition=__consumer_offsets-8, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:37:01.821136950Z [2024-04-22 14:37:01,813] INFO Created log for partition __consumer_offsets-8 in /bitnami/kafka/data/__consumer_offsets-8 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:37:01.821140928Z [2024-04-22 14:37:01,813] INFO [Partition __consumer_offsets-8 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-8 (kafka.cluster.Partition)
2024-04-22T14:37:01.821144146Z [2024-04-22 14:37:01,813] INFO [Partition __consumer_offsets-8 broker=2] Log loaded for partition __consumer_offsets-8 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:37:01.821147436Z [2024-04-22 14:37:01,813] INFO [Broker id=2] Follower __consumer_offsets-8 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:37:01.821151367Z [2024-04-22 14:37:01,813] INFO [Broker id=2] Creating new partition __consumer_offsets-35 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:37:01.861325802Z [2024-04-22 14:37:01,860] INFO [LogLoader partition=__consumer_offsets-35, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:37:01.866871521Z [2024-04-22 14:37:01,863] INFO Created log for partition __consumer_offsets-35 in /bitnami/kafka/data/__consumer_offsets-35 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:37:01.866889782Z [2024-04-22 14:37:01,863] INFO [Partition __consumer_offsets-35 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-35 (kafka.cluster.Partition)
2024-04-22T14:37:01.866893149Z [2024-04-22 14:37:01,863] INFO [Partition __consumer_offsets-35 broker=2] Log loaded for partition __consumer_offsets-35 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:37:01.866896845Z [2024-04-22 14:37:01,863] INFO [Broker id=2] Follower __consumer_offsets-35 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:37:01.866900220Z [2024-04-22 14:37:01,863] INFO [Broker id=2] Creating new partition __consumer_offsets-4 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:37:01.866903941Z [2024-04-22 14:37:01,866] INFO [LogLoader partition=__consumer_offsets-4, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:37:01.885112241Z [2024-04-22 14:37:01,871] INFO Created log for partition __consumer_offsets-4 in /bitnami/kafka/data/__consumer_offsets-4 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:37:01.885145146Z [2024-04-22 14:37:01,871] INFO [Partition __consumer_offsets-4 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-4 (kafka.cluster.Partition)
2024-04-22T14:37:01.885148918Z [2024-04-22 14:37:01,871] INFO [Partition __consumer_offsets-4 broker=2] Log loaded for partition __consumer_offsets-4 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:37:01.885151945Z [2024-04-22 14:37:01,871] INFO [Broker id=2] Follower __consumer_offsets-4 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:37:01.885156112Z [2024-04-22 14:37:01,871] INFO [Broker id=2] Creating new partition __consumer_offsets-33 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:37:01.885159487Z [2024-04-22 14:37:01,878] INFO [LogLoader partition=__consumer_offsets-33, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:37:01.885163531Z [2024-04-22 14:37:01,878] INFO Created log for partition __consumer_offsets-33 in /bitnami/kafka/data/__consumer_offsets-33 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:37:01.885166476Z [2024-04-22 14:37:01,878] INFO [Partition __consumer_offsets-33 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-33 (kafka.cluster.Partition)
2024-04-22T14:37:01.885169654Z [2024-04-22 14:37:01,879] INFO [Partition __consumer_offsets-33 broker=2] Log loaded for partition __consumer_offsets-33 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:37:01.885172623Z [2024-04-22 14:37:01,879] INFO [Broker id=2] Follower __consumer_offsets-33 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:37:01.885175767Z [2024-04-22 14:37:01,880] INFO [Broker id=2] Creating new partition __consumer_offsets-2 with topic id ytEnAvpXSiu4qCS_b1Zxag. (state.change.logger)
2024-04-22T14:37:01.901040743Z [2024-04-22 14:37:01,895] INFO [LogLoader partition=__consumer_offsets-2, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:37:01.908997419Z [2024-04-22 14:37:01,907] INFO Created log for partition __consumer_offsets-2 in /bitnami/kafka/data/__consumer_offsets-2 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} (kafka.log.LogManager)
2024-04-22T14:37:01.909016790Z [2024-04-22 14:37:01,907] INFO [Partition __consumer_offsets-2 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-2 (kafka.cluster.Partition)
2024-04-22T14:37:01.909020467Z [2024-04-22 14:37:01,907] INFO [Partition __consumer_offsets-2 broker=2] Log loaded for partition __consumer_offsets-2 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:37:01.909023988Z [2024-04-22 14:37:01,907] INFO [Broker id=2] Follower __consumer_offsets-2 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:37:01.909030310Z [2024-04-22 14:37:01,908] INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(__consumer_offsets-38, __consumer_offsets-16, __consumer_offsets-8, __consumer_offsets-19, __consumer_offsets-2, __consumer_offsets-13, __consumer_offsets-35, __consumer_offsets-46, __consumer_offsets-24, __consumer_offsets-10, __consumer_offsets-48, __consumer_offsets-29, __consumer_offsets-40, __consumer_offsets-18, __consumer_offsets-7, __consumer_offsets-23, __consumer_offsets-45, __consumer_offsets-4, __consumer_offsets-15, __consumer_offsets-42, __consumer_offsets-9, __consumer_offsets-31, __consumer_offsets-28, __consumer_offsets-39, __consumer_offsets-44, __consumer_offsets-36, __consumer_offsets-25, __consumer_offsets-3, __consumer_offsets-14, __consumer_offsets-30, __consumer_offsets-33, __consumer_offsets-22, __consumer_offsets-0) (kafka.server.ReplicaFetcherManager)
2024-04-22T14:37:01.909044990Z [2024-04-22 14:37:01,908] INFO [Broker id=2] Stopped fetchers as part of become-follower for 33 partitions (state.change.logger)
2024-04-22T14:37:02.500685891Z [2024-04-22 14:37:02,497] INFO [ReplicaFetcherThread-0-1]: Starting (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:02.639601240Z [2024-04-22 14:37:02,639] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition __consumer_offsets-25 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:02.772248131Z [2024-04-22 14:37:02,772] INFO [ReplicaFetcherManager on broker 2] Added fetcher to broker 1 for partitions Map(__consumer_offsets-38 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=1, host=kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-19 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=1, host=kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-8 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=1, host=kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-46 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=1, host=kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-40 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=1, host=kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-29 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=1, host=kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-23 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=1, host=kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-4 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=1, host=kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-15 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=1, host=kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-42 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=1, host=kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-9 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=1, host=kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-31 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=1, host=kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-25 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=1, host=kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-14 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=1, host=kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-0 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=1, host=kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-33 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=1, host=kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094),0,0)) (kafka.server.ReplicaFetcherManager)
2024-04-22T14:37:02.908945916Z [2024-04-22 14:37:02,907] INFO [UnifiedLog partition=__consumer_offsets-25, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.047427904Z [2024-04-22 14:37:03,030] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition __consumer_offsets-14 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.047489430Z [2024-04-22 14:37:03,030] INFO [UnifiedLog partition=__consumer_offsets-14, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.049948144Z [2024-04-22 14:37:03,047] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition __consumer_offsets-40 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.049967550Z [2024-04-22 14:37:03,047] INFO [UnifiedLog partition=__consumer_offsets-40, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.049976824Z [2024-04-22 14:37:03,047] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition __consumer_offsets-29 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.049985520Z [2024-04-22 14:37:03,047] INFO [UnifiedLog partition=__consumer_offsets-29, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.049994367Z [2024-04-22 14:37:03,047] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition __consumer_offsets-0 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.050002832Z [2024-04-22 14:37:03,047] INFO [UnifiedLog partition=__consumer_offsets-0, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.050011157Z [2024-04-22 14:37:03,047] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition __consumer_offsets-33 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.050019517Z [2024-04-22 14:37:03,047] INFO [UnifiedLog partition=__consumer_offsets-33, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.050028155Z [2024-04-22 14:37:03,047] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition __consumer_offsets-4 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.050036780Z [2024-04-22 14:37:03,047] INFO [UnifiedLog partition=__consumer_offsets-4, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.050045063Z [2024-04-22 14:37:03,047] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition __consumer_offsets-23 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.050053420Z [2024-04-22 14:37:03,047] INFO [UnifiedLog partition=__consumer_offsets-23, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.050061703Z [2024-04-22 14:37:03,047] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition __consumer_offsets-15 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.050069991Z [2024-04-22 14:37:03,047] INFO [UnifiedLog partition=__consumer_offsets-15, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.050090300Z [2024-04-22 14:37:03,047] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition __consumer_offsets-19 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.050099106Z [2024-04-22 14:37:03,047] INFO [UnifiedLog partition=__consumer_offsets-19, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.050107496Z [2024-04-22 14:37:03,047] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition __consumer_offsets-38 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.050116755Z [2024-04-22 14:37:03,047] INFO [UnifiedLog partition=__consumer_offsets-38, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.050128954Z [2024-04-22 14:37:03,048] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition __consumer_offsets-8 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.050137847Z [2024-04-22 14:37:03,048] INFO [UnifiedLog partition=__consumer_offsets-8, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.061024871Z [2024-04-22 14:37:03,060] INFO [ReplicaFetcherManager on broker 2] Added fetcher to broker 0 for partitions Map(__consumer_offsets-16 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-13 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-2 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-24 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-35 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-10 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-48 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-18 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-7 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-45 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-28 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-39 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-44 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-36 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-3 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-30 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-22 -> InitialFetchState(Some(ytEnAvpXSiu4qCS_b1Zxag),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0)) (kafka.server.ReplicaFetcherManager)
2024-04-22T14:37:03.081001281Z [2024-04-22 14:37:03,075] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition __consumer_offsets-42 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.081014625Z [2024-04-22 14:37:03,075] INFO [UnifiedLog partition=__consumer_offsets-42, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.081018077Z [2024-04-22 14:37:03,075] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition __consumer_offsets-9 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.081021359Z [2024-04-22 14:37:03,075] INFO [UnifiedLog partition=__consumer_offsets-9, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.081024636Z [2024-04-22 14:37:03,075] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition __consumer_offsets-31 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.081028330Z [2024-04-22 14:37:03,076] INFO [UnifiedLog partition=__consumer_offsets-31, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.081031617Z [2024-04-22 14:37:03,076] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition __consumer_offsets-46 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.081034733Z [2024-04-22 14:37:03,076] INFO [UnifiedLog partition=__consumer_offsets-46, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.097058625Z [2024-04-22 14:37:03,091] INFO [ReplicaFetcherThread-0-0]: Starting (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.097084762Z [2024-04-22 14:37:03,091] INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-24 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.097305715Z [2024-04-22 14:37:03,091] INFO [UnifiedLog partition=__consumer_offsets-24, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.097316907Z [2024-04-22 14:37:03,092] INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-28 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.097320284Z [2024-04-22 14:37:03,092] INFO [UnifiedLog partition=__consumer_offsets-28, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.097324177Z [2024-04-22 14:37:03,092] INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-39 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.097332372Z [2024-04-22 14:37:03,092] INFO [UnifiedLog partition=__consumer_offsets-39, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.097335974Z [2024-04-22 14:37:03,092] INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-10 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.097338959Z [2024-04-22 14:37:03,092] INFO [UnifiedLog partition=__consumer_offsets-10, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.097341821Z [2024-04-22 14:37:03,092] INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-36 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.097345259Z [2024-04-22 14:37:03,092] INFO [UnifiedLog partition=__consumer_offsets-36, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.097348475Z [2024-04-22 14:37:03,092] INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-44 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.097351463Z [2024-04-22 14:37:03,092] INFO [UnifiedLog partition=__consumer_offsets-44, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.097354320Z [2024-04-22 14:37:03,092] INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-3 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.097357392Z [2024-04-22 14:37:03,092] INFO [UnifiedLog partition=__consumer_offsets-3, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.097360410Z [2024-04-22 14:37:03,092] INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-18 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.097363650Z [2024-04-22 14:37:03,092] INFO [UnifiedLog partition=__consumer_offsets-18, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.097366690Z [2024-04-22 14:37:03,092] INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-48 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.097369856Z [2024-04-22 14:37:03,092] INFO [UnifiedLog partition=__consumer_offsets-48, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.097377726Z [2024-04-22 14:37:03,092] INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-7 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.097380774Z [2024-04-22 14:37:03,092] INFO [UnifiedLog partition=__consumer_offsets-7, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.097383939Z [2024-04-22 14:37:03,092] INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-22 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.097390817Z [2024-04-22 14:37:03,092] INFO [UnifiedLog partition=__consumer_offsets-22, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.097393834Z [2024-04-22 14:37:03,092] INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-30 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.097396861Z [2024-04-22 14:37:03,092] INFO [UnifiedLog partition=__consumer_offsets-30, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.097399851Z [2024-04-22 14:37:03,092] INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-45 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.097402867Z [2024-04-22 14:37:03,092] INFO [UnifiedLog partition=__consumer_offsets-45, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.117066145Z [2024-04-22 14:37:03,111] INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-16 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.117077837Z [2024-04-22 14:37:03,115] INFO [UnifiedLog partition=__consumer_offsets-16, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.117081468Z [2024-04-22 14:37:03,115] INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-35 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.117092417Z [2024-04-22 14:37:03,115] INFO [UnifiedLog partition=__consumer_offsets-35, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.117095817Z [2024-04-22 14:37:03,115] INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-13 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.117099200Z [2024-04-22 14:37:03,115] INFO [UnifiedLog partition=__consumer_offsets-13, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.117103849Z [2024-04-22 14:37:03,111] INFO [Broker id=2] Started fetchers as part of become-follower for 33 partitions (state.change.logger)
2024-04-22T14:37:03.139226319Z [2024-04-22 14:37:03,131] INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-2 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread)
2024-04-22T14:37:03.139242576Z [2024-04-22 14:37:03,131] INFO [UnifiedLog partition=__consumer_offsets-2, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog)
2024-04-22T14:37:03.693233525Z [2024-04-22 14:37:03,691] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 47 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:03.693255691Z [2024-04-22 14:37:03,692] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-47 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:03.949033122Z [2024-04-22 14:37:03,948] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-47 in 254 milliseconds for epoch 0, of which 51 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:03.957230498Z [2024-04-22 14:37:03,955] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 11 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:03.957241899Z [2024-04-22 14:37:03,955] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-11 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:03.957245404Z [2024-04-22 14:37:03,955] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 43 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:03.957248717Z [2024-04-22 14:37:03,955] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-43 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:03.957251749Z [2024-04-22 14:37:03,955] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 12 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:03.957255053Z [2024-04-22 14:37:03,955] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-12 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:03.957258031Z [2024-04-22 14:37:03,955] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 41 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:03.957260928Z [2024-04-22 14:37:03,955] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-41 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:03.984287481Z [2024-04-22 14:37:03,983] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 21 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:03.984314432Z [2024-04-22 14:37:03,983] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-21 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:03.984319752Z [2024-04-22 14:37:03,984] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 20 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:03.984324140Z [2024-04-22 14:37:03,984] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-20 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:03.984328646Z [2024-04-22 14:37:03,984] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 17 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:03.984332898Z [2024-04-22 14:37:03,984] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-17 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:03.984337950Z [2024-04-22 14:37:03,984] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 49 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.083945253Z [2024-04-22 14:37:03,984] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-49 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.126284428Z [2024-04-22 14:37:04,084] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 32 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.126307858Z [2024-04-22 14:37:04,124] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-32 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.126311333Z [2024-04-22 14:37:04,125] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 27 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.126314339Z [2024-04-22 14:37:04,125] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-27 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.126317336Z [2024-04-22 14:37:04,125] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 26 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.126327611Z [2024-04-22 14:37:04,125] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-26 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.126331188Z [2024-04-22 14:37:04,125] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 5 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.126334397Z [2024-04-22 14:37:04,125] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-5 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.126337421Z [2024-04-22 14:37:04,125] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 37 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.126346607Z [2024-04-22 14:37:04,125] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-37 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.126349874Z [2024-04-22 14:37:04,125] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 6 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.126352931Z [2024-04-22 14:37:04,125] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-6 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.126355940Z [2024-04-22 14:37:04,125] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 1 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.126359128Z [2024-04-22 14:37:04,125] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-1 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.126362566Z [2024-04-22 14:37:04,125] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 34 in epoch 0 (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.126365526Z [2024-04-22 14:37:04,125] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-34 for epoch 0 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.145131576Z [2024-04-22 14:37:03,989] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-11 in 34 milliseconds for epoch 0, of which 34 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.202168165Z [2024-04-22 14:37:04,198] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-43 in 243 milliseconds for epoch 0, of which 224 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.202190112Z [2024-04-22 14:37:04,198] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-12 in 243 milliseconds for epoch 0, of which 243 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.202231438Z [2024-04-22 14:37:04,198] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-41 in 243 milliseconds for epoch 0, of which 243 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.202234822Z [2024-04-22 14:37:04,198] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-21 in 215 milliseconds for epoch 0, of which 215 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.202238176Z [2024-04-22 14:37:04,199] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-20 in 215 milliseconds for epoch 0, of which 214 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.202241168Z [2024-04-22 14:37:04,199] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-17 in 215 milliseconds for epoch 0, of which 215 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.202243878Z [2024-04-22 14:37:04,199] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-49 in 116 milliseconds for epoch 0, of which 116 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.202246895Z [2024-04-22 14:37:04,199] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-32 in 75 milliseconds for epoch 0, of which 75 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.202249863Z [2024-04-22 14:37:04,199] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-27 in 74 milliseconds for epoch 0, of which 74 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.202252824Z [2024-04-22 14:37:04,199] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-26 in 74 milliseconds for epoch 0, of which 74 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.202256117Z [2024-04-22 14:37:04,199] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-5 in 74 milliseconds for epoch 0, of which 74 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.202258857Z [2024-04-22 14:37:04,199] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-37 in 74 milliseconds for epoch 0, of which 74 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.202261612Z [2024-04-22 14:37:04,199] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-6 in 74 milliseconds for epoch 0, of which 74 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.202264602Z [2024-04-22 14:37:04,200] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-1 in 75 milliseconds for epoch 0, of which 74 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.202267339Z [2024-04-22 14:37:04,200] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-34 in 75 milliseconds for epoch 0, of which 75 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.281764393Z [2024-04-22 14:37:04,279] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 15 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.281793693Z [2024-04-22 14:37:04,280] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-15 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.463519767Z [2024-04-22 14:37:04,462] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 48 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.463545912Z [2024-04-22 14:37:04,462] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-48 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.463549936Z [2024-04-22 14:37:04,462] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 13 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.463553436Z [2024-04-22 14:37:04,462] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-13 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.463561120Z [2024-04-22 14:37:04,462] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 46 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.463564505Z [2024-04-22 14:37:04,462] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-46 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.463567558Z [2024-04-22 14:37:04,462] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 44 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.463570670Z [2024-04-22 14:37:04,462] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-44 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.463574073Z [2024-04-22 14:37:04,462] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 9 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.463577076Z [2024-04-22 14:37:04,462] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-9 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.463579921Z [2024-04-22 14:37:04,462] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 42 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.463650095Z [2024-04-22 14:37:04,462] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-42 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.463653630Z [2024-04-22 14:37:04,462] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 23 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.463656712Z [2024-04-22 14:37:04,462] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-23 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.463659729Z [2024-04-22 14:37:04,462] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 19 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.463662672Z [2024-04-22 14:37:04,462] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-19 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.463665812Z [2024-04-22 14:37:04,462] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 30 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.463688796Z [2024-04-22 14:37:04,462] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-30 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.463692431Z [2024-04-22 14:37:04,462] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 28 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.463695536Z [2024-04-22 14:37:04,462] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-28 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.463698776Z [2024-04-22 14:37:04,462] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 7 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.463701616Z [2024-04-22 14:37:04,462] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-7 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.463707277Z [2024-04-22 14:37:04,462] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 40 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.463710376Z [2024-04-22 14:37:04,462] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-40 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.463713519Z [2024-04-22 14:37:04,462] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 38 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.463716288Z [2024-04-22 14:37:04,462] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-38 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.463719208Z [2024-04-22 14:37:04,462] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 3 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.463721962Z [2024-04-22 14:37:04,462] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-3 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.463724789Z [2024-04-22 14:37:04,462] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 36 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.463743200Z [2024-04-22 14:37:04,462] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-36 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.463746518Z [2024-04-22 14:37:04,462] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 16 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.463749321Z [2024-04-22 14:37:04,462] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-16 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.463752647Z [2024-04-22 14:37:04,462] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 45 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.463755784Z [2024-04-22 14:37:04,462] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-45 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.463758821Z [2024-04-22 14:37:04,462] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 14 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.463761670Z [2024-04-22 14:37:04,462] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-14 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.463769383Z [2024-04-22 14:37:04,462] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 10 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.463772456Z [2024-04-22 14:37:04,462] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-10 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.463775209Z [2024-04-22 14:37:04,462] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 24 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.463778412Z [2024-04-22 14:37:04,462] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-24 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.463781449Z [2024-04-22 14:37:04,462] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 22 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.463784154Z [2024-04-22 14:37:04,462] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-22 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.463786987Z [2024-04-22 14:37:04,462] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 18 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.463789755Z [2024-04-22 14:37:04,462] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-18 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.463802576Z [2024-04-22 14:37:04,462] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 31 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.463805707Z [2024-04-22 14:37:04,462] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-31 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.463820961Z [2024-04-22 14:37:04,462] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 0 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.463823992Z [2024-04-22 14:37:04,462] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-0 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.463826960Z [2024-04-22 14:37:04,462] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 29 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.463829673Z [2024-04-22 14:37:04,462] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-29 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.463832524Z [2024-04-22 14:37:04,462] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 25 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.463835271Z [2024-04-22 14:37:04,462] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-25 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.463838101Z [2024-04-22 14:37:04,462] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 39 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.463840936Z [2024-04-22 14:37:04,462] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-39 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.463848234Z [2024-04-22 14:37:04,462] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 8 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.463851287Z [2024-04-22 14:37:04,462] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-8 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.463854062Z [2024-04-22 14:37:04,462] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 35 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.463856899Z [2024-04-22 14:37:04,462] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-35 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.463859795Z [2024-04-22 14:37:04,462] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 4 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.463862465Z [2024-04-22 14:37:04,462] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-4 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.463865146Z [2024-04-22 14:37:04,462] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 33 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.463867908Z [2024-04-22 14:37:04,462] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-33 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.463870708Z [2024-04-22 14:37:04,462] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 2 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:04.463873427Z [2024-04-22 14:37:04,462] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-2 (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.481653560Z [2024-04-22 14:37:04,478] INFO [DynamicConfigPublisher broker id=2] Updating topic __consumer_offsets with new configuration : cleanup.policy -> compact,segment.bytes -> 104857600,compression.type -> producer (kafka.server.metadata.DynamicConfigPublisher)
2024-04-22T14:37:04.504951879Z [2024-04-22 14:37:04,502] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-15 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.504978048Z [2024-04-22 14:37:04,503] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-48 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.504982160Z [2024-04-22 14:37:04,503] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-13 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.504988181Z [2024-04-22 14:37:04,503] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-46 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.504992027Z [2024-04-22 14:37:04,503] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-44 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.504995128Z [2024-04-22 14:37:04,504] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-9 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.505009852Z [2024-04-22 14:37:04,504] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-42 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.505013022Z [2024-04-22 14:37:04,504] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-23 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.505016418Z [2024-04-22 14:37:04,504] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-19 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.505019520Z [2024-04-22 14:37:04,504] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-30 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.505022991Z [2024-04-22 14:37:04,504] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-28 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.505026092Z [2024-04-22 14:37:04,504] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-7 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.505029987Z [2024-04-22 14:37:04,504] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-40 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.509023256Z [2024-04-22 14:37:04,508] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-38 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.509037878Z [2024-04-22 14:37:04,508] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-3 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.509041578Z [2024-04-22 14:37:04,508] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-36 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.509312356Z [2024-04-22 14:37:04,509] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-16 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.509326783Z [2024-04-22 14:37:04,509] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-45 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.511052617Z [2024-04-22 14:37:04,510] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-14 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.511064006Z [2024-04-22 14:37:04,510] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-10 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.511083621Z [2024-04-22 14:37:04,510] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-24 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.511096155Z [2024-04-22 14:37:04,510] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-22 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.511099472Z [2024-04-22 14:37:04,510] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-18 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.511102500Z [2024-04-22 14:37:04,510] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-31 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.511105553Z [2024-04-22 14:37:04,510] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-0 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.511108891Z [2024-04-22 14:37:04,510] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-29 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.511112314Z [2024-04-22 14:37:04,510] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-25 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.511116039Z [2024-04-22 14:37:04,510] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-39 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.511119332Z [2024-04-22 14:37:04,510] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-8 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.511122245Z [2024-04-22 14:37:04,510] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-35 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.511125422Z [2024-04-22 14:37:04,510] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-4 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.511128446Z [2024-04-22 14:37:04,510] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-33 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:04.511131770Z [2024-04-22 14:37:04,510] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-2 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
2024-04-22T14:37:13.391362732Z [2024-04-22 14:37:13,390] INFO Sent auto-creation request for Set(nslcmops, vca, k8scluster, k8srepo, pla) to the active controller. (kafka.server.DefaultAutoTopicCreationManager)
2024-04-22T14:37:13.643194643Z [2024-04-22 14:37:13,643] INFO [QuorumController id=2] Created topic nslcmops with topic ID RfICgfe8QGyEvE81XXMQGw. (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:37:13.651323634Z [2024-04-22 14:37:13,651] INFO [QuorumController id=2] Created partition nslcmops-0 with topic ID RfICgfe8QGyEvE81XXMQGw and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:37:13.652694977Z [2024-04-22 14:37:13,652] INFO [QuorumController id=2] Created topic vca with topic ID CIfb2ehcSmizSYk8m0Snlw. (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:37:13.652939479Z [2024-04-22 14:37:13,652] INFO [QuorumController id=2] Created partition vca-0 with topic ID CIfb2ehcSmizSYk8m0Snlw and PartitionRegistration(replicas=[2], isr=[2], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:37:13.653177707Z [2024-04-22 14:37:13,653] INFO [QuorumController id=2] Created topic k8scluster with topic ID mYqfFbUMTuKbP4vCisi1wA. (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:37:13.653439082Z [2024-04-22 14:37:13,653] INFO [QuorumController id=2] Created partition k8scluster-0 with topic ID mYqfFbUMTuKbP4vCisi1wA and PartitionRegistration(replicas=[2], isr=[2], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:37:13.653642238Z [2024-04-22 14:37:13,653] INFO [QuorumController id=2] Created topic k8srepo with topic ID Dpz4RNVjSMufykdUiHJ3Dg. (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:37:13.654210257Z [2024-04-22 14:37:13,654] INFO [QuorumController id=2] Created partition k8srepo-0 with topic ID Dpz4RNVjSMufykdUiHJ3Dg and PartitionRegistration(replicas=[0], isr=[0], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:37:13.656792247Z [2024-04-22 14:37:13,656] INFO [QuorumController id=2] Created topic pla with topic ID ruj5MPQXS5CpPdHrSdhOWQ. (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:37:13.657014516Z [2024-04-22 14:37:13,654] INFO [Broker id=2] Transitioning 3 partition(s) to local leaders. (state.change.logger)
2024-04-22T14:37:13.657131035Z [2024-04-22 14:37:13,656] INFO [QuorumController id=2] Created partition pla-0 with topic ID ruj5MPQXS5CpPdHrSdhOWQ and PartitionRegistration(replicas=[2], isr=[2], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
2024-04-22T14:37:13.666290924Z [2024-04-22 14:37:13,666] INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(vca-0, k8scluster-0, pla-0) (kafka.server.ReplicaFetcherManager)
2024-04-22T14:37:13.666471564Z [2024-04-22 14:37:13,666] INFO [Broker id=2] Creating new partition vca-0 with topic id CIfb2ehcSmizSYk8m0Snlw. (state.change.logger)
2024-04-22T14:37:13.677442671Z [2024-04-22 14:37:13,677] INFO [LogLoader partition=vca-0, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:37:13.679311575Z [2024-04-22 14:37:13,679] INFO Created log for partition vca-0 in /bitnami/kafka/data/vca-0 with properties {} (kafka.log.LogManager)
2024-04-22T14:37:13.682454561Z [2024-04-22 14:37:13,682] INFO [Partition vca-0 broker=2] No checkpointed highwatermark is found for partition vca-0 (kafka.cluster.Partition)
2024-04-22T14:37:13.682505142Z [2024-04-22 14:37:13,682] INFO [Partition vca-0 broker=2] Log loaded for partition vca-0 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:37:13.682674257Z [2024-04-22 14:37:13,682] INFO [Broker id=2] Leader vca-0 with topic id Some(CIfb2ehcSmizSYk8m0Snlw) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:37:13.693570941Z [2024-04-22 14:37:13,693] INFO [Broker id=2] Creating new partition k8scluster-0 with topic id mYqfFbUMTuKbP4vCisi1wA. (state.change.logger)
2024-04-22T14:37:13.696664255Z [2024-04-22 14:37:13,696] INFO [LogLoader partition=k8scluster-0, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:37:13.697323304Z [2024-04-22 14:37:13,697] INFO Created log for partition k8scluster-0 in /bitnami/kafka/data/k8scluster-0 with properties {} (kafka.log.LogManager)
2024-04-22T14:37:13.697372592Z [2024-04-22 14:37:13,697] INFO [Partition k8scluster-0 broker=2] No checkpointed highwatermark is found for partition k8scluster-0 (kafka.cluster.Partition)
2024-04-22T14:37:13.697399749Z [2024-04-22 14:37:13,697] INFO [Partition k8scluster-0 broker=2] Log loaded for partition k8scluster-0 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:37:13.697664069Z [2024-04-22 14:37:13,697] INFO [Broker id=2] Leader k8scluster-0 with topic id Some(mYqfFbUMTuKbP4vCisi1wA) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:37:13.703557141Z [2024-04-22 14:37:13,703] INFO [Broker id=2] Creating new partition pla-0 with topic id ruj5MPQXS5CpPdHrSdhOWQ. (state.change.logger)
2024-04-22T14:37:13.721314921Z [2024-04-22 14:37:13,721] INFO [LogLoader partition=pla-0, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
2024-04-22T14:37:13.721988220Z [2024-04-22 14:37:13,721] INFO Created log for partition pla-0 in /bitnami/kafka/data/pla-0 with properties {} (kafka.log.LogManager)
2024-04-22T14:37:13.722050658Z [2024-04-22 14:37:13,721] INFO [Partition pla-0 broker=2] No checkpointed highwatermark is found for partition pla-0 (kafka.cluster.Partition)
2024-04-22T14:37:13.722055325Z [2024-04-22 14:37:13,722] INFO [Partition pla-0 broker=2] Log loaded for partition pla-0 with initial high watermark 0 (kafka.cluster.Partition)
2024-04-22T14:37:13.724997051Z [2024-04-22 14:37:13,724] INFO [Broker id=2] Leader pla-0 with topic id Some(ruj5MPQXS5CpPdHrSdhOWQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger)
2024-04-22T14:37:13.743781110Z [2024-04-22 14:37:13,743] INFO [GroupCoordinator 2]: Dynamic Member with unknown member id joins group lcm-server in Empty state. Created a new member id aiokafka-0.8.1-7549db72-5d92-42a5-a87c-913daabc2f63 for this member and add to the group. (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:13.876089523Z [2024-04-22 14:37:13,875] INFO [GroupCoordinator 2]: Preparing to rebalance group lcm-server in state PreparingRebalance with old generation 0 (__consumer_offsets-32) (reason: Adding new member aiokafka-0.8.1-7549db72-5d92-42a5-a87c-913daabc2f63 with group instance id None; client reason: not provided) (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:16.994450029Z [2024-04-22 14:37:16,991] INFO [GroupCoordinator 2]: Stabilized group lcm-server generation 1 (__consumer_offsets-32) with 1 members (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:37:17.076972133Z [2024-04-22 14:37:17,074] INFO [GroupCoordinator 2]: Assignment received from leader aiokafka-0.8.1-7549db72-5d92-42a5-a87c-913daabc2f63 for group lcm-server for generation 1. The group has 1 members, 0 of which are static. (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:42:13.575353156Z [2024-04-22 14:42:13,575] INFO [GroupCoordinator 2]: Preparing to rebalance group lcm-server in state PreparingRebalance with old generation 1 (__consumer_offsets-32) (reason: Leader aiokafka-0.8.1-7549db72-5d92-42a5-a87c-913daabc2f63 re-joining group during Stable; client reason: not provided) (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:42:13.582504435Z [2024-04-22 14:42:13,582] INFO [GroupCoordinator 2]: Stabilized group lcm-server generation 2 (__consumer_offsets-32) with 1 members (kafka.coordinator.group.GroupCoordinator)
2024-04-22T14:42:13.590222345Z [2024-04-22 14:42:13,590] INFO [GroupCoordinator 2]: Assignment received from leader aiokafka-0.8.1-7549db72-5d92-42a5-a87c-913daabc2f63 for group lcm-server for generation 2. The group has 1 members, 0 of which are static. (kafka.coordinator.group.GroupCoordinator)