2024-06-28T07:03:12.391124828Z kafka 07:03:12.38  2024-06-28T07:03:12.395180932Z kafka 07:03:12.39 Welcome to the Bitnami kafka container 2024-06-28T07:03:12.400147198Z kafka 07:03:12.39 Subscribe to project updates by watching https://github.com/bitnami/containers 2024-06-28T07:03:12.404020713Z kafka 07:03:12.40 Submit issues and feature requests at https://github.com/bitnami/containers/issues 2024-06-28T07:03:12.412159930Z kafka 07:03:12.40  2024-06-28T07:03:12.416505367Z kafka 07:03:12.41 INFO  ==> ** Starting Kafka setup ** 2024-06-28T07:03:12.695911159Z kafka 07:03:12.69 INFO  ==> Initializing KRaft storage metadata 2024-06-28T07:03:12.695929598Z kafka 07:03:12.69 INFO  ==> Adding KRaft SCRAM users at storage bootstrap 2024-06-28T07:03:12.779573026Z kafka 07:03:12.76 INFO  ==> Formatting storage directories to add metadata... 2024-06-28T07:03:17.840596288Z Formatting /bitnami/kafka/data with metadata.version 3.5-IV2. 2024-06-28T07:03:18.313358495Z kafka 07:03:18.30 INFO  ==> ** Kafka setup finished! ** 2024-06-28T07:03:18.313419577Z 2024-06-28T07:03:18.388022345Z kafka 07:03:18.38 INFO  ==> ** Starting Kafka ** 2024-06-28T07:03:22.280212910Z [2024-06-28 07:03:22,279] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$) 2024-06-28T07:03:23.934578700Z [2024-06-28 07:03:23,933] INFO Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation (org.apache.zookeeper.common.X509Util) 2024-06-28T07:03:25.259608136Z [2024-06-28 07:03:25,258] INFO Registered signal handlers for TERM, INT, HUP (org.apache.kafka.common.utils.LoggingSignalHandler) 2024-06-28T07:03:25.263445458Z [2024-06-28 07:03:25,262] INFO [ControllerServer id=2] Starting controller (kafka.server.ControllerServer) 2024-06-28T07:03:26.808625372Z [2024-06-28 07:03:26,803] INFO Updated connection-accept-rate max connection creation rate to 2147483647 (kafka.network.ConnectionQuotas) 2024-06-28T07:03:27.071917098Z [2024-06-28 07:03:27,068] INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin) 2024-06-28T07:03:27.114101833Z [2024-06-28 07:03:27,106] INFO [SocketServer listenerType=CONTROLLER, nodeId=2] Created data-plane acceptor and processors for endpoint : ListenerName(CONTROLLER) (kafka.network.SocketServer) 2024-06-28T07:03:27.120240212Z [2024-06-28 07:03:27,119] INFO [SharedServer id=2] Starting SharedServer (kafka.server.SharedServer) 2024-06-28T07:03:27.350485046Z [2024-06-28 07:03:27,349] 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-06-28T07:03:27.351020594Z [2024-06-28 07:03:27,350] 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-06-28T07:03:27.351096438Z [2024-06-28 07:03:27,351] 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-06-28T07:03:27.403882266Z [2024-06-28 07:03:27,402] INFO Initialized snapshots with IDs Set() from /bitnami/kafka/data/__cluster_metadata-0 (kafka.raft.KafkaMetadataLog$) 2024-06-28T07:03:27.534293930Z [2024-06-28 07:03:27,532] INFO [raft-expiration-reaper]: Starting (kafka.raft.TimingWheelExpirationService$ExpiredOperationReaper) 2024-06-28T07:03:27.737556596Z [2024-06-28 07:03:27,737] INFO [RaftManager id=2] Completed transition to Unattached(epoch=0, voters=[0, 1, 2], electionTimeoutMs=1990) from null (org.apache.kafka.raft.QuorumState) 2024-06-28T07:03:27.759621434Z [2024-06-28 07:03:27,749] INFO [kafka-2-raft-outbound-request-thread]: Starting (kafka.raft.RaftSendThread) 2024-06-28T07:03:27.759639823Z [2024-06-28 07:03:27,750] INFO [kafka-2-raft-io-thread]: Starting (kafka.raft.KafkaRaftManager$RaftIoThread) 2024-06-28T07:03:27.799715214Z [2024-06-28 07:03:27,798] INFO [ControllerServer id=2] Waiting for controller quorum voters future (kafka.server.ControllerServer) 2024-06-28T07:03:27.799723356Z [2024-06-28 07:03:27,798] INFO [ControllerServer id=2] Finished waiting for controller quorum voters future (kafka.server.ControllerServer) 2024-06-28T07:03:27.801714863Z [2024-06-28 07:03:27,800] INFO [RaftManager id=2] Registered the listener org.apache.kafka.image.loader.MetadataLoader@1471962541 (org.apache.kafka.raft.KafkaRaftClient) 2024-06-28T07:03:27.805099621Z [2024-06-28 07:03:27,802] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-06-28T07:03:27.852967601Z [2024-06-28 07:03:27,852] INFO [QuorumController id=2] Creating new QuorumController with clusterId g5twc58UcALxaneOhOSN9w, authorizer Optional.empty. (org.apache.kafka.controller.QuorumController) 2024-06-28T07:03:27.860291019Z [2024-06-28 07:03:27,853] INFO [RaftManager id=2] Registered the listener org.apache.kafka.controller.QuorumController$QuorumMetaLogListener@690301960 (org.apache.kafka.raft.KafkaRaftClient) 2024-06-28T07:03:27.867943223Z [2024-06-28 07:03:27,867] INFO [controller-2-ThrottledChannelReaper-Fetch]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) 2024-06-28T07:03:27.881917081Z [2024-06-28 07:03:27,878] INFO [controller-2-ThrottledChannelReaper-Produce]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) 2024-06-28T07:03:27.881931485Z [2024-06-28 07:03:27,879] INFO [controller-2-ThrottledChannelReaper-ControllerMutation]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) 2024-06-28T07:03:27.887893322Z [2024-06-28 07:03:27,887] INFO [controller-2-ThrottledChannelReaper-Request]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) 2024-06-28T07:03:27.902736912Z [2024-06-28 07:03:27,902] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-06-28T07:03:27.904447536Z [2024-06-28 07:03:27,904] INFO [ExpirationReaper-2-AlterAcls]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) 2024-06-28T07:03:27.919918267Z [2024-06-28 07:03:27,918] INFO [SocketServer listenerType=CONTROLLER, nodeId=2] Enabling request processing. (kafka.network.SocketServer) 2024-06-28T07:03:27.923379561Z [2024-06-28 07:03:27,923] INFO Awaiting socket connections on 0.0.0.0:9093. (kafka.network.DataPlaneAcceptor) 2024-06-28T07:03:27.947595502Z [2024-06-28 07:03:27,946] INFO [ControllerServer id=2] Waiting for all of the authorizer futures to be completed (kafka.server.ControllerServer) 2024-06-28T07:03:27.954564467Z [2024-06-28 07:03:27,952] INFO [ControllerServer id=2] Finished waiting for all of the authorizer futures to be completed (kafka.server.ControllerServer) 2024-06-28T07:03:27.954576651Z [2024-06-28 07:03:27,952] INFO [ControllerServer id=2] Waiting for all of the SocketServer Acceptors to be started (kafka.server.ControllerServer) 2024-06-28T07:03:27.954580006Z [2024-06-28 07:03:27,952] INFO [ControllerServer id=2] Finished waiting for all of the SocketServer Acceptors to be started (kafka.server.ControllerServer) 2024-06-28T07:03:27.957195440Z [2024-06-28 07:03:27,956] INFO [ControllerServer id=2] Waiting for the controller metadata publishers to be installed (kafka.server.ControllerServer) 2024-06-28T07:03:27.957229031Z [2024-06-28 07:03:27,957] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-06-28T07:03:27.957237963Z [2024-06-28 07:03:27,957] INFO [ControllerServer id=2] Finished waiting for the controller metadata publishers to be installed (kafka.server.ControllerServer) 2024-06-28T07:03:27.957993189Z [2024-06-28 07:03:27,957] INFO [BrokerServer id=2] Transition from SHUTDOWN to STARTING (kafka.server.BrokerServer) 2024-06-28T07:03:27.958585496Z [2024-06-28 07:03:27,958] INFO [BrokerServer id=2] Starting broker (kafka.server.BrokerServer) 2024-06-28T07:03:28.004592248Z [2024-06-28 07:03:27,998] INFO [broker-2-ThrottledChannelReaper-Fetch]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) 2024-06-28T07:03:28.004621637Z [2024-06-28 07:03:27,999] INFO [broker-2-ThrottledChannelReaper-Request]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) 2024-06-28T07:03:28.011718282Z [2024-06-28 07:03:28,004] INFO [broker-2-ThrottledChannelReaper-Produce]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) 2024-06-28T07:03:28.011730418Z [2024-06-28 07:03:28,007] INFO [broker-2-ThrottledChannelReaper-ControllerMutation]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) 2024-06-28T07:03:28.028950358Z [2024-06-28 07:03:28,028] INFO [BrokerServer id=2] Waiting for controller quorum voters future (kafka.server.BrokerServer) 2024-06-28T07:03:28.028968853Z [2024-06-28 07:03:28,028] INFO [BrokerServer id=2] Finished waiting for controller quorum voters future (kafka.server.BrokerServer) 2024-06-28T07:03:28.059038385Z [2024-06-28 07:03:28,057] INFO [broker-2-to-controller-forwarding-channel-manager]: Starting (kafka.server.BrokerToControllerRequestThread) 2024-06-28T07:03:28.062256199Z [2024-06-28 07:03:28,059] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-06-28T07:03:28.165385498Z [2024-06-28 07:03:28,165] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-06-28T07:03:28.187592053Z [2024-06-28 07:03:28,186] INFO Updated connection-accept-rate max connection creation rate to 2147483647 (kafka.network.ConnectionQuotas) 2024-06-28T07:03:28.230906049Z [2024-06-28 07:03:28,227] INFO [SocketServer listenerType=BROKER, nodeId=2] Created data-plane acceptor and processors for endpoint : ListenerName(CLIENT) (kafka.network.SocketServer) 2024-06-28T07:03:28.230918605Z [2024-06-28 07:03:28,230] INFO Updated connection-accept-rate max connection creation rate to 2147483647 (kafka.network.ConnectionQuotas) 2024-06-28T07:03:28.255612043Z [2024-06-28 07:03:28,251] INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin) 2024-06-28T07:03:28.255632310Z [2024-06-28 07:03:28,253] INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin) 2024-06-28T07:03:28.275720177Z [2024-06-28 07:03:28,263] INFO [SocketServer listenerType=BROKER, nodeId=2] Created data-plane acceptor and processors for endpoint : ListenerName(INTERNAL) (kafka.network.SocketServer) 2024-06-28T07:03:28.275735581Z [2024-06-28 07:03:28,265] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-06-28T07:03:28.307896572Z [2024-06-28 07:03:28,304] INFO [broker-2-to-controller-alter-partition-channel-manager]: Starting (kafka.server.BrokerToControllerRequestThread) 2024-06-28T07:03:28.375649726Z [2024-06-28 07:03:28,373] INFO [ExpirationReaper-2-Produce]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) 2024-06-28T07:03:28.375685139Z [2024-06-28 07:03:28,374] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-06-28T07:03:28.375689544Z [2024-06-28 07:03:28,375] INFO [ExpirationReaper-2-Fetch]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) 2024-06-28T07:03:28.387581167Z [2024-06-28 07:03:28,385] INFO [ExpirationReaper-2-DeleteRecords]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) 2024-06-28T07:03:28.393261477Z [2024-06-28 07:03:28,387] INFO [ExpirationReaper-2-ElectLeader]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) 2024-06-28T07:03:28.399626581Z [2024-06-28 07:03:28,395] INFO [RaftManager id=2] Completed transition to Unattached(epoch=1, voters=[0, 1, 2], electionTimeoutMs=1086) from Unattached(epoch=0, voters=[0, 1, 2], electionTimeoutMs=1990) (org.apache.kafka.raft.QuorumState) 2024-06-28T07:03:28.403626146Z [2024-06-28 07:03:28,398] INFO [QuorumController id=2] In the new epoch 1, the leader is (none). (org.apache.kafka.controller.QuorumController) 2024-06-28T07:03:28.411600856Z [2024-06-28 07:03:28,409] INFO [RaftManager id=2] Completed transition to Voted(epoch=1, votedId=0, voters=[0, 1, 2], electionTimeoutMs=1170) from Unattached(epoch=1, voters=[0, 1, 2], electionTimeoutMs=1086) (org.apache.kafka.raft.QuorumState) 2024-06-28T07:03:28.411616083Z [2024-06-28 07:03:28,410] INFO [RaftManager id=2] Vote request VoteRequestData(clusterId='g5twc58UcALxaneOhOSN9w', topics=[TopicData(topicName='__cluster_metadata', partitions=[PartitionData(partitionIndex=0, candidateEpoch=1, candidateId=0, lastOffsetEpoch=0, lastOffset=0)])]) with epoch 1 is granted (org.apache.kafka.raft.KafkaRaftClient) 2024-06-28T07:03:28.417753455Z [2024-06-28 07:03:28,415] INFO [ExpirationReaper-2-Heartbeat]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) 2024-06-28T07:03:28.505173442Z [2024-06-28 07:03:28,501] INFO [ExpirationReaper-2-Rebalance]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) 2024-06-28T07:03:28.507755906Z [2024-06-28 07:03:28,505] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-06-28T07:03:28.618153115Z [2024-06-28 07:03:28,614] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-06-28T07:03:28.722539772Z [2024-06-28 07:03:28,719] INFO [RaftManager id=2] Completed transition to FollowerState(fetchTimeoutMs=2000, epoch=1, leaderId=0, voters=[0, 1, 2], highWatermark=Optional.empty, fetchingSnapshot=Optional.empty) from Voted(epoch=1, votedId=0, voters=[0, 1, 2], electionTimeoutMs=1170) (org.apache.kafka.raft.QuorumState) 2024-06-28T07:03:28.722556284Z [2024-06-28 07:03:28,720] INFO [QuorumController id=2] In the new epoch 1, the leader is 0. (org.apache.kafka.controller.QuorumController) 2024-06-28T07:03:28.727603195Z [2024-06-28 07:03:28,724] INFO [broker-2-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-06-28T07:03:28.727621329Z [2024-06-28 07:03:28,724] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-06-28T07:03:28.727635333Z [2024-06-28 07:03:28,724] INFO [broker-2-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-06-28T07:03:28.827657792Z [2024-06-28 07:03:28,824] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-06-28T07:03:28.919674477Z [2024-06-28 07:03:28,918] INFO [BrokerLifecycleManager id=2] Incarnation _-LpEd_0SKCXz_wq6JyRsg of broker 2 in cluster g5twc58UcALxaneOhOSN9w is now STARTING. (kafka.server.BrokerLifecycleManager) 2024-06-28T07:03:28.919694393Z [2024-06-28 07:03:28,918] INFO [broker-2-to-controller-heartbeat-channel-manager]: Starting (kafka.server.BrokerToControllerRequestThread) 2024-06-28T07:03:28.919708082Z [2024-06-28 07:03:28,919] INFO [broker-2-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-06-28T07:03:28.930702849Z [2024-06-28 07:03:28,925] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-06-28T07:03:29.029418425Z [2024-06-28 07:03:29,028] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-06-28T07:03:29.055710920Z [2024-06-28 07:03:29,052] INFO [ExpirationReaper-2-AlterAcls]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) 2024-06-28T07:03:29.132320903Z [2024-06-28 07:03:29,129] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-06-28T07:03:29.257002764Z [2024-06-28 07:03:29,242] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-06-28T07:03:29.299659579Z [2024-06-28 07:03:29,299] INFO [MetadataLoader id=2] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-06-28T07:03:29.299895644Z [2024-06-28 07:03:29,299] INFO [BrokerServer id=2] Waiting for the broker metadata publishers to be installed (kafka.server.BrokerServer) 2024-06-28T07:03:29.299908685Z [2024-06-28 07:03:29,299] INFO [BrokerServer id=2] Finished waiting for the broker metadata publishers to be installed (kafka.server.BrokerServer) 2024-06-28T07:03:29.315629836Z [2024-06-28 07:03:29,299] INFO [BrokerServer id=2] Waiting for the controller to acknowledge that we are caught up (kafka.server.BrokerServer) 2024-06-28T07:03:29.332266204Z [2024-06-28 07:03:29,329] INFO [RaftManager id=2] High watermark set to Optional[LogOffsetMetadata(offset=6, metadata=Optional.empty)] for the first time for epoch 1 (org.apache.kafka.raft.FollowerState) 2024-06-28T07:03:29.353320087Z [2024-06-28 07:03:29,352] INFO [QuorumController id=2] Setting metadata version to 3.5-IV2 (org.apache.kafka.controller.FeatureControlManager) 2024-06-28T07:03:29.357715346Z [2024-06-28 07:03:29,356] INFO [QuorumController id=2] Created new SCRAM credential for user with mechanism SCRAM_SHA_256. (org.apache.kafka.controller.ScramControlManager) 2024-06-28T07:03:29.357728740Z [2024-06-28 07:03:29,356] INFO [QuorumController id=2] Created new SCRAM credential for user with mechanism SCRAM_SHA_512. (org.apache.kafka.controller.ScramControlManager) 2024-06-28T07:03:29.363156034Z [2024-06-28 07:03:29,358] INFO [QuorumController id=2] Transitioning ZK migration state from NONE to NONE (org.apache.kafka.controller.FeatureControlManager) 2024-06-28T07:03:29.394166485Z [2024-06-28 07:03:29,393] INFO [QuorumController id=2] Registered new broker: RegisterBrokerRecord(brokerId=0, isMigratingZkBroker=false, incarnationId=ECurlrv2SiKUrPAAEOB5fA, brokerEpoch=4, 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-06-28T07:03:29.395345118Z [2024-06-28 07:03:29,395] INFO [MetadataLoader id=2] handleCommit: The loader finished catching up to the current high water mark of 6 (org.apache.kafka.image.loader.MetadataLoader) 2024-06-28T07:03:29.401021070Z [2024-06-28 07:03:29,400] INFO [BrokerLifecycleManager id=2] Successfully registered broker 2 with broker epoch 7 (kafka.server.BrokerLifecycleManager) 2024-06-28T07:03:29.409368756Z [2024-06-28 07:03:29,407] INFO [MetadataLoader id=2] InitializeNewPublishers: initializing SnapshotGenerator with a snapshot at offset 5 (org.apache.kafka.image.loader.MetadataLoader) 2024-06-28T07:03:29.410528170Z [2024-06-28 07:03:29,409] INFO [MetadataLoader id=2] InitializeNewPublishers: initializing DynamicConfigPublisher controller id=2 with a snapshot at offset 5 (org.apache.kafka.image.loader.MetadataLoader) 2024-06-28T07:03:29.456544142Z [2024-06-28 07:03:29,437] INFO [MetadataLoader id=2] InitializeNewPublishers: initializing DynamicClientQuotaPublisher controller id=2 with a snapshot at offset 5 (org.apache.kafka.image.loader.MetadataLoader) 2024-06-28T07:03:29.456576860Z [2024-06-28 07:03:29,438] INFO [MetadataLoader id=2] InitializeNewPublishers: initializing ScramPublisher controller id=2 with a snapshot at offset 5 (org.apache.kafka.image.loader.MetadataLoader) 2024-06-28T07:03:29.456580497Z [2024-06-28 07:03:29,438] INFO [MetadataLoader id=2] InitializeNewPublishers: initializing ControllerMetadataMetricsPublisher with a snapshot at offset 5 (org.apache.kafka.image.loader.MetadataLoader) 2024-06-28T07:03:29.456584450Z [2024-06-28 07:03:29,439] INFO [MetadataLoader id=2] InitializeNewPublishers: initializing BrokerMetadataPublisher with a snapshot at offset 5 (org.apache.kafka.image.loader.MetadataLoader) 2024-06-28T07:03:29.456627212Z [2024-06-28 07:03:29,446] INFO [BrokerMetadataPublisher id=2] Publishing initial metadata at offset OffsetAndEpoch(offset=5, epoch=1) with metadata.version 3.5-IV2. (kafka.server.metadata.BrokerMetadataPublisher) 2024-06-28T07:03:29.456664304Z [2024-06-28 07:03:29,447] INFO Loading logs from log dirs ArrayBuffer(/bitnami/kafka/data) (kafka.log.LogManager) 2024-06-28T07:03:29.459488652Z [2024-06-28 07:03:29,458] INFO No logs found to be loaded in /bitnami/kafka/data (kafka.log.LogManager) 2024-06-28T07:03:29.506242088Z [2024-06-28 07:03:29,505] INFO Loaded 0 logs in 53ms (kafka.log.LogManager) 2024-06-28T07:03:29.506258506Z [2024-06-28 07:03:29,505] INFO Starting log cleanup with a period of 300000 ms. (kafka.log.LogManager) 2024-06-28T07:03:29.507248337Z [2024-06-28 07:03:29,506] INFO Starting log flusher with a default period of 9223372036854775807 ms. (kafka.log.LogManager) 2024-06-28T07:03:29.559279168Z [2024-06-28 07:03:29,559] INFO [QuorumController id=2] Registered new broker: RegisterBrokerRecord(brokerId=2, isMigratingZkBroker=false, incarnationId=_-LpEd_0SKCXz_wq6JyRsg, 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-06-28T07:03:29.612044171Z [2024-06-28 07:03:29,606] INFO Starting the log cleaner (kafka.log.LogCleaner) 2024-06-28T07:03:30.907767493Z [2024-06-28 07:03:30,899] INFO [kafka-log-cleaner-thread-0]: Starting (kafka.log.LogCleaner$CleanerThread) 2024-06-28T07:03:30.982382085Z [2024-06-28 07:03:30,980] INFO [LogDirFailureHandler]: Starting (kafka.server.ReplicaManager$LogDirFailureHandler) 2024-06-28T07:03:31.051633755Z [2024-06-28 07:03:31,050] INFO [GroupCoordinator 2]: Starting up. (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:03:31.098986855Z [2024-06-28 07:03:31,095] INFO [GroupCoordinator 2]: Startup complete. (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:03:31.103599996Z [2024-06-28 07:03:31,101] INFO [TransactionCoordinator id=2] Starting up. (kafka.coordinator.transaction.TransactionCoordinator) 2024-06-28T07:03:31.194477820Z [2024-06-28 07:03:31,188] INFO [TransactionCoordinator id=2] Startup complete. (kafka.coordinator.transaction.TransactionCoordinator) 2024-06-28T07:03:31.194487403Z [2024-06-28 07:03:31,189] INFO [BrokerMetadataPublisher id=2] Updating metadata.version to 11 at offset OffsetAndEpoch(offset=5, epoch=1). (kafka.server.metadata.BrokerMetadataPublisher) 2024-06-28T07:03:31.227677950Z [2024-06-28 07:03:31,225] INFO [TxnMarkerSenderThread-2]: Starting (kafka.coordinator.transaction.TransactionMarkerChannelManager) 2024-06-28T07:03:31.575233013Z [2024-06-28 07:03:31,575] INFO [BrokerLifecycleManager id=2] The broker has caught up. Transitioning from STARTING to RECOVERY. (kafka.server.BrokerLifecycleManager) 2024-06-28T07:03:31.579072225Z [2024-06-28 07:03:31,578] INFO [BrokerServer id=2] Finished waiting for the controller to acknowledge that we are caught up (kafka.server.BrokerServer) 2024-06-28T07:03:31.591798315Z [2024-06-28 07:03:31,578] INFO [QuorumController id=2] Registered new broker: RegisterBrokerRecord(brokerId=1, isMigratingZkBroker=false, incarnationId=hOAIFn_dQM6Fphos14Qe6Q, brokerEpoch=13, 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-06-28T07:03:31.596778313Z [2024-06-28 07:03:31,579] INFO [BrokerServer id=2] Waiting for the initial broker metadata update to be published (kafka.server.BrokerServer) 2024-06-28T07:03:31.597852602Z [2024-06-28 07:03:31,596] INFO [BrokerServer id=2] Finished waiting for the initial broker metadata update to be published (kafka.server.BrokerServer) 2024-06-28T07:03:31.603780623Z [2024-06-28 07:03:31,601] INFO KafkaConfig values: 2024-06-28T07:03:31.603798392Z advertised.listeners = CLIENT://kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9092,INTERNAL://kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094 2024-06-28T07:03:31.603804139Z alter.config.policy.class.name = null 2024-06-28T07:03:31.603808438Z alter.log.dirs.replication.quota.window.num = 11 2024-06-28T07:03:31.603813097Z alter.log.dirs.replication.quota.window.size.seconds = 1 2024-06-28T07:03:31.603818156Z authorizer.class.name = 2024-06-28T07:03:31.603823299Z auto.create.topics.enable = true 2024-06-28T07:03:31.603827548Z auto.include.jmx.reporter = true 2024-06-28T07:03:31.603840555Z auto.leader.rebalance.enable = true 2024-06-28T07:03:31.603845863Z background.threads = 10 2024-06-28T07:03:31.603850128Z broker.heartbeat.interval.ms = 2000 2024-06-28T07:03:31.603854437Z broker.id = 2 2024-06-28T07:03:31.603858865Z broker.id.generation.enable = true 2024-06-28T07:03:31.603863143Z broker.rack = null 2024-06-28T07:03:31.603867212Z broker.session.timeout.ms = 9000 2024-06-28T07:03:31.603871867Z client.quota.callback.class = null 2024-06-28T07:03:31.603876324Z compression.type = producer 2024-06-28T07:03:31.603880988Z connection.failed.authentication.delay.ms = 100 2024-06-28T07:03:31.603885240Z connections.max.idle.ms = 600000 2024-06-28T07:03:31.603889626Z connections.max.reauth.ms = 0 2024-06-28T07:03:31.603893988Z control.plane.listener.name = null 2024-06-28T07:03:31.603898494Z controlled.shutdown.enable = true 2024-06-28T07:03:31.603902569Z controlled.shutdown.max.retries = 3 2024-06-28T07:03:31.603907142Z controlled.shutdown.retry.backoff.ms = 5000 2024-06-28T07:03:31.603911410Z controller.listener.names = CONTROLLER 2024-06-28T07:03:31.603915748Z controller.quorum.append.linger.ms = 25 2024-06-28T07:03:31.603919967Z controller.quorum.election.backoff.max.ms = 1000 2024-06-28T07:03:31.603924138Z controller.quorum.election.timeout.ms = 1000 2024-06-28T07:03:31.603927720Z controller.quorum.fetch.timeout.ms = 2000 2024-06-28T07:03:31.603930754Z controller.quorum.request.timeout.ms = 2000 2024-06-28T07:03:31.603933750Z controller.quorum.retry.backoff.ms = 20 2024-06-28T07:03:31.603937564Z 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-06-28T07:03:31.603940539Z controller.quota.window.num = 11 2024-06-28T07:03:31.603943609Z controller.quota.window.size.seconds = 1 2024-06-28T07:03:31.603946602Z controller.socket.timeout.ms = 30000 2024-06-28T07:03:31.603949586Z create.topic.policy.class.name = null 2024-06-28T07:03:31.603952575Z default.replication.factor = 1 2024-06-28T07:03:31.603955572Z delegation.token.expiry.check.interval.ms = 3600000 2024-06-28T07:03:31.603958761Z delegation.token.expiry.time.ms = 86400000 2024-06-28T07:03:31.603961740Z delegation.token.master.key = null 2024-06-28T07:03:31.603964978Z delegation.token.max.lifetime.ms = 604800000 2024-06-28T07:03:31.603967986Z delegation.token.secret.key = null 2024-06-28T07:03:31.603973892Z delete.records.purgatory.purge.interval.requests = 1 2024-06-28T07:03:31.603976944Z delete.topic.enable = true 2024-06-28T07:03:31.603979991Z early.start.listeners = null 2024-06-28T07:03:31.603983091Z fetch.max.bytes = 57671680 2024-06-28T07:03:31.603986105Z fetch.purgatory.purge.interval.requests = 1000 2024-06-28T07:03:31.603989113Z group.consumer.assignors = [] 2024-06-28T07:03:31.603992042Z group.consumer.heartbeat.interval.ms = 5000 2024-06-28T07:03:31.603995100Z group.consumer.max.heartbeat.interval.ms = 15000 2024-06-28T07:03:31.603998126Z group.consumer.max.session.timeout.ms = 60000 2024-06-28T07:03:31.604001075Z group.consumer.max.size = 2147483647 2024-06-28T07:03:31.604004294Z group.consumer.min.heartbeat.interval.ms = 5000 2024-06-28T07:03:31.604007347Z group.consumer.min.session.timeout.ms = 45000 2024-06-28T07:03:31.604010360Z group.consumer.session.timeout.ms = 45000 2024-06-28T07:03:31.604013359Z group.coordinator.new.enable = false 2024-06-28T07:03:31.604016367Z group.coordinator.threads = 1 2024-06-28T07:03:31.604023619Z group.initial.rebalance.delay.ms = 3000 2024-06-28T07:03:31.604026905Z group.max.session.timeout.ms = 1800000 2024-06-28T07:03:31.604029893Z group.max.size = 2147483647 2024-06-28T07:03:31.604032968Z group.min.session.timeout.ms = 6000 2024-06-28T07:03:31.604036017Z initial.broker.registration.timeout.ms = 60000 2024-06-28T07:03:31.604038976Z inter.broker.listener.name = INTERNAL 2024-06-28T07:03:31.604042371Z inter.broker.protocol.version = 3.5-IV2 2024-06-28T07:03:31.604045475Z kafka.metrics.polling.interval.secs = 10 2024-06-28T07:03:31.604048409Z kafka.metrics.reporters = [] 2024-06-28T07:03:31.604051344Z leader.imbalance.check.interval.seconds = 300 2024-06-28T07:03:31.604054413Z leader.imbalance.per.broker.percentage = 10 2024-06-28T07:03:31.604057997Z listener.security.protocol.map = CLIENT:PLAINTEXT,INTERNAL:SASL_PLAINTEXT,CONTROLLER:SASL_PLAINTEXT 2024-06-28T07:03:31.604061023Z listeners = CLIENT://:9092,INTERNAL://:9094,CONTROLLER://:9093 2024-06-28T07:03:31.604064024Z log.cleaner.backoff.ms = 15000 2024-06-28T07:03:31.604067043Z log.cleaner.dedupe.buffer.size = 134217728 2024-06-28T07:03:31.604069962Z log.cleaner.delete.retention.ms = 86400000 2024-06-28T07:03:31.604072918Z log.cleaner.enable = true 2024-06-28T07:03:31.604075856Z log.cleaner.io.buffer.load.factor = 0.9 2024-06-28T07:03:31.604078788Z log.cleaner.io.buffer.size = 524288 2024-06-28T07:03:31.604081852Z log.cleaner.io.max.bytes.per.second = 1.7976931348623157E308 2024-06-28T07:03:31.604084883Z log.cleaner.max.compaction.lag.ms = 9223372036854775807 2024-06-28T07:03:31.604087801Z log.cleaner.min.cleanable.ratio = 0.5 2024-06-28T07:03:31.604090727Z log.cleaner.min.compaction.lag.ms = 0 2024-06-28T07:03:31.604093791Z log.cleaner.threads = 1 2024-06-28T07:03:31.604096802Z log.cleanup.policy = [delete] 2024-06-28T07:03:31.604099762Z log.dir = /bitnami/kafka/data 2024-06-28T07:03:31.604102717Z log.dirs = null 2024-06-28T07:03:31.604105704Z log.flush.interval.messages = 9223372036854775807 2024-06-28T07:03:31.604108707Z log.flush.interval.ms = null 2024-06-28T07:03:31.604111643Z log.flush.offset.checkpoint.interval.ms = 60000 2024-06-28T07:03:31.604114637Z log.flush.scheduler.interval.ms = 9223372036854775807 2024-06-28T07:03:31.604118628Z log.flush.start.offset.checkpoint.interval.ms = 60000 2024-06-28T07:03:31.604121604Z log.index.interval.bytes = 4096 2024-06-28T07:03:31.604124546Z log.index.size.max.bytes = 10485760 2024-06-28T07:03:31.604127479Z log.message.downconversion.enable = true 2024-06-28T07:03:31.604133138Z log.message.format.version = 3.0-IV1 2024-06-28T07:03:31.604136470Z log.message.timestamp.difference.max.ms = 9223372036854775807 2024-06-28T07:03:31.604139419Z log.message.timestamp.type = CreateTime 2024-06-28T07:03:31.604142374Z log.preallocate = false 2024-06-28T07:03:31.604145491Z log.retention.bytes = -1 2024-06-28T07:03:31.604148428Z log.retention.check.interval.ms = 300000 2024-06-28T07:03:31.604151398Z log.retention.hours = 168 2024-06-28T07:03:31.604154352Z log.retention.minutes = null 2024-06-28T07:03:31.604157396Z log.retention.ms = null 2024-06-28T07:03:31.604160391Z log.roll.hours = 168 2024-06-28T07:03:31.604163340Z log.roll.jitter.hours = 0 2024-06-28T07:03:31.604169855Z log.roll.jitter.ms = null 2024-06-28T07:03:31.604172847Z log.roll.ms = null 2024-06-28T07:03:31.604175835Z log.segment.bytes = 1073741824 2024-06-28T07:03:31.604178794Z log.segment.delete.delay.ms = 60000 2024-06-28T07:03:31.604181827Z max.connection.creation.rate = 2147483647 2024-06-28T07:03:31.604184760Z max.connections = 2147483647 2024-06-28T07:03:31.604191125Z max.connections.per.ip = 2147483647 2024-06-28T07:03:31.604194107Z max.connections.per.ip.overrides = 2024-06-28T07:03:31.604197104Z max.incremental.fetch.session.cache.slots = 1000 2024-06-28T07:03:31.604200065Z message.max.bytes = 1048588 2024-06-28T07:03:31.604203086Z metadata.log.dir = null 2024-06-28T07:03:31.604206036Z metadata.log.max.record.bytes.between.snapshots = 20971520 2024-06-28T07:03:31.604209027Z metadata.log.max.snapshot.interval.ms = 3600000 2024-06-28T07:03:31.604211952Z metadata.log.segment.bytes = 1073741824 2024-06-28T07:03:31.604214912Z metadata.log.segment.min.bytes = 8388608 2024-06-28T07:03:31.604217871Z metadata.log.segment.ms = 604800000 2024-06-28T07:03:31.604220857Z metadata.max.idle.interval.ms = 500 2024-06-28T07:03:31.604223826Z metadata.max.retention.bytes = 104857600 2024-06-28T07:03:31.604226780Z metadata.max.retention.ms = 604800000 2024-06-28T07:03:31.604229755Z metric.reporters = [] 2024-06-28T07:03:31.604232727Z metrics.num.samples = 2 2024-06-28T07:03:31.604235664Z metrics.recording.level = INFO 2024-06-28T07:03:31.604238644Z metrics.sample.window.ms = 30000 2024-06-28T07:03:31.604241558Z min.insync.replicas = 1 2024-06-28T07:03:31.604244542Z node.id = 2 2024-06-28T07:03:31.604247521Z num.io.threads = 8 2024-06-28T07:03:31.604250561Z num.network.threads = 3 2024-06-28T07:03:31.604253546Z num.partitions = 1 2024-06-28T07:03:31.604256549Z num.recovery.threads.per.data.dir = 1 2024-06-28T07:03:31.604259501Z num.replica.alter.log.dirs.threads = null 2024-06-28T07:03:31.604262467Z num.replica.fetchers = 1 2024-06-28T07:03:31.604265446Z offset.metadata.max.bytes = 4096 2024-06-28T07:03:31.604268433Z offsets.commit.required.acks = -1 2024-06-28T07:03:31.604271422Z offsets.commit.timeout.ms = 5000 2024-06-28T07:03:31.604274349Z offsets.load.buffer.size = 5242880 2024-06-28T07:03:31.604277254Z offsets.retention.check.interval.ms = 600000 2024-06-28T07:03:31.604280201Z offsets.retention.minutes = 10080 2024-06-28T07:03:31.604286535Z offsets.topic.compression.codec = 0 2024-06-28T07:03:31.604289595Z offsets.topic.num.partitions = 50 2024-06-28T07:03:31.604292570Z offsets.topic.replication.factor = 3 2024-06-28T07:03:31.604295526Z offsets.topic.segment.bytes = 104857600 2024-06-28T07:03:31.604298480Z password.encoder.cipher.algorithm = AES/CBC/PKCS5Padding 2024-06-28T07:03:31.604301488Z password.encoder.iterations = 4096 2024-06-28T07:03:31.604304451Z password.encoder.key.length = 128 2024-06-28T07:03:31.604307407Z password.encoder.keyfactory.algorithm = null 2024-06-28T07:03:31.604310387Z password.encoder.old.secret = null 2024-06-28T07:03:31.604313358Z password.encoder.secret = null 2024-06-28T07:03:31.604316412Z principal.builder.class = class org.apache.kafka.common.security.authenticator.DefaultKafkaPrincipalBuilder 2024-06-28T07:03:31.604319372Z process.roles = [controller, broker] 2024-06-28T07:03:31.604322329Z producer.id.expiration.check.interval.ms = 600000 2024-06-28T07:03:31.604325316Z producer.id.expiration.ms = 86400000 2024-06-28T07:03:31.604328252Z producer.purgatory.purge.interval.requests = 1000 2024-06-28T07:03:31.604331267Z queued.max.request.bytes = -1 2024-06-28T07:03:31.604334477Z queued.max.requests = 500 2024-06-28T07:03:31.604337454Z quota.window.num = 11 2024-06-28T07:03:31.604340601Z quota.window.size.seconds = 1 2024-06-28T07:03:31.604343609Z remote.log.index.file.cache.total.size.bytes = 1073741824 2024-06-28T07:03:31.604346622Z remote.log.manager.task.interval.ms = 30000 2024-06-28T07:03:31.604349625Z remote.log.manager.task.retry.backoff.max.ms = 30000 2024-06-28T07:03:31.604356279Z remote.log.manager.task.retry.backoff.ms = 500 2024-06-28T07:03:31.604359237Z remote.log.manager.task.retry.jitter = 0.2 2024-06-28T07:03:31.604362158Z remote.log.manager.thread.pool.size = 10 2024-06-28T07:03:31.604365065Z remote.log.metadata.manager.class.name = null 2024-06-28T07:03:31.604367987Z remote.log.metadata.manager.class.path = null 2024-06-28T07:03:31.604370904Z remote.log.metadata.manager.impl.prefix = null 2024-06-28T07:03:31.604373958Z remote.log.metadata.manager.listener.name = null 2024-06-28T07:03:31.604376887Z remote.log.reader.max.pending.tasks = 100 2024-06-28T07:03:31.604379812Z remote.log.reader.threads = 10 2024-06-28T07:03:31.604382741Z remote.log.storage.manager.class.name = null 2024-06-28T07:03:31.604385652Z remote.log.storage.manager.class.path = null 2024-06-28T07:03:31.604388559Z remote.log.storage.manager.impl.prefix = null 2024-06-28T07:03:31.604391650Z remote.log.storage.system.enable = false 2024-06-28T07:03:31.604394639Z replica.fetch.backoff.ms = 1000 2024-06-28T07:03:31.604397621Z replica.fetch.max.bytes = 1048576 2024-06-28T07:03:31.604400557Z replica.fetch.min.bytes = 1 2024-06-28T07:03:31.604403523Z replica.fetch.response.max.bytes = 10485760 2024-06-28T07:03:31.604406467Z replica.fetch.wait.max.ms = 500 2024-06-28T07:03:31.604409429Z replica.high.watermark.checkpoint.interval.ms = 5000 2024-06-28T07:03:31.604412406Z replica.lag.time.max.ms = 30000 2024-06-28T07:03:31.604415354Z replica.selector.class = null 2024-06-28T07:03:31.604418284Z replica.socket.receive.buffer.bytes = 65536 2024-06-28T07:03:31.604421277Z replica.socket.timeout.ms = 30000 2024-06-28T07:03:31.604424227Z replication.quota.window.num = 11 2024-06-28T07:03:31.604427391Z replication.quota.window.size.seconds = 1 2024-06-28T07:03:31.604432698Z request.timeout.ms = 30000 2024-06-28T07:03:31.604435743Z reserved.broker.max.id = 1000 2024-06-28T07:03:31.604438752Z sasl.client.callback.handler.class = null 2024-06-28T07:03:31.604441751Z sasl.enabled.mechanisms = [PLAIN, SCRAM-SHA-256, SCRAM-SHA-512] 2024-06-28T07:03:31.604444764Z sasl.jaas.config = null 2024-06-28T07:03:31.604447776Z sasl.kerberos.kinit.cmd = /usr/bin/kinit 2024-06-28T07:03:31.604450703Z sasl.kerberos.min.time.before.relogin = 60000 2024-06-28T07:03:31.604453694Z sasl.kerberos.principal.to.local.rules = [DEFAULT] 2024-06-28T07:03:31.604456974Z sasl.kerberos.service.name = null 2024-06-28T07:03:31.604459898Z sasl.kerberos.ticket.renew.jitter = 0.05 2024-06-28T07:03:31.604462892Z sasl.kerberos.ticket.renew.window.factor = 0.8 2024-06-28T07:03:31.604467304Z sasl.login.callback.handler.class = null 2024-06-28T07:03:31.604470431Z sasl.login.class = null 2024-06-28T07:03:31.604473551Z sasl.login.connect.timeout.ms = null 2024-06-28T07:03:31.604476537Z sasl.login.read.timeout.ms = null 2024-06-28T07:03:31.604479505Z sasl.login.refresh.buffer.seconds = 300 2024-06-28T07:03:31.604482544Z sasl.login.refresh.min.period.seconds = 60 2024-06-28T07:03:31.604485503Z sasl.login.refresh.window.factor = 0.8 2024-06-28T07:03:31.604488478Z sasl.login.refresh.window.jitter = 0.05 2024-06-28T07:03:31.604491448Z sasl.login.retry.backoff.max.ms = 10000 2024-06-28T07:03:31.604494424Z sasl.login.retry.backoff.ms = 100 2024-06-28T07:03:31.604497652Z sasl.mechanism.controller.protocol = PLAIN 2024-06-28T07:03:31.604500608Z sasl.mechanism.inter.broker.protocol = PLAIN 2024-06-28T07:03:31.604503549Z sasl.oauthbearer.clock.skew.seconds = 30 2024-06-28T07:03:31.604506496Z sasl.oauthbearer.expected.audience = null 2024-06-28T07:03:31.604512868Z sasl.oauthbearer.expected.issuer = null 2024-06-28T07:03:31.604515906Z sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 2024-06-28T07:03:31.604518897Z sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 2024-06-28T07:03:31.604521886Z sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 2024-06-28T07:03:31.604524893Z sasl.oauthbearer.jwks.endpoint.url = null 2024-06-28T07:03:31.604527815Z sasl.oauthbearer.scope.claim.name = scope 2024-06-28T07:03:31.604530884Z sasl.oauthbearer.sub.claim.name = sub 2024-06-28T07:03:31.604533852Z sasl.oauthbearer.token.endpoint.url = null 2024-06-28T07:03:31.604536791Z sasl.server.callback.handler.class = null 2024-06-28T07:03:31.604539755Z sasl.server.max.receive.size = 524288 2024-06-28T07:03:31.604542748Z security.inter.broker.protocol = PLAINTEXT 2024-06-28T07:03:31.604545759Z security.providers = null 2024-06-28T07:03:31.604548749Z server.max.startup.time.ms = 9223372036854775807 2024-06-28T07:03:31.604551661Z socket.connection.setup.timeout.max.ms = 30000 2024-06-28T07:03:31.604554666Z socket.connection.setup.timeout.ms = 10000 2024-06-28T07:03:31.604557605Z socket.listen.backlog.size = 50 2024-06-28T07:03:31.604560552Z socket.receive.buffer.bytes = 102400 2024-06-28T07:03:31.604563480Z socket.request.max.bytes = 104857600 2024-06-28T07:03:31.604566487Z socket.send.buffer.bytes = 102400 2024-06-28T07:03:31.604569439Z ssl.cipher.suites = [] 2024-06-28T07:03:31.604572446Z ssl.client.auth = none 2024-06-28T07:03:31.604575389Z ssl.enabled.protocols = [TLSv1.2, TLSv1.3] 2024-06-28T07:03:31.604578388Z ssl.endpoint.identification.algorithm = https 2024-06-28T07:03:31.604581364Z ssl.engine.factory.class = null 2024-06-28T07:03:31.604584394Z ssl.key.password = null 2024-06-28T07:03:31.604587315Z ssl.keymanager.algorithm = SunX509 2024-06-28T07:03:31.604590258Z ssl.keystore.certificate.chain = null 2024-06-28T07:03:31.604593289Z ssl.keystore.key = null 2024-06-28T07:03:31.604596234Z ssl.keystore.location = null 2024-06-28T07:03:31.604599240Z ssl.keystore.password = null 2024-06-28T07:03:31.604602200Z ssl.keystore.type = JKS 2024-06-28T07:03:31.604605220Z ssl.principal.mapping.rules = DEFAULT 2024-06-28T07:03:31.604608191Z ssl.protocol = TLSv1.3 2024-06-28T07:03:31.604611209Z ssl.provider = null 2024-06-28T07:03:31.604614207Z ssl.secure.random.implementation = null 2024-06-28T07:03:31.604617206Z ssl.trustmanager.algorithm = PKIX 2024-06-28T07:03:31.604620155Z ssl.truststore.certificates = null 2024-06-28T07:03:31.604623218Z ssl.truststore.location = null 2024-06-28T07:03:31.604626231Z ssl.truststore.password = null 2024-06-28T07:03:31.604629172Z ssl.truststore.type = JKS 2024-06-28T07:03:31.604643898Z transaction.abort.timed.out.transaction.cleanup.interval.ms = 10000 2024-06-28T07:03:31.604647116Z transaction.max.timeout.ms = 900000 2024-06-28T07:03:31.604650046Z transaction.remove.expired.transaction.cleanup.interval.ms = 3600000 2024-06-28T07:03:31.604652948Z transaction.state.log.load.buffer.size = 5242880 2024-06-28T07:03:31.604655846Z transaction.state.log.min.isr = 2 2024-06-28T07:03:31.604659539Z transaction.state.log.num.partitions = 50 2024-06-28T07:03:31.604662440Z transaction.state.log.replication.factor = 3 2024-06-28T07:03:31.604665350Z transaction.state.log.segment.bytes = 104857600 2024-06-28T07:03:31.604668227Z transactional.id.expiration.ms = 604800000 2024-06-28T07:03:31.604671101Z unclean.leader.election.enable = false 2024-06-28T07:03:31.604673975Z unstable.api.versions.enable = false 2024-06-28T07:03:31.604676851Z zookeeper.clientCnxnSocket = null 2024-06-28T07:03:31.604683104Z zookeeper.connect = null 2024-06-28T07:03:31.604686000Z zookeeper.connection.timeout.ms = null 2024-06-28T07:03:31.604688918Z zookeeper.max.in.flight.requests = 10 2024-06-28T07:03:31.604691766Z zookeeper.metadata.migration.enable = false 2024-06-28T07:03:31.604694588Z zookeeper.session.timeout.ms = 18000 2024-06-28T07:03:31.604697425Z zookeeper.set.acl = false 2024-06-28T07:03:31.604700276Z zookeeper.ssl.cipher.suites = null 2024-06-28T07:03:31.604703195Z zookeeper.ssl.client.enable = false 2024-06-28T07:03:31.604706040Z zookeeper.ssl.crl.enable = false 2024-06-28T07:03:31.604708881Z zookeeper.ssl.enabled.protocols = null 2024-06-28T07:03:31.604711781Z zookeeper.ssl.endpoint.identification.algorithm = HTTPS 2024-06-28T07:03:31.604714609Z zookeeper.ssl.keystore.location = null 2024-06-28T07:03:31.604717447Z zookeeper.ssl.keystore.password = null 2024-06-28T07:03:31.604720415Z zookeeper.ssl.keystore.type = null 2024-06-28T07:03:31.604723319Z zookeeper.ssl.ocsp.enable = false 2024-06-28T07:03:31.604726171Z zookeeper.ssl.protocol = TLSv1.2 2024-06-28T07:03:31.604729004Z zookeeper.ssl.truststore.location = null 2024-06-28T07:03:31.604731839Z zookeeper.ssl.truststore.password = null 2024-06-28T07:03:31.604734678Z zookeeper.ssl.truststore.type = null 2024-06-28T07:03:31.604737620Z (kafka.server.KafkaConfig) 2024-06-28T07:03:31.628237784Z [2024-06-28 07:03:31,597] INFO [BrokerLifecycleManager id=2] The broker is in RECOVERY. (kafka.server.BrokerLifecycleManager) 2024-06-28T07:03:31.697417864Z [2024-06-28 07:03:31,696] INFO [BrokerServer id=2] Waiting for the broker to be unfenced (kafka.server.BrokerServer) 2024-06-28T07:03:31.743723534Z [2024-06-28 07:03:31,742] INFO [BrokerLifecycleManager id=2] The broker has been unfenced. Transitioning from RECOVERY to RUNNING. (kafka.server.BrokerLifecycleManager) 2024-06-28T07:03:31.743740978Z [2024-06-28 07:03:31,742] INFO [BrokerServer id=2] Finished waiting for the broker to be unfenced (kafka.server.BrokerServer) 2024-06-28T07:03:31.743744883Z [2024-06-28 07:03:31,742] INFO [SocketServer listenerType=BROKER, nodeId=2] Enabling request processing. (kafka.network.SocketServer) 2024-06-28T07:03:31.743748766Z [2024-06-28 07:03:31,742] INFO Awaiting socket connections on 0.0.0.0:9092. (kafka.network.DataPlaneAcceptor) 2024-06-28T07:03:31.767722213Z [2024-06-28 07:03:31,758] INFO Awaiting socket connections on 0.0.0.0:9094. (kafka.network.DataPlaneAcceptor) 2024-06-28T07:03:31.812905078Z [2024-06-28 07:03:31,800] INFO [BrokerServer id=2] Waiting for all of the authorizer futures to be completed (kafka.server.BrokerServer) 2024-06-28T07:03:31.812930246Z [2024-06-28 07:03:31,800] INFO [BrokerServer id=2] Finished waiting for all of the authorizer futures to be completed (kafka.server.BrokerServer) 2024-06-28T07:03:31.812938026Z [2024-06-28 07:03:31,800] INFO [BrokerServer id=2] Waiting for all of the SocketServer Acceptors to be started (kafka.server.BrokerServer) 2024-06-28T07:03:31.812941013Z [2024-06-28 07:03:31,800] INFO [BrokerServer id=2] Finished waiting for all of the SocketServer Acceptors to be started (kafka.server.BrokerServer) 2024-06-28T07:03:31.812944418Z [2024-06-28 07:03:31,800] INFO [BrokerServer id=2] Transition from STARTING to STARTED (kafka.server.BrokerServer) 2024-06-28T07:03:31.812947979Z [2024-06-28 07:03:31,801] INFO Kafka version: 3.5.1 (org.apache.kafka.common.utils.AppInfoParser) 2024-06-28T07:03:31.812950936Z [2024-06-28 07:03:31,801] INFO Kafka commitId: 2c6fb6c54472e90a (org.apache.kafka.common.utils.AppInfoParser) 2024-06-28T07:03:31.812953803Z [2024-06-28 07:03:31,801] INFO Kafka startTimeMs: 1719558211800 (org.apache.kafka.common.utils.AppInfoParser) 2024-06-28T07:03:31.842698462Z [2024-06-28 07:03:31,837] INFO [KafkaRaftServer nodeId=2] Kafka Server started (kafka.server.KafkaRaftServer) 2024-06-28T07:04:17.206762265Z [2024-06-28 07:04:17,201] INFO [QuorumController id=2] Created topic alarm_request with topic ID KWMKhygcRUixrEX4LKiOKg. (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:04:17.207261643Z [2024-06-28 07:04:17,207] INFO [QuorumController id=2] Created partition alarm_request-0 with topic ID KWMKhygcRUixrEX4LKiOKg and PartitionRegistration(replicas=[0], isr=[0], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:04:17.684765796Z [2024-06-28 07:04:17,683] INFO [QuorumController id=2] Created topic users with topic ID DiLTMI45ScasptZgDC1KqQ. (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:04:17.684798486Z [2024-06-28 07:04:17,683] INFO [QuorumController id=2] Created partition users-0 with topic ID DiLTMI45ScasptZgDC1KqQ and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:04:18.254066058Z [2024-06-28 07:04:18,252] INFO [QuorumController id=2] Created topic project with topic ID pJZXz0gDSP-teS9rMJs58g. (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:04:18.254081596Z [2024-06-28 07:04:18,252] INFO [QuorumController id=2] Created partition project-0 with topic ID pJZXz0gDSP-teS9rMJs58g and PartitionRegistration(replicas=[2], isr=[2], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:04:18.261815489Z [2024-06-28 07:04:18,261] INFO [Broker id=2] Transitioning 1 partition(s) to local leaders. (state.change.logger) 2024-06-28T07:04:18.267613071Z [2024-06-28 07:04:18,266] INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(project-0) (kafka.server.ReplicaFetcherManager) 2024-06-28T07:04:18.278919206Z [2024-06-28 07:04:18,275] INFO [Broker id=2] Creating new partition project-0 with topic id pJZXz0gDSP-teS9rMJs58g. (state.change.logger) 2024-06-28T07:04:18.328679248Z [2024-06-28 07:04:18,328] INFO [LogLoader partition=project-0, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) 2024-06-28T07:04:18.331341291Z [2024-06-28 07:04:18,331] INFO Created log for partition project-0 in /bitnami/kafka/data/project-0 with properties {} (kafka.log.LogManager) 2024-06-28T07:04:18.341737991Z [2024-06-28 07:04:18,335] INFO [Partition project-0 broker=2] No checkpointed highwatermark is found for partition project-0 (kafka.cluster.Partition) 2024-06-28T07:04:18.343319643Z [2024-06-28 07:04:18,343] INFO [Partition project-0 broker=2] Log loaded for partition project-0 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:18.346241161Z [2024-06-28 07:04:18,346] INFO [Broker id=2] Leader project-0 with topic id Some(pJZXz0gDSP-teS9rMJs58g) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:18.700319485Z [2024-06-28 07:04:18,697] INFO [QuorumController id=2] Created topic __consumer_offsets with topic ID ZT49BHyVTgSexosJvrYoDQ. (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:04:18.704339541Z [2024-06-28 07:04:18,701] INFO [QuorumController id=2] ConfigResource(type=TOPIC, name='__consumer_offsets'): set configuration compression.type to producer (org.apache.kafka.controller.ConfigurationControlManager) 2024-06-28T07:04:18.704361760Z [2024-06-28 07:04:18,701] INFO [QuorumController id=2] ConfigResource(type=TOPIC, name='__consumer_offsets'): set configuration cleanup.policy to compact (org.apache.kafka.controller.ConfigurationControlManager) 2024-06-28T07:04:18.704374342Z [2024-06-28 07:04:18,701] INFO [QuorumController id=2] ConfigResource(type=TOPIC, name='__consumer_offsets'): set configuration segment.bytes to 104857600 (org.apache.kafka.controller.ConfigurationControlManager) 2024-06-28T07:04:18.704379352Z [2024-06-28 07:04:18,702] INFO [QuorumController id=2] Created partition __consumer_offsets-0 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.704382678Z [2024-06-28 07:04:18,702] INFO [QuorumController id=2] Created partition __consumer_offsets-1 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.704385862Z [2024-06-28 07:04:18,702] INFO [QuorumController id=2] Created partition __consumer_offsets-2 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.704389487Z [2024-06-28 07:04:18,702] INFO [QuorumController id=2] Created partition __consumer_offsets-3 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.704392697Z [2024-06-28 07:04:18,702] INFO [QuorumController id=2] Created partition __consumer_offsets-4 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.704395889Z [2024-06-28 07:04:18,702] INFO [QuorumController id=2] Created partition __consumer_offsets-5 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.704403769Z [2024-06-28 07:04:18,702] INFO [QuorumController id=2] Created partition __consumer_offsets-6 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.704407062Z [2024-06-28 07:04:18,702] INFO [QuorumController id=2] Created partition __consumer_offsets-7 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.704410179Z [2024-06-28 07:04:18,702] INFO [QuorumController id=2] Created partition __consumer_offsets-8 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.704415980Z [2024-06-28 07:04:18,702] INFO [QuorumController id=2] Created partition __consumer_offsets-9 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.704423995Z [2024-06-28 07:04:18,702] INFO [QuorumController id=2] Created partition __consumer_offsets-10 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.704427189Z [2024-06-28 07:04:18,702] INFO [QuorumController id=2] Created partition __consumer_offsets-11 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.704430422Z [2024-06-28 07:04:18,702] INFO [QuorumController id=2] Created partition __consumer_offsets-12 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.704433479Z [2024-06-28 07:04:18,702] INFO [QuorumController id=2] Created partition __consumer_offsets-13 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.704436624Z [2024-06-28 07:04:18,703] INFO [QuorumController id=2] Created partition __consumer_offsets-14 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.704439786Z [2024-06-28 07:04:18,703] INFO [QuorumController id=2] Created partition __consumer_offsets-15 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.704442879Z [2024-06-28 07:04:18,703] INFO [QuorumController id=2] Created partition __consumer_offsets-16 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.704472383Z [2024-06-28 07:04:18,703] INFO [QuorumController id=2] Created partition __consumer_offsets-17 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.704476073Z [2024-06-28 07:04:18,703] INFO [QuorumController id=2] Created partition __consumer_offsets-18 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.704479187Z [2024-06-28 07:04:18,703] INFO [QuorumController id=2] Created partition __consumer_offsets-19 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.704488104Z [2024-06-28 07:04:18,703] INFO [QuorumController id=2] Created partition __consumer_offsets-20 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.704491662Z [2024-06-28 07:04:18,703] INFO [QuorumController id=2] Created partition __consumer_offsets-21 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.704494787Z [2024-06-28 07:04:18,703] INFO [QuorumController id=2] Created partition __consumer_offsets-22 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.704498144Z [2024-06-28 07:04:18,703] INFO [QuorumController id=2] Created partition __consumer_offsets-23 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.704501279Z [2024-06-28 07:04:18,703] INFO [QuorumController id=2] Created partition __consumer_offsets-24 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.704504465Z [2024-06-28 07:04:18,703] INFO [QuorumController id=2] Created partition __consumer_offsets-25 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.704507681Z [2024-06-28 07:04:18,703] INFO [QuorumController id=2] Created partition __consumer_offsets-26 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.704510989Z [2024-06-28 07:04:18,704] INFO [QuorumController id=2] Created partition __consumer_offsets-27 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.704514422Z [2024-06-28 07:04:18,704] INFO [QuorumController id=2] Created partition __consumer_offsets-28 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.704517725Z [2024-06-28 07:04:18,704] INFO [QuorumController id=2] Created partition __consumer_offsets-29 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.706851891Z [2024-06-28 07:04:18,706] INFO [QuorumController id=2] Created partition __consumer_offsets-30 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.706862966Z [2024-06-28 07:04:18,706] INFO [QuorumController id=2] Created partition __consumer_offsets-31 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.706866175Z [2024-06-28 07:04:18,706] INFO [QuorumController id=2] Created partition __consumer_offsets-32 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.707456807Z [2024-06-28 07:04:18,706] INFO [QuorumController id=2] Created partition __consumer_offsets-33 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.707466057Z [2024-06-28 07:04:18,707] INFO [QuorumController id=2] Created partition __consumer_offsets-34 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.707469330Z [2024-06-28 07:04:18,707] INFO [QuorumController id=2] Created partition __consumer_offsets-35 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.707472475Z [2024-06-28 07:04:18,707] INFO [QuorumController id=2] Created partition __consumer_offsets-36 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.707475630Z [2024-06-28 07:04:18,707] INFO [QuorumController id=2] Created partition __consumer_offsets-37 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.710680572Z [2024-06-28 07:04:18,710] INFO [QuorumController id=2] Created partition __consumer_offsets-38 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.712159624Z [2024-06-28 07:04:18,712] INFO [QuorumController id=2] Created partition __consumer_offsets-39 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.712822448Z [2024-06-28 07:04:18,712] INFO [QuorumController id=2] Created partition __consumer_offsets-40 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.713476158Z [2024-06-28 07:04:18,712] INFO [Broker id=2] Transitioning 17 partition(s) to local leaders. (state.change.logger) 2024-06-28T07:04:18.714004962Z [2024-06-28 07:04:18,713] INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(__consumer_offsets-48, __consumer_offsets-45, __consumer_offsets-11, __consumer_offsets-43, __consumer_offsets-12, __consumer_offsets-41, __consumer_offsets-24, __consumer_offsets-22, __consumer_offsets-17, __consumer_offsets-18, __consumer_offsets-32, __consumer_offsets-27, __consumer_offsets-8, __consumer_offsets-37, __consumer_offsets-4, __consumer_offsets-33, __consumer_offsets-2) (kafka.server.ReplicaFetcherManager) 2024-06-28T07:04:18.714553312Z [2024-06-28 07:04:18,714] INFO [Broker id=2] Creating new partition __consumer_offsets-48 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:18.716265938Z [2024-06-28 07:04:18,716] INFO [QuorumController id=2] Created partition __consumer_offsets-41 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.716936142Z [2024-06-28 07:04:18,716] INFO [QuorumController id=2] Created partition __consumer_offsets-42 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.725954457Z [2024-06-28 07:04:18,720] INFO [QuorumController id=2] Created partition __consumer_offsets-43 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.725968527Z [2024-06-28 07:04:18,720] INFO [QuorumController id=2] Created partition __consumer_offsets-44 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.725972088Z [2024-06-28 07:04:18,720] INFO [QuorumController id=2] Created partition __consumer_offsets-45 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.725975147Z [2024-06-28 07:04:18,720] INFO [QuorumController id=2] Created partition __consumer_offsets-46 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.725981418Z [2024-06-28 07:04:18,720] INFO [QuorumController id=2] Created partition __consumer_offsets-47 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.726001144Z [2024-06-28 07:04:18,720] INFO [QuorumController id=2] Created partition __consumer_offsets-48 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.726004237Z [2024-06-28 07:04:18,720] INFO [QuorumController id=2] Created partition __consumer_offsets-49 with topic ID ZT49BHyVTgSexosJvrYoDQ 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-06-28T07:04:18.749670508Z [2024-06-28 07:04:18,748] 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-06-28T07:04:18.750680193Z [2024-06-28 07:04:18,750] 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-06-28T07:04:18.751404853Z [2024-06-28 07:04:18,751] INFO [Partition __consumer_offsets-48 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-48 (kafka.cluster.Partition) 2024-06-28T07:04:18.751662205Z [2024-06-28 07:04:18,751] INFO [Partition __consumer_offsets-48 broker=2] Log loaded for partition __consumer_offsets-48 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:18.752135173Z [2024-06-28 07:04:18,751] INFO [Broker id=2] Leader __consumer_offsets-48 with topic id Some(ZT49BHyVTgSexosJvrYoDQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,0,1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:18.768770721Z [2024-06-28 07:04:18,768] INFO [Broker id=2] Creating new partition __consumer_offsets-45 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:18.846809495Z [2024-06-28 07:04:18,830] 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-06-28T07:04:18.846827762Z [2024-06-28 07:04:18,843] 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-06-28T07:04:18.846831661Z [2024-06-28 07:04:18,843] INFO [Partition __consumer_offsets-45 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-45 (kafka.cluster.Partition) 2024-06-28T07:04:18.846834808Z [2024-06-28 07:04:18,843] INFO [Partition __consumer_offsets-45 broker=2] Log loaded for partition __consumer_offsets-45 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:18.846838739Z [2024-06-28 07:04:18,844] INFO [Broker id=2] Leader __consumer_offsets-45 with topic id Some(ZT49BHyVTgSexosJvrYoDQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,0,1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:18.852078060Z [2024-06-28 07:04:18,848] INFO [Broker id=2] Creating new partition __consumer_offsets-11 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:18.862354557Z [2024-06-28 07:04:18,860] 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-06-28T07:04:18.869093523Z [2024-06-28 07:04:18,862] 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-06-28T07:04:18.869102200Z [2024-06-28 07:04:18,862] INFO [Partition __consumer_offsets-11 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-11 (kafka.cluster.Partition) 2024-06-28T07:04:18.869105483Z [2024-06-28 07:04:18,862] INFO [Partition __consumer_offsets-11 broker=2] Log loaded for partition __consumer_offsets-11 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:18.869130654Z [2024-06-28 07:04:18,862] INFO [Broker id=2] Leader __consumer_offsets-11 with topic id Some(ZT49BHyVTgSexosJvrYoDQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,1,0], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:18.872809462Z [2024-06-28 07:04:18,872] INFO [Broker id=2] Creating new partition __consumer_offsets-43 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:18.876470163Z [2024-06-28 07:04:18,876] 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-06-28T07:04:18.877296286Z [2024-06-28 07:04:18,877] 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-06-28T07:04:18.877393065Z [2024-06-28 07:04:18,877] INFO [Partition __consumer_offsets-43 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-43 (kafka.cluster.Partition) 2024-06-28T07:04:18.877464791Z [2024-06-28 07:04:18,877] INFO [Partition __consumer_offsets-43 broker=2] Log loaded for partition __consumer_offsets-43 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:18.877633912Z [2024-06-28 07:04:18,877] INFO [Broker id=2] Leader __consumer_offsets-43 with topic id Some(ZT49BHyVTgSexosJvrYoDQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,1,0], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:18.883581258Z [2024-06-28 07:04:18,883] INFO [Broker id=2] Creating new partition __consumer_offsets-12 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:18.888641702Z [2024-06-28 07:04:18,888] 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-06-28T07:04:18.889182147Z [2024-06-28 07:04:18,889] 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-06-28T07:04:18.889218069Z [2024-06-28 07:04:18,889] INFO [Partition __consumer_offsets-12 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-12 (kafka.cluster.Partition) 2024-06-28T07:04:18.889342632Z [2024-06-28 07:04:18,889] INFO [Partition __consumer_offsets-12 broker=2] Log loaded for partition __consumer_offsets-12 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:18.889501384Z [2024-06-28 07:04:18,889] INFO [Broker id=2] Leader __consumer_offsets-12 with topic id Some(ZT49BHyVTgSexosJvrYoDQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,0,1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:18.892364785Z [2024-06-28 07:04:18,891] INFO [Broker id=2] Creating new partition __consumer_offsets-41 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:18.895989305Z [2024-06-28 07:04:18,895] 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-06-28T07:04:18.897255460Z [2024-06-28 07:04:18,897] 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-06-28T07:04:18.897309148Z [2024-06-28 07:04:18,897] INFO [Partition __consumer_offsets-41 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-41 (kafka.cluster.Partition) 2024-06-28T07:04:18.897313903Z [2024-06-28 07:04:18,897] INFO [Partition __consumer_offsets-41 broker=2] Log loaded for partition __consumer_offsets-41 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:18.897490368Z [2024-06-28 07:04:18,897] INFO [Broker id=2] Leader __consumer_offsets-41 with topic id Some(ZT49BHyVTgSexosJvrYoDQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,1,0], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:18.911043750Z [2024-06-28 07:04:18,910] INFO [Broker id=2] Creating new partition __consumer_offsets-24 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:18.955168167Z [2024-06-28 07:04:18,955] 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-06-28T07:04:18.956563511Z [2024-06-28 07:04:18,956] 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-06-28T07:04:18.956580403Z [2024-06-28 07:04:18,956] INFO [Partition __consumer_offsets-24 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-24 (kafka.cluster.Partition) 2024-06-28T07:04:18.956625408Z [2024-06-28 07:04:18,956] INFO [Partition __consumer_offsets-24 broker=2] Log loaded for partition __consumer_offsets-24 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:18.956757957Z [2024-06-28 07:04:18,956] INFO [Broker id=2] Leader __consumer_offsets-24 with topic id Some(ZT49BHyVTgSexosJvrYoDQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,1,0], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:18.972062147Z [2024-06-28 07:04:18,971] INFO [Broker id=2] Creating new partition __consumer_offsets-22 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:19.004834818Z [2024-06-28 07:04:19,004] 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-06-28T07:04:19.005603828Z [2024-06-28 07:04:19,005] 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-06-28T07:04:19.005719743Z [2024-06-28 07:04:19,005] INFO [Partition __consumer_offsets-22 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-22 (kafka.cluster.Partition) 2024-06-28T07:04:19.005776949Z [2024-06-28 07:04:19,005] INFO [Partition __consumer_offsets-22 broker=2] Log loaded for partition __consumer_offsets-22 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:19.005941376Z [2024-06-28 07:04:19,005] INFO [Broker id=2] Leader __consumer_offsets-22 with topic id Some(ZT49BHyVTgSexosJvrYoDQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,0,1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:19.022175760Z [2024-06-28 07:04:19,021] INFO [Broker id=2] Creating new partition __consumer_offsets-17 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:19.043233204Z [2024-06-28 07:04:19,043] 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-06-28T07:04:19.060778547Z [2024-06-28 07:04:19,060] 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-06-28T07:04:19.071964128Z [2024-06-28 07:04:19,071] INFO [Partition __consumer_offsets-17 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-17 (kafka.cluster.Partition) 2024-06-28T07:04:19.072223700Z [2024-06-28 07:04:19,072] INFO [Partition __consumer_offsets-17 broker=2] Log loaded for partition __consumer_offsets-17 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:19.076428597Z [2024-06-28 07:04:19,072] INFO [Broker id=2] Leader __consumer_offsets-17 with topic id Some(ZT49BHyVTgSexosJvrYoDQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,0,1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:19.083146753Z [2024-06-28 07:04:19,083] INFO [Broker id=2] Creating new partition __consumer_offsets-18 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:19.124174625Z [2024-06-28 07:04:19,123] 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-06-28T07:04:19.354769468Z [2024-06-28 07:04:19,354] 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-06-28T07:04:19.357921148Z [2024-06-28 07:04:19,356] INFO [Partition __consumer_offsets-18 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-18 (kafka.cluster.Partition) 2024-06-28T07:04:19.358769880Z [2024-06-28 07:04:19,358] INFO [Partition __consumer_offsets-18 broker=2] Log loaded for partition __consumer_offsets-18 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:19.362324414Z [2024-06-28 07:04:19,362] INFO [Broker id=2] Leader __consumer_offsets-18 with topic id Some(ZT49BHyVTgSexosJvrYoDQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,0,1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:19.379441204Z [2024-06-28 07:04:19,378] INFO [Broker id=2] Creating new partition __consumer_offsets-32 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:19.543243205Z [2024-06-28 07:04:19,543] 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-06-28T07:04:19.582539017Z [2024-06-28 07:04:19,582] 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-06-28T07:04:19.582635234Z [2024-06-28 07:04:19,582] INFO [Partition __consumer_offsets-32 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-32 (kafka.cluster.Partition) 2024-06-28T07:04:19.582718323Z [2024-06-28 07:04:19,582] INFO [Partition __consumer_offsets-32 broker=2] Log loaded for partition __consumer_offsets-32 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:19.583317671Z [2024-06-28 07:04:19,582] INFO [Broker id=2] Leader __consumer_offsets-32 with topic id Some(ZT49BHyVTgSexosJvrYoDQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,1,0], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:19.609086769Z [2024-06-28 07:04:19,605] INFO [Broker id=2] Creating new partition __consumer_offsets-27 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:19.617779937Z [2024-06-28 07:04:19,617] 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-06-28T07:04:19.637322234Z [2024-06-28 07:04:19,636] 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-06-28T07:04:19.637341689Z [2024-06-28 07:04:19,636] INFO [Partition __consumer_offsets-27 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-27 (kafka.cluster.Partition) 2024-06-28T07:04:19.637345120Z [2024-06-28 07:04:19,636] INFO [Partition __consumer_offsets-27 broker=2] Log loaded for partition __consumer_offsets-27 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:19.637838737Z [2024-06-28 07:04:19,636] INFO [Broker id=2] Leader __consumer_offsets-27 with topic id Some(ZT49BHyVTgSexosJvrYoDQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,1,0], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:19.702865026Z [2024-06-28 07:04:19,701] INFO [Broker id=2] Creating new partition __consumer_offsets-8 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:19.751166451Z [2024-06-28 07:04:19,749] 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-06-28T07:04:19.751193183Z [2024-06-28 07:04:19,750] 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-06-28T07:04:19.751199159Z [2024-06-28 07:04:19,750] INFO [Partition __consumer_offsets-8 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-8 (kafka.cluster.Partition) 2024-06-28T07:04:19.751203573Z [2024-06-28 07:04:19,750] INFO [Partition __consumer_offsets-8 broker=2] Log loaded for partition __consumer_offsets-8 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:19.751208772Z [2024-06-28 07:04:19,750] INFO [Broker id=2] Leader __consumer_offsets-8 with topic id Some(ZT49BHyVTgSexosJvrYoDQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,0,1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:19.821563670Z [2024-06-28 07:04:19,819] INFO [Broker id=2] Creating new partition __consumer_offsets-37 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:19.830244587Z [2024-06-28 07:04:19,829] 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-06-28T07:04:19.830299875Z [2024-06-28 07:04:19,830] 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-06-28T07:04:19.830856346Z [2024-06-28 07:04:19,830] INFO [Partition __consumer_offsets-37 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-37 (kafka.cluster.Partition) 2024-06-28T07:04:19.831454142Z [2024-06-28 07:04:19,831] INFO [Partition __consumer_offsets-37 broker=2] Log loaded for partition __consumer_offsets-37 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:19.832256019Z [2024-06-28 07:04:19,832] INFO [Broker id=2] Leader __consumer_offsets-37 with topic id Some(ZT49BHyVTgSexosJvrYoDQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,1,0], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:19.839100404Z [2024-06-28 07:04:19,838] INFO [Broker id=2] Creating new partition __consumer_offsets-4 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:19.851857968Z [2024-06-28 07:04:19,849] 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-06-28T07:04:19.851870893Z [2024-06-28 07:04:19,849] 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-06-28T07:04:19.851874522Z [2024-06-28 07:04:19,850] INFO [Partition __consumer_offsets-4 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-4 (kafka.cluster.Partition) 2024-06-28T07:04:19.851877869Z [2024-06-28 07:04:19,850] INFO [Partition __consumer_offsets-4 broker=2] Log loaded for partition __consumer_offsets-4 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:19.851881407Z [2024-06-28 07:04:19,850] INFO [Broker id=2] Leader __consumer_offsets-4 with topic id Some(ZT49BHyVTgSexosJvrYoDQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,1,0], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:19.917334587Z [2024-06-28 07:04:19,916] INFO [Broker id=2] Creating new partition __consumer_offsets-33 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:20.017531501Z [2024-06-28 07:04:20,009] 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-06-28T07:04:20.047022328Z [2024-06-28 07:04:20,046] 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-06-28T07:04:20.077040179Z [2024-06-28 07:04:20,070] INFO [Partition __consumer_offsets-33 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-33 (kafka.cluster.Partition) 2024-06-28T07:04:20.077056236Z [2024-06-28 07:04:20,072] INFO [Partition __consumer_offsets-33 broker=2] Log loaded for partition __consumer_offsets-33 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:20.077062303Z [2024-06-28 07:04:20,072] INFO [Broker id=2] Leader __consumer_offsets-33 with topic id Some(ZT49BHyVTgSexosJvrYoDQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,1,0], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:20.231626400Z [2024-06-28 07:04:20,230] INFO [Broker id=2] Creating new partition __consumer_offsets-2 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:20.332980540Z [2024-06-28 07:04:20,331] 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-06-28T07:04:20.368324952Z [2024-06-28 07:04:20,357] 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-06-28T07:04:20.368343333Z [2024-06-28 07:04:20,357] INFO [Partition __consumer_offsets-2 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-2 (kafka.cluster.Partition) 2024-06-28T07:04:20.368346816Z [2024-06-28 07:04:20,357] INFO [Partition __consumer_offsets-2 broker=2] Log loaded for partition __consumer_offsets-2 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:20.368351104Z [2024-06-28 07:04:20,358] INFO [Broker id=2] Leader __consumer_offsets-2 with topic id Some(ZT49BHyVTgSexosJvrYoDQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2,0,1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:20.403864634Z [2024-06-28 07:04:20,400] INFO [Broker id=2] Transitioning 33 partition(s) to local followers. (state.change.logger) 2024-06-28T07:04:20.428686493Z [2024-06-28 07:04:20,428] INFO [Broker id=2] Creating new partition __consumer_offsets-15 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:20.602120800Z [2024-06-28 07:04:20,590] 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-06-28T07:04:20.602185052Z [2024-06-28 07:04:20,591] 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-06-28T07:04:20.602190115Z [2024-06-28 07:04:20,591] INFO [Partition __consumer_offsets-15 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-15 (kafka.cluster.Partition) 2024-06-28T07:04:20.602193571Z [2024-06-28 07:04:20,591] INFO [Partition __consumer_offsets-15 broker=2] Log loaded for partition __consumer_offsets-15 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:20.602197471Z [2024-06-28 07:04:20,595] INFO [Broker id=2] Follower __consumer_offsets-15 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:20.701290459Z [2024-06-28 07:04:20,595] INFO [Broker id=2] Creating new partition __consumer_offsets-13 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:20.816663474Z [2024-06-28 07:04:20,814] 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-06-28T07:04:20.850856695Z [2024-06-28 07:04:20,850] 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-06-28T07:04:20.881392700Z [2024-06-28 07:04:20,866] INFO [Partition __consumer_offsets-13 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-13 (kafka.cluster.Partition) 2024-06-28T07:04:20.881402439Z [2024-06-28 07:04:20,878] INFO [Partition __consumer_offsets-13 broker=2] Log loaded for partition __consumer_offsets-13 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:20.881421959Z [2024-06-28 07:04:20,879] INFO [Broker id=2] Follower __consumer_offsets-13 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:20.892068812Z [2024-06-28 07:04:20,891] INFO [Broker id=2] Creating new partition __consumer_offsets-46 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:20.973250152Z [2024-06-28 07:04:20,973] 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-06-28T07:04:20.973935585Z [2024-06-28 07:04:20,973] 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-06-28T07:04:20.973968726Z [2024-06-28 07:04:20,973] INFO [Partition __consumer_offsets-46 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-46 (kafka.cluster.Partition) 2024-06-28T07:04:20.974050392Z [2024-06-28 07:04:20,973] INFO [Partition __consumer_offsets-46 broker=2] Log loaded for partition __consumer_offsets-46 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:20.979605408Z [2024-06-28 07:04:20,979] INFO [Broker id=2] Follower __consumer_offsets-46 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:20.984984089Z [2024-06-28 07:04:20,979] INFO [Broker id=2] Creating new partition __consumer_offsets-44 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:20.994812084Z [2024-06-28 07:04:20,993] 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-06-28T07:04:20.994826228Z [2024-06-28 07:04:20,993] 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-06-28T07:04:20.994829968Z [2024-06-28 07:04:20,993] INFO [Partition __consumer_offsets-44 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-44 (kafka.cluster.Partition) 2024-06-28T07:04:20.994832987Z [2024-06-28 07:04:20,993] INFO [Partition __consumer_offsets-44 broker=2] Log loaded for partition __consumer_offsets-44 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:20.994836539Z [2024-06-28 07:04:20,993] INFO [Broker id=2] Follower __consumer_offsets-44 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:20.994840060Z [2024-06-28 07:04:20,993] INFO [Broker id=2] Creating new partition __consumer_offsets-9 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:21.023270967Z [2024-06-28 07:04:21,020] 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-06-28T07:04:21.028697684Z [2024-06-28 07:04:21,028] 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-06-28T07:04:21.029276551Z [2024-06-28 07:04:21,029] INFO [Partition __consumer_offsets-9 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-9 (kafka.cluster.Partition) 2024-06-28T07:04:21.030224249Z [2024-06-28 07:04:21,030] INFO [Partition __consumer_offsets-9 broker=2] Log loaded for partition __consumer_offsets-9 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:21.040050020Z [2024-06-28 07:04:21,038] INFO [Broker id=2] Follower __consumer_offsets-9 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:21.042183304Z [2024-06-28 07:04:21,041] INFO [Broker id=2] Creating new partition __consumer_offsets-42 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:21.083469636Z [2024-06-28 07:04:21,083] 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-06-28T07:04:21.107602305Z [2024-06-28 07:04:21,092] 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-06-28T07:04:21.107619551Z [2024-06-28 07:04:21,105] INFO [Partition __consumer_offsets-42 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-42 (kafka.cluster.Partition) 2024-06-28T07:04:21.107623075Z [2024-06-28 07:04:21,106] INFO [Partition __consumer_offsets-42 broker=2] Log loaded for partition __consumer_offsets-42 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:21.107626923Z [2024-06-28 07:04:21,106] INFO [Broker id=2] Follower __consumer_offsets-42 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:21.107630448Z [2024-06-28 07:04:21,106] INFO [Broker id=2] Creating new partition __consumer_offsets-23 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:21.124115185Z [2024-06-28 07:04:21,123] 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-06-28T07:04:21.125075712Z [2024-06-28 07:04:21,124] 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-06-28T07:04:21.125353755Z [2024-06-28 07:04:21,125] INFO [Partition __consumer_offsets-23 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-23 (kafka.cluster.Partition) 2024-06-28T07:04:21.131043111Z [2024-06-28 07:04:21,126] INFO [Partition __consumer_offsets-23 broker=2] Log loaded for partition __consumer_offsets-23 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:21.133608851Z [2024-06-28 07:04:21,126] INFO [Broker id=2] Follower __consumer_offsets-23 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:21.133617747Z [2024-06-28 07:04:21,126] INFO [Broker id=2] Creating new partition __consumer_offsets-21 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:21.133661646Z [2024-06-28 07:04:21,130] 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-06-28T07:04:21.133679329Z [2024-06-28 07:04:21,133] 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-06-28T07:04:21.133690406Z [2024-06-28 07:04:21,133] INFO [Partition __consumer_offsets-21 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-21 (kafka.cluster.Partition) 2024-06-28T07:04:21.133702925Z [2024-06-28 07:04:21,133] INFO [Partition __consumer_offsets-21 broker=2] Log loaded for partition __consumer_offsets-21 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:21.134267386Z [2024-06-28 07:04:21,134] INFO [Broker id=2] Follower __consumer_offsets-21 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:21.134403423Z [2024-06-28 07:04:21,134] INFO [Broker id=2] Creating new partition __consumer_offsets-19 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:21.151631440Z [2024-06-28 07:04:21,142] 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-06-28T07:04:21.152122862Z [2024-06-28 07:04:21,142] 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-06-28T07:04:21.152127422Z [2024-06-28 07:04:21,143] INFO [Partition __consumer_offsets-19 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-19 (kafka.cluster.Partition) 2024-06-28T07:04:21.152130707Z [2024-06-28 07:04:21,143] INFO [Partition __consumer_offsets-19 broker=2] Log loaded for partition __consumer_offsets-19 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:21.152134662Z [2024-06-28 07:04:21,143] INFO [Broker id=2] Follower __consumer_offsets-19 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:21.152144136Z [2024-06-28 07:04:21,143] INFO [Broker id=2] Creating new partition __consumer_offsets-30 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:21.169144747Z [2024-06-28 07:04:21,166] 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-06-28T07:04:21.169159606Z [2024-06-28 07:04:21,168] 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-06-28T07:04:21.169166891Z [2024-06-28 07:04:21,169] INFO [Partition __consumer_offsets-30 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-30 (kafka.cluster.Partition) 2024-06-28T07:04:21.169208625Z [2024-06-28 07:04:21,169] INFO [Partition __consumer_offsets-30 broker=2] Log loaded for partition __consumer_offsets-30 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:21.175658588Z [2024-06-28 07:04:21,171] INFO [Broker id=2] Follower __consumer_offsets-30 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:21.188468471Z [2024-06-28 07:04:21,171] INFO [Broker id=2] Creating new partition __consumer_offsets-28 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:21.191152040Z [2024-06-28 07:04:21,191] 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-06-28T07:04:21.206039883Z [2024-06-28 07:04:21,205] 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-06-28T07:04:21.206066316Z [2024-06-28 07:04:21,205] INFO [Partition __consumer_offsets-28 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-28 (kafka.cluster.Partition) 2024-06-28T07:04:21.209238864Z [2024-06-28 07:04:21,205] INFO [Partition __consumer_offsets-28 broker=2] Log loaded for partition __consumer_offsets-28 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:21.209252367Z [2024-06-28 07:04:21,208] INFO [Broker id=2] Follower __consumer_offsets-28 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:21.209256505Z [2024-06-28 07:04:21,208] INFO [Broker id=2] Creating new partition __consumer_offsets-26 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:21.227263696Z [2024-06-28 07:04:21,226] 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-06-28T07:04:21.244129221Z [2024-06-28 07:04:21,237] 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-06-28T07:04:21.244292790Z [2024-06-28 07:04:21,241] INFO [Partition __consumer_offsets-26 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-26 (kafka.cluster.Partition) 2024-06-28T07:04:21.244297361Z [2024-06-28 07:04:21,241] INFO [Partition __consumer_offsets-26 broker=2] Log loaded for partition __consumer_offsets-26 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:21.244301923Z [2024-06-28 07:04:21,241] INFO [Broker id=2] Follower __consumer_offsets-26 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-06-28T07:04:21.244305542Z [2024-06-28 07:04:21,241] INFO [Broker id=2] Creating new partition __consumer_offsets-7 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:21.248139831Z [2024-06-28 07:04:21,247] 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-06-28T07:04:21.248241544Z [2024-06-28 07:04:21,248] 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-06-28T07:04:21.248591665Z [2024-06-28 07:04:21,248] INFO [Partition __consumer_offsets-7 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-7 (kafka.cluster.Partition) 2024-06-28T07:04:21.248601154Z [2024-06-28 07:04:21,248] INFO [Partition __consumer_offsets-7 broker=2] Log loaded for partition __consumer_offsets-7 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:21.248605091Z [2024-06-28 07:04:21,248] INFO [Broker id=2] Follower __consumer_offsets-7 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:21.248717702Z [2024-06-28 07:04:21,248] INFO [Broker id=2] Creating new partition __consumer_offsets-40 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:21.268142783Z [2024-06-28 07:04:21,265] 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-06-28T07:04:21.268237814Z [2024-06-28 07:04:21,268] 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-06-28T07:04:21.268926794Z [2024-06-28 07:04:21,268] INFO [Partition __consumer_offsets-40 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-40 (kafka.cluster.Partition) 2024-06-28T07:04:21.278602486Z [2024-06-28 07:04:21,276] INFO [Partition __consumer_offsets-40 broker=2] Log loaded for partition __consumer_offsets-40 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:21.278613311Z [2024-06-28 07:04:21,277] INFO [Broker id=2] Follower __consumer_offsets-40 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:21.278616759Z [2024-06-28 07:04:21,277] INFO [Broker id=2] Creating new partition __consumer_offsets-5 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:21.282182983Z [2024-06-28 07:04:21,282] 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-06-28T07:04:21.283550520Z [2024-06-28 07:04:21,282] 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-06-28T07:04:21.283602632Z [2024-06-28 07:04:21,282] INFO [Partition __consumer_offsets-5 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-5 (kafka.cluster.Partition) 2024-06-28T07:04:21.283606764Z [2024-06-28 07:04:21,283] INFO [Partition __consumer_offsets-5 broker=2] Log loaded for partition __consumer_offsets-5 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:21.283610111Z [2024-06-28 07:04:21,283] INFO [Broker id=2] Follower __consumer_offsets-5 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:21.283613660Z [2024-06-28 07:04:21,283] INFO [Broker id=2] Creating new partition __consumer_offsets-38 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:21.291729391Z [2024-06-28 07:04:21,288] 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-06-28T07:04:21.291745604Z [2024-06-28 07:04:21,289] 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-06-28T07:04:21.291749706Z [2024-06-28 07:04:21,289] INFO [Partition __consumer_offsets-38 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-38 (kafka.cluster.Partition) 2024-06-28T07:04:21.291753066Z [2024-06-28 07:04:21,289] INFO [Partition __consumer_offsets-38 broker=2] Log loaded for partition __consumer_offsets-38 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:21.291756700Z [2024-06-28 07:04:21,289] INFO [Broker id=2] Follower __consumer_offsets-38 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:21.291766747Z [2024-06-28 07:04:21,289] INFO [Broker id=2] Creating new partition __consumer_offsets-3 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:21.292260353Z [2024-06-28 07:04:21,291] 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-06-28T07:04:21.293507334Z [2024-06-28 07:04:21,292] 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-06-28T07:04:21.293531061Z [2024-06-28 07:04:21,292] INFO [Partition __consumer_offsets-3 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-3 (kafka.cluster.Partition) 2024-06-28T07:04:21.293534459Z [2024-06-28 07:04:21,292] INFO [Partition __consumer_offsets-3 broker=2] Log loaded for partition __consumer_offsets-3 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:21.293537596Z [2024-06-28 07:04:21,292] INFO [Broker id=2] Follower __consumer_offsets-3 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:21.293541072Z [2024-06-28 07:04:21,292] INFO [Broker id=2] Creating new partition __consumer_offsets-36 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:21.294959476Z [2024-06-28 07:04:21,294] 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-06-28T07:04:21.295306016Z [2024-06-28 07:04:21,295] 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-06-28T07:04:21.295347921Z [2024-06-28 07:04:21,295] INFO [Partition __consumer_offsets-36 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-36 (kafka.cluster.Partition) 2024-06-28T07:04:21.295400530Z [2024-06-28 07:04:21,295] INFO [Partition __consumer_offsets-36 broker=2] Log loaded for partition __consumer_offsets-36 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:21.295429004Z [2024-06-28 07:04:21,295] INFO [Broker id=2] Follower __consumer_offsets-36 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:21.295493325Z [2024-06-28 07:04:21,295] INFO [Broker id=2] Creating new partition __consumer_offsets-1 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:21.300743108Z [2024-06-28 07:04:21,297] 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-06-28T07:04:21.300759513Z [2024-06-28 07:04:21,298] 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-06-28T07:04:21.300763762Z [2024-06-28 07:04:21,298] INFO [Partition __consumer_offsets-1 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-1 (kafka.cluster.Partition) 2024-06-28T07:04:21.300767256Z [2024-06-28 07:04:21,298] INFO [Partition __consumer_offsets-1 broker=2] Log loaded for partition __consumer_offsets-1 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:21.300770558Z [2024-06-28 07:04:21,298] INFO [Broker id=2] Follower __consumer_offsets-1 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:21.300774315Z [2024-06-28 07:04:21,298] INFO [Broker id=2] Creating new partition __consumer_offsets-34 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:21.309733896Z [2024-06-28 07:04:21,309] 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-06-28T07:04:21.310509858Z [2024-06-28 07:04:21,309] 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-06-28T07:04:21.310516051Z [2024-06-28 07:04:21,309] INFO [Partition __consumer_offsets-34 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-34 (kafka.cluster.Partition) 2024-06-28T07:04:21.310518964Z [2024-06-28 07:04:21,309] INFO [Partition __consumer_offsets-34 broker=2] Log loaded for partition __consumer_offsets-34 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:21.310522285Z [2024-06-28 07:04:21,309] INFO [Broker id=2] Follower __consumer_offsets-34 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:21.310525479Z [2024-06-28 07:04:21,310] INFO [Broker id=2] Creating new partition __consumer_offsets-47 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:21.318018923Z [2024-06-28 07:04:21,313] 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-06-28T07:04:21.318032545Z [2024-06-28 07:04:21,313] 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-06-28T07:04:21.318036589Z [2024-06-28 07:04:21,313] INFO [Partition __consumer_offsets-47 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-47 (kafka.cluster.Partition) 2024-06-28T07:04:21.318039474Z [2024-06-28 07:04:21,313] INFO [Partition __consumer_offsets-47 broker=2] Log loaded for partition __consumer_offsets-47 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:21.318042979Z [2024-06-28 07:04:21,313] INFO [Broker id=2] Follower __consumer_offsets-47 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:21.318046379Z [2024-06-28 07:04:21,313] INFO [Broker id=2] Creating new partition __consumer_offsets-16 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:21.318049299Z [2024-06-28 07:04:21,317] 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-06-28T07:04:21.318052223Z [2024-06-28 07:04:21,317] 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-06-28T07:04:21.318055285Z [2024-06-28 07:04:21,317] INFO [Partition __consumer_offsets-16 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-16 (kafka.cluster.Partition) 2024-06-28T07:04:21.318058067Z [2024-06-28 07:04:21,317] INFO [Partition __consumer_offsets-16 broker=2] Log loaded for partition __consumer_offsets-16 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:21.318060924Z [2024-06-28 07:04:21,317] INFO [Broker id=2] Follower __consumer_offsets-16 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:21.318063666Z [2024-06-28 07:04:21,317] INFO [Broker id=2] Creating new partition __consumer_offsets-14 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:21.321336676Z [2024-06-28 07:04:21,321] 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-06-28T07:04:21.322467000Z [2024-06-28 07:04:21,321] 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-06-28T07:04:21.332829627Z [2024-06-28 07:04:21,321] INFO [Partition __consumer_offsets-14 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-14 (kafka.cluster.Partition) 2024-06-28T07:04:21.332837376Z [2024-06-28 07:04:21,321] INFO [Partition __consumer_offsets-14 broker=2] Log loaded for partition __consumer_offsets-14 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:21.332841936Z [2024-06-28 07:04:21,322] INFO [Broker id=2] Follower __consumer_offsets-14 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:21.332845797Z [2024-06-28 07:04:21,322] INFO [Broker id=2] Creating new partition __consumer_offsets-10 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:21.361126370Z [2024-06-28 07:04:21,360] 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-06-28T07:04:21.371680761Z [2024-06-28 07:04:21,361] 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-06-28T07:04:21.372979977Z [2024-06-28 07:04:21,361] INFO [Partition __consumer_offsets-10 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-10 (kafka.cluster.Partition) 2024-06-28T07:04:21.372985456Z [2024-06-28 07:04:21,361] INFO [Partition __consumer_offsets-10 broker=2] Log loaded for partition __consumer_offsets-10 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:21.372989673Z [2024-06-28 07:04:21,362] INFO [Broker id=2] Follower __consumer_offsets-10 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:21.372998201Z [2024-06-28 07:04:21,362] INFO [Broker id=2] Creating new partition __consumer_offsets-20 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:21.373002017Z [2024-06-28 07:04:21,365] 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-06-28T07:04:21.373005608Z [2024-06-28 07:04:21,365] 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-06-28T07:04:21.373008881Z [2024-06-28 07:04:21,365] INFO [Partition __consumer_offsets-20 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-20 (kafka.cluster.Partition) 2024-06-28T07:04:21.373012161Z [2024-06-28 07:04:21,365] INFO [Partition __consumer_offsets-20 broker=2] Log loaded for partition __consumer_offsets-20 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:21.373015345Z [2024-06-28 07:04:21,366] INFO [Broker id=2] Follower __consumer_offsets-20 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:21.373018394Z [2024-06-28 07:04:21,366] INFO [Broker id=2] Creating new partition __consumer_offsets-49 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:21.383785349Z [2024-06-28 07:04:21,378] 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-06-28T07:04:21.383804104Z [2024-06-28 07:04:21,379] 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-06-28T07:04:21.383808112Z [2024-06-28 07:04:21,379] INFO [Partition __consumer_offsets-49 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-49 (kafka.cluster.Partition) 2024-06-28T07:04:21.383811252Z [2024-06-28 07:04:21,379] INFO [Partition __consumer_offsets-49 broker=2] Log loaded for partition __consumer_offsets-49 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:21.383815125Z [2024-06-28 07:04:21,379] INFO [Broker id=2] 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-06-28T07:04:21.383819072Z [2024-06-28 07:04:21,379] INFO [Broker id=2] Creating new partition __consumer_offsets-31 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:21.392563037Z [2024-06-28 07:04:21,384] 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-06-28T07:04:21.392579389Z [2024-06-28 07:04:21,385] 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-06-28T07:04:21.392583507Z [2024-06-28 07:04:21,385] INFO [Partition __consumer_offsets-31 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-31 (kafka.cluster.Partition) 2024-06-28T07:04:21.392587179Z [2024-06-28 07:04:21,385] INFO [Partition __consumer_offsets-31 broker=2] Log loaded for partition __consumer_offsets-31 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:21.392591642Z [2024-06-28 07:04:21,385] INFO [Broker id=2] Follower __consumer_offsets-31 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:21.392595734Z [2024-06-28 07:04:21,385] INFO [Broker id=2] Creating new partition __consumer_offsets-0 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:21.466457430Z [2024-06-28 07:04:21,466] 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-06-28T07:04:21.478624711Z [2024-06-28 07:04:21,476] 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-06-28T07:04:21.481880450Z [2024-06-28 07:04:21,480] INFO [Partition __consumer_offsets-0 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-0 (kafka.cluster.Partition) 2024-06-28T07:04:21.484197006Z [2024-06-28 07:04:21,481] INFO [Partition __consumer_offsets-0 broker=2] Log loaded for partition __consumer_offsets-0 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:21.484205956Z [2024-06-28 07:04:21,481] INFO [Broker id=2] Follower __consumer_offsets-0 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:21.484219088Z [2024-06-28 07:04:21,481] INFO [Broker id=2] Creating new partition __consumer_offsets-29 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:21.539223193Z [2024-06-28 07:04:21,539] 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-06-28T07:04:21.617456782Z [2024-06-28 07:04:21,590] 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-06-28T07:04:21.619435219Z [2024-06-28 07:04:21,619] INFO [Partition __consumer_offsets-29 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-29 (kafka.cluster.Partition) 2024-06-28T07:04:21.620036336Z [2024-06-28 07:04:21,619] INFO [Partition __consumer_offsets-29 broker=2] Log loaded for partition __consumer_offsets-29 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:21.623757740Z [2024-06-28 07:04:21,623] INFO [Broker id=2] Follower __consumer_offsets-29 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:21.623876097Z [2024-06-28 07:04:21,623] INFO [Broker id=2] Creating new partition __consumer_offsets-25 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:21.730583228Z [2024-06-28 07:04:21,730] 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-06-28T07:04:21.798688785Z [2024-06-28 07:04:21,769] 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-06-28T07:04:21.798817297Z [2024-06-28 07:04:21,798] INFO [Partition __consumer_offsets-25 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-25 (kafka.cluster.Partition) 2024-06-28T07:04:21.798881174Z [2024-06-28 07:04:21,798] INFO [Partition __consumer_offsets-25 broker=2] Log loaded for partition __consumer_offsets-25 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:21.798950476Z [2024-06-28 07:04:21,798] INFO [Broker id=2] Follower __consumer_offsets-25 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:21.799054237Z [2024-06-28 07:04:21,798] INFO [Broker id=2] Creating new partition __consumer_offsets-39 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:21.850227025Z [2024-06-28 07:04:21,823] 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-06-28T07:04:21.905287463Z [2024-06-28 07:04:21,900] 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-06-28T07:04:21.905297493Z [2024-06-28 07:04:21,900] INFO [Partition __consumer_offsets-39 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-39 (kafka.cluster.Partition) 2024-06-28T07:04:21.905300751Z [2024-06-28 07:04:21,900] INFO [Partition __consumer_offsets-39 broker=2] Log loaded for partition __consumer_offsets-39 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:21.905304122Z [2024-06-28 07:04:21,900] INFO [Broker id=2] Follower __consumer_offsets-39 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 1. Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:21.914452795Z [2024-06-28 07:04:21,914] INFO [Broker id=2] Creating new partition __consumer_offsets-6 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:22.212910609Z [2024-06-28 07:04:22,212] 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-06-28T07:04:22.216072449Z [2024-06-28 07:04:22,215] 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-06-28T07:04:22.216088552Z [2024-06-28 07:04:22,215] INFO [Partition __consumer_offsets-6 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-6 (kafka.cluster.Partition) 2024-06-28T07:04:22.216092244Z [2024-06-28 07:04:22,215] INFO [Partition __consumer_offsets-6 broker=2] Log loaded for partition __consumer_offsets-6 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:22.216101855Z [2024-06-28 07:04:22,216] INFO [Broker id=2] Follower __consumer_offsets-6 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-06-28T07:04:22.216342018Z [2024-06-28 07:04:22,216] INFO [Broker id=2] Creating new partition __consumer_offsets-35 with topic id ZT49BHyVTgSexosJvrYoDQ. (state.change.logger) 2024-06-28T07:04:22.242276301Z [2024-06-28 07:04:22,242] 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-06-28T07:04:22.249787297Z [2024-06-28 07:04:22,249] 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-06-28T07:04:22.249859145Z [2024-06-28 07:04:22,249] INFO [Partition __consumer_offsets-35 broker=2] No checkpointed highwatermark is found for partition __consumer_offsets-35 (kafka.cluster.Partition) 2024-06-28T07:04:22.249863861Z [2024-06-28 07:04:22,249] INFO [Partition __consumer_offsets-35 broker=2] Log loaded for partition __consumer_offsets-35 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:22.249916224Z [2024-06-28 07:04:22,249] INFO [Broker id=2] Follower __consumer_offsets-35 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:22.251794845Z [2024-06-28 07:04:22,251] INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(__consumer_offsets-49, __consumer_offsets-38, __consumer_offsets-16, __consumer_offsets-19, __consumer_offsets-13, __consumer_offsets-35, __consumer_offsets-46, __consumer_offsets-5, __consumer_offsets-21, __consumer_offsets-10, __consumer_offsets-29, __consumer_offsets-40, __consumer_offsets-7, __consumer_offsets-23, __consumer_offsets-34, __consumer_offsets-26, __consumer_offsets-15, __consumer_offsets-42, __consumer_offsets-31, __consumer_offsets-9, __consumer_offsets-20, __consumer_offsets-1, __consumer_offsets-6, __consumer_offsets-28, __consumer_offsets-39, __consumer_offsets-44, __consumer_offsets-36, __consumer_offsets-47, __consumer_offsets-25, __consumer_offsets-3, __consumer_offsets-14, __consumer_offsets-30, __consumer_offsets-0) (kafka.server.ReplicaFetcherManager) 2024-06-28T07:04:22.254775997Z [2024-06-28 07:04:22,254] INFO [Broker id=2] Stopped fetchers as part of become-follower for 33 partitions (state.change.logger) 2024-06-28T07:04:22.390560733Z [2024-06-28 07:04:22,389] INFO Sent auto-creation request for Set(admin) to the active controller. (kafka.server.DefaultAutoTopicCreationManager) 2024-06-28T07:04:22.412987720Z [2024-06-28 07:04:22,412] INFO [ReplicaFetcherThread-0-1]: Starting (kafka.server.ReplicaFetcherThread) 2024-06-28T07:04:22.433899191Z [2024-06-28 07:04:22,433] INFO [ReplicaFetcherManager on broker 2] Added fetcher to broker 1 for partitions Map(__consumer_offsets-38 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=1, host=kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-16 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=1, host=kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-5 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=1, host=kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-21 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=1, host=kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-7 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=1, host=kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-34 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=1, host=kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-9 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=1, host=kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-20 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=1, host=kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-1 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=1, host=kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-28 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=1, host=kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-39 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=1, host=kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-44 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=1, host=kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-47 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=1, host=kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-25 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=1, host=kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-14 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=1, host=kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-30 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=1, host=kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094),0,0)) (kafka.server.ReplicaFetcherManager) 2024-06-28T07:04:22.455574342Z [2024-06-28 07:04:22,452] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition __consumer_offsets-28 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-06-28T07:04:22.459545772Z [2024-06-28 07:04:22,456] INFO [UnifiedLog partition=__consumer_offsets-28, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog) 2024-06-28T07:04:22.461609511Z [2024-06-28 07:04:22,460] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition __consumer_offsets-39 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-06-28T07:04:22.461647671Z [2024-06-28 07:04:22,460] 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-06-28T07:04:22.461651877Z [2024-06-28 07:04:22,460] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition __consumer_offsets-21 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-06-28T07:04:22.461655559Z [2024-06-28 07:04:22,460] 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-06-28T07:04:22.461659417Z [2024-06-28 07:04:22,460] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition __consumer_offsets-47 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-06-28T07:04:22.461662658Z [2024-06-28 07:04:22,460] 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-06-28T07:04:22.461665890Z [2024-06-28 07:04:22,460] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition __consumer_offsets-44 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-06-28T07:04:22.461669080Z [2024-06-28 07:04:22,460] 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-06-28T07:04:22.461672289Z [2024-06-28 07:04:22,460] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition __consumer_offsets-25 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-06-28T07:04:22.461675349Z [2024-06-28 07:04:22,460] 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-06-28T07:04:22.461701823Z [2024-06-28 07:04:22,460] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition __consumer_offsets-14 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-06-28T07:04:22.461705313Z [2024-06-28 07:04:22,460] 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-06-28T07:04:22.461708472Z [2024-06-28 07:04:22,460] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition __consumer_offsets-7 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-06-28T07:04:22.461711469Z [2024-06-28 07:04:22,460] 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-06-28T07:04:22.461714580Z [2024-06-28 07:04:22,460] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition __consumer_offsets-30 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-06-28T07:04:22.461717682Z [2024-06-28 07:04:22,460] 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-06-28T07:04:22.461720815Z [2024-06-28 07:04:22,460] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition __consumer_offsets-34 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-06-28T07:04:22.461731073Z [2024-06-28 07:04:22,461] INFO [UnifiedLog partition=__consumer_offsets-34, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog) 2024-06-28T07:04:22.461747608Z [2024-06-28 07:04:22,461] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition __consumer_offsets-38 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-06-28T07:04:22.461751520Z [2024-06-28 07:04:22,461] 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-06-28T07:04:22.461754610Z [2024-06-28 07:04:22,461] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition __consumer_offsets-16 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-06-28T07:04:22.461757633Z [2024-06-28 07:04:22,461] 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-06-28T07:04:22.461760847Z [2024-06-28 07:04:22,461] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition __consumer_offsets-1 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-06-28T07:04:22.461763902Z [2024-06-28 07:04:22,461] INFO [UnifiedLog partition=__consumer_offsets-1, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog) 2024-06-28T07:04:22.461766875Z [2024-06-28 07:04:22,461] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition __consumer_offsets-9 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-06-28T07:04:22.461769878Z [2024-06-28 07:04:22,461] 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-06-28T07:04:22.461772821Z [2024-06-28 07:04:22,461] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition __consumer_offsets-20 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-06-28T07:04:22.461775923Z [2024-06-28 07:04:22,461] 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-06-28T07:04:22.461782448Z [2024-06-28 07:04:22,461] INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Truncating partition __consumer_offsets-5 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-06-28T07:04:22.461785524Z [2024-06-28 07:04:22,461] 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-06-28T07:04:22.862500742Z [2024-06-28 07:04:22,836] INFO [ReplicaFetcherManager on broker 2] Added fetcher to broker 0 for partitions Map(__consumer_offsets-49 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-19 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-13 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-46 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-35 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-10 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-40 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-29 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-23 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-26 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-15 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-42 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-31 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-6 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-36 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-3 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-0 -> InitialFetchState(Some(ZT49BHyVTgSexosJvrYoDQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0)) (kafka.server.ReplicaFetcherManager) 2024-06-28T07:04:22.862526998Z [2024-06-28 07:04:22,855] INFO [Broker id=2] Started fetchers as part of become-follower for 33 partitions (state.change.logger) 2024-06-28T07:04:22.871594260Z [2024-06-28 07:04:22,849] INFO [ReplicaFetcherThread-0-0]: Starting (kafka.server.ReplicaFetcherThread) 2024-06-28T07:04:22.871607425Z [2024-06-28 07:04:22,870] INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-6 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-06-28T07:04:22.871611678Z [2024-06-28 07:04:22,870] INFO [UnifiedLog partition=__consumer_offsets-6, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog) 2024-06-28T07:04:22.871614850Z [2024-06-28 07:04:22,870] INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-10 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-06-28T07:04:22.871618040Z [2024-06-28 07:04:22,870] 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-06-28T07:04:22.871621193Z [2024-06-28 07:04:22,870] INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-36 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-06-28T07:04:22.873187602Z [2024-06-28 07:04:22,871] INFO [QuorumController id=2] Created topic admin with topic ID Pjo-yH4IQ7-djrUxJwcfHQ. (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:04:22.873196846Z [2024-06-28 07:04:22,871] INFO [QuorumController id=2] Created partition admin-0 with topic ID Pjo-yH4IQ7-djrUxJwcfHQ and PartitionRegistration(replicas=[0], isr=[0], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:04:22.875318737Z [2024-06-28 07:04:22,875] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 48 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.887303272Z [2024-06-28 07:04:22,882] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-48 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.888424976Z [2024-06-28 07:04:22,887] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 45 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.895152489Z [2024-06-28 07:04:22,887] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-45 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.937512971Z [2024-06-28 07:04:22,892] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 11 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.939049785Z [2024-06-28 07:04:22,938] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-11 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.939978745Z [2024-06-28 07:04:22,939] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 43 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.939986185Z [2024-06-28 07:04:22,939] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-43 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.939989535Z [2024-06-28 07:04:22,939] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 12 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.939992913Z [2024-06-28 07:04:22,939] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-12 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.939997043Z [2024-06-28 07:04:22,939] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 41 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.940000522Z [2024-06-28 07:04:22,939] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-41 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.940003514Z [2024-06-28 07:04:22,939] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 24 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.940006524Z [2024-06-28 07:04:22,939] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-24 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.940009622Z [2024-06-28 07:04:22,939] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 22 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.940012677Z [2024-06-28 07:04:22,939] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-22 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.940015696Z [2024-06-28 07:04:22,939] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 17 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.940026258Z [2024-06-28 07:04:22,939] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-17 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.940029609Z [2024-06-28 07:04:22,939] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 18 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.940032717Z [2024-06-28 07:04:22,939] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-18 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.940038786Z [2024-06-28 07:04:22,939] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 32 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.940041883Z [2024-06-28 07:04:22,939] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-32 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.940044893Z [2024-06-28 07:04:22,939] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 27 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.940048026Z [2024-06-28 07:04:22,939] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-27 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.940051050Z [2024-06-28 07:04:22,939] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 8 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.940054201Z [2024-06-28 07:04:22,939] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-8 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.940057298Z [2024-06-28 07:04:22,939] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 37 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.940060428Z [2024-06-28 07:04:22,939] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-37 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.940063443Z [2024-06-28 07:04:22,939] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 4 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.940067899Z [2024-06-28 07:04:22,939] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-4 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.940070985Z [2024-06-28 07:04:22,939] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 33 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.940074053Z [2024-06-28 07:04:22,939] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-33 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.940077111Z [2024-06-28 07:04:22,939] INFO [GroupCoordinator 2]: Elected as the group coordinator for partition 2 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.940080331Z [2024-06-28 07:04:22,939] INFO [GroupMetadataManager brokerId=2] Scheduling loading of offsets and group metadata from __consumer_offsets-2 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.947415283Z [2024-06-28 07:04:22,944] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 15 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.947425478Z [2024-06-28 07:04:22,945] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-15 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.947437343Z [2024-06-28 07:04:22,945] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 13 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.947440695Z [2024-06-28 07:04:22,945] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-13 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.947443845Z [2024-06-28 07:04:22,945] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 46 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.947447186Z [2024-06-28 07:04:22,945] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-46 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.947450362Z [2024-06-28 07:04:22,945] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 44 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.947453465Z [2024-06-28 07:04:22,945] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-44 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.955567886Z [2024-06-28 07:04:22,955] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 9 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.955587575Z [2024-06-28 07:04:22,955] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-9 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.958070809Z [2024-06-28 07:04:22,956] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 42 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.958085082Z [2024-06-28 07:04:22,956] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-42 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.958088792Z [2024-06-28 07:04:22,956] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 23 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.958091931Z [2024-06-28 07:04:22,956] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-23 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.958095063Z [2024-06-28 07:04:22,956] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 21 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.958098213Z [2024-06-28 07:04:22,956] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-21 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.958101155Z [2024-06-28 07:04:22,956] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 19 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.958104068Z [2024-06-28 07:04:22,956] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-19 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.958106973Z [2024-06-28 07:04:22,956] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 30 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.958110247Z [2024-06-28 07:04:22,956] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-30 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.958121011Z [2024-06-28 07:04:22,956] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 28 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.958123977Z [2024-06-28 07:04:22,956] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-28 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.958126921Z [2024-06-28 07:04:22,956] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 26 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.958129873Z [2024-06-28 07:04:22,956] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-26 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.958132754Z [2024-06-28 07:04:22,956] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 7 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.958135639Z [2024-06-28 07:04:22,956] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-7 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.958138542Z [2024-06-28 07:04:22,956] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 40 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.958141514Z [2024-06-28 07:04:22,956] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-40 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.958144425Z [2024-06-28 07:04:22,956] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 5 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.958147424Z [2024-06-28 07:04:22,956] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-5 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.958150333Z [2024-06-28 07:04:22,956] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 38 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.958153284Z [2024-06-28 07:04:22,956] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-38 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.958158721Z [2024-06-28 07:04:22,956] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 3 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.958161757Z [2024-06-28 07:04:22,956] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-3 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.958164662Z [2024-06-28 07:04:22,956] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 36 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.958167578Z [2024-06-28 07:04:22,956] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-36 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.958170509Z [2024-06-28 07:04:22,956] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 1 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.958173339Z [2024-06-28 07:04:22,956] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-1 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.958176268Z [2024-06-28 07:04:22,956] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 34 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.958182576Z [2024-06-28 07:04:22,956] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-34 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.958185518Z [2024-06-28 07:04:22,956] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 47 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.958188461Z [2024-06-28 07:04:22,956] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-47 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.958191299Z [2024-06-28 07:04:22,956] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 16 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.958198939Z [2024-06-28 07:04:22,956] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-16 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.958202204Z [2024-06-28 07:04:22,956] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 14 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.958205434Z [2024-06-28 07:04:22,956] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-14 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.958208404Z [2024-06-28 07:04:22,956] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 10 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.958211708Z [2024-06-28 07:04:22,956] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-10 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.958216815Z [2024-06-28 07:04:22,956] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 20 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.958219962Z [2024-06-28 07:04:22,956] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-20 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.958223260Z [2024-06-28 07:04:22,956] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 49 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.958226429Z [2024-06-28 07:04:22,956] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-49 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.958229585Z [2024-06-28 07:04:22,957] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 31 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.958232487Z [2024-06-28 07:04:22,957] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-31 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.958245533Z [2024-06-28 07:04:22,957] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 0 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.958248972Z [2024-06-28 07:04:22,957] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-0 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.958252016Z [2024-06-28 07:04:22,957] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 29 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.958258468Z [2024-06-28 07:04:22,957] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-29 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.963605773Z [2024-06-28 07:04:22,957] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 25 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.963618646Z [2024-06-28 07:04:22,960] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-25 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.963622008Z [2024-06-28 07:04:22,960] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 39 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.963625261Z [2024-06-28 07:04:22,960] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-39 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.963628443Z [2024-06-28 07:04:22,960] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 6 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.963631507Z [2024-06-28 07:04:22,960] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-6 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.963634733Z [2024-06-28 07:04:22,960] INFO [GroupCoordinator 2]: Resigned as the group coordinator for partition 35 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:04:22.963637664Z [2024-06-28 07:04:22,960] INFO [GroupMetadataManager brokerId=2] Scheduling unloading of offsets and group metadata from __consumer_offsets-35 (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:22.988169880Z [2024-06-28 07:04:22,986] INFO [DynamicConfigPublisher broker id=2] Updating topic __consumer_offsets with new configuration : cleanup.policy -> compact,segment.bytes -> 104857600,compression.type -> producer (kafka.server.metadata.DynamicConfigPublisher) 2024-06-28T07:04:23.026827737Z [2024-06-28 07:04:23,009] INFO [UnifiedLog partition=__consumer_offsets-36, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog) 2024-06-28T07:04:23.026842528Z [2024-06-28 07:04:23,010] INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-3 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-06-28T07:04:23.026852931Z [2024-06-28 07:04:23,010] INFO [UnifiedLog partition=__consumer_offsets-3, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog) 2024-06-28T07:04:23.026856904Z [2024-06-28 07:04:23,010] INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-40 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-06-28T07:04:23.026860116Z [2024-06-28 07:04:23,010] 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-06-28T07:04:23.026863209Z [2024-06-28 07:04:23,010] INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-29 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-06-28T07:04:23.026866213Z [2024-06-28 07:04:23,010] 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-06-28T07:04:23.026888456Z [2024-06-28 07:04:23,010] INFO [ReplicaFetcher replicaId=2, 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-06-28T07:04:23.026891560Z [2024-06-28 07:04:23,010] 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-06-28T07:04:23.026894546Z [2024-06-28 07:04:23,010] INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-26 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-06-28T07:04:23.026897551Z [2024-06-28 07:04:23,010] INFO [UnifiedLog partition=__consumer_offsets-26, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog) 2024-06-28T07:04:23.026900600Z [2024-06-28 07:04:23,010] INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-23 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-06-28T07:04:23.026903747Z [2024-06-28 07:04:23,010] INFO [UnifiedLog partition=__consumer_offsets-23, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog) 2024-06-28T07:04:23.026906708Z [2024-06-28 07:04:23,010] INFO [ReplicaFetcher replicaId=2, 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-06-28T07:04:23.026909758Z [2024-06-28 07:04:23,010] 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-06-28T07:04:23.026912753Z [2024-06-28 07:04:23,010] INFO [ReplicaFetcher replicaId=2, 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-06-28T07:04:23.026915763Z [2024-06-28 07:04:23,010] 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-06-28T07:04:23.026918737Z [2024-06-28 07:04:23,010] INFO [ReplicaFetcher replicaId=2, 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-06-28T07:04:23.026921747Z [2024-06-28 07:04:23,010] 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-06-28T07:04:23.026926413Z [2024-06-28 07:04:23,010] INFO [ReplicaFetcher replicaId=2, 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-06-28T07:04:23.026929704Z [2024-06-28 07:04:23,010] 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-06-28T07:04:23.026932650Z [2024-06-28 07:04:23,010] INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-31 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-06-28T07:04:23.026935574Z [2024-06-28 07:04:23,010] 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-06-28T07:04:23.026944891Z [2024-06-28 07:04:23,010] INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-13 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-06-28T07:04:23.026947908Z [2024-06-28 07:04:23,010] INFO [UnifiedLog partition=__consumer_offsets-13, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog) 2024-06-28T07:04:23.026950887Z [2024-06-28 07:04:23,010] INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-46 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-06-28T07:04:23.026953890Z [2024-06-28 07:04:23,010] 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-06-28T07:04:23.026956963Z [2024-06-28 07:04:23,010] INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-35 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-06-28T07:04:23.026959885Z [2024-06-28 07:04:23,010] 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-06-28T07:04:23.113564845Z [2024-06-28 07:04:23,112] INFO Sent auto-creation request for Set(ns) to the active controller. (kafka.server.DefaultAutoTopicCreationManager) 2024-06-28T07:04:23.118560673Z [2024-06-28 07:04:23,118] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-48 in 209 milliseconds for epoch 0, of which 89 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.125527338Z [2024-06-28 07:04:23,125] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-45 in 233 milliseconds for epoch 0, of which 231 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.137196532Z [2024-06-28 07:04:23,137] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-11 in 197 milliseconds for epoch 0, of which 186 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.140627549Z [2024-06-28 07:04:23,139] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-43 in 200 milliseconds for epoch 0, of which 199 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.140644283Z [2024-06-28 07:04:23,140] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-12 in 201 milliseconds for epoch 0, of which 200 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.140647916Z [2024-06-28 07:04:23,140] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-41 in 201 milliseconds for epoch 0, of which 201 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.140651189Z [2024-06-28 07:04:23,140] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-24 in 201 milliseconds for epoch 0, of which 201 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.140654398Z [2024-06-28 07:04:23,140] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-22 in 201 milliseconds for epoch 0, of which 201 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.140672618Z [2024-06-28 07:04:23,140] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-17 in 201 milliseconds for epoch 0, of which 201 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.150186819Z [2024-06-28 07:04:23,149] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-18 in 210 milliseconds for epoch 0, of which 201 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.150202608Z [2024-06-28 07:04:23,149] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-32 in 210 milliseconds for epoch 0, of which 210 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.150206289Z [2024-06-28 07:04:23,149] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-27 in 210 milliseconds for epoch 0, of which 210 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.150209629Z [2024-06-28 07:04:23,149] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-8 in 210 milliseconds for epoch 0, of which 210 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.150212982Z [2024-06-28 07:04:23,150] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-37 in 210 milliseconds for epoch 0, of which 210 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.156917573Z [2024-06-28 07:04:23,156] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-4 in 217 milliseconds for epoch 0, of which 211 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.156933742Z [2024-06-28 07:04:23,156] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-33 in 217 milliseconds for epoch 0, of which 217 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.156937117Z [2024-06-28 07:04:23,156] INFO [GroupMetadataManager brokerId=2] Finished loading offsets and group metadata from __consumer_offsets-2 in 217 milliseconds for epoch 0, of which 217 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.329796934Z [2024-06-28 07:04:23,329] INFO [QuorumController id=2] Created topic ns with topic ID pdNWe2vZS0yTNyJD6EB88A. (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:04:23.332158001Z [2024-06-28 07:04:23,329] INFO [QuorumController id=2] Created partition ns-0 with topic ID pdNWe2vZS0yTNyJD6EB88A and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:04:23.348862797Z [2024-06-28 07:04:23,348] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-15 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.348938228Z [2024-06-28 07:04:23,348] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-13 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.387172723Z [2024-06-28 07:04:23,387] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-46 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.389647397Z [2024-06-28 07:04:23,388] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-44 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.389664811Z [2024-06-28 07:04:23,388] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-9 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.389670141Z [2024-06-28 07:04:23,388] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-42 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.389674518Z [2024-06-28 07:04:23,388] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-23 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.389679103Z [2024-06-28 07:04:23,388] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-21 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.389683496Z [2024-06-28 07:04:23,388] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-19 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.389687690Z [2024-06-28 07:04:23,388] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-30 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.389692642Z [2024-06-28 07:04:23,388] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-28 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.389697225Z [2024-06-28 07:04:23,388] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-26 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.389702129Z [2024-06-28 07:04:23,388] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-7 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.389706746Z [2024-06-28 07:04:23,388] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-40 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.389711085Z [2024-06-28 07:04:23,389] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-5 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.389716054Z [2024-06-28 07:04:23,389] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-38 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.389719598Z [2024-06-28 07:04:23,389] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-3 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.389745404Z [2024-06-28 07:04:23,389] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-36 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.389750507Z [2024-06-28 07:04:23,389] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-1 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.389755122Z [2024-06-28 07:04:23,389] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-34 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.389762479Z [2024-06-28 07:04:23,389] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-47 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.396331155Z [2024-06-28 07:04:23,389] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-16 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.396345643Z [2024-06-28 07:04:23,389] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-14 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.396349212Z [2024-06-28 07:04:23,389] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-10 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.396352453Z [2024-06-28 07:04:23,389] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-20 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.396355717Z [2024-06-28 07:04:23,389] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-49 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.396359025Z [2024-06-28 07:04:23,389] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-31 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.396362201Z [2024-06-28 07:04:23,389] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-0 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.396365468Z [2024-06-28 07:04:23,389] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-29 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.396368504Z [2024-06-28 07:04:23,389] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-25 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.396371752Z [2024-06-28 07:04:23,389] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-39 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.396378519Z [2024-06-28 07:04:23,389] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-6 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.396389458Z [2024-06-28 07:04:23,389] INFO [GroupMetadataManager brokerId=2] Finished unloading __consumer_offsets-35 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-06-28T07:04:23.736271213Z [2024-06-28 07:04:23,735] INFO [QuorumController id=2] Created topic nsi with topic ID 0QKCxNnFTBqBD-HN3wayXw. (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:04:23.736284074Z [2024-06-28 07:04:23,735] INFO [QuorumController id=2] Created partition nsi-0 with topic ID 0QKCxNnFTBqBD-HN3wayXw and PartitionRegistration(replicas=[0], isr=[0], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:04:23.991635907Z [2024-06-28 07:04:23,989] INFO Sent auto-creation request for Set(vnf) to the active controller. (kafka.server.DefaultAutoTopicCreationManager) 2024-06-28T07:04:24.276860730Z [2024-06-28 07:04:24,276] INFO [QuorumController id=2] Created topic vnf with topic ID t0xSu6fmQZm9IUy18giZww. (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:04:24.276875226Z [2024-06-28 07:04:24,276] INFO [QuorumController id=2] Created partition vnf-0 with topic ID t0xSu6fmQZm9IUy18giZww and PartitionRegistration(replicas=[0], isr=[0], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:04:33.301362807Z [2024-06-28 07:04:33,300] INFO [QuorumController id=2] Created topic vim_account with topic ID sdq-MbLZR46KAUhiNGUTxw. (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:04:33.301377339Z [2024-06-28 07:04:33,301] INFO [QuorumController id=2] Created partition vim_account-0 with topic ID sdq-MbLZR46KAUhiNGUTxw and PartitionRegistration(replicas=[0], isr=[0], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:04:33.326494536Z [2024-06-28 07:04:33,319] INFO [Broker id=2] Transitioning 1 partition(s) to local leaders. (state.change.logger) 2024-06-28T07:04:33.326827068Z [2024-06-28 07:04:33,325] INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(wim_account-0) (kafka.server.ReplicaFetcherManager) 2024-06-28T07:04:33.327262013Z [2024-06-28 07:04:33,327] INFO [Broker id=2] Creating new partition wim_account-0 with topic id 5moFBW0yT7yF6jQD-MTS9Q. (state.change.logger) 2024-06-28T07:04:33.330541541Z [2024-06-28 07:04:33,330] INFO [QuorumController id=2] Created topic wim_account with topic ID 5moFBW0yT7yF6jQD-MTS9Q. (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:04:33.330563591Z [2024-06-28 07:04:33,330] INFO [QuorumController id=2] Created partition wim_account-0 with topic ID 5moFBW0yT7yF6jQD-MTS9Q and PartitionRegistration(replicas=[2], isr=[2], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:04:33.355292545Z [2024-06-28 07:04:33,355] INFO [LogLoader partition=wim_account-0, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) 2024-06-28T07:04:33.356534176Z [2024-06-28 07:04:33,356] INFO Created log for partition wim_account-0 in /bitnami/kafka/data/wim_account-0 with properties {} (kafka.log.LogManager) 2024-06-28T07:04:33.363023173Z [2024-06-28 07:04:33,362] INFO [Partition wim_account-0 broker=2] No checkpointed highwatermark is found for partition wim_account-0 (kafka.cluster.Partition) 2024-06-28T07:04:33.363038262Z [2024-06-28 07:04:33,362] INFO [Partition wim_account-0 broker=2] Log loaded for partition wim_account-0 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:04:33.363803702Z [2024-06-28 07:04:33,363] INFO [Broker id=2] Leader wim_account-0 with topic id Some(5moFBW0yT7yF6jQD-MTS9Q) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:04:33.596785976Z [2024-06-28 07:04:33,596] INFO Sent auto-creation request for Set(sdn) to the active controller. (kafka.server.DefaultAutoTopicCreationManager) 2024-06-28T07:04:33.821345423Z [2024-06-28 07:04:33,819] INFO [QuorumController id=2] Created topic sdn with topic ID SwEwChRBSMqZBAB6jzQMuw. (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:04:33.823459609Z [2024-06-28 07:04:33,823] INFO [QuorumController id=2] Created partition sdn-0 with topic ID SwEwChRBSMqZBAB6jzQMuw and PartitionRegistration(replicas=[0], isr=[0], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:05:28.472094551Z [2024-06-28 07:05:28,471] INFO Sent auto-creation request for Set(nslcmops, vca, k8scluster, k8srepo, pla) to the active controller. (kafka.server.DefaultAutoTopicCreationManager) 2024-06-28T07:05:28.510207916Z [2024-06-28 07:05:28,510] INFO [GroupCoordinator 2]: Dynamic Member with unknown member id joins group lcm-server in Empty state. Created a new member id aiokafka-0.8.1-7c99381b-d64e-4851-b3b8-18b59e2fee4e for this member and add to the group. (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:05:28.542591411Z [2024-06-28 07:05:28,542] INFO [GroupCoordinator 2]: Preparing to rebalance group lcm-server in state PreparingRebalance with old generation 0 (__consumer_offsets-32) (reason: Adding new member aiokafka-0.8.1-7c99381b-d64e-4851-b3b8-18b59e2fee4e with group instance id None; client reason: not provided) (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:05:29.038409729Z [2024-06-28 07:05:29,038] INFO [Broker id=2] Transitioning 2 partition(s) to local leaders. (state.change.logger) 2024-06-28T07:05:29.038852497Z [2024-06-28 07:05:29,038] INFO [ReplicaFetcherManager on broker 2] Removed fetcher for partitions Set(vca-0, k8srepo-0) (kafka.server.ReplicaFetcherManager) 2024-06-28T07:05:29.039824453Z [2024-06-28 07:05:29,039] INFO [Broker id=2] Creating new partition vca-0 with topic id UCqGoDH5SouWrG92_7B4aA. (state.change.logger) 2024-06-28T07:05:29.044377905Z [2024-06-28 07:05:29,044] INFO [QuorumController id=2] Created topic nslcmops with topic ID crh_c-cDSkSCm6BRUewVeg. (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:05:29.044505168Z [2024-06-28 07:05:29,044] INFO [QuorumController id=2] Created partition nslcmops-0 with topic ID crh_c-cDSkSCm6BRUewVeg and PartitionRegistration(replicas=[0], isr=[0], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:05:29.044680342Z [2024-06-28 07:05:29,044] INFO [QuorumController id=2] Created topic vca with topic ID UCqGoDH5SouWrG92_7B4aA. (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:05:29.044729978Z [2024-06-28 07:05:29,044] INFO [QuorumController id=2] Created partition vca-0 with topic ID UCqGoDH5SouWrG92_7B4aA and PartitionRegistration(replicas=[2], isr=[2], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:05:29.044877845Z [2024-06-28 07:05:29,044] INFO [QuorumController id=2] Created topic k8scluster with topic ID k-1LMmx6RoKtoQ4ht-Kp7Q. (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:05:29.044958500Z [2024-06-28 07:05:29,044] INFO [QuorumController id=2] Created partition k8scluster-0 with topic ID k-1LMmx6RoKtoQ4ht-Kp7Q and PartitionRegistration(replicas=[0], isr=[0], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:05:29.045041519Z [2024-06-28 07:05:29,044] INFO [QuorumController id=2] Created topic k8srepo with topic ID gjEpy_8ORpqarV64_ZJPGA. (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:05:29.045115084Z [2024-06-28 07:05:29,045] INFO [QuorumController id=2] Created partition k8srepo-0 with topic ID gjEpy_8ORpqarV64_ZJPGA and PartitionRegistration(replicas=[2], isr=[2], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:05:29.045219382Z [2024-06-28 07:05:29,045] INFO [QuorumController id=2] Created topic pla with topic ID TPpBXgT1QNCjVmxY6T0qAw. (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:05:29.045274710Z [2024-06-28 07:05:29,045] INFO [QuorumController id=2] Created partition pla-0 with topic ID TPpBXgT1QNCjVmxY6T0qAw and PartitionRegistration(replicas=[0], isr=[0], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:05:29.074293971Z [2024-06-28 07:05:29,074] INFO [LogLoader partition=vca-0, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) 2024-06-28T07:05:29.077598213Z [2024-06-28 07:05:29,077] INFO Created log for partition vca-0 in /bitnami/kafka/data/vca-0 with properties {} (kafka.log.LogManager) 2024-06-28T07:05:29.080815895Z [2024-06-28 07:05:29,080] INFO [Partition vca-0 broker=2] No checkpointed highwatermark is found for partition vca-0 (kafka.cluster.Partition) 2024-06-28T07:05:29.085419362Z [2024-06-28 07:05:29,085] INFO [Partition vca-0 broker=2] Log loaded for partition vca-0 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:05:29.085650200Z [2024-06-28 07:05:29,085] INFO [Broker id=2] Leader vca-0 with topic id Some(UCqGoDH5SouWrG92_7B4aA) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:05:29.091775914Z [2024-06-28 07:05:29,091] INFO [Broker id=2] Creating new partition k8srepo-0 with topic id gjEpy_8ORpqarV64_ZJPGA. (state.change.logger) 2024-06-28T07:05:29.096771065Z [2024-06-28 07:05:29,096] INFO [LogLoader partition=k8srepo-0, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) 2024-06-28T07:05:29.101591600Z [2024-06-28 07:05:29,101] INFO Created log for partition k8srepo-0 in /bitnami/kafka/data/k8srepo-0 with properties {} (kafka.log.LogManager) 2024-06-28T07:05:29.103305628Z [2024-06-28 07:05:29,103] INFO [Partition k8srepo-0 broker=2] No checkpointed highwatermark is found for partition k8srepo-0 (kafka.cluster.Partition) 2024-06-28T07:05:29.103483805Z [2024-06-28 07:05:29,103] INFO [Partition k8srepo-0 broker=2] Log loaded for partition k8srepo-0 with initial high watermark 0 (kafka.cluster.Partition) 2024-06-28T07:05:29.103947829Z [2024-06-28 07:05:29,103] INFO [Broker id=2] Leader k8srepo-0 with topic id Some(gjEpy_8ORpqarV64_ZJPGA) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [2], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-06-28T07:05:31.602315019Z [2024-06-28 07:05:31,602] INFO [GroupCoordinator 2]: Stabilized group lcm-server generation 1 (__consumer_offsets-32) with 1 members (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:05:31.635591036Z [2024-06-28 07:05:31,635] INFO [GroupCoordinator 2]: Assignment received from leader aiokafka-0.8.1-7c99381b-d64e-4851-b3b8-18b59e2fee4e for group lcm-server for generation 1. The group has 1 members, 0 of which are static. (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:10:28.563138938Z [2024-06-28 07:10:28,562] INFO [GroupCoordinator 2]: Preparing to rebalance group lcm-server in state PreparingRebalance with old generation 1 (__consumer_offsets-32) (reason: Leader aiokafka-0.8.1-7c99381b-d64e-4851-b3b8-18b59e2fee4e re-joining group during Stable; client reason: not provided) (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:10:28.565607534Z [2024-06-28 07:10:28,565] INFO [GroupCoordinator 2]: Stabilized group lcm-server generation 2 (__consumer_offsets-32) with 1 members (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:10:28.569162033Z [2024-06-28 07:10:28,569] INFO [GroupCoordinator 2]: Assignment received from leader aiokafka-0.8.1-7c99381b-d64e-4851-b3b8-18b59e2fee4e for group lcm-server for generation 2. The group has 1 members, 0 of which are static. (kafka.coordinator.group.GroupCoordinator) 2024-06-28T07:11:07.696569258Z [2024-06-28 07:11:07,696] INFO [QuorumController id=2] Created topic vnfd with topic ID Vvw6uGIjSfWL-4Rb2ZJjTg. (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:11:07.696961773Z [2024-06-28 07:11:07,696] INFO [QuorumController id=2] Created partition vnfd-0 with topic ID Vvw6uGIjSfWL-4Rb2ZJjTg and PartitionRegistration(replicas=[0], isr=[0], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:11:09.071844438Z [2024-06-28 07:11:09,071] INFO Sent auto-creation request for Set(nsd) to the active controller. (kafka.server.DefaultAutoTopicCreationManager) 2024-06-28T07:11:09.200037634Z [2024-06-28 07:11:09,198] INFO [QuorumController id=2] Created topic nsd with topic ID XJih7tRlSFSbdQP9WeEYSA. (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:11:09.200055261Z [2024-06-28 07:11:09,198] INFO [QuorumController id=2] Created partition nsd-0 with topic ID XJih7tRlSFSbdQP9WeEYSA and PartitionRegistration(replicas=[0], isr=[0], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-06-28T07:21:09.322177766Z [2024-06-28 07:21:09,321] INFO [BrokerToControllerChannelManager id=2 name=forwarding] Node 0 disconnected. (org.apache.kafka.clients.NetworkClient)