2024-04-06T01:29:00.466112998Z kafka 01:29:00.46  2024-04-06T01:29:00.474378053Z kafka 01:29:00.46 Welcome to the Bitnami kafka container 2024-04-06T01:29:00.481761961Z kafka 01:29:00.48 Subscribe to project updates by watching https://github.com/bitnami/containers 2024-04-06T01:29:00.490168029Z kafka 01:29:00.48 Submit issues and feature requests at https://github.com/bitnami/containers/issues 2024-04-06T01:29:00.495850507Z kafka 01:29:00.49  2024-04-06T01:29:00.502951442Z kafka 01:29:00.50 INFO  ==> ** Starting Kafka setup ** 2024-04-06T01:29:00.877381749Z kafka 01:29:00.87 INFO  ==> Initializing KRaft storage metadata 2024-04-06T01:29:00.887653735Z kafka 01:29:00.88 INFO  ==> Adding KRaft SCRAM users at storage bootstrap 2024-04-06T01:29:00.954252101Z kafka 01:29:00.95 INFO  ==> Formatting storage directories to add metadata... 2024-04-06T01:29:07.527820599Z Formatting /bitnami/kafka/data with metadata.version 3.5-IV2. 2024-04-06T01:29:07.949944688Z kafka 01:29:07.94 INFO  ==> ** Kafka setup finished! ** 2024-04-06T01:29:07.949945456Z 2024-04-06T01:29:08.013931110Z kafka 01:29:08.00 INFO  ==> ** Starting Kafka ** 2024-04-06T01:29:11.149763688Z [2024-04-06 01:29:11,148] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$) 2024-04-06T01:29:12.908715726Z [2024-04-06 01:29:12,906] INFO Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation (org.apache.zookeeper.common.X509Util) 2024-04-06T01:29:13.948825606Z [2024-04-06 01:29:13,945] INFO Registered signal handlers for TERM, INT, HUP (org.apache.kafka.common.utils.LoggingSignalHandler) 2024-04-06T01:29:13.956665518Z [2024-04-06 01:29:13,955] INFO [ControllerServer id=1] Starting controller (kafka.server.ControllerServer) 2024-04-06T01:29:16.086076214Z [2024-04-06 01:29:16,083] INFO Updated connection-accept-rate max connection creation rate to 2147483647 (kafka.network.ConnectionQuotas) 2024-04-06T01:29:16.648116802Z [2024-04-06 01:29:16,647] INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin) 2024-04-06T01:29:16.689649488Z [2024-04-06 01:29:16,689] INFO [SocketServer listenerType=CONTROLLER, nodeId=1] Created data-plane acceptor and processors for endpoint : ListenerName(CONTROLLER) (kafka.network.SocketServer) 2024-04-06T01:29:16.697272033Z [2024-04-06 01:29:16,697] INFO [SharedServer id=1] Starting SharedServer (kafka.server.SharedServer) 2024-04-06T01:29:16.815163243Z [2024-04-06 01:29:16,814] 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-06T01:29:16.815183255Z [2024-04-06 01:29:16,814] 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-06T01:29:16.815187242Z [2024-04-06 01:29:16,814] INFO [LogLoader partition=__cluster_metadata-0, dir=/bitnami/kafka/data] Producer state recovery took 0ms for snapshot load and 0ms for segment recovery from offset 0 (kafka.log.UnifiedLog$) 2024-04-06T01:29:16.939968384Z [2024-04-06 01:29:16,939] INFO Initialized snapshots with IDs Set() from /bitnami/kafka/data/__cluster_metadata-0 (kafka.raft.KafkaMetadataLog$) 2024-04-06T01:29:17.015461019Z [2024-04-06 01:29:17,015] INFO [raft-expiration-reaper]: Starting (kafka.raft.TimingWheelExpirationService$ExpiredOperationReaper) 2024-04-06T01:29:17.446160607Z [2024-04-06 01:29:17,445] INFO [RaftManager id=1] Completed transition to Unattached(epoch=0, voters=[0, 1, 2], electionTimeoutMs=1282) from null (org.apache.kafka.raft.QuorumState) 2024-04-06T01:29:17.459208895Z [2024-04-06 01:29:17,458] INFO [kafka-1-raft-io-thread]: Starting (kafka.raft.KafkaRaftManager$RaftIoThread) 2024-04-06T01:29:17.459606705Z [2024-04-06 01:29:17,459] INFO [kafka-1-raft-outbound-request-thread]: Starting (kafka.raft.RaftSendThread) 2024-04-06T01:29:17.492174220Z [2024-04-06 01:29:17,491] INFO [ControllerServer id=1] Waiting for controller quorum voters future (kafka.server.ControllerServer) 2024-04-06T01:29:17.492200550Z [2024-04-06 01:29:17,492] INFO [ControllerServer id=1] Finished waiting for controller quorum voters future (kafka.server.ControllerServer) 2024-04-06T01:29:17.494281511Z [2024-04-06 01:29:17,494] INFO [RaftManager id=1] Registered the listener org.apache.kafka.image.loader.MetadataLoader@339092511 (org.apache.kafka.raft.KafkaRaftClient) 2024-04-06T01:29:17.506030485Z [2024-04-06 01:29:17,505] INFO [MetadataLoader id=1] 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-06T01:29:17.543349890Z [2024-04-06 01:29:17,543] INFO [QuorumController id=1] Creating new QuorumController with clusterId H2s836mnkcba8O5Yz3sPmQ, authorizer Optional.empty. (org.apache.kafka.controller.QuorumController) 2024-04-06T01:29:17.544234505Z [2024-04-06 01:29:17,544] INFO [RaftManager id=1] Registered the listener org.apache.kafka.controller.QuorumController$QuorumMetaLogListener@1365859114 (org.apache.kafka.raft.KafkaRaftClient) 2024-04-06T01:29:17.558269947Z [2024-04-06 01:29:17,558] INFO [controller-1-ThrottledChannelReaper-Fetch]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) 2024-04-06T01:29:17.563990202Z [2024-04-06 01:29:17,563] INFO [controller-1-ThrottledChannelReaper-Produce]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) 2024-04-06T01:29:17.565241502Z [2024-04-06 01:29:17,565] INFO [controller-1-ThrottledChannelReaper-Request]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) 2024-04-06T01:29:17.574639214Z [2024-04-06 01:29:17,574] INFO [controller-1-ThrottledChannelReaper-ControllerMutation]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) 2024-04-06T01:29:17.614691152Z [2024-04-06 01:29:17,614] INFO [MetadataLoader id=1] 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-06T01:29:17.622053068Z [2024-04-06 01:29:17,621] INFO [ExpirationReaper-1-AlterAcls]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) 2024-04-06T01:29:17.637531619Z [2024-04-06 01:29:17,637] INFO [SocketServer listenerType=CONTROLLER, nodeId=1] Enabling request processing. (kafka.network.SocketServer) 2024-04-06T01:29:17.644741730Z [2024-04-06 01:29:17,644] INFO Awaiting socket connections on 0.0.0.0:9093. (kafka.network.DataPlaneAcceptor) 2024-04-06T01:29:17.663616351Z [2024-04-06 01:29:17,663] INFO [ControllerServer id=1] Waiting for all of the authorizer futures to be completed (kafka.server.ControllerServer) 2024-04-06T01:29:17.663837439Z [2024-04-06 01:29:17,663] INFO [ControllerServer id=1] Finished waiting for all of the authorizer futures to be completed (kafka.server.ControllerServer) 2024-04-06T01:29:17.664047932Z [2024-04-06 01:29:17,663] INFO [ControllerServer id=1] Waiting for all of the SocketServer Acceptors to be started (kafka.server.ControllerServer) 2024-04-06T01:29:17.664202693Z [2024-04-06 01:29:17,664] INFO [ControllerServer id=1] Finished waiting for all of the SocketServer Acceptors to be started (kafka.server.ControllerServer) 2024-04-06T01:29:17.669391130Z [2024-04-06 01:29:17,669] INFO [ControllerServer id=1] Waiting for the controller metadata publishers to be installed (kafka.server.ControllerServer) 2024-04-06T01:29:17.672774253Z [2024-04-06 01:29:17,672] INFO [ControllerServer id=1] Finished waiting for the controller metadata publishers to be installed (kafka.server.ControllerServer) 2024-04-06T01:29:17.674290296Z [2024-04-06 01:29:17,672] INFO [MetadataLoader id=1] 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-06T01:29:17.675121448Z [2024-04-06 01:29:17,673] INFO [BrokerServer id=1] Transition from SHUTDOWN to STARTING (kafka.server.BrokerServer) 2024-04-06T01:29:17.675911102Z [2024-04-06 01:29:17,675] INFO [BrokerServer id=1] Starting broker (kafka.server.BrokerServer) 2024-04-06T01:29:17.702243365Z [2024-04-06 01:29:17,700] INFO [broker-1-ThrottledChannelReaper-Fetch]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) 2024-04-06T01:29:17.703612810Z [2024-04-06 01:29:17,703] INFO [broker-1-ThrottledChannelReaper-Produce]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) 2024-04-06T01:29:17.704530637Z [2024-04-06 01:29:17,704] INFO [broker-1-ThrottledChannelReaper-ControllerMutation]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) 2024-04-06T01:29:17.718041369Z [2024-04-06 01:29:17,717] INFO [broker-1-ThrottledChannelReaper-Request]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) 2024-04-06T01:29:17.734150911Z [2024-04-06 01:29:17,732] INFO [BrokerServer id=1] Waiting for controller quorum voters future (kafka.server.BrokerServer) 2024-04-06T01:29:17.742830363Z [2024-04-06 01:29:17,742] INFO [BrokerServer id=1] Finished waiting for controller quorum voters future (kafka.server.BrokerServer) 2024-04-06T01:29:17.752701069Z [2024-04-06 01:29:17,752] INFO [broker-1-to-controller-forwarding-channel-manager]: Starting (kafka.server.BrokerToControllerRequestThread) 2024-04-06T01:29:17.779249071Z [2024-04-06 01:29:17,778] INFO [MetadataLoader id=1] 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-06T01:29:17.830550148Z [2024-04-06 01:29:17,829] INFO Updated connection-accept-rate max connection creation rate to 2147483647 (kafka.network.ConnectionQuotas) 2024-04-06T01:29:17.841939643Z [2024-04-06 01:29:17,837] INFO [SocketServer listenerType=BROKER, nodeId=1] Created data-plane acceptor and processors for endpoint : ListenerName(CLIENT) (kafka.network.SocketServer) 2024-04-06T01:29:17.841961207Z [2024-04-06 01:29:17,838] INFO Updated connection-accept-rate max connection creation rate to 2147483647 (kafka.network.ConnectionQuotas) 2024-04-06T01:29:17.841965460Z [2024-04-06 01:29:17,840] INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin) 2024-04-06T01:29:17.843430343Z [2024-04-06 01:29:17,842] INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin) 2024-04-06T01:29:17.848003542Z [2024-04-06 01:29:17,847] INFO [SocketServer listenerType=BROKER, nodeId=1] Created data-plane acceptor and processors for endpoint : ListenerName(INTERNAL) (kafka.network.SocketServer) 2024-04-06T01:29:17.861474669Z [2024-04-06 01:29:17,860] INFO [broker-1-to-controller-alter-partition-channel-manager]: Starting (kafka.server.BrokerToControllerRequestThread) 2024-04-06T01:29:17.882495580Z [2024-04-06 01:29:17,878] INFO [MetadataLoader id=1] 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-06T01:29:17.882518712Z [2024-04-06 01:29:17,880] INFO [ExpirationReaper-1-Produce]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) 2024-04-06T01:29:17.886397740Z [2024-04-06 01:29:17,886] INFO [ExpirationReaper-1-Fetch]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) 2024-04-06T01:29:17.891284658Z [2024-04-06 01:29:17,888] INFO [ExpirationReaper-1-DeleteRecords]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) 2024-04-06T01:29:17.891553688Z [2024-04-06 01:29:17,889] INFO [ExpirationReaper-1-ElectLeader]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) 2024-04-06T01:29:17.927904053Z [2024-04-06 01:29:17,926] INFO [ExpirationReaper-1-Heartbeat]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) 2024-04-06T01:29:17.931908665Z [2024-04-06 01:29:17,927] INFO [ExpirationReaper-1-Rebalance]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) 2024-04-06T01:29:17.989902846Z [2024-04-06 01:29:17,981] INFO [MetadataLoader id=1] 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-06T01:29:18.092657429Z [2024-04-06 01:29:18,092] INFO [MetadataLoader id=1] 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-06T01:29:18.205926090Z [2024-04-06 01:29:18,192] INFO [MetadataLoader id=1] 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-06T01:29:18.248418945Z [2024-04-06 01:29:18,245] INFO [RaftManager id=1] Completed transition to Unattached(epoch=25, voters=[0, 1, 2], electionTimeoutMs=115) from Unattached(epoch=0, voters=[0, 1, 2], electionTimeoutMs=1282) (org.apache.kafka.raft.QuorumState) 2024-04-06T01:29:18.257337291Z [2024-04-06 01:29:18,255] INFO [QuorumController id=1] In the new epoch 25, the leader is (none). (org.apache.kafka.controller.QuorumController) 2024-04-06T01:29:18.268946405Z [2024-04-06 01:29:18,267] INFO [RaftManager id=1] Completed transition to Voted(epoch=25, votedId=0, voters=[0, 1, 2], electionTimeoutMs=1195) from Unattached(epoch=25, voters=[0, 1, 2], electionTimeoutMs=115) (org.apache.kafka.raft.QuorumState) 2024-04-06T01:29:18.268966401Z [2024-04-06 01:29:18,267] INFO [RaftManager id=1] Vote request VoteRequestData(clusterId='H2s836mnkcba8O5Yz3sPmQ', topics=[TopicData(topicName='__cluster_metadata', partitions=[PartitionData(partitionIndex=0, candidateEpoch=25, candidateId=0, lastOffsetEpoch=0, lastOffset=0)])]) with epoch 25 is granted (org.apache.kafka.raft.KafkaRaftClient) 2024-04-06T01:29:18.294623340Z [2024-04-06 01:29:18,294] INFO [MetadataLoader id=1] 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-06T01:29:18.324575492Z [2024-04-06 01:29:18,323] INFO [BrokerLifecycleManager id=1] Incarnation SFvwhgQ7RRuJ-cR87ArFiw of broker 1 in cluster H2s836mnkcba8O5Yz3sPmQ is now STARTING. (kafka.server.BrokerLifecycleManager) 2024-04-06T01:29:18.324587942Z [2024-04-06 01:29:18,324] INFO [broker-1-to-controller-heartbeat-channel-manager]: Starting (kafka.server.BrokerToControllerRequestThread) 2024-04-06T01:29:18.362966405Z [2024-04-06 01:29:18,360] INFO [ExpirationReaper-1-AlterAcls]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) 2024-04-06T01:29:18.414129445Z [2024-04-06 01:29:18,410] INFO [MetadataLoader id=1] 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-06T01:29:18.513925768Z [2024-04-06 01:29:18,513] INFO [MetadataLoader id=1] 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-06T01:29:18.558215310Z [2024-04-06 01:29:18,554] INFO [BrokerServer id=1] Waiting for the broker metadata publishers to be installed (kafka.server.BrokerServer) 2024-04-06T01:29:18.558225612Z [2024-04-06 01:29:18,556] INFO [MetadataLoader id=1] 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-06T01:29:18.562392754Z [2024-04-06 01:29:18,562] INFO [BrokerServer id=1] Finished waiting for the broker metadata publishers to be installed (kafka.server.BrokerServer) 2024-04-06T01:29:18.562573137Z [2024-04-06 01:29:18,562] INFO [BrokerServer id=1] Waiting for the controller to acknowledge that we are caught up (kafka.server.BrokerServer) 2024-04-06T01:29:18.607268012Z [2024-04-06 01:29:18,607] INFO [RaftManager id=1] Completed transition to FollowerState(fetchTimeoutMs=2000, epoch=25, leaderId=0, voters=[0, 1, 2], highWatermark=Optional.empty, fetchingSnapshot=Optional.empty) from Voted(epoch=25, votedId=0, voters=[0, 1, 2], electionTimeoutMs=1195) (org.apache.kafka.raft.QuorumState) 2024-04-06T01:29:18.608218825Z [2024-04-06 01:29:18,607] INFO [QuorumController id=1] In the new epoch 25, the leader is 0. (org.apache.kafka.controller.QuorumController) 2024-04-06T01:29:18.615068608Z [2024-04-06 01:29:18,614] INFO [broker-1-to-controller-alter-partition-channel-manager]: Recorded new controller, from now on will use node kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9093 (id: 0 rack: null) (kafka.server.BrokerToControllerRequestThread) 2024-04-06T01:29:18.620121447Z [2024-04-06 01:29:18,618] INFO [RaftManager id=1] Become candidate due to fetch timeout (org.apache.kafka.raft.KafkaRaftClient) 2024-04-06T01:29:18.633941484Z [2024-04-06 01:29:18,629] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9093 (id: 0 rack: null) (kafka.server.BrokerToControllerRequestThread) 2024-04-06T01:29:18.633950383Z [2024-04-06 01:29:18,631] INFO [broker-1-to-controller-forwarding-channel-manager]: Recorded new controller, from now on will use node kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9093 (id: 0 rack: null) (kafka.server.BrokerToControllerRequestThread) 2024-04-06T01:29:18.648348296Z [2024-04-06 01:29:18,643] INFO [RaftManager id=1] Completed transition to CandidateState(localId=1, epoch=26, retries=1, voteStates={0=UNRECORDED, 1=GRANTED, 2=UNRECORDED}, highWatermark=Optional.empty, electionTimeoutMs=1136) from FollowerState(fetchTimeoutMs=2000, epoch=25, leaderId=0, voters=[0, 1, 2], highWatermark=Optional.empty, fetchingSnapshot=Optional.empty) (org.apache.kafka.raft.QuorumState) 2024-04-06T01:29:18.648377009Z [2024-04-06 01:29:18,644] INFO [QuorumController id=1] In the new epoch 26, the leader is (none). (org.apache.kafka.controller.QuorumController) 2024-04-06T01:29:18.685126217Z [2024-04-06 01:29:18,679] INFO [MetadataLoader id=1] 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-06T01:29:18.791745757Z [2024-04-06 01:29:18,788] INFO [MetadataLoader id=1] 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-06T01:29:18.885972609Z [2024-04-06 01:29:18,885] INFO [RaftManager id=1] Completed transition to Leader(localId=1, epoch=26, epochStartOffset=0, highWatermark=Optional.empty, voterStates={0=ReplicaState(nodeId=0, endOffset=Optional.empty, lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=false), 1=ReplicaState(nodeId=1, endOffset=Optional.empty, lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=true), 2=ReplicaState(nodeId=2, endOffset=Optional.empty, lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=false)}) from CandidateState(localId=1, epoch=26, retries=1, voteStates={0=UNRECORDED, 1=GRANTED, 2=GRANTED}, highWatermark=Optional.empty, electionTimeoutMs=1136) (org.apache.kafka.raft.QuorumState) 2024-04-06T01:29:18.891775080Z [2024-04-06 01:29:18,890] INFO [QuorumController id=1] Becoming the active controller at epoch 26, committed offset -1, committed epoch -1 (org.apache.kafka.controller.QuorumController) 2024-04-06T01:29:18.893978686Z [2024-04-06 01:29:18,893] INFO [MetadataLoader id=1] 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-06T01:29:18.894005264Z [2024-04-06 01:29:18,893] INFO [QuorumController id=1] The metadata log appears to be empty. Appending 3 bootstrap record(s) at metadata.version 3.5-IV2 from the binary bootstrap metadata file: /bitnami/kafka/data/bootstrap.checkpoint. (org.apache.kafka.controller.QuorumController) 2024-04-06T01:29:18.917906533Z [2024-04-06 01:29:18,913] INFO [QuorumController id=1] Setting metadata version to 3.5-IV2 (org.apache.kafka.controller.FeatureControlManager) 2024-04-06T01:29:18.925080405Z [2024-04-06 01:29:18,924] INFO [QuorumController id=1] Created new SCRAM credential for user with mechanism SCRAM_SHA_256. (org.apache.kafka.controller.ScramControlManager) 2024-04-06T01:29:18.925098905Z [2024-04-06 01:29:18,924] INFO [QuorumController id=1] Created new SCRAM credential for user with mechanism SCRAM_SHA_512. (org.apache.kafka.controller.ScramControlManager) 2024-04-06T01:29:18.925103517Z [2024-04-06 01:29:18,924] INFO [QuorumController id=1] Transitioning ZK migration state from NONE to NONE (org.apache.kafka.controller.FeatureControlManager) 2024-04-06T01:29:18.960416073Z [2024-04-06 01:29:18,959] INFO [BrokerToControllerChannelManager id=1 name=heartbeat] Client requested disconnect from node 0 (org.apache.kafka.clients.NetworkClient) 2024-04-06T01:29:18.986068379Z [2024-04-06 01:29:18,985] INFO [broker-1-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-06T01:29:18.994707668Z [2024-04-06 01:29:18,994] INFO [MetadataLoader id=1] 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-06T01:29:19.057986751Z [2024-04-06 01:29:19,055] INFO [QuorumController id=1] Registered new broker: RegisterBrokerRecord(brokerId=1, isMigratingZkBroker=false, incarnationId=SFvwhgQ7RRuJ-cR87ArFiw, 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-06T01:29:19.121928893Z [2024-04-06 01:29:19,115] INFO [MetadataLoader id=1] 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-06T01:29:19.249004265Z [2024-04-06 01:29:19,248] INFO [MetadataLoader id=1] 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-06T01:29:19.331876271Z [2024-04-06 01:29:19,328] INFO [RaftManager id=1] Node 0 disconnected. (org.apache.kafka.clients.NetworkClient) 2024-04-06T01:29:19.357947436Z [2024-04-06 01:29:19,357] INFO [MetadataLoader id=1] 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-06T01:29:19.467844565Z [2024-04-06 01:29:19,467] INFO [MetadataLoader id=1] 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-06T01:29:19.529841438Z [2024-04-06 01:29:19,516] INFO [QuorumController id=1] Registered new broker: RegisterBrokerRecord(brokerId=2, isMigratingZkBroker=false, incarnationId=eseFVMOrQiG-cx3XQe9DXQ, 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-06T01:29:19.569715962Z [2024-04-06 01:29:19,568] INFO [MetadataLoader id=1] 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-06T01:29:19.673138932Z [2024-04-06 01:29:19,671] INFO [MetadataLoader id=1] 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-06T01:29:19.777668924Z [2024-04-06 01:29:19,774] INFO [MetadataLoader id=1] 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-06T01:29:19.816306954Z [2024-04-06 01:29:19,815] INFO [RaftManager id=1] High watermark set to LogOffsetMetadata(offset=6, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=794)]) for the first time for epoch 26 based on indexOfHw 1 and voters [ReplicaState(nodeId=1, endOffset=Optional[LogOffsetMetadata(offset=8, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=1095)])], lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=true), ReplicaState(nodeId=2, endOffset=Optional[LogOffsetMetadata(offset=6, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=794)])], lastFetchTimestamp=1712366959806, lastCaughtUpTimestamp=1712366959439, hasAcknowledgedLeader=true), ReplicaState(nodeId=0, endOffset=Optional.empty, lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=true)] (org.apache.kafka.raft.LeaderState) 2024-04-06T01:29:19.889215543Z [2024-04-06 01:29:19,888] INFO [MetadataLoader id=1] initializeNewPublishers: The loader is still catching up because we have loaded up to offset -1, but the high water mark is 6 (org.apache.kafka.image.loader.MetadataLoader) 2024-04-06T01:29:19.938443933Z [2024-04-06 01:29:19,935] INFO [MetadataLoader id=1] handleCommit: The loader is still catching up because we have loaded up to offset 3, but the high water mark is 6 (org.apache.kafka.image.loader.MetadataLoader) 2024-04-06T01:29:19.944402727Z [2024-04-06 01:29:19,943] INFO [MetadataLoader id=1] handleCommit: The loader finished catching up to the current high water mark of 6 (org.apache.kafka.image.loader.MetadataLoader) 2024-04-06T01:29:19.959370954Z [2024-04-06 01:29:19,958] INFO [BrokerLifecycleManager id=1] Successfully registered broker 1 with broker epoch 4 (kafka.server.BrokerLifecycleManager) 2024-04-06T01:29:20.002122327Z [2024-04-06 01:29:19,993] INFO [MetadataLoader id=1] InitializeNewPublishers: initializing SnapshotGenerator with a snapshot at offset 5 (org.apache.kafka.image.loader.MetadataLoader) 2024-04-06T01:29:20.002148262Z [2024-04-06 01:29:19,995] INFO [MetadataLoader id=1] InitializeNewPublishers: initializing DynamicConfigPublisher controller id=1 with a snapshot at offset 5 (org.apache.kafka.image.loader.MetadataLoader) 2024-04-06T01:29:20.002166081Z [2024-04-06 01:29:19,997] INFO [MetadataLoader id=1] InitializeNewPublishers: initializing DynamicClientQuotaPublisher controller id=1 with a snapshot at offset 5 (org.apache.kafka.image.loader.MetadataLoader) 2024-04-06T01:29:20.002169392Z [2024-04-06 01:29:19,997] INFO [MetadataLoader id=1] InitializeNewPublishers: initializing ScramPublisher controller id=1 with a snapshot at offset 5 (org.apache.kafka.image.loader.MetadataLoader) 2024-04-06T01:29:20.002172544Z [2024-04-06 01:29:19,998] INFO [MetadataLoader id=1] InitializeNewPublishers: initializing ControllerMetadataMetricsPublisher with a snapshot at offset 5 (org.apache.kafka.image.loader.MetadataLoader) 2024-04-06T01:29:20.010109785Z [2024-04-06 01:29:20,009] INFO [MetadataLoader id=1] InitializeNewPublishers: initializing BrokerMetadataPublisher with a snapshot at offset 5 (org.apache.kafka.image.loader.MetadataLoader) 2024-04-06T01:29:20.011182106Z [2024-04-06 01:29:20,010] INFO [BrokerMetadataPublisher id=1] Publishing initial metadata at offset OffsetAndEpoch(offset=5, epoch=26) with metadata.version 3.5-IV2. (kafka.server.metadata.BrokerMetadataPublisher) 2024-04-06T01:29:20.024782204Z [2024-04-06 01:29:20,024] INFO Loading logs from log dirs ArrayBuffer(/bitnami/kafka/data) (kafka.log.LogManager) 2024-04-06T01:29:20.068340237Z [2024-04-06 01:29:20,068] INFO [BrokerLifecycleManager id=1] The broker has caught up. Transitioning from STARTING to RECOVERY. (kafka.server.BrokerLifecycleManager) 2024-04-06T01:29:20.093904208Z [2024-04-06 01:29:20,090] INFO [BrokerServer id=1] Finished waiting for the controller to acknowledge that we are caught up (kafka.server.BrokerServer) 2024-04-06T01:29:20.097901420Z [2024-04-06 01:29:20,097] INFO [BrokerServer id=1] Waiting for the initial broker metadata update to be published (kafka.server.BrokerServer) 2024-04-06T01:29:20.120167019Z [2024-04-06 01:29:20,119] INFO No logs found to be loaded in /bitnami/kafka/data (kafka.log.LogManager) 2024-04-06T01:29:20.125552282Z [2024-04-06 01:29:20,125] INFO [BrokerLifecycleManager id=1] The broker is in RECOVERY. (kafka.server.BrokerLifecycleManager) 2024-04-06T01:29:20.283184106Z [2024-04-06 01:29:20,281] INFO Loaded 0 logs in 256ms (kafka.log.LogManager) 2024-04-06T01:29:20.283197967Z [2024-04-06 01:29:20,282] INFO Starting log cleanup with a period of 300000 ms. (kafka.log.LogManager) 2024-04-06T01:29:20.306286109Z [2024-04-06 01:29:20,297] INFO Starting log flusher with a default period of 9223372036854775807 ms. (kafka.log.LogManager) 2024-04-06T01:29:20.376171208Z [2024-04-06 01:29:20,371] INFO Starting the log cleaner (kafka.log.LogCleaner) 2024-04-06T01:29:21.034417725Z [2024-04-06 01:29:21,034] INFO [QuorumController id=1] The request from broker 2 to unfence has been granted because it has caught up with the offset of its register broker record 7. (org.apache.kafka.controller.BrokerHeartbeatManager) 2024-04-06T01:29:21.531821568Z [2024-04-06 01:29:21,531] INFO [kafka-log-cleaner-thread-0]: Starting (kafka.log.LogCleaner$CleanerThread) 2024-04-06T01:29:21.612240232Z [2024-04-06 01:29:21,609] INFO [LogDirFailureHandler]: Starting (kafka.server.ReplicaManager$LogDirFailureHandler) 2024-04-06T01:29:21.618287288Z [2024-04-06 01:29:21,618] INFO [GroupCoordinator 1]: Starting up. (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:29:21.644165870Z [2024-04-06 01:29:21,643] INFO [GroupCoordinator 1]: Startup complete. (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:29:21.645393242Z [2024-04-06 01:29:21,645] INFO [TransactionCoordinator id=1] Starting up. (kafka.coordinator.transaction.TransactionCoordinator) 2024-04-06T01:29:21.660568321Z [2024-04-06 01:29:21,660] INFO [TransactionCoordinator id=1] Startup complete. (kafka.coordinator.transaction.TransactionCoordinator) 2024-04-06T01:29:21.661323549Z [2024-04-06 01:29:21,661] INFO [BrokerMetadataPublisher id=1] Updating metadata.version to 11 at offset OffsetAndEpoch(offset=5, epoch=26). (kafka.server.metadata.BrokerMetadataPublisher) 2024-04-06T01:29:22.025949351Z [2024-04-06 01:29:22,010] INFO [TxnMarkerSenderThread-1]: Starting (kafka.coordinator.transaction.TransactionMarkerChannelManager) 2024-04-06T01:29:22.157013026Z [2024-04-06 01:29:22,154] INFO [BrokerLifecycleManager id=1] The broker is in RECOVERY. (kafka.server.BrokerLifecycleManager) 2024-04-06T01:29:22.207550483Z [2024-04-06 01:29:22,205] INFO [BrokerServer id=1] Finished waiting for the initial broker metadata update to be published (kafka.server.BrokerServer) 2024-04-06T01:29:22.267232903Z [2024-04-06 01:29:22,207] INFO KafkaConfig values: 2024-04-06T01:29:22.267251053Z advertised.listeners = CLIENT://kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9092,INTERNAL://kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094 2024-04-06T01:29:22.267255747Z alter.config.policy.class.name = null 2024-04-06T01:29:22.267258784Z alter.log.dirs.replication.quota.window.num = 11 2024-04-06T01:29:22.267261744Z alter.log.dirs.replication.quota.window.size.seconds = 1 2024-04-06T01:29:22.267265455Z authorizer.class.name = 2024-04-06T01:29:22.267268351Z auto.create.topics.enable = true 2024-04-06T01:29:22.267271133Z auto.include.jmx.reporter = true 2024-04-06T01:29:22.267273958Z auto.leader.rebalance.enable = true 2024-04-06T01:29:22.267277678Z background.threads = 10 2024-04-06T01:29:22.267280633Z broker.heartbeat.interval.ms = 2000 2024-04-06T01:29:22.267283437Z broker.id = 1 2024-04-06T01:29:22.267286280Z broker.id.generation.enable = true 2024-04-06T01:29:22.267289153Z broker.rack = null 2024-04-06T01:29:22.267292307Z broker.session.timeout.ms = 9000 2024-04-06T01:29:22.267295081Z client.quota.callback.class = null 2024-04-06T01:29:22.267297867Z compression.type = producer 2024-04-06T01:29:22.267300628Z connection.failed.authentication.delay.ms = 100 2024-04-06T01:29:22.267303498Z connections.max.idle.ms = 600000 2024-04-06T01:29:22.267306268Z connections.max.reauth.ms = 0 2024-04-06T01:29:22.267308979Z control.plane.listener.name = null 2024-04-06T01:29:22.267311767Z controlled.shutdown.enable = true 2024-04-06T01:29:22.267314499Z controlled.shutdown.max.retries = 3 2024-04-06T01:29:22.267317143Z controlled.shutdown.retry.backoff.ms = 5000 2024-04-06T01:29:22.267319836Z controller.listener.names = CONTROLLER 2024-04-06T01:29:22.267322621Z controller.quorum.append.linger.ms = 25 2024-04-06T01:29:22.267325310Z controller.quorum.election.backoff.max.ms = 1000 2024-04-06T01:29:22.267328063Z controller.quorum.election.timeout.ms = 1000 2024-04-06T01:29:22.267330751Z controller.quorum.fetch.timeout.ms = 2000 2024-04-06T01:29:22.267333464Z controller.quorum.request.timeout.ms = 2000 2024-04-06T01:29:22.267336201Z controller.quorum.retry.backoff.ms = 20 2024-04-06T01:29:22.267339970Z 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-06T01:29:22.267342780Z controller.quota.window.num = 11 2024-04-06T01:29:22.267345429Z controller.quota.window.size.seconds = 1 2024-04-06T01:29:22.267348085Z controller.socket.timeout.ms = 30000 2024-04-06T01:29:22.267350874Z create.topic.policy.class.name = null 2024-04-06T01:29:22.267353610Z default.replication.factor = 1 2024-04-06T01:29:22.267356347Z delegation.token.expiry.check.interval.ms = 3600000 2024-04-06T01:29:22.267374557Z delegation.token.expiry.time.ms = 86400000 2024-04-06T01:29:22.267377472Z delegation.token.master.key = null 2024-04-06T01:29:22.267380668Z delegation.token.max.lifetime.ms = 604800000 2024-04-06T01:29:22.267383458Z delegation.token.secret.key = null 2024-04-06T01:29:22.267386141Z delete.records.purgatory.purge.interval.requests = 1 2024-04-06T01:29:22.267388927Z delete.topic.enable = true 2024-04-06T01:29:22.267391712Z early.start.listeners = null 2024-04-06T01:29:22.267394558Z fetch.max.bytes = 57671680 2024-04-06T01:29:22.267397308Z fetch.purgatory.purge.interval.requests = 1000 2024-04-06T01:29:22.267400122Z group.consumer.assignors = [] 2024-04-06T01:29:22.267402907Z group.consumer.heartbeat.interval.ms = 5000 2024-04-06T01:29:22.267405763Z group.consumer.max.heartbeat.interval.ms = 15000 2024-04-06T01:29:22.267408684Z group.consumer.max.session.timeout.ms = 60000 2024-04-06T01:29:22.267411510Z group.consumer.max.size = 2147483647 2024-04-06T01:29:22.267414244Z group.consumer.min.heartbeat.interval.ms = 5000 2024-04-06T01:29:22.267416878Z group.consumer.min.session.timeout.ms = 45000 2024-04-06T01:29:22.267419635Z group.consumer.session.timeout.ms = 45000 2024-04-06T01:29:22.267422349Z group.coordinator.new.enable = false 2024-04-06T01:29:22.267424951Z group.coordinator.threads = 1 2024-04-06T01:29:22.267427686Z group.initial.rebalance.delay.ms = 3000 2024-04-06T01:29:22.267430371Z group.max.session.timeout.ms = 1800000 2024-04-06T01:29:22.267434090Z group.max.size = 2147483647 2024-04-06T01:29:22.267436868Z group.min.session.timeout.ms = 6000 2024-04-06T01:29:22.267439663Z initial.broker.registration.timeout.ms = 60000 2024-04-06T01:29:22.267442330Z inter.broker.listener.name = INTERNAL 2024-04-06T01:29:22.267444982Z inter.broker.protocol.version = 3.5-IV2 2024-04-06T01:29:22.267447659Z kafka.metrics.polling.interval.secs = 10 2024-04-06T01:29:22.267450398Z kafka.metrics.reporters = [] 2024-04-06T01:29:22.267453132Z leader.imbalance.check.interval.seconds = 300 2024-04-06T01:29:22.267455795Z leader.imbalance.per.broker.percentage = 10 2024-04-06T01:29:22.267459738Z listener.security.protocol.map = CLIENT:PLAINTEXT,INTERNAL:SASL_PLAINTEXT,CONTROLLER:SASL_PLAINTEXT 2024-04-06T01:29:22.267462586Z listeners = CLIENT://:9092,INTERNAL://:9094,CONTROLLER://:9093 2024-04-06T01:29:22.267465612Z log.cleaner.backoff.ms = 15000 2024-04-06T01:29:22.267468309Z log.cleaner.dedupe.buffer.size = 134217728 2024-04-06T01:29:22.267471023Z log.cleaner.delete.retention.ms = 86400000 2024-04-06T01:29:22.267473760Z log.cleaner.enable = true 2024-04-06T01:29:22.267476747Z log.cleaner.io.buffer.load.factor = 0.9 2024-04-06T01:29:22.267479458Z log.cleaner.io.buffer.size = 524288 2024-04-06T01:29:22.267482170Z log.cleaner.io.max.bytes.per.second = 1.7976931348623157E308 2024-04-06T01:29:22.267485182Z log.cleaner.max.compaction.lag.ms = 9223372036854775807 2024-04-06T01:29:22.267488024Z log.cleaner.min.cleanable.ratio = 0.5 2024-04-06T01:29:22.267490716Z log.cleaner.min.compaction.lag.ms = 0 2024-04-06T01:29:22.267493657Z log.cleaner.threads = 1 2024-04-06T01:29:22.267496497Z log.cleanup.policy = [delete] 2024-04-06T01:29:22.267499418Z log.dir = /bitnami/kafka/data 2024-04-06T01:29:22.267502145Z log.dirs = null 2024-04-06T01:29:22.267505112Z log.flush.interval.messages = 9223372036854775807 2024-04-06T01:29:22.267507851Z log.flush.interval.ms = null 2024-04-06T01:29:22.267510574Z log.flush.offset.checkpoint.interval.ms = 60000 2024-04-06T01:29:22.267513371Z log.flush.scheduler.interval.ms = 9223372036854775807 2024-04-06T01:29:22.267522346Z log.flush.start.offset.checkpoint.interval.ms = 60000 2024-04-06T01:29:22.267525184Z log.index.interval.bytes = 4096 2024-04-06T01:29:22.267527883Z log.index.size.max.bytes = 10485760 2024-04-06T01:29:22.267530649Z log.message.downconversion.enable = true 2024-04-06T01:29:22.267543905Z log.message.format.version = 3.0-IV1 2024-04-06T01:29:22.267547204Z log.message.timestamp.difference.max.ms = 9223372036854775807 2024-04-06T01:29:22.267564670Z log.message.timestamp.type = CreateTime 2024-04-06T01:29:22.267567651Z log.preallocate = false 2024-04-06T01:29:22.267570734Z log.retention.bytes = -1 2024-04-06T01:29:22.267573456Z log.retention.check.interval.ms = 300000 2024-04-06T01:29:22.267576186Z log.retention.hours = 168 2024-04-06T01:29:22.267579162Z log.retention.minutes = null 2024-04-06T01:29:22.267581898Z log.retention.ms = null 2024-04-06T01:29:22.267584791Z log.roll.hours = 168 2024-04-06T01:29:22.267587615Z log.roll.jitter.hours = 0 2024-04-06T01:29:22.267590463Z log.roll.jitter.ms = null 2024-04-06T01:29:22.267593492Z log.roll.ms = null 2024-04-06T01:29:22.267596288Z log.segment.bytes = 1073741824 2024-04-06T01:29:22.267599092Z log.segment.delete.delay.ms = 60000 2024-04-06T01:29:22.267601973Z max.connection.creation.rate = 2147483647 2024-04-06T01:29:22.267604736Z max.connections = 2147483647 2024-04-06T01:29:22.267607580Z max.connections.per.ip = 2147483647 2024-04-06T01:29:22.267610547Z max.connections.per.ip.overrides = 2024-04-06T01:29:22.267613310Z max.incremental.fetch.session.cache.slots = 1000 2024-04-06T01:29:22.267616084Z message.max.bytes = 1048588 2024-04-06T01:29:22.267618789Z metadata.log.dir = null 2024-04-06T01:29:22.267621747Z metadata.log.max.record.bytes.between.snapshots = 20971520 2024-04-06T01:29:22.267624506Z metadata.log.max.snapshot.interval.ms = 3600000 2024-04-06T01:29:22.267627298Z metadata.log.segment.bytes = 1073741824 2024-04-06T01:29:22.267630135Z metadata.log.segment.min.bytes = 8388608 2024-04-06T01:29:22.267632895Z metadata.log.segment.ms = 604800000 2024-04-06T01:29:22.267635600Z metadata.max.idle.interval.ms = 500 2024-04-06T01:29:22.267638461Z metadata.max.retention.bytes = 104857600 2024-04-06T01:29:22.267641332Z metadata.max.retention.ms = 604800000 2024-04-06T01:29:22.267644126Z metric.reporters = [] 2024-04-06T01:29:22.267646857Z metrics.num.samples = 2 2024-04-06T01:29:22.267649620Z metrics.recording.level = INFO 2024-04-06T01:29:22.267652524Z metrics.sample.window.ms = 30000 2024-04-06T01:29:22.267655207Z min.insync.replicas = 1 2024-04-06T01:29:22.267658074Z node.id = 1 2024-04-06T01:29:22.267661064Z num.io.threads = 8 2024-04-06T01:29:22.267664160Z num.network.threads = 3 2024-04-06T01:29:22.267666908Z num.partitions = 1 2024-04-06T01:29:22.267669642Z num.recovery.threads.per.data.dir = 1 2024-04-06T01:29:22.267672480Z num.replica.alter.log.dirs.threads = null 2024-04-06T01:29:22.267675286Z num.replica.fetchers = 1 2024-04-06T01:29:22.267678035Z offset.metadata.max.bytes = 4096 2024-04-06T01:29:22.267680754Z offsets.commit.required.acks = -1 2024-04-06T01:29:22.267683507Z offsets.commit.timeout.ms = 5000 2024-04-06T01:29:22.267686196Z offsets.load.buffer.size = 5242880 2024-04-06T01:29:22.267688878Z offsets.retention.check.interval.ms = 600000 2024-04-06T01:29:22.267691594Z offsets.retention.minutes = 10080 2024-04-06T01:29:22.267694316Z offsets.topic.compression.codec = 0 2024-04-06T01:29:22.267697027Z offsets.topic.num.partitions = 50 2024-04-06T01:29:22.267699699Z offsets.topic.replication.factor = 3 2024-04-06T01:29:22.267710070Z offsets.topic.segment.bytes = 104857600 2024-04-06T01:29:22.267712971Z password.encoder.cipher.algorithm = AES/CBC/PKCS5Padding 2024-04-06T01:29:22.267715636Z password.encoder.iterations = 4096 2024-04-06T01:29:22.267718330Z password.encoder.key.length = 128 2024-04-06T01:29:22.267720996Z password.encoder.keyfactory.algorithm = null 2024-04-06T01:29:22.267723756Z password.encoder.old.secret = null 2024-04-06T01:29:22.267726606Z password.encoder.secret = null 2024-04-06T01:29:22.267729329Z principal.builder.class = class org.apache.kafka.common.security.authenticator.DefaultKafkaPrincipalBuilder 2024-04-06T01:29:22.267732076Z process.roles = [controller, broker] 2024-04-06T01:29:22.267734819Z producer.id.expiration.check.interval.ms = 600000 2024-04-06T01:29:22.267737459Z producer.id.expiration.ms = 86400000 2024-04-06T01:29:22.267740169Z producer.purgatory.purge.interval.requests = 1000 2024-04-06T01:29:22.267742947Z queued.max.request.bytes = -1 2024-04-06T01:29:22.267745654Z queued.max.requests = 500 2024-04-06T01:29:22.267748528Z quota.window.num = 11 2024-04-06T01:29:22.267751273Z quota.window.size.seconds = 1 2024-04-06T01:29:22.267754058Z remote.log.index.file.cache.total.size.bytes = 1073741824 2024-04-06T01:29:22.267756737Z remote.log.manager.task.interval.ms = 30000 2024-04-06T01:29:22.267759597Z remote.log.manager.task.retry.backoff.max.ms = 30000 2024-04-06T01:29:22.267762338Z remote.log.manager.task.retry.backoff.ms = 500 2024-04-06T01:29:22.267765127Z remote.log.manager.task.retry.jitter = 0.2 2024-04-06T01:29:22.267767788Z remote.log.manager.thread.pool.size = 10 2024-04-06T01:29:22.267770554Z remote.log.metadata.manager.class.name = null 2024-04-06T01:29:22.267773233Z remote.log.metadata.manager.class.path = null 2024-04-06T01:29:22.267775935Z remote.log.metadata.manager.impl.prefix = null 2024-04-06T01:29:22.267778783Z remote.log.metadata.manager.listener.name = null 2024-04-06T01:29:22.267781614Z remote.log.reader.max.pending.tasks = 100 2024-04-06T01:29:22.267784331Z remote.log.reader.threads = 10 2024-04-06T01:29:22.267787139Z remote.log.storage.manager.class.name = null 2024-04-06T01:29:22.267789802Z remote.log.storage.manager.class.path = null 2024-04-06T01:29:22.267792602Z remote.log.storage.manager.impl.prefix = null 2024-04-06T01:29:22.267795450Z remote.log.storage.system.enable = false 2024-04-06T01:29:22.267798270Z replica.fetch.backoff.ms = 1000 2024-04-06T01:29:22.267800975Z replica.fetch.max.bytes = 1048576 2024-04-06T01:29:22.267803692Z replica.fetch.min.bytes = 1 2024-04-06T01:29:22.267807502Z replica.fetch.response.max.bytes = 10485760 2024-04-06T01:29:22.267810299Z replica.fetch.wait.max.ms = 500 2024-04-06T01:29:22.267813066Z replica.high.watermark.checkpoint.interval.ms = 5000 2024-04-06T01:29:22.267815872Z replica.lag.time.max.ms = 30000 2024-04-06T01:29:22.267818611Z replica.selector.class = null 2024-04-06T01:29:22.267821286Z replica.socket.receive.buffer.bytes = 65536 2024-04-06T01:29:22.267824003Z replica.socket.timeout.ms = 30000 2024-04-06T01:29:22.267826721Z replication.quota.window.num = 11 2024-04-06T01:29:22.267829437Z replication.quota.window.size.seconds = 1 2024-04-06T01:29:22.267832201Z request.timeout.ms = 30000 2024-04-06T01:29:22.267834894Z reserved.broker.max.id = 1000 2024-04-06T01:29:22.267837754Z sasl.client.callback.handler.class = null 2024-04-06T01:29:22.267840501Z sasl.enabled.mechanisms = [PLAIN, SCRAM-SHA-256, SCRAM-SHA-512] 2024-04-06T01:29:22.267843199Z sasl.jaas.config = null 2024-04-06T01:29:22.267845935Z sasl.kerberos.kinit.cmd = /usr/bin/kinit 2024-04-06T01:29:22.267854969Z sasl.kerberos.min.time.before.relogin = 60000 2024-04-06T01:29:22.267857814Z sasl.kerberos.principal.to.local.rules = [DEFAULT] 2024-04-06T01:29:22.267860533Z sasl.kerberos.service.name = null 2024-04-06T01:29:22.267863212Z sasl.kerberos.ticket.renew.jitter = 0.05 2024-04-06T01:29:22.267865959Z sasl.kerberos.ticket.renew.window.factor = 0.8 2024-04-06T01:29:22.267870276Z sasl.login.callback.handler.class = null 2024-04-06T01:29:22.267873205Z sasl.login.class = null 2024-04-06T01:29:22.267876023Z sasl.login.connect.timeout.ms = null 2024-04-06T01:29:22.267878696Z sasl.login.read.timeout.ms = null 2024-04-06T01:29:22.267881462Z sasl.login.refresh.buffer.seconds = 300 2024-04-06T01:29:22.267884121Z sasl.login.refresh.min.period.seconds = 60 2024-04-06T01:29:22.267886890Z sasl.login.refresh.window.factor = 0.8 2024-04-06T01:29:22.267889585Z sasl.login.refresh.window.jitter = 0.05 2024-04-06T01:29:22.267892341Z sasl.login.retry.backoff.max.ms = 10000 2024-04-06T01:29:22.267895045Z sasl.login.retry.backoff.ms = 100 2024-04-06T01:29:22.267897704Z sasl.mechanism.controller.protocol = PLAIN 2024-04-06T01:29:22.267900429Z sasl.mechanism.inter.broker.protocol = PLAIN 2024-04-06T01:29:22.267903188Z sasl.oauthbearer.clock.skew.seconds = 30 2024-04-06T01:29:22.267905876Z sasl.oauthbearer.expected.audience = null 2024-04-06T01:29:22.267908691Z sasl.oauthbearer.expected.issuer = null 2024-04-06T01:29:22.267911471Z sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 2024-04-06T01:29:22.267914207Z sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 2024-04-06T01:29:22.267916975Z sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 2024-04-06T01:29:22.267919762Z sasl.oauthbearer.jwks.endpoint.url = null 2024-04-06T01:29:22.267922419Z sasl.oauthbearer.scope.claim.name = scope 2024-04-06T01:29:22.267925107Z sasl.oauthbearer.sub.claim.name = sub 2024-04-06T01:29:22.267927819Z sasl.oauthbearer.token.endpoint.url = null 2024-04-06T01:29:22.267930571Z sasl.server.callback.handler.class = null 2024-04-06T01:29:22.267933229Z sasl.server.max.receive.size = 524288 2024-04-06T01:29:22.267935896Z security.inter.broker.protocol = PLAINTEXT 2024-04-06T01:29:22.267938631Z security.providers = null 2024-04-06T01:29:22.267941325Z server.max.startup.time.ms = 9223372036854775807 2024-04-06T01:29:22.267943990Z socket.connection.setup.timeout.max.ms = 30000 2024-04-06T01:29:22.267946765Z socket.connection.setup.timeout.ms = 10000 2024-04-06T01:29:22.267949489Z socket.listen.backlog.size = 50 2024-04-06T01:29:22.267952317Z socket.receive.buffer.bytes = 102400 2024-04-06T01:29:22.267954970Z socket.request.max.bytes = 104857600 2024-04-06T01:29:22.267957653Z socket.send.buffer.bytes = 102400 2024-04-06T01:29:22.267960347Z ssl.cipher.suites = [] 2024-04-06T01:29:22.267963010Z ssl.client.auth = none 2024-04-06T01:29:22.267965679Z ssl.enabled.protocols = [TLSv1.2, TLSv1.3] 2024-04-06T01:29:22.267968392Z ssl.endpoint.identification.algorithm = https 2024-04-06T01:29:22.267971090Z ssl.engine.factory.class = null 2024-04-06T01:29:22.267973914Z ssl.key.password = null 2024-04-06T01:29:22.267976846Z ssl.keymanager.algorithm = SunX509 2024-04-06T01:29:22.267979554Z ssl.keystore.certificate.chain = null 2024-04-06T01:29:22.267982298Z ssl.keystore.key = null 2024-04-06T01:29:22.267984998Z ssl.keystore.location = null 2024-04-06T01:29:22.267987663Z ssl.keystore.password = null 2024-04-06T01:29:22.267990355Z ssl.keystore.type = JKS 2024-04-06T01:29:22.267993099Z ssl.principal.mapping.rules = DEFAULT 2024-04-06T01:29:22.267996004Z ssl.protocol = TLSv1.3 2024-04-06T01:29:22.268005328Z ssl.provider = null 2024-04-06T01:29:22.268008141Z ssl.secure.random.implementation = null 2024-04-06T01:29:22.268010855Z ssl.trustmanager.algorithm = PKIX 2024-04-06T01:29:22.268013570Z ssl.truststore.certificates = null 2024-04-06T01:29:22.268016274Z ssl.truststore.location = null 2024-04-06T01:29:22.268019174Z ssl.truststore.password = null 2024-04-06T01:29:22.268021900Z ssl.truststore.type = JKS 2024-04-06T01:29:22.268025518Z transaction.abort.timed.out.transaction.cleanup.interval.ms = 10000 2024-04-06T01:29:22.268028470Z transaction.max.timeout.ms = 900000 2024-04-06T01:29:22.268031346Z transaction.remove.expired.transaction.cleanup.interval.ms = 3600000 2024-04-06T01:29:22.268034192Z transaction.state.log.load.buffer.size = 5242880 2024-04-06T01:29:22.268036885Z transaction.state.log.min.isr = 2 2024-04-06T01:29:22.268039650Z transaction.state.log.num.partitions = 50 2024-04-06T01:29:22.268042370Z transaction.state.log.replication.factor = 3 2024-04-06T01:29:22.268045041Z transaction.state.log.segment.bytes = 104857600 2024-04-06T01:29:22.268047866Z transactional.id.expiration.ms = 604800000 2024-04-06T01:29:22.268050621Z unclean.leader.election.enable = false 2024-04-06T01:29:22.268053319Z unstable.api.versions.enable = false 2024-04-06T01:29:22.268055981Z zookeeper.clientCnxnSocket = null 2024-04-06T01:29:22.268058676Z zookeeper.connect = null 2024-04-06T01:29:22.268061482Z zookeeper.connection.timeout.ms = null 2024-04-06T01:29:22.268064163Z zookeeper.max.in.flight.requests = 10 2024-04-06T01:29:22.268066915Z zookeeper.metadata.migration.enable = false 2024-04-06T01:29:22.268069692Z zookeeper.session.timeout.ms = 18000 2024-04-06T01:29:22.268072352Z zookeeper.set.acl = false 2024-04-06T01:29:22.268075073Z zookeeper.ssl.cipher.suites = null 2024-04-06T01:29:22.268077812Z zookeeper.ssl.client.enable = false 2024-04-06T01:29:22.268080513Z zookeeper.ssl.crl.enable = false 2024-04-06T01:29:22.268083215Z zookeeper.ssl.enabled.protocols = null 2024-04-06T01:29:22.268085896Z zookeeper.ssl.endpoint.identification.algorithm = HTTPS 2024-04-06T01:29:22.268088651Z zookeeper.ssl.keystore.location = null 2024-04-06T01:29:22.268091416Z zookeeper.ssl.keystore.password = null 2024-04-06T01:29:22.268094080Z zookeeper.ssl.keystore.type = null 2024-04-06T01:29:22.268096821Z zookeeper.ssl.ocsp.enable = false 2024-04-06T01:29:22.268099663Z zookeeper.ssl.protocol = TLSv1.2 2024-04-06T01:29:22.268102338Z zookeeper.ssl.truststore.location = null 2024-04-06T01:29:22.268105032Z zookeeper.ssl.truststore.password = null 2024-04-06T01:29:22.268107791Z zookeeper.ssl.truststore.type = null 2024-04-06T01:29:22.268110691Z (kafka.server.KafkaConfig) 2024-04-06T01:29:22.403710139Z [2024-04-06 01:29:22,403] INFO [BrokerServer id=1] Waiting for the broker to be unfenced (kafka.server.BrokerServer) 2024-04-06T01:29:22.404632400Z [2024-04-06 01:29:22,404] INFO [QuorumController id=1] The request from broker 1 to unfence has been granted because it has caught up with the offset of its register broker record 4. (org.apache.kafka.controller.BrokerHeartbeatManager) 2024-04-06T01:29:22.491380092Z [2024-04-06 01:29:22,491] INFO [BrokerLifecycleManager id=1] The broker has been unfenced. Transitioning from RECOVERY to RUNNING. (kafka.server.BrokerLifecycleManager) 2024-04-06T01:29:22.491930209Z [2024-04-06 01:29:22,491] INFO [BrokerServer id=1] Finished waiting for the broker to be unfenced (kafka.server.BrokerServer) 2024-04-06T01:29:22.491962064Z [2024-04-06 01:29:22,491] INFO [SocketServer listenerType=BROKER, nodeId=1] Enabling request processing. (kafka.network.SocketServer) 2024-04-06T01:29:22.494545041Z [2024-04-06 01:29:22,492] INFO Awaiting socket connections on 0.0.0.0:9092. (kafka.network.DataPlaneAcceptor) 2024-04-06T01:29:22.514417357Z [2024-04-06 01:29:22,514] INFO Awaiting socket connections on 0.0.0.0:9094. (kafka.network.DataPlaneAcceptor) 2024-04-06T01:29:22.518918593Z [2024-04-06 01:29:22,518] INFO [BrokerServer id=1] Waiting for all of the authorizer futures to be completed (kafka.server.BrokerServer) 2024-04-06T01:29:22.518935285Z [2024-04-06 01:29:22,518] INFO [BrokerServer id=1] Finished waiting for all of the authorizer futures to be completed (kafka.server.BrokerServer) 2024-04-06T01:29:22.518938468Z [2024-04-06 01:29:22,518] INFO [BrokerServer id=1] Waiting for all of the SocketServer Acceptors to be started (kafka.server.BrokerServer) 2024-04-06T01:29:22.518941450Z [2024-04-06 01:29:22,518] INFO [BrokerServer id=1] Finished waiting for all of the SocketServer Acceptors to be started (kafka.server.BrokerServer) 2024-04-06T01:29:22.518944767Z [2024-04-06 01:29:22,518] INFO [BrokerServer id=1] Transition from STARTING to STARTED (kafka.server.BrokerServer) 2024-04-06T01:29:22.518947954Z [2024-04-06 01:29:22,518] INFO Kafka version: 3.5.1 (org.apache.kafka.common.utils.AppInfoParser) 2024-04-06T01:29:22.518950706Z [2024-04-06 01:29:22,518] INFO Kafka commitId: 2c6fb6c54472e90a (org.apache.kafka.common.utils.AppInfoParser) 2024-04-06T01:29:22.519073192Z [2024-04-06 01:29:22,519] INFO Kafka startTimeMs: 1712366962518 (org.apache.kafka.common.utils.AppInfoParser) 2024-04-06T01:29:22.523147854Z [2024-04-06 01:29:22,520] INFO [KafkaRaftServer nodeId=1] Kafka Server started (kafka.server.KafkaRaftServer) 2024-04-06T01:29:44.762506353Z [2024-04-06 01:29:44,762] INFO [QuorumController id=1] Registered new broker: RegisterBrokerRecord(brokerId=0, isMigratingZkBroker=false, incarnationId=lFmn-wGcTuigTxAkoEZgSw, brokerEpoch=60, 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-06T01:29:46.382342133Z [2024-04-06 01:29:46,382] INFO [QuorumController id=1] The request from broker 0 to unfence has been granted because it has caught up with the offset of its register broker record 60. (org.apache.kafka.controller.BrokerHeartbeatManager) 2024-04-06T01:30:12.023204228Z [2024-04-06 01:30:12,021] INFO Sent auto-creation request for Set(vim_account) to the active controller. (kafka.server.DefaultAutoTopicCreationManager) 2024-04-06T01:30:12.213869254Z [2024-04-06 01:30:12,206] INFO [BrokerToControllerChannelManager id=1 name=forwarding] Client requested disconnect from node 0 (org.apache.kafka.clients.NetworkClient) 2024-04-06T01:30:12.213889173Z [2024-04-06 01:30:12,208] INFO [broker-1-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-06T01:30:12.215817803Z [2024-04-06 01:30:12,215] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='vim_account', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:12.217120041Z [2024-04-06 01:30:12,216] INFO [QuorumController id=1] Created topic vim_account with topic ID OzllJ1ppTemh1HynLzlX3g. (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:12.218020601Z [2024-04-06 01:30:12,217] INFO [QuorumController id=1] Created partition vim_account-0 with topic ID OzllJ1ppTemh1HynLzlX3g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:12.358057931Z [2024-04-06 01:30:12,356] INFO [Broker id=1] Transitioning 1 partition(s) to local leaders. (state.change.logger) 2024-04-06T01:30:12.373933182Z [2024-04-06 01:30:12,365] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='vim_account', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'vim_account' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:12.375126335Z [2024-04-06 01:30:12,374] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions Set(vim_account-0) (kafka.server.ReplicaFetcherManager) 2024-04-06T01:30:12.465634800Z [2024-04-06 01:30:12,455] INFO [Broker id=1] Creating new partition vim_account-0 with topic id OzllJ1ppTemh1HynLzlX3g. (state.change.logger) 2024-04-06T01:30:12.653557979Z [2024-04-06 01:30:12,653] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='vim_account', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'vim_account' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:12.741779128Z [2024-04-06 01:30:12,740] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='vim_account', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'vim_account' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:12.839872457Z [2024-04-06 01:30:12,828] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='vim_account', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'vim_account' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:13.087058661Z [2024-04-06 01:30:13,068] INFO [LogLoader partition=vim_account-0, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) 2024-04-06T01:30:13.276302951Z [2024-04-06 01:30:13,267] INFO Created log for partition vim_account-0 in /bitnami/kafka/data/vim_account-0 with properties {} (kafka.log.LogManager) 2024-04-06T01:30:13.346801354Z [2024-04-06 01:30:13,345] INFO [Partition vim_account-0 broker=1] No checkpointed highwatermark is found for partition vim_account-0 (kafka.cluster.Partition) 2024-04-06T01:30:13.414561220Z [2024-04-06 01:30:13,407] INFO [Partition vim_account-0 broker=1] Log loaded for partition vim_account-0 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:13.450486107Z [2024-04-06 01:30:13,450] INFO [Broker id=1] Leader vim_account-0 with topic id Some(OzllJ1ppTemh1HynLzlX3g) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:13.710628610Z [2024-04-06 01:30:13,710] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='wim_account', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:13.713952253Z [2024-04-06 01:30:13,713] INFO [QuorumController id=1] Created topic wim_account with topic ID m1anKSr8THKNSkEwWjwDRA. (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:13.724056762Z [2024-04-06 01:30:13,723] INFO [QuorumController id=1] Created partition wim_account-0 with topic ID m1anKSr8THKNSkEwWjwDRA and PartitionRegistration(replicas=[2], isr=[2], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:13.849610113Z [2024-04-06 01:30:13,849] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='wim_account', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'wim_account' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:13.960352619Z [2024-04-06 01:30:13,954] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='wim_account', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'wim_account' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:14.071427787Z [2024-04-06 01:30:14,070] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='wim_account', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'wim_account' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:14.232933372Z [2024-04-06 01:30:14,231] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='wim_account', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'wim_account' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:14.604534207Z [2024-04-06 01:30:14,604] INFO Sent auto-creation request for Set(sdn) to the active controller. (kafka.server.DefaultAutoTopicCreationManager) 2024-04-06T01:30:14.606619329Z [2024-04-06 01:30:14,606] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='sdn', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:14.610223757Z [2024-04-06 01:30:14,606] INFO [QuorumController id=1] Created topic sdn with topic ID dDL480NJTGy0IXum70shNg. (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:14.610448715Z [2024-04-06 01:30:14,610] INFO [QuorumController id=1] Created partition sdn-0 with topic ID dDL480NJTGy0IXum70shNg and PartitionRegistration(replicas=[0], isr=[0], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:33.722291874Z [2024-04-06 01:30:33,721] INFO Sent auto-creation request for Set(alarm_request) to the active controller. (kafka.server.DefaultAutoTopicCreationManager) 2024-04-06T01:30:33.725915466Z [2024-04-06 01:30:33,724] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='alarm_request', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:33.725929159Z [2024-04-06 01:30:33,725] INFO [QuorumController id=1] Created topic alarm_request with topic ID 8RLxNlbaQ5WhXtTGT1zIrQ. (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:33.725934533Z [2024-04-06 01:30:33,725] INFO [QuorumController id=1] Created partition alarm_request-0 with topic ID 8RLxNlbaQ5WhXtTGT1zIrQ and PartitionRegistration(replicas=[0], isr=[0], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:33.937337306Z [2024-04-06 01:30:33,936] INFO Sent auto-creation request for Set(users) to the active controller. (kafka.server.DefaultAutoTopicCreationManager) 2024-04-06T01:30:33.941285623Z [2024-04-06 01:30:33,940] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='users', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:33.941295657Z [2024-04-06 01:30:33,940] INFO [QuorumController id=1] Created topic users with topic ID ea0gDmHuQEqQH_QdLCd75Q. (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:33.941306009Z [2024-04-06 01:30:33,940] INFO [QuorumController id=1] Created partition users-0 with topic ID ea0gDmHuQEqQH_QdLCd75Q and PartitionRegistration(replicas=[0], isr=[0], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:34.053130196Z [2024-04-06 01:30:34,050] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='users', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'users' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:34.158910974Z [2024-04-06 01:30:34,157] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='users', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'users' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:34.275731525Z [2024-04-06 01:30:34,274] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='users', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'users' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:34.380445227Z [2024-04-06 01:30:34,377] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='users', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'users' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:34.582840030Z [2024-04-06 01:30:34,582] INFO Sent auto-creation request for Set(project) to the active controller. (kafka.server.DefaultAutoTopicCreationManager) 2024-04-06T01:30:34.584595764Z [2024-04-06 01:30:34,584] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='project', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:34.584739019Z [2024-04-06 01:30:34,584] INFO [QuorumController id=1] Created topic project with topic ID JXmT5vV8SU21Gy62qqt14w. (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:34.584934259Z [2024-04-06 01:30:34,584] INFO [QuorumController id=1] Created partition project-0 with topic ID JXmT5vV8SU21Gy62qqt14w and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:34.623164271Z [2024-04-06 01:30:34,622] INFO [Broker id=1] Transitioning 1 partition(s) to local leaders. (state.change.logger) 2024-04-06T01:30:34.625726773Z [2024-04-06 01:30:34,625] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions Set(project-0) (kafka.server.ReplicaFetcherManager) 2024-04-06T01:30:34.625917693Z [2024-04-06 01:30:34,625] INFO [Broker id=1] Creating new partition project-0 with topic id JXmT5vV8SU21Gy62qqt14w. (state.change.logger) 2024-04-06T01:30:34.649180318Z [2024-04-06 01:30:34,634] INFO [LogLoader partition=project-0, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) 2024-04-06T01:30:34.649197594Z [2024-04-06 01:30:34,644] INFO Created log for partition project-0 in /bitnami/kafka/data/project-0 with properties {} (kafka.log.LogManager) 2024-04-06T01:30:34.649202015Z [2024-04-06 01:30:34,645] INFO [Partition project-0 broker=1] No checkpointed highwatermark is found for partition project-0 (kafka.cluster.Partition) 2024-04-06T01:30:34.649205801Z [2024-04-06 01:30:34,645] INFO [Partition project-0 broker=1] Log loaded for partition project-0 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:34.649220138Z [2024-04-06 01:30:34,645] INFO [Broker id=1] Leader project-0 with topic id Some(JXmT5vV8SU21Gy62qqt14w) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:34.694063768Z [2024-04-06 01:30:34,693] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='project', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'project' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:35.038249026Z [2024-04-06 01:30:35,034] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='__consumer_offsets', numPartitions=50, replicationFactor=3, assignments=[], configs=[CreateableTopicConfig(name='compression.type', value='producer'), CreateableTopicConfig(name='cleanup.policy', value='compact'), CreateableTopicConfig(name='segment.bytes', value='104857600')]): SUCCESS (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:35.038262968Z [2024-04-06 01:30:35,034] INFO [QuorumController id=1] Created topic __consumer_offsets with topic ID boK1ajUYRFOU6jbgLgsCww. (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:35.038268057Z [2024-04-06 01:30:35,035] INFO [QuorumController id=1] ConfigResource(type=TOPIC, name='__consumer_offsets'): set configuration compression.type to producer (org.apache.kafka.controller.ConfigurationControlManager) 2024-04-06T01:30:35.038271436Z [2024-04-06 01:30:35,035] INFO [QuorumController id=1] ConfigResource(type=TOPIC, name='__consumer_offsets'): set configuration cleanup.policy to compact (org.apache.kafka.controller.ConfigurationControlManager) 2024-04-06T01:30:35.038274656Z [2024-04-06 01:30:35,035] INFO [QuorumController id=1] ConfigResource(type=TOPIC, name='__consumer_offsets'): set configuration segment.bytes to 104857600 (org.apache.kafka.controller.ConfigurationControlManager) 2024-04-06T01:30:35.038278520Z [2024-04-06 01:30:35,035] INFO [QuorumController id=1] Created partition __consumer_offsets-0 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038281842Z [2024-04-06 01:30:35,035] INFO [QuorumController id=1] Created partition __consumer_offsets-1 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038284951Z [2024-04-06 01:30:35,035] INFO [QuorumController id=1] Created partition __consumer_offsets-2 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038288186Z [2024-04-06 01:30:35,035] INFO [QuorumController id=1] Created partition __consumer_offsets-3 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038291486Z [2024-04-06 01:30:35,035] INFO [QuorumController id=1] Created partition __consumer_offsets-4 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038302316Z [2024-04-06 01:30:35,035] INFO [QuorumController id=1] Created partition __consumer_offsets-5 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038305455Z [2024-04-06 01:30:35,035] INFO [QuorumController id=1] Created partition __consumer_offsets-6 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038310391Z [2024-04-06 01:30:35,035] INFO [QuorumController id=1] Created partition __consumer_offsets-7 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038318181Z [2024-04-06 01:30:35,035] INFO [QuorumController id=1] Created partition __consumer_offsets-8 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038321748Z [2024-04-06 01:30:35,035] INFO [QuorumController id=1] Created partition __consumer_offsets-9 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038324772Z [2024-04-06 01:30:35,035] INFO [QuorumController id=1] Created partition __consumer_offsets-10 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038327863Z [2024-04-06 01:30:35,036] INFO [QuorumController id=1] Created partition __consumer_offsets-11 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038330856Z [2024-04-06 01:30:35,036] INFO [QuorumController id=1] Created partition __consumer_offsets-12 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038334366Z [2024-04-06 01:30:35,036] INFO [QuorumController id=1] Created partition __consumer_offsets-13 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038337478Z [2024-04-06 01:30:35,036] INFO [QuorumController id=1] Created partition __consumer_offsets-14 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038347958Z [2024-04-06 01:30:35,036] INFO [QuorumController id=1] Created partition __consumer_offsets-15 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038351151Z [2024-04-06 01:30:35,036] INFO [QuorumController id=1] Created partition __consumer_offsets-16 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038354118Z [2024-04-06 01:30:35,036] INFO [QuorumController id=1] Created partition __consumer_offsets-17 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038358944Z [2024-04-06 01:30:35,036] INFO [QuorumController id=1] Created partition __consumer_offsets-18 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038362191Z [2024-04-06 01:30:35,036] INFO [QuorumController id=1] Created partition __consumer_offsets-19 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038365208Z [2024-04-06 01:30:35,036] INFO [QuorumController id=1] Created partition __consumer_offsets-20 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038368218Z [2024-04-06 01:30:35,036] INFO [QuorumController id=1] Created partition __consumer_offsets-21 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038371173Z [2024-04-06 01:30:35,036] INFO [QuorumController id=1] Created partition __consumer_offsets-22 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038374192Z [2024-04-06 01:30:35,036] INFO [QuorumController id=1] Created partition __consumer_offsets-23 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038377115Z [2024-04-06 01:30:35,037] INFO [QuorumController id=1] Created partition __consumer_offsets-24 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038387527Z [2024-04-06 01:30:35,037] INFO [QuorumController id=1] Created partition __consumer_offsets-25 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038390687Z [2024-04-06 01:30:35,037] INFO [QuorumController id=1] Created partition __consumer_offsets-26 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038393712Z [2024-04-06 01:30:35,037] INFO [QuorumController id=1] Created partition __consumer_offsets-27 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038396684Z [2024-04-06 01:30:35,037] INFO [QuorumController id=1] Created partition __consumer_offsets-28 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038404706Z [2024-04-06 01:30:35,037] INFO [QuorumController id=1] Created partition __consumer_offsets-29 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038407975Z [2024-04-06 01:30:35,037] INFO [QuorumController id=1] Created partition __consumer_offsets-30 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038411096Z [2024-04-06 01:30:35,037] INFO [QuorumController id=1] Created partition __consumer_offsets-31 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038414044Z [2024-04-06 01:30:35,037] INFO [QuorumController id=1] Created partition __consumer_offsets-32 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.038417023Z [2024-04-06 01:30:35,037] INFO [QuorumController id=1] Created partition __consumer_offsets-33 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.056481877Z [2024-04-06 01:30:35,050] INFO [QuorumController id=1] Created partition __consumer_offsets-34 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.056496817Z [2024-04-06 01:30:35,050] INFO [QuorumController id=1] Created partition __consumer_offsets-35 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.056511595Z [2024-04-06 01:30:35,051] INFO [QuorumController id=1] Created partition __consumer_offsets-36 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.056515064Z [2024-04-06 01:30:35,051] INFO [QuorumController id=1] Created partition __consumer_offsets-37 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.063487982Z [2024-04-06 01:30:35,055] INFO [QuorumController id=1] Created partition __consumer_offsets-38 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.063502536Z [2024-04-06 01:30:35,062] INFO [QuorumController id=1] Created partition __consumer_offsets-39 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.063505947Z [2024-04-06 01:30:35,062] INFO [QuorumController id=1] Created partition __consumer_offsets-40 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.063509792Z [2024-04-06 01:30:35,063] INFO [QuorumController id=1] Created partition __consumer_offsets-41 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.063513035Z [2024-04-06 01:30:35,063] INFO [QuorumController id=1] Created partition __consumer_offsets-42 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.063516179Z [2024-04-06 01:30:35,063] INFO [QuorumController id=1] Created partition __consumer_offsets-43 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.063519505Z [2024-04-06 01:30:35,063] INFO [QuorumController id=1] Created partition __consumer_offsets-44 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.076774282Z [2024-04-06 01:30:35,068] INFO [QuorumController id=1] Created partition __consumer_offsets-45 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.077444889Z [2024-04-06 01:30:35,077] INFO [QuorumController id=1] Created partition __consumer_offsets-46 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.077892076Z [2024-04-06 01:30:35,077] INFO [QuorumController id=1] Created partition __consumer_offsets-47 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.077899532Z [2024-04-06 01:30:35,077] INFO [QuorumController id=1] Created partition __consumer_offsets-48 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.077902971Z [2024-04-06 01:30:35,077] INFO [QuorumController id=1] Created partition __consumer_offsets-49 with topic ID boK1ajUYRFOU6jbgLgsCww 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-06T01:30:35.144329868Z [2024-04-06 01:30:35,142] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='__consumer_offsets', numPartitions=50, replicationFactor=3, assignments=[], configs=[CreateableTopicConfig(name='compression.type', value='producer'), CreateableTopicConfig(name='cleanup.policy', value='compact'), CreateableTopicConfig(name='segment.bytes', value='104857600')]): TOPIC_ALREADY_EXISTS (Topic '__consumer_offsets' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:35.153906122Z [2024-04-06 01:30:35,149] INFO [Broker id=1] Transitioning 17 partition(s) to local leaders. (state.change.logger) 2024-04-06T01:30:35.153922785Z [2024-04-06 01:30:35,149] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions Set(__consumer_offsets-48, __consumer_offsets-13, __consumer_offsets-45, __consumer_offsets-11, __consumer_offsets-43, __consumer_offsets-41, __consumer_offsets-23, __consumer_offsets-17, __consumer_offsets-18, __consumer_offsets-32, __consumer_offsets-28, __consumer_offsets-26, __consumer_offsets-6, __consumer_offsets-3, __consumer_offsets-36, __consumer_offsets-1, __consumer_offsets-34) (kafka.server.ReplicaFetcherManager) 2024-04-06T01:30:35.153926975Z [2024-04-06 01:30:35,149] INFO [Broker id=1] Creating new partition __consumer_offsets-48 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:35.230801730Z [2024-04-06 01:30:35,213] 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-06T01:30:35.236627474Z [2024-04-06 01:30:35,235] 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-06T01:30:35.236643821Z [2024-04-06 01:30:35,236] INFO [Partition __consumer_offsets-48 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-48 (kafka.cluster.Partition) 2024-04-06T01:30:35.236658008Z [2024-04-06 01:30:35,236] INFO [Partition __consumer_offsets-48 broker=1] Log loaded for partition __consumer_offsets-48 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:35.239699333Z [2024-04-06 01:30:35,239] INFO [Broker id=1] Leader __consumer_offsets-48 with topic id Some(boK1ajUYRFOU6jbgLgsCww) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,0,2], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:35.277973973Z [2024-04-06 01:30:35,277] INFO [Broker id=1] Creating new partition __consumer_offsets-13 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:35.291459466Z [2024-04-06 01:30:35,290] 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-06T01:30:35.305908492Z [2024-04-06 01:30:35,300] 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-06T01:30:35.305927887Z [2024-04-06 01:30:35,300] INFO [Partition __consumer_offsets-13 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-13 (kafka.cluster.Partition) 2024-04-06T01:30:35.305931375Z [2024-04-06 01:30:35,300] INFO [Partition __consumer_offsets-13 broker=1] Log loaded for partition __consumer_offsets-13 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:35.322139529Z [2024-04-06 01:30:35,321] INFO [Broker id=1] Leader __consumer_offsets-13 with topic id Some(boK1ajUYRFOU6jbgLgsCww) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,2,0], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:35.336547231Z [2024-04-06 01:30:35,336] INFO [Broker id=1] Creating new partition __consumer_offsets-45 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:35.353955607Z [2024-04-06 01:30:35,349] 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-06T01:30:35.355291449Z [2024-04-06 01:30:35,354] 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-06T01:30:35.355301147Z [2024-04-06 01:30:35,354] INFO [Partition __consumer_offsets-45 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-45 (kafka.cluster.Partition) 2024-04-06T01:30:35.355304679Z [2024-04-06 01:30:35,354] INFO [Partition __consumer_offsets-45 broker=1] Log loaded for partition __consumer_offsets-45 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:35.355308551Z [2024-04-06 01:30:35,354] INFO [Broker id=1] Leader __consumer_offsets-45 with topic id Some(boK1ajUYRFOU6jbgLgsCww) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,2,0], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:35.369415267Z [2024-04-06 01:30:35,366] INFO [Broker id=1] Creating new partition __consumer_offsets-11 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:35.410228359Z [2024-04-06 01:30:35,409] 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-06T01:30:35.424819722Z [2024-04-06 01:30:35,424] 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-06T01:30:35.424848754Z [2024-04-06 01:30:35,424] INFO [Partition __consumer_offsets-11 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-11 (kafka.cluster.Partition) 2024-04-06T01:30:35.424852548Z [2024-04-06 01:30:35,424] INFO [Partition __consumer_offsets-11 broker=1] Log loaded for partition __consumer_offsets-11 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:35.424856233Z [2024-04-06 01:30:35,424] INFO [Broker id=1] Leader __consumer_offsets-11 with topic id Some(boK1ajUYRFOU6jbgLgsCww) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,0,2], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:35.432609024Z [2024-04-06 01:30:35,432] INFO [Broker id=1] Creating new partition __consumer_offsets-43 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:35.458391704Z [2024-04-06 01:30:35,455] 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-06T01:30:35.462381711Z [2024-04-06 01:30:35,460] 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-06T01:30:35.462799330Z [2024-04-06 01:30:35,461] INFO [Partition __consumer_offsets-43 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-43 (kafka.cluster.Partition) 2024-04-06T01:30:35.462803321Z [2024-04-06 01:30:35,461] INFO [Partition __consumer_offsets-43 broker=1] Log loaded for partition __consumer_offsets-43 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:35.462806842Z [2024-04-06 01:30:35,461] INFO [Broker id=1] Leader __consumer_offsets-43 with topic id Some(boK1ajUYRFOU6jbgLgsCww) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,2,0], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:35.494077442Z [2024-04-06 01:30:35,491] INFO [Broker id=1] Creating new partition __consumer_offsets-41 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:35.517722937Z [2024-04-06 01:30:35,513] 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-06T01:30:35.520195816Z [2024-04-06 01:30:35,518] 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-06T01:30:35.520328056Z [2024-04-06 01:30:35,518] INFO [Partition __consumer_offsets-41 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-41 (kafka.cluster.Partition) 2024-04-06T01:30:35.520344928Z [2024-04-06 01:30:35,518] INFO [Partition __consumer_offsets-41 broker=1] Log loaded for partition __consumer_offsets-41 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:35.520351522Z [2024-04-06 01:30:35,518] INFO [Broker id=1] Leader __consumer_offsets-41 with topic id Some(boK1ajUYRFOU6jbgLgsCww) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,0,2], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:35.564091285Z [2024-04-06 01:30:35,563] INFO [Broker id=1] Creating new partition __consumer_offsets-23 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:35.596586928Z [2024-04-06 01:30:35,596] 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-06T01:30:35.598015063Z [2024-04-06 01:30:35,597] 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-06T01:30:35.599553995Z [2024-04-06 01:30:35,597] INFO [Partition __consumer_offsets-23 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-23 (kafka.cluster.Partition) 2024-04-06T01:30:35.599558916Z [2024-04-06 01:30:35,597] INFO [Partition __consumer_offsets-23 broker=1] Log loaded for partition __consumer_offsets-23 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:35.599562833Z [2024-04-06 01:30:35,597] INFO [Broker id=1] Leader __consumer_offsets-23 with topic id Some(boK1ajUYRFOU6jbgLgsCww) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,0,2], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:35.610484282Z [2024-04-06 01:30:35,610] INFO [Broker id=1] Creating new partition __consumer_offsets-17 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:35.659479667Z [2024-04-06 01:30:35,659] 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-06T01:30:35.660555591Z [2024-04-06 01:30:35,660] 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-06T01:30:35.660577446Z [2024-04-06 01:30:35,660] INFO [Partition __consumer_offsets-17 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-17 (kafka.cluster.Partition) 2024-04-06T01:30:35.660644051Z [2024-04-06 01:30:35,660] INFO [Partition __consumer_offsets-17 broker=1] Log loaded for partition __consumer_offsets-17 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:35.660773920Z [2024-04-06 01:30:35,660] INFO [Broker id=1] Leader __consumer_offsets-17 with topic id Some(boK1ajUYRFOU6jbgLgsCww) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,0,2], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:35.682307370Z [2024-04-06 01:30:35,682] INFO [Broker id=1] Creating new partition __consumer_offsets-18 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:35.745240290Z [2024-04-06 01:30:35,745] 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-06T01:30:35.746826468Z [2024-04-06 01:30:35,746] 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-06T01:30:35.747005031Z [2024-04-06 01:30:35,746] INFO [Partition __consumer_offsets-18 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-18 (kafka.cluster.Partition) 2024-04-06T01:30:35.747012225Z [2024-04-06 01:30:35,746] INFO [Partition __consumer_offsets-18 broker=1] Log loaded for partition __consumer_offsets-18 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:35.747037355Z [2024-04-06 01:30:35,746] INFO [Broker id=1] Leader __consumer_offsets-18 with topic id Some(boK1ajUYRFOU6jbgLgsCww) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,0,2], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:35.795642065Z [2024-04-06 01:30:35,794] INFO [Broker id=1] Creating new partition __consumer_offsets-32 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:35.828739906Z [2024-04-06 01:30:35,823] 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-06T01:30:35.828760691Z [2024-04-06 01:30:35,824] 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-06T01:30:35.828765507Z [2024-04-06 01:30:35,824] INFO [Partition __consumer_offsets-32 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-32 (kafka.cluster.Partition) 2024-04-06T01:30:35.828769925Z [2024-04-06 01:30:35,824] INFO [Partition __consumer_offsets-32 broker=1] Log loaded for partition __consumer_offsets-32 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:35.828774338Z [2024-04-06 01:30:35,824] INFO [Broker id=1] Leader __consumer_offsets-32 with topic id Some(boK1ajUYRFOU6jbgLgsCww) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,0,2], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:35.879043839Z [2024-04-06 01:30:35,873] INFO [Broker id=1] Creating new partition __consumer_offsets-28 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:35.915037666Z [2024-04-06 01:30:35,913] 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-06T01:30:35.937629775Z [2024-04-06 01:30:35,937] 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-06T01:30:35.946813317Z [2024-04-06 01:30:35,938] INFO [Partition __consumer_offsets-28 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-28 (kafka.cluster.Partition) 2024-04-06T01:30:35.947051911Z [2024-04-06 01:30:35,946] INFO [Partition __consumer_offsets-28 broker=1] Log loaded for partition __consumer_offsets-28 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:35.947552073Z [2024-04-06 01:30:35,947] INFO [Broker id=1] Leader __consumer_offsets-28 with topic id Some(boK1ajUYRFOU6jbgLgsCww) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,2,0], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:35.961985574Z [2024-04-06 01:30:35,960] INFO [Broker id=1] Creating new partition __consumer_offsets-26 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:35.985893257Z [2024-04-06 01:30:35,985] 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-06T01:30:36.017702183Z [2024-04-06 01:30:36,015] 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-06T01:30:36.017711016Z [2024-04-06 01:30:36,015] INFO [Partition __consumer_offsets-26 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-26 (kafka.cluster.Partition) 2024-04-06T01:30:36.017714038Z [2024-04-06 01:30:36,016] INFO [Partition __consumer_offsets-26 broker=1] Log loaded for partition __consumer_offsets-26 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:36.017721365Z [2024-04-06 01:30:36,016] INFO [Broker id=1] Leader __consumer_offsets-26 with topic id Some(boK1ajUYRFOU6jbgLgsCww) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,0,2], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:36.060856490Z [2024-04-06 01:30:36,059] INFO [Broker id=1] Creating new partition __consumer_offsets-6 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:36.084491654Z [2024-04-06 01:30:36,082] 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-06T01:30:36.114774261Z [2024-04-06 01:30:36,107] 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-06T01:30:36.117796147Z [2024-04-06 01:30:36,107] INFO [Partition __consumer_offsets-6 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-6 (kafka.cluster.Partition) 2024-04-06T01:30:36.117803489Z [2024-04-06 01:30:36,107] INFO [Partition __consumer_offsets-6 broker=1] Log loaded for partition __consumer_offsets-6 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:36.117823812Z [2024-04-06 01:30:36,108] INFO [Broker id=1] Leader __consumer_offsets-6 with topic id Some(boK1ajUYRFOU6jbgLgsCww) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,2,0], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:36.147008092Z [2024-04-06 01:30:36,146] INFO [Broker id=1] Creating new partition __consumer_offsets-3 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:36.187457225Z [2024-04-06 01:30:36,184] 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-06T01:30:36.201302054Z [2024-04-06 01:30:36,184] 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-06T01:30:36.203772164Z [2024-04-06 01:30:36,203] INFO [Partition __consumer_offsets-3 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-3 (kafka.cluster.Partition) 2024-04-06T01:30:36.203875277Z [2024-04-06 01:30:36,203] INFO [Partition __consumer_offsets-3 broker=1] Log loaded for partition __consumer_offsets-3 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:36.204393378Z [2024-04-06 01:30:36,204] INFO [Broker id=1] Leader __consumer_offsets-3 with topic id Some(boK1ajUYRFOU6jbgLgsCww) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,0,2], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:36.219397290Z [2024-04-06 01:30:36,218] INFO [Broker id=1] Creating new partition __consumer_offsets-36 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:36.225910683Z [2024-04-06 01:30:36,225] 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-06T01:30:36.245120371Z [2024-04-06 01:30:36,241] 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-06T01:30:36.245155926Z [2024-04-06 01:30:36,241] INFO [Partition __consumer_offsets-36 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-36 (kafka.cluster.Partition) 2024-04-06T01:30:36.245160009Z [2024-04-06 01:30:36,242] INFO [Partition __consumer_offsets-36 broker=1] Log loaded for partition __consumer_offsets-36 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:36.247558933Z [2024-04-06 01:30:36,246] INFO [Broker id=1] Leader __consumer_offsets-36 with topic id Some(boK1ajUYRFOU6jbgLgsCww) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,2,0], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:36.265894674Z [2024-04-06 01:30:36,262] INFO [Broker id=1] Creating new partition __consumer_offsets-1 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:36.265905743Z [2024-04-06 01:30:36,265] 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-06T01:30:36.268165821Z [2024-04-06 01:30:36,265] 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-06T01:30:36.268551112Z [2024-04-06 01:30:36,268] INFO [Partition __consumer_offsets-1 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-1 (kafka.cluster.Partition) 2024-04-06T01:30:36.269958771Z [2024-04-06 01:30:36,268] INFO [Partition __consumer_offsets-1 broker=1] Log loaded for partition __consumer_offsets-1 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:36.269964831Z [2024-04-06 01:30:36,268] INFO [Broker id=1] Leader __consumer_offsets-1 with topic id Some(boK1ajUYRFOU6jbgLgsCww) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,2,0], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:36.277946672Z [2024-04-06 01:30:36,276] INFO [Broker id=1] Creating new partition __consumer_offsets-34 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:36.308109982Z [2024-04-06 01:30:36,305] 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-06T01:30:36.308123064Z [2024-04-06 01:30:36,306] 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-06T01:30:36.308126804Z [2024-04-06 01:30:36,306] INFO [Partition __consumer_offsets-34 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-34 (kafka.cluster.Partition) 2024-04-06T01:30:36.312422367Z [2024-04-06 01:30:36,309] INFO [Partition __consumer_offsets-34 broker=1] Log loaded for partition __consumer_offsets-34 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:36.312434389Z [2024-04-06 01:30:36,310] INFO [Broker id=1] Leader __consumer_offsets-34 with topic id Some(boK1ajUYRFOU6jbgLgsCww) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,2,0], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:36.323181830Z [2024-04-06 01:30:36,322] INFO [Broker id=1] Transitioning 33 partition(s) to local followers. (state.change.logger) 2024-04-06T01:30:36.339753090Z [2024-04-06 01:30:36,337] INFO [Broker id=1] Creating new partition __consumer_offsets-15 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:36.357993819Z [2024-04-06 01:30:36,356] 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-06T01:30:36.376542518Z [2024-04-06 01:30:36,375] 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-06T01:30:36.376555862Z [2024-04-06 01:30:36,376] INFO [Partition __consumer_offsets-15 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-15 (kafka.cluster.Partition) 2024-04-06T01:30:36.376559219Z [2024-04-06 01:30:36,376] INFO [Partition __consumer_offsets-15 broker=1] Log loaded for partition __consumer_offsets-15 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:36.379742599Z [2024-04-06 01:30:36,377] INFO [Broker id=1] Follower __consumer_offsets-15 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-06T01:30:36.379763805Z [2024-04-06 01:30:36,377] INFO [Broker id=1] Creating new partition __consumer_offsets-46 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:36.444511246Z [2024-04-06 01:30:36,443] 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-06T01:30:36.451736506Z [2024-04-06 01:30:36,450] 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-06T01:30:36.451754617Z [2024-04-06 01:30:36,451] INFO [Partition __consumer_offsets-46 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-46 (kafka.cluster.Partition) 2024-04-06T01:30:36.451758595Z [2024-04-06 01:30:36,451] INFO [Partition __consumer_offsets-46 broker=1] Log loaded for partition __consumer_offsets-46 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:36.451762575Z [2024-04-06 01:30:36,451] INFO [Broker id=1] Follower __consumer_offsets-46 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:36.452979448Z [2024-04-06 01:30:36,451] INFO [Broker id=1] Creating new partition __consumer_offsets-44 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:36.487634930Z [2024-04-06 01:30:36,487] 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-06T01:30:36.502554238Z [2024-04-06 01:30:36,501] 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-06T01:30:36.504609303Z [2024-04-06 01:30:36,504] INFO [Partition __consumer_offsets-44 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-44 (kafka.cluster.Partition) 2024-04-06T01:30:36.508063102Z [2024-04-06 01:30:36,507] INFO [Partition __consumer_offsets-44 broker=1] Log loaded for partition __consumer_offsets-44 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:36.522675658Z [2024-04-06 01:30:36,511] INFO [Broker id=1] Follower __consumer_offsets-44 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:36.522683558Z [2024-04-06 01:30:36,517] INFO [Broker id=1] Creating new partition __consumer_offsets-9 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:36.560651327Z [2024-04-06 01:30:36,560] 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-06T01:30:36.563609960Z [2024-04-06 01:30:36,563] 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-06T01:30:36.567123436Z [2024-04-06 01:30:36,563] INFO [Partition __consumer_offsets-9 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-9 (kafka.cluster.Partition) 2024-04-06T01:30:36.567137232Z [2024-04-06 01:30:36,564] INFO [Partition __consumer_offsets-9 broker=1] Log loaded for partition __consumer_offsets-9 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:36.567164162Z [2024-04-06 01:30:36,564] INFO [Broker id=1] Follower __consumer_offsets-9 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-06T01:30:36.567168828Z [2024-04-06 01:30:36,564] INFO [Broker id=1] Creating new partition __consumer_offsets-42 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:36.570933710Z [2024-04-06 01:30:36,569] 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-06T01:30:36.571268060Z [2024-04-06 01:30:36,571] 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-06T01:30:36.571277866Z [2024-04-06 01:30:36,571] INFO [Partition __consumer_offsets-42 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-42 (kafka.cluster.Partition) 2024-04-06T01:30:36.571281323Z [2024-04-06 01:30:36,571] INFO [Partition __consumer_offsets-42 broker=1] Log loaded for partition __consumer_offsets-42 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:36.571284797Z [2024-04-06 01:30:36,571] INFO [Broker id=1] Follower __consumer_offsets-42 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-06T01:30:36.571850068Z [2024-04-06 01:30:36,571] INFO [Broker id=1] Creating new partition __consumer_offsets-21 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:36.574593088Z [2024-04-06 01:30:36,574] 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-06T01:30:36.575155832Z [2024-04-06 01:30:36,575] 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-06T01:30:36.575274215Z [2024-04-06 01:30:36,575] INFO [Partition __consumer_offsets-21 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-21 (kafka.cluster.Partition) 2024-04-06T01:30:36.575343818Z [2024-04-06 01:30:36,575] INFO [Partition __consumer_offsets-21 broker=1] Log loaded for partition __consumer_offsets-21 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:36.575428804Z [2024-04-06 01:30:36,575] INFO [Broker id=1] Follower __consumer_offsets-21 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-06T01:30:36.575549098Z [2024-04-06 01:30:36,575] INFO [Broker id=1] Creating new partition __consumer_offsets-19 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:36.578737495Z [2024-04-06 01:30:36,578] 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-06T01:30:36.579104802Z [2024-04-06 01:30:36,579] 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-06T01:30:36.579175851Z [2024-04-06 01:30:36,579] INFO [Partition __consumer_offsets-19 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-19 (kafka.cluster.Partition) 2024-04-06T01:30:36.579241012Z [2024-04-06 01:30:36,579] INFO [Partition __consumer_offsets-19 broker=1] Log loaded for partition __consumer_offsets-19 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:36.579325783Z [2024-04-06 01:30:36,579] INFO [Broker id=1] Follower __consumer_offsets-19 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-06T01:30:36.579429370Z [2024-04-06 01:30:36,579] INFO [Broker id=1] Creating new partition __consumer_offsets-30 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:36.582902159Z [2024-04-06 01:30:36,581] 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-06T01:30:36.582918163Z [2024-04-06 01:30:36,582] 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-06T01:30:36.582921946Z [2024-04-06 01:30:36,582] INFO [Partition __consumer_offsets-30 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-30 (kafka.cluster.Partition) 2024-04-06T01:30:36.582924891Z [2024-04-06 01:30:36,582] INFO [Partition __consumer_offsets-30 broker=1] Log loaded for partition __consumer_offsets-30 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:36.582928473Z [2024-04-06 01:30:36,582] INFO [Broker id=1] 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-06T01:30:36.582932039Z [2024-04-06 01:30:36,582] INFO [Broker id=1] Creating new partition __consumer_offsets-7 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:36.589243890Z [2024-04-06 01:30:36,589] 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-06T01:30:36.591060679Z [2024-04-06 01:30:36,590] 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-06T01:30:36.591067506Z [2024-04-06 01:30:36,590] INFO [Partition __consumer_offsets-7 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-7 (kafka.cluster.Partition) 2024-04-06T01:30:36.591070677Z [2024-04-06 01:30:36,590] INFO [Partition __consumer_offsets-7 broker=1] Log loaded for partition __consumer_offsets-7 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:36.591073756Z [2024-04-06 01:30:36,590] INFO [Broker id=1] Follower __consumer_offsets-7 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:36.591128327Z [2024-04-06 01:30:36,590] INFO [Broker id=1] Creating new partition __consumer_offsets-40 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:36.597067183Z [2024-04-06 01:30:36,596] 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-06T01:30:36.597701764Z [2024-04-06 01:30:36,597] 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-06T01:30:36.598999229Z [2024-04-06 01:30:36,598] INFO [Partition __consumer_offsets-40 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-40 (kafka.cluster.Partition) 2024-04-06T01:30:36.599318940Z [2024-04-06 01:30:36,599] INFO [Partition __consumer_offsets-40 broker=1] Log loaded for partition __consumer_offsets-40 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:36.599331452Z [2024-04-06 01:30:36,599] INFO [Broker id=1] Follower __consumer_offsets-40 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:36.599336306Z [2024-04-06 01:30:36,599] INFO [Broker id=1] Creating new partition __consumer_offsets-5 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:36.609924134Z [2024-04-06 01:30:36,604] 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-06T01:30:36.609938864Z [2024-04-06 01:30:36,605] 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-06T01:30:36.609942740Z [2024-04-06 01:30:36,605] INFO [Partition __consumer_offsets-5 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-5 (kafka.cluster.Partition) 2024-04-06T01:30:36.609945960Z [2024-04-06 01:30:36,605] INFO [Partition __consumer_offsets-5 broker=1] Log loaded for partition __consumer_offsets-5 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:36.609949324Z [2024-04-06 01:30:36,605] INFO [Broker id=1] Follower __consumer_offsets-5 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:36.609953216Z [2024-04-06 01:30:36,605] INFO [Broker id=1] Creating new partition __consumer_offsets-38 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:36.609956275Z [2024-04-06 01:30:36,607] 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-06T01:30:36.609959614Z [2024-04-06 01:30:36,608] 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-06T01:30:36.609962701Z [2024-04-06 01:30:36,608] INFO [Partition __consumer_offsets-38 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-38 (kafka.cluster.Partition) 2024-04-06T01:30:36.609966374Z [2024-04-06 01:30:36,608] INFO [Partition __consumer_offsets-38 broker=1] Log loaded for partition __consumer_offsets-38 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:36.610250462Z [2024-04-06 01:30:36,608] INFO [Broker id=1] Follower __consumer_offsets-38 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-06T01:30:36.610254701Z [2024-04-06 01:30:36,608] INFO [Broker id=1] Creating new partition __consumer_offsets-47 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:36.610977195Z [2024-04-06 01:30:36,610] 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-06T01:30:36.611822845Z [2024-04-06 01:30:36,611] 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-06T01:30:36.630766321Z [2024-04-06 01:30:36,611] INFO [Partition __consumer_offsets-47 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-47 (kafka.cluster.Partition) 2024-04-06T01:30:36.630782180Z [2024-04-06 01:30:36,611] INFO [Partition __consumer_offsets-47 broker=1] Log loaded for partition __consumer_offsets-47 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:36.630786596Z [2024-04-06 01:30:36,611] INFO [Broker id=1] Follower __consumer_offsets-47 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-06T01:30:36.630790986Z [2024-04-06 01:30:36,611] INFO [Broker id=1] Creating new partition __consumer_offsets-16 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:36.640535019Z [2024-04-06 01:30:36,640] 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-06T01:30:36.646687782Z [2024-04-06 01:30:36,646] 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-06T01:30:36.646880236Z [2024-04-06 01:30:36,646] INFO [Partition __consumer_offsets-16 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-16 (kafka.cluster.Partition) 2024-04-06T01:30:36.647581134Z [2024-04-06 01:30:36,647] INFO [Partition __consumer_offsets-16 broker=1] Log loaded for partition __consumer_offsets-16 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:36.648173623Z [2024-04-06 01:30:36,648] INFO [Broker id=1] Follower __consumer_offsets-16 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:36.648875098Z [2024-04-06 01:30:36,648] INFO [Broker id=1] Creating new partition __consumer_offsets-14 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:36.662373583Z [2024-04-06 01:30:36,662] 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-06T01:30:36.751501002Z [2024-04-06 01:30:36,751] 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-06T01:30:36.758169510Z [2024-04-06 01:30:36,758] INFO [Partition __consumer_offsets-14 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-14 (kafka.cluster.Partition) 2024-04-06T01:30:36.762324514Z [2024-04-06 01:30:36,758] INFO [Partition __consumer_offsets-14 broker=1] Log loaded for partition __consumer_offsets-14 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:36.769125183Z [2024-04-06 01:30:36,768] INFO [Broker id=1] Follower __consumer_offsets-14 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:36.769135809Z [2024-04-06 01:30:36,768] INFO [Broker id=1] Creating new partition __consumer_offsets-12 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:36.802083809Z [2024-04-06 01:30:36,801] 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-06T01:30:36.806642223Z [2024-04-06 01:30:36,806] 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-06T01:30:36.806711195Z [2024-04-06 01:30:36,806] INFO [Partition __consumer_offsets-12 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-12 (kafka.cluster.Partition) 2024-04-06T01:30:36.806836250Z [2024-04-06 01:30:36,806] INFO [Partition __consumer_offsets-12 broker=1] Log loaded for partition __consumer_offsets-12 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:36.806913210Z [2024-04-06 01:30:36,806] INFO [Broker id=1] Follower __consumer_offsets-12 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-06T01:30:36.807401013Z [2024-04-06 01:30:36,807] INFO [Broker id=1] Creating new partition __consumer_offsets-10 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:36.815442887Z [2024-04-06 01:30:36,814] 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-06T01:30:36.815450030Z [2024-04-06 01:30:36,815] 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-06T01:30:36.815453693Z [2024-04-06 01:30:36,815] INFO [Partition __consumer_offsets-10 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-10 (kafka.cluster.Partition) 2024-04-06T01:30:36.816964073Z [2024-04-06 01:30:36,816] INFO [Partition __consumer_offsets-10 broker=1] Log loaded for partition __consumer_offsets-10 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:36.817035841Z [2024-04-06 01:30:36,816] INFO [Broker id=1] Follower __consumer_offsets-10 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:36.817225714Z [2024-04-06 01:30:36,817] INFO [Broker id=1] Creating new partition __consumer_offsets-24 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:36.823703422Z [2024-04-06 01:30:36,823] 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-06T01:30:36.824495011Z [2024-04-06 01:30:36,824] 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-06T01:30:36.824504865Z [2024-04-06 01:30:36,824] INFO [Partition __consumer_offsets-24 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-24 (kafka.cluster.Partition) 2024-04-06T01:30:36.824522739Z [2024-04-06 01:30:36,824] INFO [Partition __consumer_offsets-24 broker=1] Log loaded for partition __consumer_offsets-24 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:36.824526698Z [2024-04-06 01:30:36,824] INFO [Broker id=1] 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-06T01:30:36.824535102Z [2024-04-06 01:30:36,824] INFO [Broker id=1] Creating new partition __consumer_offsets-22 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:36.832825319Z [2024-04-06 01:30:36,831] 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-06T01:30:36.832841916Z [2024-04-06 01:30:36,831] 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-06T01:30:36.832847821Z [2024-04-06 01:30:36,831] INFO [Partition __consumer_offsets-22 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-22 (kafka.cluster.Partition) 2024-04-06T01:30:36.832852360Z [2024-04-06 01:30:36,831] INFO [Partition __consumer_offsets-22 broker=1] Log loaded for partition __consumer_offsets-22 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:36.832862190Z [2024-04-06 01:30:36,831] INFO [Broker id=1] Follower __consumer_offsets-22 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:36.832867158Z [2024-04-06 01:30:36,831] INFO [Broker id=1] Creating new partition __consumer_offsets-20 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:36.837611925Z [2024-04-06 01:30:36,836] 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-06T01:30:36.845898888Z [2024-04-06 01:30:36,836] 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-06T01:30:36.845913164Z [2024-04-06 01:30:36,840] INFO [Partition __consumer_offsets-20 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-20 (kafka.cluster.Partition) 2024-04-06T01:30:36.845916320Z [2024-04-06 01:30:36,840] INFO [Partition __consumer_offsets-20 broker=1] Log loaded for partition __consumer_offsets-20 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:36.845919912Z [2024-04-06 01:30:36,840] INFO [Broker id=1] Follower __consumer_offsets-20 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:36.845923036Z [2024-04-06 01:30:36,840] INFO [Broker id=1] Creating new partition __consumer_offsets-49 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:36.845926389Z [2024-04-06 01:30:36,842] 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-06T01:30:36.845929374Z [2024-04-06 01:30:36,843] 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-06T01:30:36.845940879Z [2024-04-06 01:30:36,843] INFO [Partition __consumer_offsets-49 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-49 (kafka.cluster.Partition) 2024-04-06T01:30:36.845944155Z [2024-04-06 01:30:36,843] INFO [Partition __consumer_offsets-49 broker=1] Log loaded for partition __consumer_offsets-49 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:36.845946905Z [2024-04-06 01:30:36,843] INFO [Broker id=1] Follower __consumer_offsets-49 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-06T01:30:36.845949673Z [2024-04-06 01:30:36,843] INFO [Broker id=1] Creating new partition __consumer_offsets-31 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:36.853134404Z [2024-04-06 01:30:36,853] 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-06T01:30:36.853801719Z [2024-04-06 01:30:36,853] 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-06T01:30:36.868754892Z [2024-04-06 01:30:36,868] INFO [Partition __consumer_offsets-31 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-31 (kafka.cluster.Partition) 2024-04-06T01:30:36.874912083Z [2024-04-06 01:30:36,874] INFO [Partition __consumer_offsets-31 broker=1] Log loaded for partition __consumer_offsets-31 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:36.874925994Z [2024-04-06 01:30:36,874] INFO [Broker id=1] Follower __consumer_offsets-31 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:36.874929606Z [2024-04-06 01:30:36,874] INFO [Broker id=1] Creating new partition __consumer_offsets-0 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:36.948025610Z [2024-04-06 01:30:36,947] 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-06T01:30:36.948838162Z [2024-04-06 01:30:36,948] 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-06T01:30:36.948987176Z [2024-04-06 01:30:36,948] INFO [Partition __consumer_offsets-0 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-0 (kafka.cluster.Partition) 2024-04-06T01:30:36.949044835Z [2024-04-06 01:30:36,948] INFO [Partition __consumer_offsets-0 broker=1] Log loaded for partition __consumer_offsets-0 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:36.949097872Z [2024-04-06 01:30:36,949] INFO [Broker id=1] Follower __consumer_offsets-0 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-06T01:30:36.949205951Z [2024-04-06 01:30:36,949] INFO [Broker id=1] Creating new partition __consumer_offsets-29 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:36.981923049Z [2024-04-06 01:30:36,981] 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-06T01:30:36.985451535Z [2024-04-06 01:30:36,985] 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-06T01:30:36.985476619Z [2024-04-06 01:30:36,985] INFO [Partition __consumer_offsets-29 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-29 (kafka.cluster.Partition) 2024-04-06T01:30:36.985547101Z [2024-04-06 01:30:36,985] INFO [Partition __consumer_offsets-29 broker=1] Log loaded for partition __consumer_offsets-29 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:36.985604822Z [2024-04-06 01:30:36,985] INFO [Broker id=1] Follower __consumer_offsets-29 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:36.985684335Z [2024-04-06 01:30:36,985] INFO [Broker id=1] Creating new partition __consumer_offsets-27 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:37.097958217Z [2024-04-06 01:30:37,079] 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-06T01:30:37.119967384Z [2024-04-06 01:30:37,102] 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-06T01:30:37.119976605Z [2024-04-06 01:30:37,102] INFO [Partition __consumer_offsets-27 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-27 (kafka.cluster.Partition) 2024-04-06T01:30:37.119979892Z [2024-04-06 01:30:37,102] INFO [Partition __consumer_offsets-27 broker=1] Log loaded for partition __consumer_offsets-27 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:37.119983850Z [2024-04-06 01:30:37,102] INFO [Broker id=1] Follower __consumer_offsets-27 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-06T01:30:37.119987896Z [2024-04-06 01:30:37,102] INFO [Broker id=1] Creating new partition __consumer_offsets-25 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:37.183769089Z [2024-04-06 01:30:37,182] 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-06T01:30:37.220144003Z [2024-04-06 01:30:37,219] 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-06T01:30:37.250100765Z [2024-04-06 01:30:37,249] INFO [Partition __consumer_offsets-25 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-25 (kafka.cluster.Partition) 2024-04-06T01:30:37.253409735Z [2024-04-06 01:30:37,253] INFO [Partition __consumer_offsets-25 broker=1] Log loaded for partition __consumer_offsets-25 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:37.253906414Z [2024-04-06 01:30:37,253] INFO [Broker id=1] Follower __consumer_offsets-25 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:37.254057490Z [2024-04-06 01:30:37,253] INFO [Broker id=1] Creating new partition __consumer_offsets-39 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:37.316504422Z [2024-04-06 01:30:37,316] 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-06T01:30:37.333740717Z [2024-04-06 01:30:37,333] 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-06T01:30:37.334676111Z [2024-04-06 01:30:37,334] INFO [Partition __consumer_offsets-39 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-39 (kafka.cluster.Partition) 2024-04-06T01:30:37.336075919Z [2024-04-06 01:30:37,335] INFO [Partition __consumer_offsets-39 broker=1] Log loaded for partition __consumer_offsets-39 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:37.346413085Z [2024-04-06 01:30:37,336] INFO [Broker id=1] 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-06T01:30:37.346568916Z [2024-04-06 01:30:37,346] INFO [Broker id=1] Creating new partition __consumer_offsets-8 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:37.417517153Z [2024-04-06 01:30:37,417] 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-06T01:30:37.498345087Z [2024-04-06 01:30:37,493] 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-06T01:30:37.498362443Z [2024-04-06 01:30:37,494] INFO [Partition __consumer_offsets-8 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-8 (kafka.cluster.Partition) 2024-04-06T01:30:37.498366130Z [2024-04-06 01:30:37,494] INFO [Partition __consumer_offsets-8 broker=1] Log loaded for partition __consumer_offsets-8 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:37.498369396Z [2024-04-06 01:30:37,494] INFO [Broker id=1] Follower __consumer_offsets-8 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-06T01:30:37.498373397Z [2024-04-06 01:30:37,494] INFO [Broker id=1] Creating new partition __consumer_offsets-37 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:37.635859032Z [2024-04-06 01:30:37,634] 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-06T01:30:37.720742202Z [2024-04-06 01:30:37,719] 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-06T01:30:37.720774320Z [2024-04-06 01:30:37,719] INFO [Partition __consumer_offsets-37 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-37 (kafka.cluster.Partition) 2024-04-06T01:30:37.720802025Z [2024-04-06 01:30:37,719] INFO [Partition __consumer_offsets-37 broker=1] Log loaded for partition __consumer_offsets-37 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:37.720805963Z [2024-04-06 01:30:37,719] INFO [Broker id=1] Follower __consumer_offsets-37 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:37.720809717Z [2024-04-06 01:30:37,719] INFO [Broker id=1] Creating new partition __consumer_offsets-35 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:37.818668416Z [2024-04-06 01:30:37,816] 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-06T01:30:37.818698790Z [2024-04-06 01:30:37,817] 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-06T01:30:37.818703067Z [2024-04-06 01:30:37,817] INFO [Partition __consumer_offsets-35 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-35 (kafka.cluster.Partition) 2024-04-06T01:30:37.818706107Z [2024-04-06 01:30:37,817] INFO [Partition __consumer_offsets-35 broker=1] Log loaded for partition __consumer_offsets-35 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:37.818709400Z [2024-04-06 01:30:37,817] INFO [Broker id=1] Follower __consumer_offsets-35 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:37.818712684Z [2024-04-06 01:30:37,817] INFO [Broker id=1] Creating new partition __consumer_offsets-4 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:38.017898224Z [2024-04-06 01:30:38,016] 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-06T01:30:38.021476626Z [2024-04-06 01:30:38,020] 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-06T01:30:38.038415186Z [2024-04-06 01:30:38,037] INFO [Partition __consumer_offsets-4 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-4 (kafka.cluster.Partition) 2024-04-06T01:30:38.038429612Z [2024-04-06 01:30:38,037] INFO [Partition __consumer_offsets-4 broker=1] Log loaded for partition __consumer_offsets-4 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:38.038433721Z [2024-04-06 01:30:38,037] INFO [Broker id=1] Follower __consumer_offsets-4 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-06T01:30:38.038437562Z [2024-04-06 01:30:38,037] INFO [Broker id=1] Creating new partition __consumer_offsets-33 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:38.113415639Z [2024-04-06 01:30:38,110] 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-06T01:30:38.113430059Z [2024-04-06 01:30:38,112] 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-06T01:30:38.113434287Z [2024-04-06 01:30:38,112] INFO [Partition __consumer_offsets-33 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-33 (kafka.cluster.Partition) 2024-04-06T01:30:38.113437431Z [2024-04-06 01:30:38,112] INFO [Partition __consumer_offsets-33 broker=1] Log loaded for partition __consumer_offsets-33 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:38.113441108Z [2024-04-06 01:30:38,112] INFO [Broker id=1] Follower __consumer_offsets-33 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-06T01:30:38.113445439Z [2024-04-06 01:30:38,112] INFO [Broker id=1] Creating new partition __consumer_offsets-2 with topic id boK1ajUYRFOU6jbgLgsCww. (state.change.logger) 2024-04-06T01:30:38.137186809Z [2024-04-06 01:30:38,132] 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-06T01:30:38.146928747Z [2024-04-06 01:30:38,140] 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-06T01:30:38.146944603Z [2024-04-06 01:30:38,140] INFO [Partition __consumer_offsets-2 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-2 (kafka.cluster.Partition) 2024-04-06T01:30:38.146948156Z [2024-04-06 01:30:38,140] INFO [Partition __consumer_offsets-2 broker=1] Log loaded for partition __consumer_offsets-2 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:38.146951291Z [2024-04-06 01:30:38,140] INFO [Broker id=1] Follower __consumer_offsets-2 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:38.146956679Z [2024-04-06 01:30:38,141] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions Set(__consumer_offsets-38, __consumer_offsets-49, __consumer_offsets-16, __consumer_offsets-27, __consumer_offsets-8, __consumer_offsets-19, __consumer_offsets-2, __consumer_offsets-35, __consumer_offsets-46, __consumer_offsets-24, __consumer_offsets-5, __consumer_offsets-21, __consumer_offsets-10, __consumer_offsets-37, __consumer_offsets-40, __consumer_offsets-29, __consumer_offsets-7, __consumer_offsets-4, __consumer_offsets-15, __consumer_offsets-42, __consumer_offsets-9, __consumer_offsets-20, __consumer_offsets-31, __consumer_offsets-12, __consumer_offsets-39, __consumer_offsets-44, __consumer_offsets-47, __consumer_offsets-25, __consumer_offsets-14, __consumer_offsets-30, __consumer_offsets-33, __consumer_offsets-22, __consumer_offsets-0) (kafka.server.ReplicaFetcherManager) 2024-04-06T01:30:38.146960718Z [2024-04-06 01:30:38,141] INFO [Broker id=1] Stopped fetchers as part of become-follower for 33 partitions (state.change.logger) 2024-04-06T01:30:38.511585120Z [2024-04-06 01:30:38,502] INFO [ReplicaFetcherThread-0-0]: Starting (kafka.server.ReplicaFetcherThread) 2024-04-06T01:30:38.541489502Z [2024-04-06 01:30:38,540] INFO [ReplicaFetcher replicaId=1, 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-06T01:30:38.578890746Z [2024-04-06 01:30:38,572] INFO [ReplicaFetcherManager on broker 1] Added fetcher to broker 0 for partitions Map(__consumer_offsets-49 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-38 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-27 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-19 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-8 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-24 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-21 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-4 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-15 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-42 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-9 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-12 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-39 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-47 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-30 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-0 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-33 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0)) (kafka.server.ReplicaFetcherManager) 2024-04-06T01:30:38.588035791Z [2024-04-06 01:30:38,586] 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-06T01:30:38.588633962Z [2024-04-06 01:30:38,587] INFO [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-21 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-04-06T01:30:38.588640652Z [2024-04-06 01:30:38,587] INFO [UnifiedLog partition=__consumer_offsets-21, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog) 2024-04-06T01:30:38.588657803Z [2024-04-06 01:30:38,587] INFO [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-47 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-04-06T01:30:38.588661241Z [2024-04-06 01:30:38,587] INFO [UnifiedLog partition=__consumer_offsets-47, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog) 2024-04-06T01:30:38.588664383Z [2024-04-06 01:30:38,587] INFO [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-0 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-04-06T01:30:38.588667390Z [2024-04-06 01:30:38,587] 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-06T01:30:38.588697143Z [2024-04-06 01:30:38,588] INFO [ReplicaFetcher replicaId=1, 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-06T01:30:38.588714152Z [2024-04-06 01:30:38,588] 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-06T01:30:38.588717967Z [2024-04-06 01:30:38,588] INFO [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-33 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-04-06T01:30:38.588727866Z [2024-04-06 01:30:38,588] 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-06T01:30:38.588730990Z [2024-04-06 01:30:38,588] INFO [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-4 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-04-06T01:30:38.588747189Z [2024-04-06 01:30:38,588] 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-06T01:30:38.588750366Z [2024-04-06 01:30:38,588] INFO [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-15 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-04-06T01:30:38.588753292Z [2024-04-06 01:30:38,588] 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-06T01:30:38.588767597Z [2024-04-06 01:30:38,588] INFO [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-19 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-04-06T01:30:38.588770752Z [2024-04-06 01:30:38,588] 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-06T01:30:38.588788798Z [2024-04-06 01:30:38,588] INFO [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-49 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-04-06T01:30:38.588791813Z [2024-04-06 01:30:38,588] INFO [UnifiedLog partition=__consumer_offsets-49, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog) 2024-04-06T01:30:38.588794775Z [2024-04-06 01:30:38,588] INFO [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-38 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-04-06T01:30:38.588797771Z [2024-04-06 01:30:38,588] 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-06T01:30:38.588813126Z [2024-04-06 01:30:38,588] INFO [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-27 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-04-06T01:30:38.588816206Z [2024-04-06 01:30:38,588] INFO [UnifiedLog partition=__consumer_offsets-27, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog) 2024-04-06T01:30:38.588819139Z [2024-04-06 01:30:38,588] INFO [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-8 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-04-06T01:30:38.588822060Z [2024-04-06 01:30:38,588] 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-06T01:30:38.588830722Z [2024-04-06 01:30:38,588] INFO [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-12 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-04-06T01:30:38.588833864Z [2024-04-06 01:30:38,588] INFO [UnifiedLog partition=__consumer_offsets-12, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog) 2024-04-06T01:30:38.588837187Z [2024-04-06 01:30:38,588] INFO [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-42 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-04-06T01:30:38.588840132Z [2024-04-06 01:30:38,588] 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-06T01:30:38.588846333Z [2024-04-06 01:30:38,588] INFO [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-9 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-04-06T01:30:38.588849536Z [2024-04-06 01:30:38,588] 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-06T01:30:38.588852432Z [2024-04-06 01:30:38,588] INFO [ReplicaFetcher replicaId=1, 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-06T01:30:38.588855421Z [2024-04-06 01:30:38,588] 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-06T01:30:38.636355535Z [2024-04-06 01:30:38,635] INFO [ReplicaFetcherManager on broker 1] Added fetcher to broker 2 for partitions Map(__consumer_offsets-16 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=2, host=kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-2 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=2, host=kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-46 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=2, host=kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-35 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=2, host=kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-5 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=2, host=kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-10 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=2, host=kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-37 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=2, host=kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-40 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=2, host=kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-29 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=2, host=kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-7 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=2, host=kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-20 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=2, host=kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-31 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=2, host=kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-44 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=2, host=kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-25 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=2, host=kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-14 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=2, host=kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-22 -> InitialFetchState(Some(boK1ajUYRFOU6jbgLgsCww),BrokerEndPoint(id=2, host=kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094),0,0)) (kafka.server.ReplicaFetcherManager) 2024-04-06T01:30:38.644915424Z [2024-04-06 01:30:38,644] INFO [Broker id=1] Started fetchers as part of become-follower for 33 partitions (state.change.logger) 2024-04-06T01:30:38.826116585Z [2024-04-06 01:30:38,823] INFO [ReplicaFetcherThread-0-2]: Starting (kafka.server.ReplicaFetcherThread) 2024-04-06T01:30:38.826130563Z [2024-04-06 01:30:38,823] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-10 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-04-06T01:30:38.826134623Z [2024-04-06 01:30:38,824] 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-06T01:30:38.826138331Z [2024-04-06 01:30:38,824] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-25 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-04-06T01:30:38.826141676Z [2024-04-06 01:30:38,824] 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-06T01:30:38.826145360Z [2024-04-06 01:30:38,824] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-44 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-04-06T01:30:38.826148540Z [2024-04-06 01:30:38,824] 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-06T01:30:38.826151564Z [2024-04-06 01:30:38,824] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-14 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-04-06T01:30:38.826154658Z [2024-04-06 01:30:38,824] 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-06T01:30:38.826157931Z [2024-04-06 01:30:38,824] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-7 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-04-06T01:30:38.860839013Z [2024-04-06 01:30:38,859] 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-06T01:30:38.860848479Z [2024-04-06 01:30:38,859] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-40 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-04-06T01:30:38.860870786Z [2024-04-06 01:30:38,859] 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-06T01:30:38.860874149Z [2024-04-06 01:30:38,859] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-37 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-04-06T01:30:38.860877162Z [2024-04-06 01:30:38,859] INFO [UnifiedLog partition=__consumer_offsets-37, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog) 2024-04-06T01:30:38.860880221Z [2024-04-06 01:30:38,860] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-29 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-04-06T01:30:38.860883368Z [2024-04-06 01:30:38,860] 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-06T01:30:38.860886410Z [2024-04-06 01:30:38,860] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-22 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-04-06T01:30:38.860889536Z [2024-04-06 01:30:38,860] 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-06T01:30:38.860892448Z [2024-04-06 01:30:38,860] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-16 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-04-06T01:30:38.860895540Z [2024-04-06 01:30:38,860] 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-06T01:30:38.860898587Z [2024-04-06 01:30:38,860] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-20 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-04-06T01:30:38.860901552Z [2024-04-06 01:30:38,860] INFO [UnifiedLog partition=__consumer_offsets-20, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog) 2024-04-06T01:30:38.860904588Z [2024-04-06 01:30:38,860] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-31 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-04-06T01:30:38.860907736Z [2024-04-06 01:30:38,860] 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-06T01:30:38.860910795Z [2024-04-06 01:30:38,860] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-5 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-04-06T01:30:38.860913962Z [2024-04-06 01:30:38,860] INFO [UnifiedLog partition=__consumer_offsets-5, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog) 2024-04-06T01:30:38.860917111Z [2024-04-06 01:30:38,860] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-2 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-04-06T01:30:38.860928232Z [2024-04-06 01:30:38,860] 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-06T01:30:38.860952066Z [2024-04-06 01:30:38,860] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-46 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-04-06T01:30:38.860955536Z [2024-04-06 01:30:38,860] 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-06T01:30:38.860958923Z [2024-04-06 01:30:38,860] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-35 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-04-06T01:30:39.067619512Z [2024-04-06 01:30:38,860] 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-06T01:30:39.070017561Z [2024-04-06 01:30:39,066] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 48 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.070024767Z [2024-04-06 01:30:39,067] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-48 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.081358856Z [2024-04-06 01:30:39,076] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-48 in 7 milliseconds for epoch 0, of which 3 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.081379130Z [2024-04-06 01:30:39,077] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 13 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.081383432Z [2024-04-06 01:30:39,077] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-13 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.086173885Z [2024-04-06 01:30:39,080] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-13 in 3 milliseconds for epoch 0, of which 3 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.086184445Z [2024-04-06 01:30:39,080] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 45 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.086188303Z [2024-04-06 01:30:39,080] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-45 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.086191609Z [2024-04-06 01:30:39,081] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-45 in 1 milliseconds for epoch 0, of which 1 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.086194895Z [2024-04-06 01:30:39,081] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 11 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.086198146Z [2024-04-06 01:30:39,081] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-11 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.086201650Z [2024-04-06 01:30:39,081] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-11 in 0 milliseconds for epoch 0, of which 0 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.086234929Z [2024-04-06 01:30:39,081] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 43 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.086238570Z [2024-04-06 01:30:39,081] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-43 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.086241938Z [2024-04-06 01:30:39,081] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 41 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.086245039Z [2024-04-06 01:30:39,081] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-41 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.086248158Z [2024-04-06 01:30:39,081] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 23 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.086251372Z [2024-04-06 01:30:39,081] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-23 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.086254447Z [2024-04-06 01:30:39,081] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 17 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.086257786Z [2024-04-06 01:30:39,081] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-17 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.086261114Z [2024-04-06 01:30:39,081] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 18 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.086264180Z [2024-04-06 01:30:39,081] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-18 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.086267354Z [2024-04-06 01:30:39,081] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 32 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.086270310Z [2024-04-06 01:30:39,081] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-32 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.086273632Z [2024-04-06 01:30:39,081] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 28 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.086276642Z [2024-04-06 01:30:39,081] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-28 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.086282330Z [2024-04-06 01:30:39,081] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 26 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.086285567Z [2024-04-06 01:30:39,081] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-26 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.086288712Z [2024-04-06 01:30:39,081] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 6 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.086292078Z [2024-04-06 01:30:39,081] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-6 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.086305061Z [2024-04-06 01:30:39,081] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 3 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.086315220Z [2024-04-06 01:30:39,081] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-3 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.086318709Z [2024-04-06 01:30:39,081] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 36 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.086321814Z [2024-04-06 01:30:39,081] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-36 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.086324981Z [2024-04-06 01:30:39,081] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 1 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.086328154Z [2024-04-06 01:30:39,081] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-1 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.086331487Z [2024-04-06 01:30:39,081] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 34 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.086334675Z [2024-04-06 01:30:39,081] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-34 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.086337867Z [2024-04-06 01:30:39,083] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-43 in 2 milliseconds for epoch 0, of which 1 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.086341167Z [2024-04-06 01:30:39,083] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-41 in 2 milliseconds for epoch 0, of which 2 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.086344351Z [2024-04-06 01:30:39,083] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-23 in 2 milliseconds for epoch 0, of which 2 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.086347488Z [2024-04-06 01:30:39,083] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-17 in 2 milliseconds for epoch 0, of which 2 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.086353801Z [2024-04-06 01:30:39,084] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-18 in 3 milliseconds for epoch 0, of which 2 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.086357101Z [2024-04-06 01:30:39,084] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-32 in 3 milliseconds for epoch 0, of which 3 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.086360191Z [2024-04-06 01:30:39,084] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-28 in 3 milliseconds for epoch 0, of which 3 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.086364810Z [2024-04-06 01:30:39,084] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-26 in 3 milliseconds for epoch 0, of which 3 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.086376136Z [2024-04-06 01:30:39,084] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-6 in 3 milliseconds for epoch 0, of which 3 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.086379344Z [2024-04-06 01:30:39,084] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-3 in 3 milliseconds for epoch 0, of which 3 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.086382637Z [2024-04-06 01:30:39,084] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-36 in 3 milliseconds for epoch 0, of which 3 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.086385652Z [2024-04-06 01:30:39,084] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-1 in 3 milliseconds for epoch 0, of which 3 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.086388797Z [2024-04-06 01:30:39,084] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-34 in 3 milliseconds for epoch 0, of which 3 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.097307770Z [2024-04-06 01:30:39,094] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 15 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.106887587Z [2024-04-06 01:30:39,098] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-15 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.113216093Z [2024-04-06 01:30:39,110] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-15 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.113225429Z [2024-04-06 01:30:39,111] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 46 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.113230493Z [2024-04-06 01:30:39,111] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-46 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.113235088Z [2024-04-06 01:30:39,111] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 44 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.113239823Z [2024-04-06 01:30:39,111] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-44 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.113244187Z [2024-04-06 01:30:39,111] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 9 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.113248559Z [2024-04-06 01:30:39,111] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-9 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.113252869Z [2024-04-06 01:30:39,111] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 42 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.113258045Z [2024-04-06 01:30:39,111] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-42 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.113275228Z [2024-04-06 01:30:39,111] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 21 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.115040830Z [2024-04-06 01:30:39,112] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-46 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.115054829Z [2024-04-06 01:30:39,112] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-44 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.115063019Z [2024-04-06 01:30:39,112] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-9 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.115066373Z [2024-04-06 01:30:39,112] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-42 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.115070061Z [2024-04-06 01:30:39,112] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-21 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.115073737Z [2024-04-06 01:30:39,112] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 19 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.115076821Z [2024-04-06 01:30:39,112] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-19 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.115080056Z [2024-04-06 01:30:39,112] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 30 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.115083140Z [2024-04-06 01:30:39,112] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-30 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.115086407Z [2024-04-06 01:30:39,112] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 7 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.115089422Z [2024-04-06 01:30:39,112] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-7 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.115092447Z [2024-04-06 01:30:39,112] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 40 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.115095349Z [2024-04-06 01:30:39,112] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-40 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.115098688Z [2024-04-06 01:30:39,112] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 5 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.115101582Z [2024-04-06 01:30:39,112] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-5 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.115104512Z [2024-04-06 01:30:39,112] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 38 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.115107631Z [2024-04-06 01:30:39,112] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-38 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.115125608Z [2024-04-06 01:30:39,112] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 47 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.115128805Z [2024-04-06 01:30:39,112] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-47 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.115131795Z [2024-04-06 01:30:39,112] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 16 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.115134749Z [2024-04-06 01:30:39,112] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-16 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.115140772Z [2024-04-06 01:30:39,112] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 14 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.115143983Z [2024-04-06 01:30:39,112] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-14 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.115146955Z [2024-04-06 01:30:39,112] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 12 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.115150009Z [2024-04-06 01:30:39,112] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-12 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.115153075Z [2024-04-06 01:30:39,112] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 10 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.115156131Z [2024-04-06 01:30:39,112] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-10 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.115159100Z [2024-04-06 01:30:39,112] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 24 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.115162108Z [2024-04-06 01:30:39,112] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-24 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.115165269Z [2024-04-06 01:30:39,112] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 22 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.115168500Z [2024-04-06 01:30:39,112] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-22 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.115171413Z [2024-04-06 01:30:39,112] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 20 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.115174701Z [2024-04-06 01:30:39,112] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-20 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.115177744Z [2024-04-06 01:30:39,112] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 49 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.115180674Z [2024-04-06 01:30:39,112] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-49 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.115184105Z [2024-04-06 01:30:39,112] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 31 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.115194393Z [2024-04-06 01:30:39,112] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-31 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.115198847Z [2024-04-06 01:30:39,112] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 0 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.115203238Z [2024-04-06 01:30:39,112] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-0 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.115208555Z [2024-04-06 01:30:39,112] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 29 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.115212820Z [2024-04-06 01:30:39,112] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-29 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.115217496Z [2024-04-06 01:30:39,112] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 27 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.115221840Z [2024-04-06 01:30:39,112] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-27 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.115228547Z [2024-04-06 01:30:39,112] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 25 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.115232881Z [2024-04-06 01:30:39,113] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-25 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.115237492Z [2024-04-06 01:30:39,113] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 39 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.115242143Z [2024-04-06 01:30:39,113] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-39 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.115246551Z [2024-04-06 01:30:39,113] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 8 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.115250764Z [2024-04-06 01:30:39,113] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-8 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.115255445Z [2024-04-06 01:30:39,113] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 37 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.115260018Z [2024-04-06 01:30:39,113] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-37 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.115264502Z [2024-04-06 01:30:39,113] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 35 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.115267929Z [2024-04-06 01:30:39,113] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-35 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.115271289Z [2024-04-06 01:30:39,113] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 4 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.115282734Z [2024-04-06 01:30:39,113] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-4 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.115285836Z [2024-04-06 01:30:39,113] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 33 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.115288807Z [2024-04-06 01:30:39,113] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-33 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.115291850Z [2024-04-06 01:30:39,113] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 2 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.115294854Z [2024-04-06 01:30:39,113] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-2 (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.126246440Z [2024-04-06 01:30:39,122] INFO [DynamicConfigPublisher broker id=1] Updating topic __consumer_offsets with new configuration : cleanup.policy -> compact,segment.bytes -> 104857600,compression.type -> producer (kafka.server.metadata.DynamicConfigPublisher) 2024-04-06T01:30:39.126254092Z [2024-04-06 01:30:39,124] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-21 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.131070031Z [2024-04-06 01:30:39,130] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-19 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.145422775Z [2024-04-06 01:30:39,143] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-30 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.145466610Z [2024-04-06 01:30:39,143] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-7 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.145470069Z [2024-04-06 01:30:39,143] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-40 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.145473596Z [2024-04-06 01:30:39,143] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-5 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.145476879Z [2024-04-06 01:30:39,143] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-38 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.145480080Z [2024-04-06 01:30:39,143] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-47 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.145483406Z [2024-04-06 01:30:39,143] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-16 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.145486493Z [2024-04-06 01:30:39,143] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-14 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.145504082Z [2024-04-06 01:30:39,143] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-12 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.145507585Z [2024-04-06 01:30:39,143] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-10 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.145510549Z [2024-04-06 01:30:39,143] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-24 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.145530189Z [2024-04-06 01:30:39,143] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-22 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.145533342Z [2024-04-06 01:30:39,143] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-20 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.145536311Z [2024-04-06 01:30:39,143] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-49 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.145539451Z [2024-04-06 01:30:39,143] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-31 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.145542406Z [2024-04-06 01:30:39,143] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-0 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.145545461Z [2024-04-06 01:30:39,143] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-29 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.145550072Z [2024-04-06 01:30:39,143] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-27 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.145553238Z [2024-04-06 01:30:39,143] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-25 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.145556501Z [2024-04-06 01:30:39,143] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-39 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.145559391Z [2024-04-06 01:30:39,143] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-8 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.145562457Z [2024-04-06 01:30:39,143] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-37 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.145571812Z [2024-04-06 01:30:39,143] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-35 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.145583560Z [2024-04-06 01:30:39,143] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-4 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.145586636Z [2024-04-06 01:30:39,143] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-33 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.145589774Z [2024-04-06 01:30:39,143] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-2 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-04-06T01:30:39.194228144Z [2024-04-06 01:30:39,188] INFO [GroupCoordinator 1]: Dynamic Member with unknown member id joins group mon-consumer in Empty state. Created a new member id aiokafka-0.8.1-7893282c-7a34-46c2-9aea-d7092943d786 for this member and add to the group. (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:39.238067381Z [2024-04-06 01:30:39,235] INFO [GroupCoordinator 1]: Preparing to rebalance group mon-consumer in state PreparingRebalance with old generation 0 (__consumer_offsets-3) (reason: Adding new member aiokafka-0.8.1-7893282c-7a34-46c2-9aea-d7092943d786 with group instance id None; client reason: not provided) (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:40.317167711Z [2024-04-06 01:30:40,314] INFO Sent auto-creation request for Set(admin) to the active controller. (kafka.server.DefaultAutoTopicCreationManager) 2024-04-06T01:30:40.320386280Z [2024-04-06 01:30:40,319] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='admin', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:40.324193211Z [2024-04-06 01:30:40,322] INFO [QuorumController id=1] Created topic admin with topic ID DvdVSczITgisbqV6orc1Ag. (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:40.328123398Z [2024-04-06 01:30:40,325] INFO [QuorumController id=1] Created partition admin-0 with topic ID DvdVSczITgisbqV6orc1Ag and PartitionRegistration(replicas=[0], isr=[0], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:40.467511879Z [2024-04-06 01:30:40,465] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='admin', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'admin' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:40.698221620Z [2024-04-06 01:30:40,697] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='ns', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:40.702732158Z [2024-04-06 01:30:40,702] INFO [QuorumController id=1] Created topic ns with topic ID kY-epoZpSFu4iYEGsYLsHA. (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:40.702763279Z [2024-04-06 01:30:40,702] INFO [QuorumController id=1] Created partition ns-0 with topic ID kY-epoZpSFu4iYEGsYLsHA and PartitionRegistration(replicas=[2], isr=[2], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:40.865228629Z [2024-04-06 01:30:40,862] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='ns', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'ns' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:40.962071940Z [2024-04-06 01:30:40,960] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='ns', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'ns' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:41.185938024Z [2024-04-06 01:30:41,181] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='nsi', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:41.185949920Z [2024-04-06 01:30:41,181] INFO [QuorumController id=1] Created topic nsi with topic ID cmP-g4LLQveRIEy5RUWaiA. (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:41.185953319Z [2024-04-06 01:30:41,181] INFO [QuorumController id=1] Created partition nsi-0 with topic ID cmP-g4LLQveRIEy5RUWaiA and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:41.223061033Z [2024-04-06 01:30:41,222] INFO [Broker id=1] Transitioning 1 partition(s) to local leaders. (state.change.logger) 2024-04-06T01:30:41.226965779Z [2024-04-06 01:30:41,226] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions Set(nsi-0) (kafka.server.ReplicaFetcherManager) 2024-04-06T01:30:41.226975813Z [2024-04-06 01:30:41,226] INFO [Broker id=1] Creating new partition nsi-0 with topic id cmP-g4LLQveRIEy5RUWaiA. (state.change.logger) 2024-04-06T01:30:41.229507847Z [2024-04-06 01:30:41,229] 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-06T01:30:41.242306138Z [2024-04-06 01:30:41,242] INFO Created log for partition nsi-0 in /bitnami/kafka/data/nsi-0 with properties {} (kafka.log.LogManager) 2024-04-06T01:30:41.249787303Z [2024-04-06 01:30:41,243] INFO [Partition nsi-0 broker=1] No checkpointed highwatermark is found for partition nsi-0 (kafka.cluster.Partition) 2024-04-06T01:30:41.249807568Z [2024-04-06 01:30:41,249] INFO [Partition nsi-0 broker=1] Log loaded for partition nsi-0 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:41.249829109Z [2024-04-06 01:30:41,249] INFO [Broker id=1] Leader nsi-0 with topic id Some(cmP-g4LLQveRIEy5RUWaiA) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:41.302633386Z [2024-04-06 01:30:41,302] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='nsi', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'nsi' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:41.474480125Z [2024-04-06 01:30:41,474] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='vnf', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:41.474707153Z [2024-04-06 01:30:41,474] INFO [QuorumController id=1] Created topic vnf with topic ID wUSGyiziSou7gOVqGdMKjQ. (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:41.476733921Z [2024-04-06 01:30:41,476] INFO [QuorumController id=1] Created partition vnf-0 with topic ID wUSGyiziSou7gOVqGdMKjQ and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:41.541026522Z [2024-04-06 01:30:41,538] INFO [Broker id=1] Transitioning 1 partition(s) to local leaders. (state.change.logger) 2024-04-06T01:30:41.541044256Z [2024-04-06 01:30:41,538] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions Set(vnf-0) (kafka.server.ReplicaFetcherManager) 2024-04-06T01:30:41.541048261Z [2024-04-06 01:30:41,538] INFO [Broker id=1] Creating new partition vnf-0 with topic id wUSGyiziSou7gOVqGdMKjQ. (state.change.logger) 2024-04-06T01:30:41.544135594Z [2024-04-06 01:30:41,544] INFO [LogLoader partition=vnf-0, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) 2024-04-06T01:30:41.544588099Z [2024-04-06 01:30:41,544] INFO Created log for partition vnf-0 in /bitnami/kafka/data/vnf-0 with properties {} (kafka.log.LogManager) 2024-04-06T01:30:41.559065414Z [2024-04-06 01:30:41,557] INFO [Partition vnf-0 broker=1] No checkpointed highwatermark is found for partition vnf-0 (kafka.cluster.Partition) 2024-04-06T01:30:41.559082046Z [2024-04-06 01:30:41,557] INFO [Partition vnf-0 broker=1] Log loaded for partition vnf-0 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:41.559086495Z [2024-04-06 01:30:41,557] INFO [Broker id=1] Leader vnf-0 with topic id Some(wUSGyiziSou7gOVqGdMKjQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:42.256138171Z [2024-04-06 01:30:42,255] INFO [GroupCoordinator 1]: Stabilized group mon-consumer generation 1 (__consumer_offsets-3) with 1 members (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:42.283987647Z [2024-04-06 01:30:42,283] INFO [GroupCoordinator 1]: Assignment received from leader aiokafka-0.8.1-7893282c-7a34-46c2-9aea-d7092943d786 for group mon-consumer for generation 1. The group has 1 members, 0 of which are static. (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:53.613697601Z [2024-04-06 01:30:53,613] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='nslcmops', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS, CreatableTopic(name='vca', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS, CreatableTopic(name='k8scluster', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS, CreatableTopic(name='k8srepo', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS, CreatableTopic(name='pla', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:53.621648244Z [2024-04-06 01:30:53,621] INFO [QuorumController id=1] Created topic nslcmops with topic ID FlWOosHmSpOyq-mPvOs9QA. (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:53.643794772Z [2024-04-06 01:30:53,623] INFO [GroupCoordinator 1]: Dynamic Member with unknown member id joins group lcm-server in Empty state. Created a new member id aiokafka-0.8.1-bf5e86d5-0a97-412c-8a04-7aac0092f335 for this member and add to the group. (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:53.643806325Z [2024-04-06 01:30:53,642] INFO [GroupCoordinator 1]: Preparing to rebalance group lcm-server in state PreparingRebalance with old generation 0 (__consumer_offsets-32) (reason: Adding new member aiokafka-0.8.1-bf5e86d5-0a97-412c-8a04-7aac0092f335 with group instance id None; client reason: not provided) (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:53.643809957Z [2024-04-06 01:30:53,643] INFO [QuorumController id=1] Created partition nslcmops-0 with topic ID FlWOosHmSpOyq-mPvOs9QA and PartitionRegistration(replicas=[0], isr=[0], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:53.643824553Z [2024-04-06 01:30:53,643] INFO [QuorumController id=1] Created topic vca with topic ID LXZULCg1T1atq2sfUnJIKA. (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:53.643829850Z [2024-04-06 01:30:53,643] INFO [QuorumController id=1] Created partition vca-0 with topic ID LXZULCg1T1atq2sfUnJIKA and PartitionRegistration(replicas=[0], isr=[0], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:53.645991726Z [2024-04-06 01:30:53,643] INFO [QuorumController id=1] Created topic k8scluster with topic ID 2rysMKebQKiy8QMIcGbXxw. (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:53.646003305Z [2024-04-06 01:30:53,644] INFO [QuorumController id=1] Created partition k8scluster-0 with topic ID 2rysMKebQKiy8QMIcGbXxw and PartitionRegistration(replicas=[2], isr=[2], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:53.646006484Z [2024-04-06 01:30:53,644] INFO [QuorumController id=1] Created topic k8srepo with topic ID akbjli4YT8OlK3HlCx__ZQ. (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:53.646009481Z [2024-04-06 01:30:53,644] INFO [QuorumController id=1] Created partition k8srepo-0 with topic ID akbjli4YT8OlK3HlCx__ZQ and PartitionRegistration(replicas=[0], isr=[0], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:53.646012650Z [2024-04-06 01:30:53,644] INFO [QuorumController id=1] Created topic pla with topic ID QoS3WQBiTPaed3zG-fepvQ. (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:53.646015796Z [2024-04-06 01:30:53,644] INFO [QuorumController id=1] Created partition pla-0 with topic ID QoS3WQBiTPaed3zG-fepvQ and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:30:53.699339591Z [2024-04-06 01:30:53,698] INFO [Broker id=1] Transitioning 1 partition(s) to local leaders. (state.change.logger) 2024-04-06T01:30:53.700861373Z [2024-04-06 01:30:53,700] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions Set(pla-0) (kafka.server.ReplicaFetcherManager) 2024-04-06T01:30:53.701182842Z [2024-04-06 01:30:53,701] INFO [Broker id=1] Creating new partition pla-0 with topic id QoS3WQBiTPaed3zG-fepvQ. (state.change.logger) 2024-04-06T01:30:53.706089596Z [2024-04-06 01:30:53,704] 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-06T01:30:53.706103268Z [2024-04-06 01:30:53,704] INFO Created log for partition pla-0 in /bitnami/kafka/data/pla-0 with properties {} (kafka.log.LogManager) 2024-04-06T01:30:53.706106563Z [2024-04-06 01:30:53,705] INFO [Partition pla-0 broker=1] No checkpointed highwatermark is found for partition pla-0 (kafka.cluster.Partition) 2024-04-06T01:30:53.706194913Z [2024-04-06 01:30:53,706] INFO [Partition pla-0 broker=1] Log loaded for partition pla-0 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:30:53.706444573Z [2024-04-06 01:30:53,706] INFO [Broker id=1] Leader pla-0 with topic id Some(QoS3WQBiTPaed3zG-fepvQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:30:56.644249596Z [2024-04-06 01:30:56,644] INFO [GroupCoordinator 1]: Stabilized group lcm-server generation 1 (__consumer_offsets-32) with 1 members (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:30:56.662233237Z [2024-04-06 01:30:56,662] INFO [GroupCoordinator 1]: Assignment received from leader aiokafka-0.8.1-bf5e86d5-0a97-412c-8a04-7aac0092f335 for group lcm-server for generation 1. The group has 1 members, 0 of which are static. (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:31:01.793534450Z [2024-04-06 01:31:01,792] INFO [GroupCoordinator 1]: Dynamic Member with unknown member id joins group nbi-server in Empty state. Created a new member id aiokafka-0.8.1-7392d836-fe45-4b93-807d-b7bda60d95f7 for this member and add to the group. (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:31:01.798876928Z [2024-04-06 01:31:01,798] INFO [GroupCoordinator 1]: Preparing to rebalance group nbi-server in state PreparingRebalance with old generation 0 (__consumer_offsets-23) (reason: Adding new member aiokafka-0.8.1-7392d836-fe45-4b93-807d-b7bda60d95f7 with group instance id None; client reason: not provided) (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:31:04.805085616Z [2024-04-06 01:31:04,804] INFO [GroupCoordinator 1]: Stabilized group nbi-server generation 1 (__consumer_offsets-23) with 1 members (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:31:04.809894499Z [2024-04-06 01:31:04,809] INFO [GroupCoordinator 1]: Assignment received from leader aiokafka-0.8.1-7392d836-fe45-4b93-807d-b7bda60d95f7 for group nbi-server for generation 1. The group has 1 members, 0 of which are static. (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:35:54.084358802Z [2024-04-06 01:35:54,083] INFO [GroupCoordinator 1]: Preparing to rebalance group lcm-server in state PreparingRebalance with old generation 1 (__consumer_offsets-32) (reason: Leader aiokafka-0.8.1-bf5e86d5-0a97-412c-8a04-7aac0092f335 re-joining group during Stable; client reason: not provided) (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:35:54.086509186Z [2024-04-06 01:35:54,086] INFO [GroupCoordinator 1]: Stabilized group lcm-server generation 2 (__consumer_offsets-32) with 1 members (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:35:54.091062842Z [2024-04-06 01:35:54,090] INFO [GroupCoordinator 1]: Assignment received from leader aiokafka-0.8.1-bf5e86d5-0a97-412c-8a04-7aac0092f335 for group lcm-server for generation 2. The group has 1 members, 0 of which are static. (kafka.coordinator.group.GroupCoordinator) 2024-04-06T01:38:06.992127211Z [2024-04-06 01:38:06,991] INFO Sent auto-creation request for Set(vnfd) to the active controller. (kafka.server.DefaultAutoTopicCreationManager) 2024-04-06T01:38:07.004172066Z [2024-04-06 01:38:07,003] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='vnfd', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:38:07.006922134Z [2024-04-06 01:38:07,006] INFO [QuorumController id=1] Created topic vnfd with topic ID 4ByktkNXQGaqItpCIB-Xuw. (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:38:07.007992427Z [2024-04-06 01:38:07,007] INFO [QuorumController id=1] Created partition vnfd-0 with topic ID 4ByktkNXQGaqItpCIB-Xuw and PartitionRegistration(replicas=[2], isr=[2], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:38:07.128509369Z [2024-04-06 01:38:07,128] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='vnfd', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'vnfd' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:38:09.667891390Z [2024-04-06 01:38:09,667] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='nsd', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:38:09.668163278Z [2024-04-06 01:38:09,668] INFO [QuorumController id=1] Created topic nsd with topic ID TfkON65nTg6N5o5OPU-GLA. (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:38:09.668567877Z [2024-04-06 01:38:09,668] INFO [QuorumController id=1] Created partition nsd-0 with topic ID TfkON65nTg6N5o5OPU-GLA and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:38:09.703283347Z [2024-04-06 01:38:09,703] INFO [Broker id=1] Transitioning 1 partition(s) to local leaders. (state.change.logger) 2024-04-06T01:38:09.704126971Z [2024-04-06 01:38:09,704] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions Set(nsd-0) (kafka.server.ReplicaFetcherManager) 2024-04-06T01:38:09.704193730Z [2024-04-06 01:38:09,704] INFO [Broker id=1] Creating new partition nsd-0 with topic id TfkON65nTg6N5o5OPU-GLA. (state.change.logger) 2024-04-06T01:38:09.709373405Z [2024-04-06 01:38:09,709] INFO [LogLoader partition=nsd-0, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) 2024-04-06T01:38:09.710138082Z [2024-04-06 01:38:09,710] INFO Created log for partition nsd-0 in /bitnami/kafka/data/nsd-0 with properties {} (kafka.log.LogManager) 2024-04-06T01:38:09.712227133Z [2024-04-06 01:38:09,712] INFO [Partition nsd-0 broker=1] No checkpointed highwatermark is found for partition nsd-0 (kafka.cluster.Partition) 2024-04-06T01:38:09.712243421Z [2024-04-06 01:38:09,712] INFO [Partition nsd-0 broker=1] Log loaded for partition nsd-0 with initial high watermark 0 (kafka.cluster.Partition) 2024-04-06T01:38:09.712372447Z [2024-04-06 01:38:09,712] INFO [Broker id=1] Leader nsd-0 with topic id Some(TfkON65nTg6N5o5OPU-GLA) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-04-06T01:38:09.771220109Z [2024-04-06 01:38:09,771] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='nsd', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'nsd' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T01:39:19.310908186Z [2024-04-06 01:39:19,310] INFO [RaftManager id=1] Node 2 disconnected. (org.apache.kafka.clients.NetworkClient) 2024-04-06T01:48:07.235114507Z [2024-04-06 01:48:07,234] INFO [BrokerToControllerChannelManager id=1 name=forwarding] Node 1 disconnected. (org.apache.kafka.clients.NetworkClient) 2024-04-06T02:29:20.308954682Z [2024-04-06 02:29:20,307] INFO [SnapshotGenerator id=1] Creating new KRaft snapshot file snapshot 00000000000000007290-0000000026 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator) 2024-04-06T02:29:20.335344670Z [2024-04-06 02:29:20,335] INFO [SnapshotEmitter id=1] Successfully wrote snapshot 00000000000000007290-0000000026 (org.apache.kafka.image.publisher.SnapshotEmitter) 2024-04-06T03:29:20.622278390Z [2024-04-06 03:29:20,621] INFO [SnapshotGenerator id=1] Creating new KRaft snapshot file snapshot 00000000000000014482-0000000026 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator) 2024-04-06T03:29:20.630241952Z [2024-04-06 03:29:20,630] INFO [SnapshotEmitter id=1] Successfully wrote snapshot 00000000000000014482-0000000026 (org.apache.kafka.image.publisher.SnapshotEmitter) 2024-04-06T03:45:23.591605994Z [2024-04-06 03:45:23,591] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='nst', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T03:45:23.592190667Z [2024-04-06 03:45:23,592] INFO [QuorumController id=1] Created topic nst with topic ID VkM0seQrQlucXB4zSNZSDQ. (org.apache.kafka.controller.ReplicationControlManager) 2024-04-06T03:45:23.592500190Z [2024-04-06 03:45:23,592] INFO [QuorumController id=1] Created partition nst-0 with topic ID VkM0seQrQlucXB4zSNZSDQ and PartitionRegistration(replicas=[2], isr=[2], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)