2024-07-04T01:24:28.875666555Z kafka 01:24:28.87  2024-07-04T01:24:28.881208091Z kafka 01:24:28.87 Welcome to the Bitnami kafka container 2024-07-04T01:24:28.883054700Z kafka 01:24:28.88 Subscribe to project updates by watching https://github.com/bitnami/containers 2024-07-04T01:24:28.889508724Z kafka 01:24:28.88 Submit issues and feature requests at https://github.com/bitnami/containers/issues 2024-07-04T01:24:28.894345286Z kafka 01:24:28.89  2024-07-04T01:24:28.896716797Z kafka 01:24:28.89 INFO  ==> ** Starting Kafka setup ** 2024-07-04T01:24:29.305764250Z kafka 01:24:29.29 INFO  ==> Initializing KRaft storage metadata 2024-07-04T01:24:29.308056932Z kafka 01:24:29.30 INFO  ==> Adding KRaft SCRAM users at storage bootstrap 2024-07-04T01:24:29.374576921Z kafka 01:24:29.37 INFO  ==> Formatting storage directories to add metadata... 2024-07-04T01:24:35.920978800Z Formatting /bitnami/kafka/data with metadata.version 3.5-IV2. 2024-07-04T01:24:36.450550157Z kafka 01:24:36.44 INFO  ==> ** Kafka setup finished! ** 2024-07-04T01:24:36.450577393Z 2024-07-04T01:24:36.484512614Z kafka 01:24:36.48 INFO  ==> ** Starting Kafka ** 2024-07-04T01:24:39.221688339Z [2024-07-04 01:24:39,221] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$) 2024-07-04T01:24:41.195561582Z [2024-07-04 01:24:41,192] INFO Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation (org.apache.zookeeper.common.X509Util) 2024-07-04T01:24:42.095993557Z [2024-07-04 01:24:42,095] INFO Registered signal handlers for TERM, INT, HUP (org.apache.kafka.common.utils.LoggingSignalHandler) 2024-07-04T01:24:42.139599716Z [2024-07-04 01:24:42,139] INFO [ControllerServer id=1] Starting controller (kafka.server.ControllerServer) 2024-07-04T01:24:43.790963921Z [2024-07-04 01:24:43,789] INFO Updated connection-accept-rate max connection creation rate to 2147483647 (kafka.network.ConnectionQuotas) 2024-07-04T01:24:44.406968256Z [2024-07-04 01:24:44,405] INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin) 2024-07-04T01:24:44.438360340Z [2024-07-04 01:24:44,437] INFO [SocketServer listenerType=CONTROLLER, nodeId=1] Created data-plane acceptor and processors for endpoint : ListenerName(CONTROLLER) (kafka.network.SocketServer) 2024-07-04T01:24:44.440437464Z [2024-07-04 01:24:44,440] INFO [SharedServer id=1] Starting SharedServer (kafka.server.SharedServer) 2024-07-04T01:24:44.527989471Z [2024-07-04 01:24:44,527] 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-07-04T01:24:44.528673193Z [2024-07-04 01:24:44,528] 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-07-04T01:24:44.528687045Z [2024-07-04 01:24:44,528] 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-07-04T01:24:44.564837245Z [2024-07-04 01:24:44,564] INFO Initialized snapshots with IDs Set() from /bitnami/kafka/data/__cluster_metadata-0 (kafka.raft.KafkaMetadataLog$) 2024-07-04T01:24:44.692771789Z [2024-07-04 01:24:44,692] INFO [raft-expiration-reaper]: Starting (kafka.raft.TimingWheelExpirationService$ExpiredOperationReaper) 2024-07-04T01:24:45.519654679Z [2024-07-04 01:24:45,518] INFO [RaftManager id=1] Completed transition to Unattached(epoch=0, voters=[0, 1, 2], electionTimeoutMs=1013) from null (org.apache.kafka.raft.QuorumState) 2024-07-04T01:24:45.578051642Z [2024-07-04 01:24:45,574] INFO [kafka-1-raft-outbound-request-thread]: Starting (kafka.raft.RaftSendThread) 2024-07-04T01:24:45.607350790Z [2024-07-04 01:24:45,607] INFO [kafka-1-raft-io-thread]: Starting (kafka.raft.KafkaRaftManager$RaftIoThread) 2024-07-04T01:24:45.653412060Z [2024-07-04 01:24:45,653] INFO [RaftManager id=1] Registered the listener org.apache.kafka.image.loader.MetadataLoader@1471962541 (org.apache.kafka.raft.KafkaRaftClient) 2024-07-04T01:24:45.660207991Z [2024-07-04 01:24:45,656] INFO [ControllerServer id=1] Waiting for controller quorum voters future (kafka.server.ControllerServer) 2024-07-04T01:24:45.660219786Z [2024-07-04 01:24:45,656] INFO [ControllerServer id=1] Finished waiting for controller quorum voters future (kafka.server.ControllerServer) 2024-07-04T01:24:45.660223649Z [2024-07-04 01:24:45,658] INFO [MetadataLoader id=1] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-07-04T01:24:45.752025611Z [2024-07-04 01:24:45,750] INFO [QuorumController id=1] Creating new QuorumController with clusterId ailvFhVv5RrIynbzjfI6GQ, authorizer Optional.empty. (org.apache.kafka.controller.QuorumController) 2024-07-04T01:24:45.759860682Z [2024-07-04 01:24:45,759] INFO [RaftManager id=1] Registered the listener org.apache.kafka.controller.QuorumController$QuorumMetaLogListener@690301960 (org.apache.kafka.raft.KafkaRaftClient) 2024-07-04T01:24:45.761612161Z [2024-07-04 01:24:45,761] INFO [MetadataLoader id=1] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-07-04T01:24:45.768314070Z [2024-07-04 01:24:45,768] INFO [RaftManager id=1] Completed transition to CandidateState(localId=1, epoch=1, retries=1, voteStates={0=UNRECORDED, 1=GRANTED, 2=UNRECORDED}, highWatermark=Optional.empty, electionTimeoutMs=1140) from Unattached(epoch=0, voters=[0, 1, 2], electionTimeoutMs=1013) (org.apache.kafka.raft.QuorumState) 2024-07-04T01:24:45.770745675Z [2024-07-04 01:24:45,770] INFO [QuorumController id=1] In the new epoch 1, the leader is (none). (org.apache.kafka.controller.QuorumController) 2024-07-04T01:24:45.787504443Z [2024-07-04 01:24:45,779] INFO [controller-1-ThrottledChannelReaper-Fetch]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) 2024-07-04T01:24:45.788738412Z [2024-07-04 01:24:45,788] INFO [controller-1-ThrottledChannelReaper-Produce]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) 2024-07-04T01:24:45.790682263Z [2024-07-04 01:24:45,790] INFO [controller-1-ThrottledChannelReaper-Request]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) 2024-07-04T01:24:45.823221002Z [2024-07-04 01:24:45,823] INFO [controller-1-ThrottledChannelReaper-ControllerMutation]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) 2024-07-04T01:24:45.877315475Z [2024-07-04 01:24:45,876] INFO [MetadataLoader id=1] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-07-04T01:24:45.931427317Z [2024-07-04 01:24:45,927] INFO [ExpirationReaper-1-AlterAcls]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) 2024-07-04T01:24:45.978640991Z [2024-07-04 01:24:45,978] INFO [MetadataLoader id=1] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-07-04T01:24:45.987306863Z [2024-07-04 01:24:45,981] INFO [SocketServer listenerType=CONTROLLER, nodeId=1] Enabling request processing. (kafka.network.SocketServer) 2024-07-04T01:24:45.987333500Z [2024-07-04 01:24:45,984] INFO Awaiting socket connections on 0.0.0.0:9093. (kafka.network.DataPlaneAcceptor) 2024-07-04T01:24:46.032814744Z [2024-07-04 01:24:46,030] INFO [RaftManager id=1] Node 2 disconnected. (org.apache.kafka.clients.NetworkClient) 2024-07-04T01:24:46.039286584Z [2024-07-04 01:24:46,033] WARN [RaftManager id=1] Connection to node 2 (kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local/10.42.0.44:9093) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) 2024-07-04T01:24:46.082883755Z [2024-07-04 01:24:46,080] INFO [MetadataLoader id=1] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-07-04T01:24:46.128830041Z [2024-07-04 01:24:46,120] INFO [RaftManager id=1] Node 2 disconnected. (org.apache.kafka.clients.NetworkClient) 2024-07-04T01:24:46.128851303Z [2024-07-04 01:24:46,121] WARN [RaftManager id=1] Connection to node 2 (kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local/10.42.0.44:9093) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) 2024-07-04T01:24:46.157115312Z [2024-07-04 01:24:46,156] INFO [ControllerServer id=1] Waiting for all of the authorizer futures to be completed (kafka.server.ControllerServer) 2024-07-04T01:24:46.162944295Z [2024-07-04 01:24:46,159] INFO [ControllerServer id=1] Finished waiting for all of the authorizer futures to be completed (kafka.server.ControllerServer) 2024-07-04T01:24:46.164596139Z [2024-07-04 01:24:46,160] INFO [ControllerServer id=1] Waiting for all of the SocketServer Acceptors to be started (kafka.server.ControllerServer) 2024-07-04T01:24:46.164601909Z [2024-07-04 01:24:46,160] INFO [ControllerServer id=1] Finished waiting for all of the SocketServer Acceptors to be started (kafka.server.ControllerServer) 2024-07-04T01:24:46.180876161Z [2024-07-04 01:24:46,178] INFO [ControllerServer id=1] Waiting for the controller metadata publishers to be installed (kafka.server.ControllerServer) 2024-07-04T01:24:46.184670470Z [2024-07-04 01:24:46,184] INFO [MetadataLoader id=1] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-07-04T01:24:46.185150599Z [2024-07-04 01:24:46,184] INFO [MetadataLoader id=1] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-07-04T01:24:46.186425312Z [2024-07-04 01:24:46,186] INFO [ControllerServer id=1] Finished waiting for the controller metadata publishers to be installed (kafka.server.ControllerServer) 2024-07-04T01:24:46.192142526Z [2024-07-04 01:24:46,192] INFO [BrokerServer id=1] Transition from SHUTDOWN to STARTING (kafka.server.BrokerServer) 2024-07-04T01:24:46.194220248Z [2024-07-04 01:24:46,193] INFO [BrokerServer id=1] Starting broker (kafka.server.BrokerServer) 2024-07-04T01:24:46.229526839Z [2024-07-04 01:24:46,228] INFO [RaftManager id=1] Node 2 disconnected. (org.apache.kafka.clients.NetworkClient) 2024-07-04T01:24:46.229536030Z [2024-07-04 01:24:46,228] WARN [RaftManager id=1] Connection to node 2 (kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local/10.42.0.44:9093) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) 2024-07-04T01:24:46.252576371Z [2024-07-04 01:24:46,251] INFO [broker-1-ThrottledChannelReaper-Fetch]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) 2024-07-04T01:24:46.256480444Z [2024-07-04 01:24:46,255] INFO [broker-1-ThrottledChannelReaper-Produce]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) 2024-07-04T01:24:46.286221040Z [2024-07-04 01:24:46,285] INFO [MetadataLoader id=1] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-07-04T01:24:46.296812386Z [2024-07-04 01:24:46,296] INFO [broker-1-ThrottledChannelReaper-Request]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) 2024-07-04T01:24:46.303560904Z [2024-07-04 01:24:46,303] INFO [broker-1-ThrottledChannelReaper-ControllerMutation]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) 2024-07-04T01:24:46.362745928Z [2024-07-04 01:24:46,361] INFO [RaftManager id=1] Completed transition to Leader(localId=1, epoch=1, epochStartOffset=0, highWatermark=Optional.empty, voterStates={0=ReplicaState(nodeId=0, endOffset=Optional.empty, lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=false), 1=ReplicaState(nodeId=1, endOffset=Optional.empty, lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=true), 2=ReplicaState(nodeId=2, endOffset=Optional.empty, lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=false)}) from CandidateState(localId=1, epoch=1, retries=1, voteStates={0=GRANTED, 1=GRANTED, 2=UNRECORDED}, highWatermark=Optional.empty, electionTimeoutMs=1140) (org.apache.kafka.raft.QuorumState) 2024-07-04T01:24:46.369113004Z [2024-07-04 01:24:46,363] INFO [QuorumController id=1] Becoming the active controller at epoch 1, committed offset -1, committed epoch -1 (org.apache.kafka.controller.QuorumController) 2024-07-04T01:24:46.371959943Z [2024-07-04 01:24:46,371] INFO [QuorumController id=1] The metadata log appears to be empty. Appending 3 bootstrap record(s) at metadata.version 3.5-IV2 from the binary bootstrap metadata file: /bitnami/kafka/data/bootstrap.checkpoint. (org.apache.kafka.controller.QuorumController) 2024-07-04T01:24:46.387848855Z [2024-07-04 01:24:46,375] INFO [QuorumController id=1] Setting metadata version to 3.5-IV2 (org.apache.kafka.controller.FeatureControlManager) 2024-07-04T01:24:46.387865219Z [2024-07-04 01:24:46,382] INFO [QuorumController id=1] Created new SCRAM credential for user with mechanism SCRAM_SHA_256. (org.apache.kafka.controller.ScramControlManager) 2024-07-04T01:24:46.387869190Z [2024-07-04 01:24:46,382] INFO [QuorumController id=1] Created new SCRAM credential for user with mechanism SCRAM_SHA_512. (org.apache.kafka.controller.ScramControlManager) 2024-07-04T01:24:46.398958671Z [2024-07-04 01:24:46,391] INFO [MetadataLoader id=1] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-07-04T01:24:46.398981202Z [2024-07-04 01:24:46,392] INFO [QuorumController id=1] Transitioning ZK migration state from NONE to NONE (org.apache.kafka.controller.FeatureControlManager) 2024-07-04T01:24:46.427914017Z [2024-07-04 01:24:46,427] INFO [BrokerServer id=1] Waiting for controller quorum voters future (kafka.server.BrokerServer) 2024-07-04T01:24:46.427925193Z [2024-07-04 01:24:46,427] INFO [BrokerServer id=1] Finished waiting for controller quorum voters future (kafka.server.BrokerServer) 2024-07-04T01:24:46.509272982Z [2024-07-04 01:24:46,508] INFO [broker-1-to-controller-forwarding-channel-manager]: Starting (kafka.server.BrokerToControllerRequestThread) 2024-07-04T01:24:46.510607524Z [2024-07-04 01:24:46,510] INFO [broker-1-to-controller-forwarding-channel-manager]: Recorded new controller, from now on will use node kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9093 (id: 1 rack: null) (kafka.server.BrokerToControllerRequestThread) 2024-07-04T01:24:46.511216643Z [2024-07-04 01:24:46,511] INFO [MetadataLoader id=1] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-07-04T01:24:46.615804634Z [2024-07-04 01:24:46,612] INFO [MetadataLoader id=1] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-07-04T01:24:46.715234777Z [2024-07-04 01:24:46,713] INFO [MetadataLoader id=1] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-07-04T01:24:46.794322044Z [2024-07-04 01:24:46,783] INFO Updated connection-accept-rate max connection creation rate to 2147483647 (kafka.network.ConnectionQuotas) 2024-07-04T01:24:46.794341644Z [2024-07-04 01:24:46,793] INFO [SocketServer listenerType=BROKER, nodeId=1] Created data-plane acceptor and processors for endpoint : ListenerName(CLIENT) (kafka.network.SocketServer) 2024-07-04T01:24:46.807510579Z [2024-07-04 01:24:46,799] INFO Updated connection-accept-rate max connection creation rate to 2147483647 (kafka.network.ConnectionQuotas) 2024-07-04T01:24:46.807526426Z [2024-07-04 01:24:46,806] INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin) 2024-07-04T01:24:46.833707809Z [2024-07-04 01:24:46,815] INFO [MetadataLoader id=1] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-07-04T01:24:46.833724824Z [2024-07-04 01:24:46,816] INFO Successfully logged in. (org.apache.kafka.common.security.authenticator.AbstractLogin) 2024-07-04T01:24:46.833728907Z [2024-07-04 01:24:46,827] INFO [SocketServer listenerType=BROKER, nodeId=1] Created data-plane acceptor and processors for endpoint : ListenerName(INTERNAL) (kafka.network.SocketServer) 2024-07-04T01:24:46.854004842Z [2024-07-04 01:24:46,853] INFO [broker-1-to-controller-alter-partition-channel-manager]: Starting (kafka.server.BrokerToControllerRequestThread) 2024-07-04T01:24:46.854371540Z [2024-07-04 01:24:46,854] INFO [broker-1-to-controller-alter-partition-channel-manager]: Recorded new controller, from now on will use node kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9093 (id: 1 rack: null) (kafka.server.BrokerToControllerRequestThread) 2024-07-04T01:24:46.892866633Z [2024-07-04 01:24:46,890] INFO [ExpirationReaper-1-Produce]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) 2024-07-04T01:24:46.895476315Z [2024-07-04 01:24:46,892] INFO [ExpirationReaper-1-Fetch]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) 2024-07-04T01:24:46.920143711Z [2024-07-04 01:24:46,919] INFO [MetadataLoader id=1] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-07-04T01:24:46.946392218Z [2024-07-04 01:24:46,943] INFO [ExpirationReaper-1-DeleteRecords]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) 2024-07-04T01:24:47.013034114Z [2024-07-04 01:24:47,006] INFO [ExpirationReaper-1-ElectLeader]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) 2024-07-04T01:24:47.029514541Z [2024-07-04 01:24:47,024] INFO [MetadataLoader id=1] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-07-04T01:24:47.085332806Z [2024-07-04 01:24:47,083] INFO [ExpirationReaper-1-Heartbeat]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) 2024-07-04T01:24:47.085358195Z [2024-07-04 01:24:47,083] INFO [QuorumController id=1] Registered new broker: RegisterBrokerRecord(brokerId=0, isMigratingZkBroker=false, incarnationId=W3jOUXEsRqSrQyARI-H94A, brokerEpoch=6, 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-07-04T01:24:47.090788599Z [2024-07-04 01:24:47,085] INFO [ExpirationReaper-1-Rebalance]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) 2024-07-04T01:24:47.126762378Z [2024-07-04 01:24:47,125] INFO [MetadataLoader id=1] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-07-04T01:24:47.180581288Z [2024-07-04 01:24:47,175] INFO [BrokerLifecycleManager id=1] Incarnation eAOF0N_9SfSfOnV-fOLp0w of broker 1 in cluster ailvFhVv5RrIynbzjfI6GQ is now STARTING. (kafka.server.BrokerLifecycleManager) 2024-07-04T01:24:47.180595410Z [2024-07-04 01:24:47,176] INFO [broker-1-to-controller-heartbeat-channel-manager]: Starting (kafka.server.BrokerToControllerRequestThread) 2024-07-04T01:24:47.180600588Z [2024-07-04 01:24:47,176] INFO [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9093 (id: 1 rack: null) (kafka.server.BrokerToControllerRequestThread) 2024-07-04T01:24:47.227367390Z [2024-07-04 01:24:47,225] INFO [MetadataLoader id=1] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-07-04T01:24:47.304584584Z [2024-07-04 01:24:47,303] INFO [ExpirationReaper-1-AlterAcls]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) 2024-07-04T01:24:47.308135614Z [2024-07-04 01:24:47,307] INFO [QuorumController id=1] Registered new broker: RegisterBrokerRecord(brokerId=1, isMigratingZkBroker=false, incarnationId=eAOF0N_9SfSfOnV-fOLp0w, brokerEpoch=7, 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-07-04T01:24:47.328017492Z [2024-07-04 01:24:47,325] INFO [MetadataLoader id=1] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet. (org.apache.kafka.image.loader.MetadataLoader) 2024-07-04T01:24:47.358650149Z [2024-07-04 01:24:47,358] INFO [RaftManager id=1] High watermark set to LogOffsetMetadata(offset=6, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=576)]) for the first time for epoch 1 based on indexOfHw 1 and voters [ReplicaState(nodeId=1, endOffset=Optional[LogOffsetMetadata(offset=8, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=1156)])], lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=true), ReplicaState(nodeId=0, endOffset=Optional[LogOffsetMetadata(offset=6, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=576)])], lastFetchTimestamp=1720056287355, lastCaughtUpTimestamp=1720056287040, hasAcknowledgedLeader=true), ReplicaState(nodeId=2, endOffset=Optional[LogOffsetMetadata(offset=0, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=0)])], lastFetchTimestamp=1720056287168, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=true)] (org.apache.kafka.raft.LeaderState) 2024-07-04T01:24:47.362027619Z [2024-07-04 01:24:47,361] INFO [MetadataLoader id=1] initializeNewPublishers: The loader is still catching up because we have loaded up to offset -1, but the high water mark is 6 (org.apache.kafka.image.loader.MetadataLoader) 2024-07-04T01:24:47.362938747Z [2024-07-04 01:24:47,362] INFO [BrokerServer id=1] Waiting for the broker metadata publishers to be installed (kafka.server.BrokerServer) 2024-07-04T01:24:47.363309415Z [2024-07-04 01:24:47,362] INFO [BrokerServer id=1] Finished waiting for the broker metadata publishers to be installed (kafka.server.BrokerServer) 2024-07-04T01:24:47.363314066Z [2024-07-04 01:24:47,362] INFO [BrokerServer id=1] Waiting for the controller to acknowledge that we are caught up (kafka.server.BrokerServer) 2024-07-04T01:24:47.408940204Z [2024-07-04 01:24:47,405] INFO [MetadataLoader id=1] handleCommit: The loader finished catching up to the current high water mark of 6 (org.apache.kafka.image.loader.MetadataLoader) 2024-07-04T01:24:47.474621275Z [2024-07-04 01:24:47,472] INFO [BrokerLifecycleManager id=1] Successfully registered broker 1 with broker epoch 7 (kafka.server.BrokerLifecycleManager) 2024-07-04T01:24:47.502377738Z [2024-07-04 01:24:47,497] INFO [MetadataLoader id=1] InitializeNewPublishers: initializing SnapshotGenerator with a snapshot at offset 7 (org.apache.kafka.image.loader.MetadataLoader) 2024-07-04T01:24:47.502389659Z [2024-07-04 01:24:47,499] INFO [MetadataLoader id=1] InitializeNewPublishers: initializing DynamicConfigPublisher controller id=1 with a snapshot at offset 7 (org.apache.kafka.image.loader.MetadataLoader) 2024-07-04T01:24:47.502394700Z [2024-07-04 01:24:47,500] INFO [MetadataLoader id=1] InitializeNewPublishers: initializing DynamicClientQuotaPublisher controller id=1 with a snapshot at offset 7 (org.apache.kafka.image.loader.MetadataLoader) 2024-07-04T01:24:47.503941351Z [2024-07-04 01:24:47,502] INFO [MetadataLoader id=1] InitializeNewPublishers: initializing ScramPublisher controller id=1 with a snapshot at offset 7 (org.apache.kafka.image.loader.MetadataLoader) 2024-07-04T01:24:47.509519627Z [2024-07-04 01:24:47,504] INFO [MetadataLoader id=1] InitializeNewPublishers: initializing ControllerMetadataMetricsPublisher with a snapshot at offset 7 (org.apache.kafka.image.loader.MetadataLoader) 2024-07-04T01:24:47.509537155Z [2024-07-04 01:24:47,504] INFO [MetadataLoader id=1] InitializeNewPublishers: initializing BrokerMetadataPublisher with a snapshot at offset 7 (org.apache.kafka.image.loader.MetadataLoader) 2024-07-04T01:24:47.509541584Z [2024-07-04 01:24:47,505] INFO [BrokerMetadataPublisher id=1] Publishing initial metadata at offset OffsetAndEpoch(offset=7, epoch=1) with metadata.version 3.5-IV2. (kafka.server.metadata.BrokerMetadataPublisher) 2024-07-04T01:24:47.512284820Z [2024-07-04 01:24:47,510] INFO Loading logs from log dirs ArrayBuffer(/bitnami/kafka/data) (kafka.log.LogManager) 2024-07-04T01:24:47.513545585Z [2024-07-04 01:24:47,512] INFO [BrokerLifecycleManager id=1] The broker has caught up. Transitioning from STARTING to RECOVERY. (kafka.server.BrokerLifecycleManager) 2024-07-04T01:24:47.513559489Z [2024-07-04 01:24:47,513] INFO [BrokerServer id=1] Finished waiting for the controller to acknowledge that we are caught up (kafka.server.BrokerServer) 2024-07-04T01:24:47.515228976Z [2024-07-04 01:24:47,513] INFO [BrokerServer id=1] Waiting for the initial broker metadata update to be published (kafka.server.BrokerServer) 2024-07-04T01:24:47.523266508Z [2024-07-04 01:24:47,522] INFO No logs found to be loaded in /bitnami/kafka/data (kafka.log.LogManager) 2024-07-04T01:24:47.583115425Z [2024-07-04 01:24:47,573] INFO [BrokerLifecycleManager id=1] The broker is in RECOVERY. (kafka.server.BrokerLifecycleManager) 2024-07-04T01:24:47.687010555Z [2024-07-04 01:24:47,682] INFO Loaded 0 logs in 171ms (kafka.log.LogManager) 2024-07-04T01:24:47.687051994Z [2024-07-04 01:24:47,685] INFO Starting log cleanup with a period of 300000 ms. (kafka.log.LogManager) 2024-07-04T01:24:47.687059450Z [2024-07-04 01:24:47,686] INFO Starting log flusher with a default period of 9223372036854775807 ms. (kafka.log.LogManager) 2024-07-04T01:24:47.709775092Z [2024-07-04 01:24:47,705] INFO Starting the log cleaner (kafka.log.LogCleaner) 2024-07-04T01:24:47.738678036Z [2024-07-04 01:24:47,736] INFO [QuorumController id=1] Registered new broker: RegisterBrokerRecord(brokerId=2, isMigratingZkBroker=false, incarnationId=t5izIHiLRp6BkU4Wp4mGOA, brokerEpoch=9, 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-07-04T01:24:48.040322808Z [2024-07-04 01:24:48,035] INFO [kafka-log-cleaner-thread-0]: Starting (kafka.log.LogCleaner$CleanerThread) 2024-07-04T01:24:48.044528270Z [2024-07-04 01:24:48,044] INFO [LogDirFailureHandler]: Starting (kafka.server.ReplicaManager$LogDirFailureHandler) 2024-07-04T01:24:48.051236896Z [2024-07-04 01:24:48,046] INFO [GroupCoordinator 1]: Starting up. (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:24:48.116843757Z [2024-07-04 01:24:48,115] INFO [GroupCoordinator 1]: Startup complete. (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:24:48.116859683Z [2024-07-04 01:24:48,116] INFO [TransactionCoordinator id=1] Starting up. (kafka.coordinator.transaction.TransactionCoordinator) 2024-07-04T01:24:48.130988173Z [2024-07-04 01:24:48,127] INFO [TxnMarkerSenderThread-1]: Starting (kafka.coordinator.transaction.TransactionMarkerChannelManager) 2024-07-04T01:24:48.131006510Z [2024-07-04 01:24:48,130] INFO [TransactionCoordinator id=1] Startup complete. (kafka.coordinator.transaction.TransactionCoordinator) 2024-07-04T01:24:48.134148099Z [2024-07-04 01:24:48,131] INFO [BrokerMetadataPublisher id=1] Updating metadata.version to 11 at offset OffsetAndEpoch(offset=7, epoch=1). (kafka.server.metadata.BrokerMetadataPublisher) 2024-07-04T01:24:48.223446710Z [2024-07-04 01:24:48,223] INFO [BrokerServer id=1] Finished waiting for the initial broker metadata update to be published (kafka.server.BrokerServer) 2024-07-04T01:24:48.234818640Z [2024-07-04 01:24:48,230] INFO KafkaConfig values: 2024-07-04T01:24:48.234832880Z advertised.listeners = CLIENT://kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9092,INTERNAL://kafka-controller-1.kafka-controller-headless.osm.svc.cluster.local:9094 2024-07-04T01:24:48.234836991Z alter.config.policy.class.name = null 2024-07-04T01:24:48.234840105Z alter.log.dirs.replication.quota.window.num = 11 2024-07-04T01:24:48.234843148Z alter.log.dirs.replication.quota.window.size.seconds = 1 2024-07-04T01:24:48.234846675Z authorizer.class.name = 2024-07-04T01:24:48.234849693Z auto.create.topics.enable = true 2024-07-04T01:24:48.234852659Z auto.include.jmx.reporter = true 2024-07-04T01:24:48.234855703Z auto.leader.rebalance.enable = true 2024-07-04T01:24:48.234859437Z background.threads = 10 2024-07-04T01:24:48.234862399Z broker.heartbeat.interval.ms = 2000 2024-07-04T01:24:48.234865339Z broker.id = 1 2024-07-04T01:24:48.234868396Z broker.id.generation.enable = true 2024-07-04T01:24:48.234924118Z broker.rack = null 2024-07-04T01:24:48.234927217Z broker.session.timeout.ms = 9000 2024-07-04T01:24:48.234930331Z client.quota.callback.class = null 2024-07-04T01:24:48.234933420Z compression.type = producer 2024-07-04T01:24:48.234936480Z connection.failed.authentication.delay.ms = 100 2024-07-04T01:24:48.234939493Z connections.max.idle.ms = 600000 2024-07-04T01:24:48.234942533Z connections.max.reauth.ms = 0 2024-07-04T01:24:48.234953297Z control.plane.listener.name = null 2024-07-04T01:24:48.234956282Z controlled.shutdown.enable = true 2024-07-04T01:24:48.234959584Z controlled.shutdown.max.retries = 3 2024-07-04T01:24:48.234962654Z controlled.shutdown.retry.backoff.ms = 5000 2024-07-04T01:24:48.234965679Z controller.listener.names = CONTROLLER 2024-07-04T01:24:48.234969067Z controller.quorum.append.linger.ms = 25 2024-07-04T01:24:48.234972069Z controller.quorum.election.backoff.max.ms = 1000 2024-07-04T01:24:48.234975135Z controller.quorum.election.timeout.ms = 1000 2024-07-04T01:24:48.234978151Z controller.quorum.fetch.timeout.ms = 2000 2024-07-04T01:24:48.234981114Z controller.quorum.request.timeout.ms = 2000 2024-07-04T01:24:48.234984379Z controller.quorum.retry.backoff.ms = 20 2024-07-04T01:24:48.234988083Z 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-07-04T01:24:48.234991102Z controller.quota.window.num = 11 2024-07-04T01:24:48.234994105Z controller.quota.window.size.seconds = 1 2024-07-04T01:24:48.234997147Z controller.socket.timeout.ms = 30000 2024-07-04T01:24:48.235000116Z create.topic.policy.class.name = null 2024-07-04T01:24:48.235003128Z default.replication.factor = 1 2024-07-04T01:24:48.235006098Z delegation.token.expiry.check.interval.ms = 3600000 2024-07-04T01:24:48.235009130Z delegation.token.expiry.time.ms = 86400000 2024-07-04T01:24:48.235012065Z delegation.token.master.key = null 2024-07-04T01:24:48.235015016Z delegation.token.max.lifetime.ms = 604800000 2024-07-04T01:24:48.235018093Z delegation.token.secret.key = null 2024-07-04T01:24:48.235032782Z delete.records.purgatory.purge.interval.requests = 1 2024-07-04T01:24:48.235035619Z delete.topic.enable = true 2024-07-04T01:24:48.235038423Z early.start.listeners = null 2024-07-04T01:24:48.235041344Z fetch.max.bytes = 57671680 2024-07-04T01:24:48.235044125Z fetch.purgatory.purge.interval.requests = 1000 2024-07-04T01:24:48.235046928Z group.consumer.assignors = [] 2024-07-04T01:24:48.235049741Z group.consumer.heartbeat.interval.ms = 5000 2024-07-04T01:24:48.235052911Z group.consumer.max.heartbeat.interval.ms = 15000 2024-07-04T01:24:48.235055678Z group.consumer.max.session.timeout.ms = 60000 2024-07-04T01:24:48.235058452Z group.consumer.max.size = 2147483647 2024-07-04T01:24:48.235063460Z group.consumer.min.heartbeat.interval.ms = 5000 2024-07-04T01:24:48.235066428Z group.consumer.min.session.timeout.ms = 45000 2024-07-04T01:24:48.235069301Z group.consumer.session.timeout.ms = 45000 2024-07-04T01:24:48.235072078Z group.coordinator.new.enable = false 2024-07-04T01:24:48.235074997Z group.coordinator.threads = 1 2024-07-04T01:24:48.235077869Z group.initial.rebalance.delay.ms = 3000 2024-07-04T01:24:48.235080666Z group.max.session.timeout.ms = 1800000 2024-07-04T01:24:48.235083602Z group.max.size = 2147483647 2024-07-04T01:24:48.235086545Z group.min.session.timeout.ms = 6000 2024-07-04T01:24:48.235089337Z initial.broker.registration.timeout.ms = 60000 2024-07-04T01:24:48.235092200Z inter.broker.listener.name = INTERNAL 2024-07-04T01:24:48.235095016Z inter.broker.protocol.version = 3.5-IV2 2024-07-04T01:24:48.235097915Z kafka.metrics.polling.interval.secs = 10 2024-07-04T01:24:48.235100763Z kafka.metrics.reporters = [] 2024-07-04T01:24:48.235103646Z leader.imbalance.check.interval.seconds = 300 2024-07-04T01:24:48.235106493Z leader.imbalance.per.broker.percentage = 10 2024-07-04T01:24:48.235114364Z listener.security.protocol.map = CLIENT:PLAINTEXT,INTERNAL:SASL_PLAINTEXT,CONTROLLER:SASL_PLAINTEXT 2024-07-04T01:24:48.235117415Z listeners = CLIENT://:9092,INTERNAL://:9094,CONTROLLER://:9093 2024-07-04T01:24:48.235120325Z log.cleaner.backoff.ms = 15000 2024-07-04T01:24:48.235123213Z log.cleaner.dedupe.buffer.size = 134217728 2024-07-04T01:24:48.235126124Z log.cleaner.delete.retention.ms = 86400000 2024-07-04T01:24:48.235134920Z log.cleaner.enable = true 2024-07-04T01:24:48.235138119Z log.cleaner.io.buffer.load.factor = 0.9 2024-07-04T01:24:48.235141007Z log.cleaner.io.buffer.size = 524288 2024-07-04T01:24:48.235143904Z log.cleaner.io.max.bytes.per.second = 1.7976931348623157E308 2024-07-04T01:24:48.235146788Z log.cleaner.max.compaction.lag.ms = 9223372036854775807 2024-07-04T01:24:48.235149730Z log.cleaner.min.cleanable.ratio = 0.5 2024-07-04T01:24:48.235152586Z log.cleaner.min.compaction.lag.ms = 0 2024-07-04T01:24:48.235155519Z log.cleaner.threads = 1 2024-07-04T01:24:48.235158384Z log.cleanup.policy = [delete] 2024-07-04T01:24:48.235161312Z log.dir = /bitnami/kafka/data 2024-07-04T01:24:48.235164186Z log.dirs = null 2024-07-04T01:24:48.235167457Z log.flush.interval.messages = 9223372036854775807 2024-07-04T01:24:48.235170370Z log.flush.interval.ms = null 2024-07-04T01:24:48.235173290Z log.flush.offset.checkpoint.interval.ms = 60000 2024-07-04T01:24:48.235176183Z log.flush.scheduler.interval.ms = 9223372036854775807 2024-07-04T01:24:48.235179143Z log.flush.start.offset.checkpoint.interval.ms = 60000 2024-07-04T01:24:48.235182105Z log.index.interval.bytes = 4096 2024-07-04T01:24:48.235185005Z log.index.size.max.bytes = 10485760 2024-07-04T01:24:48.235187907Z log.message.downconversion.enable = true 2024-07-04T01:24:48.235193407Z log.message.format.version = 3.0-IV1 2024-07-04T01:24:48.235198532Z log.message.timestamp.difference.max.ms = 9223372036854775807 2024-07-04T01:24:48.235201474Z log.message.timestamp.type = CreateTime 2024-07-04T01:24:48.235204366Z log.preallocate = false 2024-07-04T01:24:48.235207222Z log.retention.bytes = -1 2024-07-04T01:24:48.235210196Z log.retention.check.interval.ms = 300000 2024-07-04T01:24:48.235213078Z log.retention.hours = 168 2024-07-04T01:24:48.235215929Z log.retention.minutes = null 2024-07-04T01:24:48.235218870Z log.retention.ms = null 2024-07-04T01:24:48.235221734Z log.roll.hours = 168 2024-07-04T01:24:48.235224635Z log.roll.jitter.hours = 0 2024-07-04T01:24:48.235227504Z log.roll.jitter.ms = null 2024-07-04T01:24:48.235230413Z log.roll.ms = null 2024-07-04T01:24:48.235233303Z log.segment.bytes = 1073741824 2024-07-04T01:24:48.235236202Z log.segment.delete.delay.ms = 60000 2024-07-04T01:24:48.235239066Z max.connection.creation.rate = 2147483647 2024-07-04T01:24:48.235242047Z max.connections = 2147483647 2024-07-04T01:24:48.235244936Z max.connections.per.ip = 2147483647 2024-07-04T01:24:48.235247954Z max.connections.per.ip.overrides = 2024-07-04T01:24:48.235250884Z max.incremental.fetch.session.cache.slots = 1000 2024-07-04T01:24:48.235253769Z message.max.bytes = 1048588 2024-07-04T01:24:48.235256683Z metadata.log.dir = null 2024-07-04T01:24:48.235259602Z metadata.log.max.record.bytes.between.snapshots = 20971520 2024-07-04T01:24:48.235262581Z metadata.log.max.snapshot.interval.ms = 3600000 2024-07-04T01:24:48.235265600Z metadata.log.segment.bytes = 1073741824 2024-07-04T01:24:48.235268704Z metadata.log.segment.min.bytes = 8388608 2024-07-04T01:24:48.235271653Z metadata.log.segment.ms = 604800000 2024-07-04T01:24:48.235274972Z metadata.max.idle.interval.ms = 500 2024-07-04T01:24:48.235281442Z metadata.max.retention.bytes = 104857600 2024-07-04T01:24:48.235284352Z metadata.max.retention.ms = 604800000 2024-07-04T01:24:48.235287198Z metric.reporters = [] 2024-07-04T01:24:48.235290113Z metrics.num.samples = 2 2024-07-04T01:24:48.235293117Z metrics.recording.level = INFO 2024-07-04T01:24:48.235295991Z metrics.sample.window.ms = 30000 2024-07-04T01:24:48.235298957Z min.insync.replicas = 1 2024-07-04T01:24:48.235301943Z node.id = 1 2024-07-04T01:24:48.235304800Z num.io.threads = 8 2024-07-04T01:24:48.235307807Z num.network.threads = 3 2024-07-04T01:24:48.235310640Z num.partitions = 1 2024-07-04T01:24:48.235313609Z num.recovery.threads.per.data.dir = 1 2024-07-04T01:24:48.235316527Z num.replica.alter.log.dirs.threads = null 2024-07-04T01:24:48.235319402Z num.replica.fetchers = 1 2024-07-04T01:24:48.235322254Z offset.metadata.max.bytes = 4096 2024-07-04T01:24:48.235325114Z offsets.commit.required.acks = -1 2024-07-04T01:24:48.235327938Z offsets.commit.timeout.ms = 5000 2024-07-04T01:24:48.235330801Z offsets.load.buffer.size = 5242880 2024-07-04T01:24:48.235333621Z offsets.retention.check.interval.ms = 600000 2024-07-04T01:24:48.235336843Z offsets.retention.minutes = 10080 2024-07-04T01:24:48.235339858Z offsets.topic.compression.codec = 0 2024-07-04T01:24:48.235342681Z offsets.topic.num.partitions = 50 2024-07-04T01:24:48.235345511Z offsets.topic.replication.factor = 3 2024-07-04T01:24:48.235348373Z offsets.topic.segment.bytes = 104857600 2024-07-04T01:24:48.235351347Z password.encoder.cipher.algorithm = AES/CBC/PKCS5Padding 2024-07-04T01:24:48.235354183Z password.encoder.iterations = 4096 2024-07-04T01:24:48.235357282Z password.encoder.key.length = 128 2024-07-04T01:24:48.235360101Z password.encoder.keyfactory.algorithm = null 2024-07-04T01:24:48.235363185Z password.encoder.old.secret = null 2024-07-04T01:24:48.235366035Z password.encoder.secret = null 2024-07-04T01:24:48.235368984Z principal.builder.class = class org.apache.kafka.common.security.authenticator.DefaultKafkaPrincipalBuilder 2024-07-04T01:24:48.235371889Z process.roles = [controller, broker] 2024-07-04T01:24:48.235374770Z producer.id.expiration.check.interval.ms = 600000 2024-07-04T01:24:48.235377612Z producer.id.expiration.ms = 86400000 2024-07-04T01:24:48.235380482Z producer.purgatory.purge.interval.requests = 1000 2024-07-04T01:24:48.235383358Z queued.max.request.bytes = -1 2024-07-04T01:24:48.235386210Z queued.max.requests = 500 2024-07-04T01:24:48.235389069Z quota.window.num = 11 2024-07-04T01:24:48.235391958Z quota.window.size.seconds = 1 2024-07-04T01:24:48.235394852Z remote.log.index.file.cache.total.size.bytes = 1073741824 2024-07-04T01:24:48.235397698Z remote.log.manager.task.interval.ms = 30000 2024-07-04T01:24:48.235400582Z remote.log.manager.task.retry.backoff.max.ms = 30000 2024-07-04T01:24:48.235403401Z remote.log.manager.task.retry.backoff.ms = 500 2024-07-04T01:24:48.235407545Z remote.log.manager.task.retry.jitter = 0.2 2024-07-04T01:24:48.235410445Z remote.log.manager.thread.pool.size = 10 2024-07-04T01:24:48.235413269Z remote.log.metadata.manager.class.name = null 2024-07-04T01:24:48.235416239Z remote.log.metadata.manager.class.path = null 2024-07-04T01:24:48.235419181Z remote.log.metadata.manager.impl.prefix = null 2024-07-04T01:24:48.235422048Z remote.log.metadata.manager.listener.name = null 2024-07-04T01:24:48.235424982Z remote.log.reader.max.pending.tasks = 100 2024-07-04T01:24:48.235427838Z remote.log.reader.threads = 10 2024-07-04T01:24:48.235430671Z remote.log.storage.manager.class.name = null 2024-07-04T01:24:48.235436841Z remote.log.storage.manager.class.path = null 2024-07-04T01:24:48.235439742Z remote.log.storage.manager.impl.prefix = null 2024-07-04T01:24:48.235442623Z remote.log.storage.system.enable = false 2024-07-04T01:24:48.235445519Z replica.fetch.backoff.ms = 1000 2024-07-04T01:24:48.235448336Z replica.fetch.max.bytes = 1048576 2024-07-04T01:24:48.235451285Z replica.fetch.min.bytes = 1 2024-07-04T01:24:48.235463212Z replica.fetch.response.max.bytes = 10485760 2024-07-04T01:24:48.235466286Z replica.fetch.wait.max.ms = 500 2024-07-04T01:24:48.235469134Z replica.high.watermark.checkpoint.interval.ms = 5000 2024-07-04T01:24:48.235472274Z replica.lag.time.max.ms = 30000 2024-07-04T01:24:48.235475127Z replica.selector.class = null 2024-07-04T01:24:48.235477961Z replica.socket.receive.buffer.bytes = 65536 2024-07-04T01:24:48.235480737Z replica.socket.timeout.ms = 30000 2024-07-04T01:24:48.235483519Z replication.quota.window.num = 11 2024-07-04T01:24:48.235486324Z replication.quota.window.size.seconds = 1 2024-07-04T01:24:48.235489123Z request.timeout.ms = 30000 2024-07-04T01:24:48.235491969Z reserved.broker.max.id = 1000 2024-07-04T01:24:48.235494817Z sasl.client.callback.handler.class = null 2024-07-04T01:24:48.235497693Z sasl.enabled.mechanisms = [PLAIN, SCRAM-SHA-256, SCRAM-SHA-512] 2024-07-04T01:24:48.235500575Z sasl.jaas.config = null 2024-07-04T01:24:48.235503405Z sasl.kerberos.kinit.cmd = /usr/bin/kinit 2024-07-04T01:24:48.235506228Z sasl.kerberos.min.time.before.relogin = 60000 2024-07-04T01:24:48.235509056Z sasl.kerberos.principal.to.local.rules = [DEFAULT] 2024-07-04T01:24:48.235515135Z sasl.kerberos.service.name = null 2024-07-04T01:24:48.235518146Z sasl.kerberos.ticket.renew.jitter = 0.05 2024-07-04T01:24:48.235520971Z sasl.kerberos.ticket.renew.window.factor = 0.8 2024-07-04T01:24:48.235535812Z sasl.login.callback.handler.class = null 2024-07-04T01:24:48.236575431Z sasl.login.class = null 2024-07-04T01:24:48.236583233Z sasl.login.connect.timeout.ms = null 2024-07-04T01:24:48.236586346Z sasl.login.read.timeout.ms = null 2024-07-04T01:24:48.236589428Z sasl.login.refresh.buffer.seconds = 300 2024-07-04T01:24:48.236592386Z sasl.login.refresh.min.period.seconds = 60 2024-07-04T01:24:48.236595310Z sasl.login.refresh.window.factor = 0.8 2024-07-04T01:24:48.236598367Z sasl.login.refresh.window.jitter = 0.05 2024-07-04T01:24:48.236601651Z sasl.login.retry.backoff.max.ms = 10000 2024-07-04T01:24:48.236604588Z sasl.login.retry.backoff.ms = 100 2024-07-04T01:24:48.236607487Z sasl.mechanism.controller.protocol = PLAIN 2024-07-04T01:24:48.236610451Z sasl.mechanism.inter.broker.protocol = PLAIN 2024-07-04T01:24:48.236613462Z sasl.oauthbearer.clock.skew.seconds = 30 2024-07-04T01:24:48.236616335Z sasl.oauthbearer.expected.audience = null 2024-07-04T01:24:48.236619542Z sasl.oauthbearer.expected.issuer = null 2024-07-04T01:24:48.236623284Z sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 2024-07-04T01:24:48.236637799Z sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 2024-07-04T01:24:48.236640793Z sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 2024-07-04T01:24:48.236643698Z sasl.oauthbearer.jwks.endpoint.url = null 2024-07-04T01:24:48.236646638Z sasl.oauthbearer.scope.claim.name = scope 2024-07-04T01:24:48.236649581Z sasl.oauthbearer.sub.claim.name = sub 2024-07-04T01:24:48.236652458Z sasl.oauthbearer.token.endpoint.url = null 2024-07-04T01:24:48.236655347Z sasl.server.callback.handler.class = null 2024-07-04T01:24:48.236658250Z sasl.server.max.receive.size = 524288 2024-07-04T01:24:48.236665890Z security.inter.broker.protocol = PLAINTEXT 2024-07-04T01:24:48.236669487Z security.providers = null 2024-07-04T01:24:48.236672487Z server.max.startup.time.ms = 9223372036854775807 2024-07-04T01:24:48.236675655Z socket.connection.setup.timeout.max.ms = 30000 2024-07-04T01:24:48.236678570Z socket.connection.setup.timeout.ms = 10000 2024-07-04T01:24:48.236681471Z socket.listen.backlog.size = 50 2024-07-04T01:24:48.236684552Z socket.receive.buffer.bytes = 102400 2024-07-04T01:24:48.236687535Z socket.request.max.bytes = 104857600 2024-07-04T01:24:48.236690411Z socket.send.buffer.bytes = 102400 2024-07-04T01:24:48.236693311Z ssl.cipher.suites = [] 2024-07-04T01:24:48.236696288Z ssl.client.auth = none 2024-07-04T01:24:48.236699182Z ssl.enabled.protocols = [TLSv1.2, TLSv1.3] 2024-07-04T01:24:48.236711775Z ssl.endpoint.identification.algorithm = https 2024-07-04T01:24:48.236714881Z ssl.engine.factory.class = null 2024-07-04T01:24:48.236717887Z ssl.key.password = null 2024-07-04T01:24:48.236720808Z ssl.keymanager.algorithm = SunX509 2024-07-04T01:24:48.236723697Z ssl.keystore.certificate.chain = null 2024-07-04T01:24:48.236726573Z ssl.keystore.key = null 2024-07-04T01:24:48.236729538Z ssl.keystore.location = null 2024-07-04T01:24:48.236732499Z ssl.keystore.password = null 2024-07-04T01:24:48.236735459Z ssl.keystore.type = JKS 2024-07-04T01:24:48.236738363Z ssl.principal.mapping.rules = DEFAULT 2024-07-04T01:24:48.236741334Z ssl.protocol = TLSv1.3 2024-07-04T01:24:48.236744241Z ssl.provider = null 2024-07-04T01:24:48.236747195Z ssl.secure.random.implementation = null 2024-07-04T01:24:48.236750087Z ssl.trustmanager.algorithm = PKIX 2024-07-04T01:24:48.236753072Z ssl.truststore.certificates = null 2024-07-04T01:24:48.236756245Z ssl.truststore.location = null 2024-07-04T01:24:48.236759211Z ssl.truststore.password = null 2024-07-04T01:24:48.236762340Z ssl.truststore.type = JKS 2024-07-04T01:24:48.236766150Z transaction.abort.timed.out.transaction.cleanup.interval.ms = 10000 2024-07-04T01:24:48.236769139Z transaction.max.timeout.ms = 900000 2024-07-04T01:24:48.236772126Z transaction.remove.expired.transaction.cleanup.interval.ms = 3600000 2024-07-04T01:24:48.236775174Z transaction.state.log.load.buffer.size = 5242880 2024-07-04T01:24:48.236788668Z transaction.state.log.min.isr = 2 2024-07-04T01:24:48.236791742Z transaction.state.log.num.partitions = 50 2024-07-04T01:24:48.236794577Z transaction.state.log.replication.factor = 3 2024-07-04T01:24:48.236797520Z transaction.state.log.segment.bytes = 104857600 2024-07-04T01:24:48.236800540Z transactional.id.expiration.ms = 604800000 2024-07-04T01:24:48.236803651Z unclean.leader.election.enable = false 2024-07-04T01:24:48.236809550Z unstable.api.versions.enable = false 2024-07-04T01:24:48.236812547Z zookeeper.clientCnxnSocket = null 2024-07-04T01:24:48.236815447Z zookeeper.connect = null 2024-07-04T01:24:48.236821133Z zookeeper.connection.timeout.ms = null 2024-07-04T01:24:48.236824208Z zookeeper.max.in.flight.requests = 10 2024-07-04T01:24:48.236827121Z zookeeper.metadata.migration.enable = false 2024-07-04T01:24:48.236830379Z zookeeper.session.timeout.ms = 18000 2024-07-04T01:24:48.236833651Z zookeeper.set.acl = false 2024-07-04T01:24:48.236836824Z zookeeper.ssl.cipher.suites = null 2024-07-04T01:24:48.236839945Z zookeeper.ssl.client.enable = false 2024-07-04T01:24:48.236842938Z zookeeper.ssl.crl.enable = false 2024-07-04T01:24:48.236845800Z zookeeper.ssl.enabled.protocols = null 2024-07-04T01:24:48.236848779Z zookeeper.ssl.endpoint.identification.algorithm = HTTPS 2024-07-04T01:24:48.236865263Z zookeeper.ssl.keystore.location = null 2024-07-04T01:24:48.236868505Z zookeeper.ssl.keystore.password = null 2024-07-04T01:24:48.236871444Z zookeeper.ssl.keystore.type = null 2024-07-04T01:24:48.236874431Z zookeeper.ssl.ocsp.enable = false 2024-07-04T01:24:48.236877316Z zookeeper.ssl.protocol = TLSv1.2 2024-07-04T01:24:48.236880226Z zookeeper.ssl.truststore.location = null 2024-07-04T01:24:48.236883162Z zookeeper.ssl.truststore.password = null 2024-07-04T01:24:48.236886065Z zookeeper.ssl.truststore.type = null 2024-07-04T01:24:48.236889033Z (kafka.server.KafkaConfig) 2024-07-04T01:24:48.236901832Z [2024-07-04 01:24:48,235] INFO [QuorumController id=1] The request from broker 0 to unfence has been granted because it has caught up with the offset of its register broker record 6. (org.apache.kafka.controller.BrokerHeartbeatManager) 2024-07-04T01:24:48.281655529Z [2024-07-04 01:24:48,281] INFO [BrokerServer id=1] Waiting for the broker to be unfenced (kafka.server.BrokerServer) 2024-07-04T01:24:48.314951707Z [2024-07-04 01:24:48,307] INFO [QuorumController id=1] The request from broker 1 to unfence has been granted because it has caught up with the offset of its register broker record 7. (org.apache.kafka.controller.BrokerHeartbeatManager) 2024-07-04T01:24:48.459090366Z [2024-07-04 01:24:48,458] INFO [BrokerLifecycleManager id=1] The broker has been unfenced. Transitioning from RECOVERY to RUNNING. (kafka.server.BrokerLifecycleManager) 2024-07-04T01:24:48.459123380Z [2024-07-04 01:24:48,458] INFO [BrokerServer id=1] Finished waiting for the broker to be unfenced (kafka.server.BrokerServer) 2024-07-04T01:24:48.459128410Z [2024-07-04 01:24:48,458] INFO [SocketServer listenerType=BROKER, nodeId=1] Enabling request processing. (kafka.network.SocketServer) 2024-07-04T01:24:48.462511688Z [2024-07-04 01:24:48,458] INFO Awaiting socket connections on 0.0.0.0:9094. (kafka.network.DataPlaneAcceptor) 2024-07-04T01:24:48.519170384Z [2024-07-04 01:24:48,518] INFO Awaiting socket connections on 0.0.0.0:9092. (kafka.network.DataPlaneAcceptor) 2024-07-04T01:24:48.541943121Z [2024-07-04 01:24:48,540] INFO [BrokerServer id=1] Waiting for all of the authorizer futures to be completed (kafka.server.BrokerServer) 2024-07-04T01:24:48.541955615Z [2024-07-04 01:24:48,540] INFO [BrokerServer id=1] Finished waiting for all of the authorizer futures to be completed (kafka.server.BrokerServer) 2024-07-04T01:24:48.541959136Z [2024-07-04 01:24:48,541] INFO [BrokerServer id=1] Waiting for all of the SocketServer Acceptors to be started (kafka.server.BrokerServer) 2024-07-04T01:24:48.541962571Z [2024-07-04 01:24:48,541] INFO [BrokerServer id=1] Finished waiting for all of the SocketServer Acceptors to be started (kafka.server.BrokerServer) 2024-07-04T01:24:48.543941823Z [2024-07-04 01:24:48,541] INFO [BrokerServer id=1] Transition from STARTING to STARTED (kafka.server.BrokerServer) 2024-07-04T01:24:48.543951579Z [2024-07-04 01:24:48,542] INFO Kafka version: 3.5.1 (org.apache.kafka.common.utils.AppInfoParser) 2024-07-04T01:24:48.543954679Z [2024-07-04 01:24:48,542] INFO Kafka commitId: 2c6fb6c54472e90a (org.apache.kafka.common.utils.AppInfoParser) 2024-07-04T01:24:48.543957637Z [2024-07-04 01:24:48,542] INFO Kafka startTimeMs: 1720056288541 (org.apache.kafka.common.utils.AppInfoParser) 2024-07-04T01:24:48.543960682Z [2024-07-04 01:24:48,543] INFO [KafkaRaftServer nodeId=1] Kafka Server started (kafka.server.KafkaRaftServer) 2024-07-04T01:24:48.654305050Z [2024-07-04 01:24:48,653] INFO [QuorumController id=1] The request from broker 2 to unfence has been granted because it has caught up with the offset of its register broker record 9. (org.apache.kafka.controller.BrokerHeartbeatManager) 2024-07-04T01:25:00.566643802Z [2024-07-04 01:25:00,555] INFO Sent auto-creation request for Set(admin) to the active controller. (kafka.server.DefaultAutoTopicCreationManager) 2024-07-04T01:25:00.604180838Z [2024-07-04 01:25:00,601] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='admin', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:00.604200917Z [2024-07-04 01:25:00,602] INFO [QuorumController id=1] Created topic admin with topic ID xsVOMBTXSx6ZXIMyucXiKg. (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:00.604207020Z [2024-07-04 01:25:00,602] INFO [QuorumController id=1] Created partition admin-0 with topic ID xsVOMBTXSx6ZXIMyucXiKg and PartitionRegistration(replicas=[2], isr=[2], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:00.839175723Z [2024-07-04 01:25:00,826] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='admin', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'admin' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:01.443003718Z [2024-07-04 01:25:01,436] INFO Sent auto-creation request for Set(ns) to the active controller. (kafka.server.DefaultAutoTopicCreationManager) 2024-07-04T01:25:01.443025329Z [2024-07-04 01:25:01,440] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='ns', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:01.443029396Z [2024-07-04 01:25:01,440] INFO [QuorumController id=1] Created topic ns with topic ID 9LA51hOXTiGKvIblKs0hmg. (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:01.443034353Z [2024-07-04 01:25:01,440] INFO [QuorumController id=1] Created partition ns-0 with topic ID 9LA51hOXTiGKvIblKs0hmg and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:01.492040758Z [2024-07-04 01:25:01,480] INFO [Broker id=1] Transitioning 1 partition(s) to local leaders. (state.change.logger) 2024-07-04T01:25:01.492061380Z [2024-07-04 01:25:01,481] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions Set(ns-0) (kafka.server.ReplicaFetcherManager) 2024-07-04T01:25:01.492066401Z [2024-07-04 01:25:01,483] INFO [Broker id=1] Creating new partition ns-0 with topic id 9LA51hOXTiGKvIblKs0hmg. (state.change.logger) 2024-07-04T01:25:01.518976711Z [2024-07-04 01:25:01,508] INFO [LogLoader partition=ns-0, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) 2024-07-04T01:25:01.518997447Z [2024-07-04 01:25:01,513] INFO Created log for partition ns-0 in /bitnami/kafka/data/ns-0 with properties {} (kafka.log.LogManager) 2024-07-04T01:25:01.519007555Z [2024-07-04 01:25:01,515] INFO [Partition ns-0 broker=1] No checkpointed highwatermark is found for partition ns-0 (kafka.cluster.Partition) 2024-07-04T01:25:01.519010795Z [2024-07-04 01:25:01,516] INFO [Partition ns-0 broker=1] Log loaded for partition ns-0 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:01.520227310Z [2024-07-04 01:25:01,519] INFO [Broker id=1] Leader ns-0 with topic id Some(9LA51hOXTiGKvIblKs0hmg) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:01.655812375Z [2024-07-04 01:25:01,636] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='ns', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'ns' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:01.721422261Z [2024-07-04 01:25:01,719] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='ns', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'ns' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:01.852388564Z [2024-07-04 01:25:01,848] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='ns', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'ns' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:01.966995900Z [2024-07-04 01:25:01,965] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='ns', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'ns' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:02.176716910Z [2024-07-04 01:25:02,175] INFO Sent auto-creation request for Set(nsi) to the active controller. (kafka.server.DefaultAutoTopicCreationManager) 2024-07-04T01:25:02.187002360Z [2024-07-04 01:25:02,185] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='nsi', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:02.187018056Z [2024-07-04 01:25:02,185] INFO [QuorumController id=1] Created topic nsi with topic ID JfFPuulRQxOIWB09eb6c5Q. (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:02.187023451Z [2024-07-04 01:25:02,185] INFO [QuorumController id=1] Created partition nsi-0 with topic ID JfFPuulRQxOIWB09eb6c5Q and PartitionRegistration(replicas=[0], isr=[0], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:02.357813262Z [2024-07-04 01:25:02,354] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='nsi', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'nsi' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:02.478061308Z [2024-07-04 01:25:02,477] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='nsi', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'nsi' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:02.716922384Z [2024-07-04 01:25:02,711] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='vnf', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:02.716933270Z [2024-07-04 01:25:02,711] INFO [QuorumController id=1] Created topic vnf with topic ID FLCLCZIWT_uuuXnWh7Kb9g. (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:02.716938742Z [2024-07-04 01:25:02,711] INFO [QuorumController id=1] Created partition vnf-0 with topic ID FLCLCZIWT_uuuXnWh7Kb9g and PartitionRegistration(replicas=[2], isr=[2], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:02.824097605Z [2024-07-04 01:25:02,821] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='vnf', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'vnf' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:02.930256933Z [2024-07-04 01:25:02,929] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='vnf', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'vnf' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:13.443065330Z [2024-07-04 01:25:13,442] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='vim_account', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:13.443088301Z [2024-07-04 01:25:13,442] INFO [QuorumController id=1] Created topic vim_account with topic ID qUYoaB-HQDy1QEkmi1-Qrw. (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:13.443095935Z [2024-07-04 01:25:13,442] INFO [QuorumController id=1] Created partition vim_account-0 with topic ID qUYoaB-HQDy1QEkmi1-Qrw and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:13.524411140Z [2024-07-04 01:25:13,523] INFO [Broker id=1] Transitioning 1 partition(s) to local leaders. (state.change.logger) 2024-07-04T01:25:13.526769992Z [2024-07-04 01:25:13,524] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions Set(vim_account-0) (kafka.server.ReplicaFetcherManager) 2024-07-04T01:25:13.526782071Z [2024-07-04 01:25:13,525] INFO [Broker id=1] Creating new partition vim_account-0 with topic id qUYoaB-HQDy1QEkmi1-Qrw. (state.change.logger) 2024-07-04T01:25:13.538472321Z [2024-07-04 01:25:13,538] INFO [LogLoader partition=vim_account-0, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) 2024-07-04T01:25:13.539384857Z [2024-07-04 01:25:13,539] INFO Created log for partition vim_account-0 in /bitnami/kafka/data/vim_account-0 with properties {} (kafka.log.LogManager) 2024-07-04T01:25:13.541331101Z [2024-07-04 01:25:13,540] INFO [Partition vim_account-0 broker=1] No checkpointed highwatermark is found for partition vim_account-0 (kafka.cluster.Partition) 2024-07-04T01:25:13.541341869Z [2024-07-04 01:25:13,540] INFO [Partition vim_account-0 broker=1] Log loaded for partition vim_account-0 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:13.541347572Z [2024-07-04 01:25:13,540] INFO [Broker id=1] Leader vim_account-0 with topic id Some(qUYoaB-HQDy1QEkmi1-Qrw) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:13.825651979Z [2024-07-04 01:25:13,824] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='wim_account', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:13.825669349Z [2024-07-04 01:25:13,824] INFO [QuorumController id=1] Created topic wim_account with topic ID G9WyhjPkT_K2DnoGxxlhUQ. (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:13.825675069Z [2024-07-04 01:25:13,824] INFO [QuorumController id=1] Created partition wim_account-0 with topic ID G9WyhjPkT_K2DnoGxxlhUQ and PartitionRegistration(replicas=[0], isr=[0], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:14.269252299Z [2024-07-04 01:25:14,268] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='sdn', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:14.269262137Z [2024-07-04 01:25:14,268] INFO [QuorumController id=1] Created topic sdn with topic ID u_Mqm5aCS6WdDvnPDNMmyA. (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:14.269283173Z [2024-07-04 01:25:14,268] INFO [QuorumController id=1] Created partition sdn-0 with topic ID u_Mqm5aCS6WdDvnPDNMmyA and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:14.363591118Z [2024-07-04 01:25:14,363] INFO [Broker id=1] Transitioning 1 partition(s) to local leaders. (state.change.logger) 2024-07-04T01:25:14.363714135Z [2024-07-04 01:25:14,363] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions Set(sdn-0) (kafka.server.ReplicaFetcherManager) 2024-07-04T01:25:14.363799721Z [2024-07-04 01:25:14,363] INFO [Broker id=1] Creating new partition sdn-0 with topic id u_Mqm5aCS6WdDvnPDNMmyA. (state.change.logger) 2024-07-04T01:25:14.376176497Z [2024-07-04 01:25:14,375] INFO [LogLoader partition=sdn-0, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) 2024-07-04T01:25:14.377084539Z [2024-07-04 01:25:14,376] INFO Created log for partition sdn-0 in /bitnami/kafka/data/sdn-0 with properties {} (kafka.log.LogManager) 2024-07-04T01:25:14.377790380Z [2024-07-04 01:25:14,377] INFO [Partition sdn-0 broker=1] No checkpointed highwatermark is found for partition sdn-0 (kafka.cluster.Partition) 2024-07-04T01:25:14.377802187Z [2024-07-04 01:25:14,377] INFO [Partition sdn-0 broker=1] Log loaded for partition sdn-0 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:14.377807334Z [2024-07-04 01:25:14,377] INFO [Broker id=1] Leader sdn-0 with topic id Some(u_Mqm5aCS6WdDvnPDNMmyA) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:14.395123870Z [2024-07-04 01:25:14,394] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='sdn', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'sdn' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:14.675165150Z [2024-07-04 01:25:14,674] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='sdn', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'sdn' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:23.147706479Z [2024-07-04 01:25:23,142] INFO Sent auto-creation request for Set(__consumer_offsets) to the active controller. (kafka.server.DefaultAutoTopicCreationManager) 2024-07-04T01:25:23.162895789Z [2024-07-04 01:25:23,158] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='__consumer_offsets', numPartitions=50, replicationFactor=3, assignments=[], configs=[CreateableTopicConfig(name='compression.type', value='producer'), CreateableTopicConfig(name='cleanup.policy', value='compact'), CreateableTopicConfig(name='segment.bytes', value='104857600')]): SUCCESS (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:23.162906554Z [2024-07-04 01:25:23,158] INFO [QuorumController id=1] Created topic __consumer_offsets with topic ID RyS8mwweRHmB0P-eZeLopQ. (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:23.162911631Z [2024-07-04 01:25:23,158] INFO [QuorumController id=1] ConfigResource(type=TOPIC, name='__consumer_offsets'): set configuration compression.type to producer (org.apache.kafka.controller.ConfigurationControlManager) 2024-07-04T01:25:23.162914872Z [2024-07-04 01:25:23,158] INFO [QuorumController id=1] ConfigResource(type=TOPIC, name='__consumer_offsets'): set configuration cleanup.policy to compact (org.apache.kafka.controller.ConfigurationControlManager) 2024-07-04T01:25:23.162918040Z [2024-07-04 01:25:23,158] INFO [QuorumController id=1] ConfigResource(type=TOPIC, name='__consumer_offsets'): set configuration segment.bytes to 104857600 (org.apache.kafka.controller.ConfigurationControlManager) 2024-07-04T01:25:23.163007108Z [2024-07-04 01:25:23,158] INFO [QuorumController id=1] Created partition __consumer_offsets-0 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.163010648Z [2024-07-04 01:25:23,158] INFO [QuorumController id=1] Created partition __consumer_offsets-1 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.163796580Z [2024-07-04 01:25:23,161] INFO [QuorumController id=1] Created partition __consumer_offsets-2 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.163815918Z [2024-07-04 01:25:23,162] INFO [QuorumController id=1] Created partition __consumer_offsets-3 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.163821762Z [2024-07-04 01:25:23,162] INFO [QuorumController id=1] Created partition __consumer_offsets-4 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.163827331Z [2024-07-04 01:25:23,162] INFO [QuorumController id=1] Created partition __consumer_offsets-5 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.163831836Z [2024-07-04 01:25:23,162] INFO [QuorumController id=1] Created partition __consumer_offsets-6 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.163836887Z [2024-07-04 01:25:23,162] INFO [QuorumController id=1] Created partition __consumer_offsets-7 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.163841909Z [2024-07-04 01:25:23,162] INFO [QuorumController id=1] Created partition __consumer_offsets-8 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.163846379Z [2024-07-04 01:25:23,162] INFO [QuorumController id=1] Created partition __consumer_offsets-9 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.163870895Z [2024-07-04 01:25:23,162] INFO [QuorumController id=1] Created partition __consumer_offsets-10 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.163875389Z [2024-07-04 01:25:23,162] INFO [QuorumController id=1] Created partition __consumer_offsets-11 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.171381271Z [2024-07-04 01:25:23,164] INFO [QuorumController id=1] Created partition __consumer_offsets-12 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.171393055Z [2024-07-04 01:25:23,164] INFO [QuorumController id=1] Created partition __consumer_offsets-13 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.188264626Z [2024-07-04 01:25:23,164] INFO [QuorumController id=1] Created partition __consumer_offsets-14 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.188282843Z [2024-07-04 01:25:23,183] INFO [QuorumController id=1] Created partition __consumer_offsets-15 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.188286522Z [2024-07-04 01:25:23,183] INFO [QuorumController id=1] Created partition __consumer_offsets-16 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.188289663Z [2024-07-04 01:25:23,183] INFO [QuorumController id=1] Created partition __consumer_offsets-17 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.188292719Z [2024-07-04 01:25:23,183] INFO [QuorumController id=1] Created partition __consumer_offsets-18 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.188298374Z [2024-07-04 01:25:23,183] INFO [QuorumController id=1] Created partition __consumer_offsets-19 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.188315721Z [2024-07-04 01:25:23,184] INFO [QuorumController id=1] Created partition __consumer_offsets-20 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.188328506Z [2024-07-04 01:25:23,184] INFO [QuorumController id=1] Created partition __consumer_offsets-21 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.189398189Z [2024-07-04 01:25:23,184] INFO [QuorumController id=1] Created partition __consumer_offsets-22 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.189411523Z [2024-07-04 01:25:23,184] INFO [QuorumController id=1] Created partition __consumer_offsets-23 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.189415602Z [2024-07-04 01:25:23,184] INFO [QuorumController id=1] Created partition __consumer_offsets-24 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.189418861Z [2024-07-04 01:25:23,184] INFO [QuorumController id=1] Created partition __consumer_offsets-25 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.189421973Z [2024-07-04 01:25:23,184] INFO [QuorumController id=1] Created partition __consumer_offsets-26 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.189425067Z [2024-07-04 01:25:23,184] INFO [QuorumController id=1] Created partition __consumer_offsets-27 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.189428241Z [2024-07-04 01:25:23,185] INFO [QuorumController id=1] Created partition __consumer_offsets-28 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.189431631Z [2024-07-04 01:25:23,185] INFO [QuorumController id=1] Created partition __consumer_offsets-29 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.189443792Z [2024-07-04 01:25:23,185] INFO [QuorumController id=1] Created partition __consumer_offsets-30 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.189447142Z [2024-07-04 01:25:23,185] INFO [QuorumController id=1] Created partition __consumer_offsets-31 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.189450312Z [2024-07-04 01:25:23,185] INFO [QuorumController id=1] Created partition __consumer_offsets-32 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.189459677Z [2024-07-04 01:25:23,185] INFO [QuorumController id=1] Created partition __consumer_offsets-33 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.189463162Z [2024-07-04 01:25:23,185] INFO [QuorumController id=1] Created partition __consumer_offsets-34 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.201667737Z [2024-07-04 01:25:23,199] INFO [QuorumController id=1] Created partition __consumer_offsets-35 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.201674984Z [2024-07-04 01:25:23,199] INFO [QuorumController id=1] Created partition __consumer_offsets-36 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.201678516Z [2024-07-04 01:25:23,199] INFO [QuorumController id=1] Created partition __consumer_offsets-37 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.201682027Z [2024-07-04 01:25:23,199] INFO [QuorumController id=1] Created partition __consumer_offsets-38 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.201687508Z [2024-07-04 01:25:23,199] INFO [QuorumController id=1] Created partition __consumer_offsets-39 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.201690577Z [2024-07-04 01:25:23,200] INFO [QuorumController id=1] Created partition __consumer_offsets-40 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.201698765Z [2024-07-04 01:25:23,200] INFO [QuorumController id=1] Created partition __consumer_offsets-41 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.201701725Z [2024-07-04 01:25:23,200] INFO [QuorumController id=1] Created partition __consumer_offsets-42 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.201704991Z [2024-07-04 01:25:23,200] INFO [QuorumController id=1] Created partition __consumer_offsets-43 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.201707871Z [2024-07-04 01:25:23,200] INFO [QuorumController id=1] Created partition __consumer_offsets-44 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.201710853Z [2024-07-04 01:25:23,200] INFO [QuorumController id=1] Created partition __consumer_offsets-45 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.201717094Z [2024-07-04 01:25:23,200] INFO [QuorumController id=1] Created partition __consumer_offsets-46 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.201721232Z [2024-07-04 01:25:23,200] INFO [QuorumController id=1] Created partition __consumer_offsets-47 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.201725549Z [2024-07-04 01:25:23,200] INFO [QuorumController id=1] Created partition __consumer_offsets-48 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.201731457Z [2024-07-04 01:25:23,200] INFO [QuorumController id=1] Created partition __consumer_offsets-49 with topic ID RyS8mwweRHmB0P-eZeLopQ 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-07-04T01:25:23.284434627Z [2024-07-04 01:25:23,284] INFO [Broker id=1] Transitioning 17 partition(s) to local leaders. (state.change.logger) 2024-07-04T01:25:23.285593330Z [2024-07-04 01:25:23,284] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions Set(__consumer_offsets-15, __consumer_offsets-13, __consumer_offsets-45, __consumer_offsets-10, __consumer_offsets-42, __consumer_offsets-23, __consumer_offsets-20, __consumer_offsets-49, __consumer_offsets-0, __consumer_offsets-32, __consumer_offsets-27, __consumer_offsets-26, __consumer_offsets-7, __consumer_offsets-39, __consumer_offsets-5, __consumer_offsets-37, __consumer_offsets-34) (kafka.server.ReplicaFetcherManager) 2024-07-04T01:25:23.285600811Z [2024-07-04 01:25:23,284] INFO [Broker id=1] Creating new partition __consumer_offsets-15 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:23.322822451Z [2024-07-04 01:25:23,319] 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-07-04T01:25:23.323123210Z [2024-07-04 01:25:23,320] 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-07-04T01:25:23.323811867Z [2024-07-04 01:25:23,323] INFO [Partition __consumer_offsets-15 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-15 (kafka.cluster.Partition) 2024-07-04T01:25:23.325471931Z [2024-07-04 01:25:23,324] INFO [Partition __consumer_offsets-15 broker=1] Log loaded for partition __consumer_offsets-15 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:23.325484548Z [2024-07-04 01:25:23,325] INFO [Broker id=1] Leader __consumer_offsets-15 with topic id Some(RyS8mwweRHmB0P-eZeLopQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,2,0], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:23.347902096Z [2024-07-04 01:25:23,346] INFO [Broker id=1] Creating new partition __consumer_offsets-13 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:23.363467417Z [2024-07-04 01:25:23,361] 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-07-04T01:25:23.363743836Z [2024-07-04 01:25:23,362] 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-07-04T01:25:23.363748670Z [2024-07-04 01:25:23,362] INFO [Partition __consumer_offsets-13 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-13 (kafka.cluster.Partition) 2024-07-04T01:25:23.363751892Z [2024-07-04 01:25:23,362] INFO [Partition __consumer_offsets-13 broker=1] Log loaded for partition __consumer_offsets-13 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:23.363758921Z [2024-07-04 01:25:23,362] INFO [Broker id=1] Leader __consumer_offsets-13 with topic id Some(RyS8mwweRHmB0P-eZeLopQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,0,2], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:23.375358219Z [2024-07-04 01:25:23,375] INFO [Broker id=1] Creating new partition __consumer_offsets-45 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:23.381734655Z [2024-07-04 01:25:23,380] 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-07-04T01:25:23.381754576Z [2024-07-04 01:25:23,381] 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-07-04T01:25:23.381774396Z [2024-07-04 01:25:23,381] INFO [Partition __consumer_offsets-45 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-45 (kafka.cluster.Partition) 2024-07-04T01:25:23.382214663Z [2024-07-04 01:25:23,381] INFO [Partition __consumer_offsets-45 broker=1] Log loaded for partition __consumer_offsets-45 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:23.382228325Z [2024-07-04 01:25:23,381] INFO [Broker id=1] Leader __consumer_offsets-45 with topic id Some(RyS8mwweRHmB0P-eZeLopQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,2,0], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:23.389957791Z [2024-07-04 01:25:23,389] INFO [Broker id=1] Creating new partition __consumer_offsets-10 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:23.406160746Z [2024-07-04 01:25:23,405] 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-07-04T01:25:23.407268760Z [2024-07-04 01:25:23,407] 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-07-04T01:25:23.407543964Z [2024-07-04 01:25:23,407] INFO [Partition __consumer_offsets-10 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-10 (kafka.cluster.Partition) 2024-07-04T01:25:23.407622181Z [2024-07-04 01:25:23,407] INFO [Partition __consumer_offsets-10 broker=1] Log loaded for partition __consumer_offsets-10 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:23.408004408Z [2024-07-04 01:25:23,407] INFO [Broker id=1] Leader __consumer_offsets-10 with topic id Some(RyS8mwweRHmB0P-eZeLopQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,0,2], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:23.416715208Z [2024-07-04 01:25:23,416] INFO [Broker id=1] Creating new partition __consumer_offsets-42 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:23.421202661Z [2024-07-04 01:25:23,420] 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-07-04T01:25:23.429022033Z [2024-07-04 01:25:23,421] 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-07-04T01:25:23.429038889Z [2024-07-04 01:25:23,421] INFO [Partition __consumer_offsets-42 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-42 (kafka.cluster.Partition) 2024-07-04T01:25:23.429046138Z [2024-07-04 01:25:23,421] INFO [Partition __consumer_offsets-42 broker=1] Log loaded for partition __consumer_offsets-42 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:23.429062944Z [2024-07-04 01:25:23,422] INFO [Broker id=1] Leader __consumer_offsets-42 with topic id Some(RyS8mwweRHmB0P-eZeLopQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,2,0], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:23.429067853Z [2024-07-04 01:25:23,425] INFO [Broker id=1] Creating new partition __consumer_offsets-23 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:23.429909576Z [2024-07-04 01:25:23,429] 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-07-04T01:25:23.431017085Z [2024-07-04 01:25:23,430] 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-07-04T01:25:23.431179110Z [2024-07-04 01:25:23,430] INFO [Partition __consumer_offsets-23 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-23 (kafka.cluster.Partition) 2024-07-04T01:25:23.431184788Z [2024-07-04 01:25:23,431] INFO [Partition __consumer_offsets-23 broker=1] Log loaded for partition __consumer_offsets-23 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:23.431188724Z [2024-07-04 01:25:23,431] INFO [Broker id=1] Leader __consumer_offsets-23 with topic id Some(RyS8mwweRHmB0P-eZeLopQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,0,2], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:23.438441020Z [2024-07-04 01:25:23,416] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='__consumer_offsets', numPartitions=50, replicationFactor=3, assignments=[], configs=[CreateableTopicConfig(name='compression.type', value='producer'), CreateableTopicConfig(name='cleanup.policy', value='compact'), CreateableTopicConfig(name='segment.bytes', value='104857600')]): TOPIC_ALREADY_EXISTS (Topic '__consumer_offsets' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:23.441200862Z [2024-07-04 01:25:23,440] INFO [Broker id=1] Creating new partition __consumer_offsets-20 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:23.482465445Z [2024-07-04 01:25:23,475] 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-07-04T01:25:23.482489744Z [2024-07-04 01:25:23,476] 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-07-04T01:25:23.482494263Z [2024-07-04 01:25:23,476] INFO [Partition __consumer_offsets-20 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-20 (kafka.cluster.Partition) 2024-07-04T01:25:23.482497285Z [2024-07-04 01:25:23,476] INFO [Partition __consumer_offsets-20 broker=1] Log loaded for partition __consumer_offsets-20 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:23.484571805Z [2024-07-04 01:25:23,477] INFO [Broker id=1] Leader __consumer_offsets-20 with topic id Some(RyS8mwweRHmB0P-eZeLopQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,0,2], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:23.491996489Z [2024-07-04 01:25:23,491] INFO [Broker id=1] Creating new partition __consumer_offsets-49 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:23.531028145Z [2024-07-04 01:25:23,526] 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-07-04T01:25:23.531102051Z [2024-07-04 01:25:23,527] 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-07-04T01:25:23.531106888Z [2024-07-04 01:25:23,527] INFO [Partition __consumer_offsets-49 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-49 (kafka.cluster.Partition) 2024-07-04T01:25:23.531119445Z [2024-07-04 01:25:23,527] INFO [Partition __consumer_offsets-49 broker=1] Log loaded for partition __consumer_offsets-49 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:23.531123197Z [2024-07-04 01:25:23,528] INFO [Broker id=1] Leader __consumer_offsets-49 with topic id Some(RyS8mwweRHmB0P-eZeLopQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,2,0], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:23.531127174Z [2024-07-04 01:25:23,529] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='__consumer_offsets', numPartitions=50, replicationFactor=3, assignments=[], configs=[CreateableTopicConfig(name='compression.type', value='producer'), CreateableTopicConfig(name='cleanup.policy', value='compact'), CreateableTopicConfig(name='segment.bytes', value='104857600')]): TOPIC_ALREADY_EXISTS (Topic '__consumer_offsets' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:23.535175967Z [2024-07-04 01:25:23,532] INFO [Broker id=1] Creating new partition __consumer_offsets-0 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:23.537581218Z [2024-07-04 01:25:23,536] 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-07-04T01:25:23.538470459Z [2024-07-04 01:25:23,537] 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-07-04T01:25:23.539396607Z [2024-07-04 01:25:23,537] INFO [Partition __consumer_offsets-0 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-0 (kafka.cluster.Partition) 2024-07-04T01:25:23.539421918Z [2024-07-04 01:25:23,537] INFO [Partition __consumer_offsets-0 broker=1] Log loaded for partition __consumer_offsets-0 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:23.539433159Z [2024-07-04 01:25:23,539] INFO [Broker id=1] Leader __consumer_offsets-0 with topic id Some(RyS8mwweRHmB0P-eZeLopQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,2,0], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:23.547313179Z [2024-07-04 01:25:23,546] INFO [Broker id=1] Creating new partition __consumer_offsets-32 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:23.553184978Z [2024-07-04 01:25:23,552] 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-07-04T01:25:23.554416817Z [2024-07-04 01:25:23,553] 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-07-04T01:25:23.554423552Z [2024-07-04 01:25:23,553] INFO [Partition __consumer_offsets-32 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-32 (kafka.cluster.Partition) 2024-07-04T01:25:23.554426631Z [2024-07-04 01:25:23,553] INFO [Partition __consumer_offsets-32 broker=1] Log loaded for partition __consumer_offsets-32 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:23.554430143Z [2024-07-04 01:25:23,553] INFO [Broker id=1] Leader __consumer_offsets-32 with topic id Some(RyS8mwweRHmB0P-eZeLopQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,0,2], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:23.558437120Z [2024-07-04 01:25:23,558] INFO [Broker id=1] Creating new partition __consumer_offsets-27 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:23.567821115Z [2024-07-04 01:25:23,566] 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-07-04T01:25:23.571620316Z [2024-07-04 01:25:23,570] 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-07-04T01:25:23.571635212Z [2024-07-04 01:25:23,570] INFO [Partition __consumer_offsets-27 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-27 (kafka.cluster.Partition) 2024-07-04T01:25:23.571640288Z [2024-07-04 01:25:23,570] INFO [Partition __consumer_offsets-27 broker=1] Log loaded for partition __consumer_offsets-27 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:23.571645684Z [2024-07-04 01:25:23,570] INFO [Broker id=1] Leader __consumer_offsets-27 with topic id Some(RyS8mwweRHmB0P-eZeLopQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,2,0], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:23.577902679Z [2024-07-04 01:25:23,577] INFO [Broker id=1] Creating new partition __consumer_offsets-26 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:23.583867718Z [2024-07-04 01:25:23,583] 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-07-04T01:25:23.584656160Z [2024-07-04 01:25:23,584] 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-07-04T01:25:23.584820352Z [2024-07-04 01:25:23,584] INFO [Partition __consumer_offsets-26 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-26 (kafka.cluster.Partition) 2024-07-04T01:25:23.584825173Z [2024-07-04 01:25:23,584] INFO [Partition __consumer_offsets-26 broker=1] Log loaded for partition __consumer_offsets-26 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:23.585402204Z [2024-07-04 01:25:23,584] INFO [Broker id=1] Leader __consumer_offsets-26 with topic id Some(RyS8mwweRHmB0P-eZeLopQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,0,2], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:23.596442118Z [2024-07-04 01:25:23,591] INFO [Broker id=1] Creating new partition __consumer_offsets-7 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:23.604189155Z [2024-07-04 01:25:23,604] 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-07-04T01:25:23.606738811Z [2024-07-04 01:25:23,605] 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-07-04T01:25:23.607498074Z [2024-07-04 01:25:23,606] INFO [Partition __consumer_offsets-7 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-7 (kafka.cluster.Partition) 2024-07-04T01:25:23.609749319Z [2024-07-04 01:25:23,608] INFO [Partition __consumer_offsets-7 broker=1] Log loaded for partition __consumer_offsets-7 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:23.609778135Z [2024-07-04 01:25:23,608] INFO [Broker id=1] Leader __consumer_offsets-7 with topic id Some(RyS8mwweRHmB0P-eZeLopQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,0,2], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:23.619722136Z [2024-07-04 01:25:23,618] INFO [Broker id=1] Creating new partition __consumer_offsets-39 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:23.628229824Z [2024-07-04 01:25:23,627] 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-07-04T01:25:23.628243778Z [2024-07-04 01:25:23,627] 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-07-04T01:25:23.628247848Z [2024-07-04 01:25:23,627] INFO [Partition __consumer_offsets-39 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-39 (kafka.cluster.Partition) 2024-07-04T01:25:23.628251551Z [2024-07-04 01:25:23,627] INFO [Partition __consumer_offsets-39 broker=1] Log loaded for partition __consumer_offsets-39 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:23.628255352Z [2024-07-04 01:25:23,627] INFO [Broker id=1] Leader __consumer_offsets-39 with topic id Some(RyS8mwweRHmB0P-eZeLopQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,2,0], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:23.638378153Z [2024-07-04 01:25:23,637] INFO [Broker id=1] Creating new partition __consumer_offsets-5 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:23.660733475Z [2024-07-04 01:25:23,659] 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-07-04T01:25:23.663996670Z [2024-07-04 01:25:23,662] 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-07-04T01:25:23.665115310Z [2024-07-04 01:25:23,662] INFO [Partition __consumer_offsets-5 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-5 (kafka.cluster.Partition) 2024-07-04T01:25:23.665120935Z [2024-07-04 01:25:23,662] INFO [Partition __consumer_offsets-5 broker=1] Log loaded for partition __consumer_offsets-5 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:23.665128741Z [2024-07-04 01:25:23,662] INFO [Broker id=1] Leader __consumer_offsets-5 with topic id Some(RyS8mwweRHmB0P-eZeLopQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,2,0], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:23.672055935Z [2024-07-04 01:25:23,671] INFO [Broker id=1] Creating new partition __consumer_offsets-37 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:23.843961780Z [2024-07-04 01:25:23,843] 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-07-04T01:25:23.848109587Z [2024-07-04 01:25:23,846] 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-07-04T01:25:23.848125069Z [2024-07-04 01:25:23,846] INFO [Partition __consumer_offsets-37 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-37 (kafka.cluster.Partition) 2024-07-04T01:25:23.848557860Z [2024-07-04 01:25:23,847] INFO [Partition __consumer_offsets-37 broker=1] Log loaded for partition __consumer_offsets-37 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:23.851692281Z [2024-07-04 01:25:23,847] INFO [Broker id=1] Leader __consumer_offsets-37 with topic id Some(RyS8mwweRHmB0P-eZeLopQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,0,2], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:23.887605692Z [2024-07-04 01:25:23,884] INFO [Broker id=1] Creating new partition __consumer_offsets-34 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:23.942782656Z [2024-07-04 01:25:23,941] 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-07-04T01:25:23.952016741Z [2024-07-04 01:25:23,942] 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-07-04T01:25:23.955337211Z [2024-07-04 01:25:23,952] INFO [Partition __consumer_offsets-34 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-34 (kafka.cluster.Partition) 2024-07-04T01:25:23.955826117Z [2024-07-04 01:25:23,952] INFO [Partition __consumer_offsets-34 broker=1] Log loaded for partition __consumer_offsets-34 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:23.955832069Z [2024-07-04 01:25:23,952] INFO [Broker id=1] Leader __consumer_offsets-34 with topic id Some(RyS8mwweRHmB0P-eZeLopQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1,2,0], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:23.982755894Z [2024-07-04 01:25:23,982] INFO [Broker id=1] Transitioning 33 partition(s) to local followers. (state.change.logger) 2024-07-04T01:25:23.992639803Z [2024-07-04 01:25:23,990] INFO [Broker id=1] Creating new partition __consumer_offsets-48 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:24.028102446Z [2024-07-04 01:25:24,010] 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-07-04T01:25:24.028245914Z [2024-07-04 01:25:24,025] 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-07-04T01:25:24.028254309Z [2024-07-04 01:25:24,025] INFO [Partition __consumer_offsets-48 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-48 (kafka.cluster.Partition) 2024-07-04T01:25:24.028499412Z [2024-07-04 01:25:24,025] INFO [Partition __consumer_offsets-48 broker=1] Log loaded for partition __consumer_offsets-48 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:24.028512552Z [2024-07-04 01:25:24,026] INFO [Broker id=1] Follower __consumer_offsets-48 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:24.030273421Z [2024-07-04 01:25:24,029] INFO [Broker id=1] Creating new partition __consumer_offsets-46 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:24.111766494Z [2024-07-04 01:25:24,111] 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-07-04T01:25:24.139568185Z [2024-07-04 01:25:24,139] 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-07-04T01:25:24.157943163Z [2024-07-04 01:25:24,155] INFO [Partition __consumer_offsets-46 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-46 (kafka.cluster.Partition) 2024-07-04T01:25:24.193613500Z [2024-07-04 01:25:24,156] INFO [Partition __consumer_offsets-46 broker=1] Log loaded for partition __consumer_offsets-46 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:24.230715880Z [2024-07-04 01:25:24,224] INFO [Broker id=1] Follower __consumer_offsets-46 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:24.263014149Z [2024-07-04 01:25:24,225] INFO [Broker id=1] Creating new partition __consumer_offsets-11 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:24.288718438Z [2024-07-04 01:25:24,287] 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-07-04T01:25:24.292568835Z [2024-07-04 01:25:24,290] 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-07-04T01:25:24.292583916Z [2024-07-04 01:25:24,291] INFO [Partition __consumer_offsets-11 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-11 (kafka.cluster.Partition) 2024-07-04T01:25:24.292587777Z [2024-07-04 01:25:24,291] INFO [Partition __consumer_offsets-11 broker=1] Log loaded for partition __consumer_offsets-11 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:24.292591787Z [2024-07-04 01:25:24,291] INFO [Broker id=1] Follower __consumer_offsets-11 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-07-04T01:25:24.292595953Z [2024-07-04 01:25:24,291] INFO [Broker id=1] Creating new partition __consumer_offsets-44 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:24.359308208Z [2024-07-04 01:25:24,358] 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-07-04T01:25:24.426462012Z [2024-07-04 01:25:24,422] 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-07-04T01:25:24.426470910Z [2024-07-04 01:25:24,423] INFO [Partition __consumer_offsets-44 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-44 (kafka.cluster.Partition) 2024-07-04T01:25:24.426474280Z [2024-07-04 01:25:24,423] INFO [Partition __consumer_offsets-44 broker=1] Log loaded for partition __consumer_offsets-44 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:24.426478457Z [2024-07-04 01:25:24,423] INFO [Broker id=1] Follower __consumer_offsets-44 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:24.426482259Z [2024-07-04 01:25:24,423] INFO [Broker id=1] Creating new partition __consumer_offsets-9 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:24.545391876Z [2024-07-04 01:25:24,545] 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-07-04T01:25:24.546384294Z [2024-07-04 01:25:24,546] 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-07-04T01:25:24.546702346Z [2024-07-04 01:25:24,546] INFO [Partition __consumer_offsets-9 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-9 (kafka.cluster.Partition) 2024-07-04T01:25:24.546708832Z [2024-07-04 01:25:24,546] INFO [Partition __consumer_offsets-9 broker=1] Log loaded for partition __consumer_offsets-9 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:24.546713255Z [2024-07-04 01:25:24,546] INFO [Broker id=1] Follower __consumer_offsets-9 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:24.546717419Z [2024-07-04 01:25:24,546] INFO [Broker id=1] Creating new partition __consumer_offsets-21 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:24.552767696Z [2024-07-04 01:25:24,550] 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-07-04T01:25:24.574756395Z [2024-07-04 01:25:24,572] 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-07-04T01:25:24.574772841Z [2024-07-04 01:25:24,572] INFO [Partition __consumer_offsets-21 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-21 (kafka.cluster.Partition) 2024-07-04T01:25:24.574776132Z [2024-07-04 01:25:24,572] INFO [Partition __consumer_offsets-21 broker=1] Log loaded for partition __consumer_offsets-21 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:24.574779966Z [2024-07-04 01:25:24,572] INFO [Broker id=1] Follower __consumer_offsets-21 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:24.574783996Z [2024-07-04 01:25:24,572] INFO [Broker id=1] Creating new partition __consumer_offsets-19 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:24.586191969Z [2024-07-04 01:25:24,586] 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-07-04T01:25:24.586735220Z [2024-07-04 01:25:24,586] 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-07-04T01:25:24.586745746Z [2024-07-04 01:25:24,586] INFO [Partition __consumer_offsets-19 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-19 (kafka.cluster.Partition) 2024-07-04T01:25:24.586856188Z [2024-07-04 01:25:24,586] INFO [Partition __consumer_offsets-19 broker=1] Log loaded for partition __consumer_offsets-19 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:24.586861961Z [2024-07-04 01:25:24,586] INFO [Broker id=1] Follower __consumer_offsets-19 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:24.587188298Z [2024-07-04 01:25:24,586] INFO [Broker id=1] Creating new partition __consumer_offsets-17 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:24.599949234Z [2024-07-04 01:25:24,599] 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-07-04T01:25:24.601838928Z [2024-07-04 01:25:24,600] 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-07-04T01:25:24.603290061Z [2024-07-04 01:25:24,600] INFO [Partition __consumer_offsets-17 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-17 (kafka.cluster.Partition) 2024-07-04T01:25:24.606779678Z [2024-07-04 01:25:24,600] INFO [Partition __consumer_offsets-17 broker=1] Log loaded for partition __consumer_offsets-17 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:24.607399089Z [2024-07-04 01:25:24,600] INFO [Broker id=1] Follower __consumer_offsets-17 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-07-04T01:25:24.607417792Z [2024-07-04 01:25:24,602] INFO [Broker id=1] Creating new partition __consumer_offsets-30 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:24.634580909Z [2024-07-04 01:25:24,634] 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-07-04T01:25:24.638620417Z [2024-07-04 01:25:24,636] 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-07-04T01:25:24.638629883Z [2024-07-04 01:25:24,636] INFO [Partition __consumer_offsets-30 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-30 (kafka.cluster.Partition) 2024-07-04T01:25:24.638633540Z [2024-07-04 01:25:24,636] INFO [Partition __consumer_offsets-30 broker=1] Log loaded for partition __consumer_offsets-30 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:24.638637953Z [2024-07-04 01:25:24,636] INFO [Broker id=1] Follower __consumer_offsets-30 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:24.638642007Z [2024-07-04 01:25:24,636] INFO [Broker id=1] Creating new partition __consumer_offsets-28 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:24.640015453Z [2024-07-04 01:25:24,639] 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-07-04T01:25:24.655749617Z [2024-07-04 01:25:24,655] 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-07-04T01:25:24.655808436Z [2024-07-04 01:25:24,655] INFO [Partition __consumer_offsets-28 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-28 (kafka.cluster.Partition) 2024-07-04T01:25:24.655826789Z [2024-07-04 01:25:24,655] INFO [Partition __consumer_offsets-28 broker=1] Log loaded for partition __consumer_offsets-28 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:24.655849494Z [2024-07-04 01:25:24,655] INFO [Broker id=1] Follower __consumer_offsets-28 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:24.655897955Z [2024-07-04 01:25:24,655] INFO [Broker id=1] Creating new partition __consumer_offsets-40 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:24.708884304Z [2024-07-04 01:25:24,708] 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-07-04T01:25:24.709618763Z [2024-07-04 01:25:24,709] 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-07-04T01:25:24.709671844Z [2024-07-04 01:25:24,709] INFO [Partition __consumer_offsets-40 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-40 (kafka.cluster.Partition) 2024-07-04T01:25:24.710980317Z [2024-07-04 01:25:24,709] INFO [Partition __consumer_offsets-40 broker=1] Log loaded for partition __consumer_offsets-40 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:24.714910115Z [2024-07-04 01:25:24,709] INFO [Broker id=1] Follower __consumer_offsets-40 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:24.714917350Z [2024-07-04 01:25:24,709] INFO [Broker id=1] Creating new partition __consumer_offsets-38 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:24.741570705Z [2024-07-04 01:25:24,738] 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-07-04T01:25:24.743668733Z [2024-07-04 01:25:24,739] 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-07-04T01:25:24.743676906Z [2024-07-04 01:25:24,739] INFO [Partition __consumer_offsets-38 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-38 (kafka.cluster.Partition) 2024-07-04T01:25:24.743680342Z [2024-07-04 01:25:24,739] INFO [Partition __consumer_offsets-38 broker=1] Log loaded for partition __consumer_offsets-38 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:24.743684300Z [2024-07-04 01:25:24,739] INFO [Broker id=1] Follower __consumer_offsets-38 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:24.743688298Z [2024-07-04 01:25:24,739] INFO [Broker id=1] Creating new partition __consumer_offsets-3 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:24.778854900Z [2024-07-04 01:25:24,769] 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-07-04T01:25:24.778868344Z [2024-07-04 01:25:24,770] 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-07-04T01:25:24.778897478Z [2024-07-04 01:25:24,770] INFO [Partition __consumer_offsets-3 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-3 (kafka.cluster.Partition) 2024-07-04T01:25:24.778900697Z [2024-07-04 01:25:24,770] INFO [Partition __consumer_offsets-3 broker=1] Log loaded for partition __consumer_offsets-3 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:24.778908833Z [2024-07-04 01:25:24,770] INFO [Broker id=1] Follower __consumer_offsets-3 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:24.778912999Z [2024-07-04 01:25:24,770] INFO [Broker id=1] Creating new partition __consumer_offsets-36 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:24.778916034Z [2024-07-04 01:25:24,776] 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-07-04T01:25:24.778919820Z [2024-07-04 01:25:24,776] 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-07-04T01:25:24.778922803Z [2024-07-04 01:25:24,776] INFO [Partition __consumer_offsets-36 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-36 (kafka.cluster.Partition) 2024-07-04T01:25:24.778926110Z [2024-07-04 01:25:24,776] INFO [Partition __consumer_offsets-36 broker=1] Log loaded for partition __consumer_offsets-36 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:24.778933154Z [2024-07-04 01:25:24,776] INFO [Broker id=1] Follower __consumer_offsets-36 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:24.778936226Z [2024-07-04 01:25:24,776] INFO [Broker id=1] Creating new partition __consumer_offsets-1 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:24.811211235Z [2024-07-04 01:25:24,801] 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-07-04T01:25:24.811228966Z [2024-07-04 01:25:24,802] 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-07-04T01:25:24.811232920Z [2024-07-04 01:25:24,802] INFO [Partition __consumer_offsets-1 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-1 (kafka.cluster.Partition) 2024-07-04T01:25:24.811236809Z [2024-07-04 01:25:24,802] INFO [Partition __consumer_offsets-1 broker=1] Log loaded for partition __consumer_offsets-1 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:24.811239998Z [2024-07-04 01:25:24,802] INFO [Broker id=1] Follower __consumer_offsets-1 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:24.811244112Z [2024-07-04 01:25:24,802] INFO [Broker id=1] Creating new partition __consumer_offsets-47 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:24.826123439Z [2024-07-04 01:25:24,820] 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-07-04T01:25:24.827561701Z [2024-07-04 01:25:24,825] 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-07-04T01:25:24.827582015Z [2024-07-04 01:25:24,825] INFO [Partition __consumer_offsets-47 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-47 (kafka.cluster.Partition) 2024-07-04T01:25:24.827585893Z [2024-07-04 01:25:24,825] INFO [Partition __consumer_offsets-47 broker=1] Log loaded for partition __consumer_offsets-47 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:24.827598870Z [2024-07-04 01:25:24,825] INFO [Broker id=1] Follower __consumer_offsets-47 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:24.827603510Z [2024-07-04 01:25:24,827] INFO [Broker id=1] Creating new partition __consumer_offsets-16 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:24.931087790Z [2024-07-04 01:25:24,925] 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-07-04T01:25:24.971784485Z [2024-07-04 01:25:24,971] 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-07-04T01:25:24.974108625Z [2024-07-04 01:25:24,971] INFO [Partition __consumer_offsets-16 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-16 (kafka.cluster.Partition) 2024-07-04T01:25:24.976397361Z [2024-07-04 01:25:24,972] INFO [Partition __consumer_offsets-16 broker=1] Log loaded for partition __consumer_offsets-16 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:24.976415177Z [2024-07-04 01:25:24,972] INFO [Broker id=1] Follower __consumer_offsets-16 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:24.976419875Z [2024-07-04 01:25:24,972] INFO [Broker id=1] Creating new partition __consumer_offsets-14 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:24.982942718Z [2024-07-04 01:25:24,981] 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-07-04T01:25:24.985799235Z [2024-07-04 01:25:24,983] 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-07-04T01:25:24.985812694Z [2024-07-04 01:25:24,984] INFO [Partition __consumer_offsets-14 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-14 (kafka.cluster.Partition) 2024-07-04T01:25:24.985816616Z [2024-07-04 01:25:24,984] INFO [Partition __consumer_offsets-14 broker=1] Log loaded for partition __consumer_offsets-14 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:24.985820432Z [2024-07-04 01:25:24,984] INFO [Broker id=1] Follower __consumer_offsets-14 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:24.985827774Z [2024-07-04 01:25:24,984] INFO [Broker id=1] Creating new partition __consumer_offsets-43 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:24.997920673Z [2024-07-04 01:25:24,987] 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-07-04T01:25:24.998911428Z [2024-07-04 01:25:24,988] 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-07-04T01:25:24.998921220Z [2024-07-04 01:25:24,988] INFO [Partition __consumer_offsets-43 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-43 (kafka.cluster.Partition) 2024-07-04T01:25:24.998934253Z [2024-07-04 01:25:24,988] INFO [Partition __consumer_offsets-43 broker=1] Log loaded for partition __consumer_offsets-43 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:24.998938504Z [2024-07-04 01:25:24,988] INFO [Broker id=1] Follower __consumer_offsets-43 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:24.998943410Z [2024-07-04 01:25:24,989] INFO [Broker id=1] Creating new partition __consumer_offsets-12 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:24.998951153Z [2024-07-04 01:25:24,991] 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-07-04T01:25:24.998954379Z [2024-07-04 01:25:24,992] 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-07-04T01:25:24.998958060Z [2024-07-04 01:25:24,992] INFO [Partition __consumer_offsets-12 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-12 (kafka.cluster.Partition) 2024-07-04T01:25:24.998961485Z [2024-07-04 01:25:24,992] INFO [Partition __consumer_offsets-12 broker=1] Log loaded for partition __consumer_offsets-12 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:24.998964626Z [2024-07-04 01:25:24,992] INFO [Broker id=1] Follower __consumer_offsets-12 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:24.998967637Z [2024-07-04 01:25:24,992] INFO [Broker id=1] Creating new partition __consumer_offsets-41 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:24.998970715Z [2024-07-04 01:25:24,994] 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-07-04T01:25:25.005437225Z [2024-07-04 01:25:24,998] 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-07-04T01:25:25.005454010Z [2024-07-04 01:25:24,998] INFO [Partition __consumer_offsets-41 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-41 (kafka.cluster.Partition) 2024-07-04T01:25:25.005457900Z [2024-07-04 01:25:24,998] INFO [Partition __consumer_offsets-41 broker=1] Log loaded for partition __consumer_offsets-41 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:25.005462206Z [2024-07-04 01:25:24,998] INFO [Broker id=1] Follower __consumer_offsets-41 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-07-04T01:25:25.005467234Z [2024-07-04 01:25:24,998] INFO [Broker id=1] Creating new partition __consumer_offsets-24 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:25.005471533Z [2024-07-04 01:25:25,002] 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-07-04T01:25:25.005475018Z [2024-07-04 01:25:25,002] 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-07-04T01:25:25.005478292Z [2024-07-04 01:25:25,002] INFO [Partition __consumer_offsets-24 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-24 (kafka.cluster.Partition) 2024-07-04T01:25:25.005495105Z [2024-07-04 01:25:25,002] INFO [Partition __consumer_offsets-24 broker=1] Log loaded for partition __consumer_offsets-24 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:25.005498625Z [2024-07-04 01:25:25,002] INFO [Broker id=1] Follower __consumer_offsets-24 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:25.005502291Z [2024-07-04 01:25:25,005] INFO [Broker id=1] Creating new partition __consumer_offsets-22 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:25.013532784Z [2024-07-04 01:25:25,011] 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-07-04T01:25:25.013550802Z [2024-07-04 01:25:25,012] 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-07-04T01:25:25.013555440Z [2024-07-04 01:25:25,012] INFO [Partition __consumer_offsets-22 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-22 (kafka.cluster.Partition) 2024-07-04T01:25:25.013559004Z [2024-07-04 01:25:25,012] INFO [Partition __consumer_offsets-22 broker=1] Log loaded for partition __consumer_offsets-22 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:25.013563416Z [2024-07-04 01:25:25,012] INFO [Broker id=1] Follower __consumer_offsets-22 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:25.013568041Z [2024-07-04 01:25:25,012] INFO [Broker id=1] Creating new partition __consumer_offsets-18 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:25.016421809Z [2024-07-04 01:25:25,016] 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-07-04T01:25:25.019115053Z [2024-07-04 01:25:25,016] 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-07-04T01:25:25.019126730Z [2024-07-04 01:25:25,016] INFO [Partition __consumer_offsets-18 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-18 (kafka.cluster.Partition) 2024-07-04T01:25:25.019132072Z [2024-07-04 01:25:25,016] INFO [Partition __consumer_offsets-18 broker=1] Log loaded for partition __consumer_offsets-18 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:25.019135945Z [2024-07-04 01:25:25,016] INFO [Broker id=1] Follower __consumer_offsets-18 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:25.019139488Z [2024-07-04 01:25:25,017] INFO [Broker id=1] Creating new partition __consumer_offsets-31 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:25.019853447Z [2024-07-04 01:25:25,019] 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-07-04T01:25:25.020352536Z [2024-07-04 01:25:25,020] 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-07-04T01:25:25.020395987Z [2024-07-04 01:25:25,020] INFO [Partition __consumer_offsets-31 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-31 (kafka.cluster.Partition) 2024-07-04T01:25:25.020446880Z [2024-07-04 01:25:25,020] INFO [Partition __consumer_offsets-31 broker=1] Log loaded for partition __consumer_offsets-31 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:25.020482975Z [2024-07-04 01:25:25,020] INFO [Broker id=1] Follower __consumer_offsets-31 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:25.020569154Z [2024-07-04 01:25:25,020] INFO [Broker id=1] Creating new partition __consumer_offsets-29 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:25.023357049Z [2024-07-04 01:25:25,022] 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-07-04T01:25:25.023508568Z [2024-07-04 01:25:25,023] 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-07-04T01:25:25.023553884Z [2024-07-04 01:25:25,023] INFO [Partition __consumer_offsets-29 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-29 (kafka.cluster.Partition) 2024-07-04T01:25:25.023612412Z [2024-07-04 01:25:25,023] INFO [Partition __consumer_offsets-29 broker=1] Log loaded for partition __consumer_offsets-29 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:25.023650553Z [2024-07-04 01:25:25,023] INFO [Broker id=1] Follower __consumer_offsets-29 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:25.023718775Z [2024-07-04 01:25:25,023] INFO [Broker id=1] Creating new partition __consumer_offsets-25 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:25.038208617Z [2024-07-04 01:25:25,025] 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-07-04T01:25:25.038226523Z [2024-07-04 01:25:25,026] 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-07-04T01:25:25.038230431Z [2024-07-04 01:25:25,026] INFO [Partition __consumer_offsets-25 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-25 (kafka.cluster.Partition) 2024-07-04T01:25:25.038234105Z [2024-07-04 01:25:25,026] INFO [Partition __consumer_offsets-25 broker=1] Log loaded for partition __consumer_offsets-25 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:25.038238286Z [2024-07-04 01:25:25,026] INFO [Broker id=1] Follower __consumer_offsets-25 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:25.038241674Z [2024-07-04 01:25:25,026] INFO [Broker id=1] Creating new partition __consumer_offsets-8 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:25.038245081Z [2024-07-04 01:25:25,028] 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-07-04T01:25:25.038248810Z [2024-07-04 01:25:25,029] 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-07-04T01:25:25.038264822Z [2024-07-04 01:25:25,029] INFO [Partition __consumer_offsets-8 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-8 (kafka.cluster.Partition) 2024-07-04T01:25:25.038268298Z [2024-07-04 01:25:25,029] INFO [Partition __consumer_offsets-8 broker=1] Log loaded for partition __consumer_offsets-8 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:25.038271979Z [2024-07-04 01:25:25,029] INFO [Broker id=1] Follower __consumer_offsets-8 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:25.038275235Z [2024-07-04 01:25:25,029] INFO [Broker id=1] Creating new partition __consumer_offsets-6 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:25.115904057Z [2024-07-04 01:25:25,114] 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-07-04T01:25:25.119137805Z [2024-07-04 01:25:25,116] 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-07-04T01:25:25.119149038Z [2024-07-04 01:25:25,116] INFO [Partition __consumer_offsets-6 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-6 (kafka.cluster.Partition) 2024-07-04T01:25:25.119152329Z [2024-07-04 01:25:25,116] INFO [Partition __consumer_offsets-6 broker=1] Log loaded for partition __consumer_offsets-6 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:25.119155556Z [2024-07-04 01:25:25,116] INFO [Broker id=1] Follower __consumer_offsets-6 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:25.119159083Z [2024-07-04 01:25:25,116] INFO [Broker id=1] Creating new partition __consumer_offsets-35 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:25.147608298Z [2024-07-04 01:25:25,143] 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-07-04T01:25:25.147620293Z [2024-07-04 01:25:25,144] 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-07-04T01:25:25.147624620Z [2024-07-04 01:25:25,144] INFO [Partition __consumer_offsets-35 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-35 (kafka.cluster.Partition) 2024-07-04T01:25:25.147628141Z [2024-07-04 01:25:25,144] INFO [Partition __consumer_offsets-35 broker=1] Log loaded for partition __consumer_offsets-35 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:25.147632062Z [2024-07-04 01:25:25,144] INFO [Broker id=1] Follower __consumer_offsets-35 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 2. Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:25.147635831Z [2024-07-04 01:25:25,144] INFO [Broker id=1] Creating new partition __consumer_offsets-4 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:25.187004049Z [2024-07-04 01:25:25,184] 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-07-04T01:25:25.187037574Z [2024-07-04 01:25:25,185] 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-07-04T01:25:25.187041835Z [2024-07-04 01:25:25,185] INFO [Partition __consumer_offsets-4 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-4 (kafka.cluster.Partition) 2024-07-04T01:25:25.187071864Z [2024-07-04 01:25:25,185] INFO [Partition __consumer_offsets-4 broker=1] Log loaded for partition __consumer_offsets-4 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:25.187076542Z [2024-07-04 01:25:25,186] INFO [Broker id=1] Follower __consumer_offsets-4 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:25.187080328Z [2024-07-04 01:25:25,186] INFO [Broker id=1] Creating new partition __consumer_offsets-33 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:25.214103489Z [2024-07-04 01:25:25,211] 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-07-04T01:25:25.214112056Z [2024-07-04 01:25:25,212] 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-07-04T01:25:25.214115682Z [2024-07-04 01:25:25,212] INFO [Partition __consumer_offsets-33 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-33 (kafka.cluster.Partition) 2024-07-04T01:25:25.214119337Z [2024-07-04 01:25:25,212] INFO [Partition __consumer_offsets-33 broker=1] Log loaded for partition __consumer_offsets-33 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:25.214123013Z [2024-07-04 01:25:25,212] INFO [Broker id=1] Follower __consumer_offsets-33 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:25.214126596Z [2024-07-04 01:25:25,212] INFO [Broker id=1] Creating new partition __consumer_offsets-2 with topic id RyS8mwweRHmB0P-eZeLopQ. (state.change.logger) 2024-07-04T01:25:25.217455132Z [2024-07-04 01:25:25,217] 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-07-04T01:25:25.218157473Z [2024-07-04 01:25:25,217] 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-07-04T01:25:25.218555211Z [2024-07-04 01:25:25,218] INFO [Partition __consumer_offsets-2 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-2 (kafka.cluster.Partition) 2024-07-04T01:25:25.218566509Z [2024-07-04 01:25:25,218] INFO [Partition __consumer_offsets-2 broker=1] Log loaded for partition __consumer_offsets-2 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:25.218570874Z [2024-07-04 01:25:25,218] INFO [Broker id=1] Follower __consumer_offsets-2 starts at leader epoch 0 from offset 0 with partition epoch 0 and high watermark 0. Current leader is 0. Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:25.219099915Z [2024-07-04 01:25:25,218] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions Set(__consumer_offsets-38, __consumer_offsets-16, __consumer_offsets-8, __consumer_offsets-19, __consumer_offsets-2, __consumer_offsets-35, __consumer_offsets-46, __consumer_offsets-24, __consumer_offsets-43, __consumer_offsets-21, __consumer_offsets-48, __consumer_offsets-29, __consumer_offsets-40, __consumer_offsets-18, __consumer_offsets-4, __consumer_offsets-9, __consumer_offsets-31, __consumer_offsets-1, __consumer_offsets-12, __consumer_offsets-6, __consumer_offsets-28, __consumer_offsets-17, __consumer_offsets-44, __consumer_offsets-36, __consumer_offsets-47, __consumer_offsets-25, __consumer_offsets-3, __consumer_offsets-14, __consumer_offsets-30, __consumer_offsets-41, __consumer_offsets-33, __consumer_offsets-11, __consumer_offsets-22) (kafka.server.ReplicaFetcherManager) 2024-07-04T01:25:25.285530258Z [2024-07-04 01:25:25,279] INFO [Broker id=1] Stopped fetchers as part of become-follower for 33 partitions (state.change.logger) 2024-07-04T01:25:25.599395211Z [2024-07-04 01:25:25,598] INFO [ReplicaFetcherManager on broker 1] Added fetcher to broker 0 for partitions Map(__consumer_offsets-38 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-8 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-2 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-24 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-21 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-48 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-29 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-18 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-4 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-17 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-44 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-47 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-14 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-30 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-41 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-33 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-11 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=0, host=kafka-controller-0.kafka-controller-headless.osm.svc.cluster.local:9094),0,0)) (kafka.server.ReplicaFetcherManager) 2024-07-04T01:25:25.603770727Z [2024-07-04 01:25:25,600] INFO [ReplicaFetcherThread-0-0]: Starting (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.668362957Z [2024-07-04 01:25:25,667] INFO [ReplicaFetcherManager on broker 1] Added fetcher to broker 2 for partitions Map(__consumer_offsets-16 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=2, host=kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-19 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=2, host=kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-46 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=2, host=kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-35 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=2, host=kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-43 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=2, host=kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-40 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=2, host=kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-9 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=2, host=kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-31 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=2, host=kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-1 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=2, host=kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-12 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=2, host=kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-6 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=2, host=kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-28 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=2, host=kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-36 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=2, host=kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-25 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=2, host=kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-3 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=2, host=kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094),0,0), __consumer_offsets-22 -> InitialFetchState(Some(RyS8mwweRHmB0P-eZeLopQ),BrokerEndPoint(id=2, host=kafka-controller-2.kafka-controller-headless.osm.svc.cluster.local:9094),0,0)) (kafka.server.ReplicaFetcherManager) 2024-07-04T01:25:25.670734407Z [2024-07-04 01:25:25,670] INFO [ReplicaFetcherThread-0-2]: Starting (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.675879580Z [2024-07-04 01:25:25,671] INFO [Broker id=1] Started fetchers as part of become-follower for 33 partitions (state.change.logger) 2024-07-04T01:25:25.678441479Z [2024-07-04 01:25:25,678] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-6 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.680054539Z [2024-07-04 01:25:25,679] 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-07-04T01:25:25.687999550Z [2024-07-04 01:25:25,686] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-28 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.688042725Z [2024-07-04 01:25:25,686] 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-07-04T01:25:25.688047787Z [2024-07-04 01:25:25,686] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-43 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.688051177Z [2024-07-04 01:25:25,686] INFO [UnifiedLog partition=__consumer_offsets-43, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog) 2024-07-04T01:25:25.688054183Z [2024-07-04 01:25:25,687] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-36 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.688057204Z [2024-07-04 01:25:25,687] INFO [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-17 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.697186944Z [2024-07-04 01:25:25,687] 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-07-04T01:25:25.697198463Z [2024-07-04 01:25:25,690] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-25 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.697201851Z [2024-07-04 01:25:25,690] 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-07-04T01:25:25.697205037Z [2024-07-04 01:25:25,690] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-3 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.697230362Z [2024-07-04 01:25:25,690] 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-07-04T01:25:25.697233692Z [2024-07-04 01:25:25,690] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-40 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.697236809Z [2024-07-04 01:25:25,690] 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-07-04T01:25:25.697240168Z [2024-07-04 01:25:25,690] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-22 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.697243831Z [2024-07-04 01:25:25,690] INFO [UnifiedLog partition=__consumer_offsets-22, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog) 2024-07-04T01:25:25.697246923Z [2024-07-04 01:25:25,690] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-19 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.697250045Z [2024-07-04 01:25:25,690] 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-07-04T01:25:25.697257637Z [2024-07-04 01:25:25,690] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-16 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.697260831Z [2024-07-04 01:25:25,690] 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-07-04T01:25:25.697266431Z [2024-07-04 01:25:25,690] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-1 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.697269532Z [2024-07-04 01:25:25,690] 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-07-04T01:25:25.697272702Z [2024-07-04 01:25:25,690] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-9 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.697275874Z [2024-07-04 01:25:25,690] 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-07-04T01:25:25.697279046Z [2024-07-04 01:25:25,690] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-31 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.697282159Z [2024-07-04 01:25:25,690] 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-07-04T01:25:25.697287115Z [2024-07-04 01:25:25,690] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-12 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.697290334Z [2024-07-04 01:25:25,690] INFO [UnifiedLog partition=__consumer_offsets-12, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog) 2024-07-04T01:25:25.697293279Z [2024-07-04 01:25:25,690] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-46 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.697296469Z [2024-07-04 01:25:25,690] 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-07-04T01:25:25.697299668Z [2024-07-04 01:25:25,690] INFO [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Truncating partition __consumer_offsets-35 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.697303077Z [2024-07-04 01:25:25,691] 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-07-04T01:25:25.697306474Z [2024-07-04 01:25:25,693] INFO [UnifiedLog partition=__consumer_offsets-17, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog) 2024-07-04T01:25:25.697309540Z [2024-07-04 01:25:25,694] INFO [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-21 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.697316703Z [2024-07-04 01:25:25,694] 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-07-04T01:25:25.697319796Z [2024-07-04 01:25:25,694] INFO [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-47 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.697322746Z [2024-07-04 01:25:25,694] 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-07-04T01:25:25.697325681Z [2024-07-04 01:25:25,694] INFO [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-44 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.697328768Z [2024-07-04 01:25:25,694] 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-07-04T01:25:25.697331693Z [2024-07-04 01:25:25,694] INFO [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-14 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.697334697Z [2024-07-04 01:25:25,694] 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-07-04T01:25:25.697342553Z [2024-07-04 01:25:25,694] INFO [ReplicaFetcher replicaId=1, 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-07-04T01:25:25.697345936Z [2024-07-04 01:25:25,694] 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-07-04T01:25:25.697349344Z [2024-07-04 01:25:25,694] INFO [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-48 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.697353786Z [2024-07-04 01:25:25,694] INFO [UnifiedLog partition=__consumer_offsets-48, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog) 2024-07-04T01:25:25.697356822Z [2024-07-04 01:25:25,694] INFO [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-18 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.697360527Z [2024-07-04 01:25:25,694] INFO [UnifiedLog partition=__consumer_offsets-18, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog) 2024-07-04T01:25:25.697363588Z [2024-07-04 01:25:25,694] INFO [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-33 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.697366824Z [2024-07-04 01:25:25,694] INFO [UnifiedLog partition=__consumer_offsets-33, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog) 2024-07-04T01:25:25.697370620Z [2024-07-04 01:25:25,694] INFO [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-30 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.697377664Z [2024-07-04 01:25:25,694] 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-07-04T01:25:25.697380714Z [2024-07-04 01:25:25,694] INFO [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-41 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.697383719Z [2024-07-04 01:25:25,694] INFO [UnifiedLog partition=__consumer_offsets-41, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog) 2024-07-04T01:25:25.697387066Z [2024-07-04 01:25:25,695] INFO [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-11 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.697390133Z [2024-07-04 01:25:25,695] INFO [UnifiedLog partition=__consumer_offsets-11, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog) 2024-07-04T01:25:25.697393619Z [2024-07-04 01:25:25,695] INFO [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-4 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.697396620Z [2024-07-04 01:25:25,695] INFO [UnifiedLog partition=__consumer_offsets-4, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog) 2024-07-04T01:25:25.697400074Z [2024-07-04 01:25:25,695] INFO [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-8 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.697403136Z [2024-07-04 01:25:25,695] INFO [UnifiedLog partition=__consumer_offsets-8, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog) 2024-07-04T01:25:25.697406178Z [2024-07-04 01:25:25,695] INFO [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-38 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.697409186Z [2024-07-04 01:25:25,695] 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-07-04T01:25:25.697412170Z [2024-07-04 01:25:25,695] INFO [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-2 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.697415507Z [2024-07-04 01:25:25,695] INFO [UnifiedLog partition=__consumer_offsets-2, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog) 2024-07-04T01:25:25.697419623Z [2024-07-04 01:25:25,695] INFO [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Truncating partition __consumer_offsets-24 with TruncationState(offset=0, completed=true) due to local high watermark 0 (kafka.server.ReplicaFetcherThread) 2024-07-04T01:25:25.697422695Z [2024-07-04 01:25:25,695] INFO [UnifiedLog partition=__consumer_offsets-24, dir=/bitnami/kafka/data] Truncating to 0 has no effect as the largest offset in the log is -1 (kafka.log.UnifiedLog) 2024-07-04T01:25:25.712101297Z [2024-07-04 01:25:25,711] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 15 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.714747788Z [2024-07-04 01:25:25,713] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-15 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.718333765Z [2024-07-04 01:25:25,718] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 13 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.718469387Z [2024-07-04 01:25:25,718] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-13 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.718625823Z [2024-07-04 01:25:25,718] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 45 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.718747133Z [2024-07-04 01:25:25,718] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-45 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.718913196Z [2024-07-04 01:25:25,718] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 10 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.723078843Z [2024-07-04 01:25:25,718] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-10 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.723089933Z [2024-07-04 01:25:25,719] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 42 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.723093419Z [2024-07-04 01:25:25,719] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-42 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.723096574Z [2024-07-04 01:25:25,719] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 23 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.723099644Z [2024-07-04 01:25:25,719] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-23 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.723102625Z [2024-07-04 01:25:25,719] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 20 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.723105536Z [2024-07-04 01:25:25,719] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-20 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.723108434Z [2024-07-04 01:25:25,719] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 49 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.723111607Z [2024-07-04 01:25:25,719] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-49 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.723114509Z [2024-07-04 01:25:25,719] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 0 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.723117388Z [2024-07-04 01:25:25,719] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-0 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.723120542Z [2024-07-04 01:25:25,719] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 32 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.723123527Z [2024-07-04 01:25:25,719] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-32 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.723135198Z [2024-07-04 01:25:25,719] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 27 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.723138309Z [2024-07-04 01:25:25,719] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-27 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.723141116Z [2024-07-04 01:25:25,719] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 26 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.723144082Z [2024-07-04 01:25:25,719] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-26 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.723146967Z [2024-07-04 01:25:25,719] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 7 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.723149835Z [2024-07-04 01:25:25,719] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-7 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.723152745Z [2024-07-04 01:25:25,719] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 39 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.723155712Z [2024-07-04 01:25:25,719] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-39 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.723158656Z [2024-07-04 01:25:25,719] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 5 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.723163288Z [2024-07-04 01:25:25,719] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-5 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.723166395Z [2024-07-04 01:25:25,719] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 37 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.723169801Z [2024-07-04 01:25:25,719] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-37 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.723173403Z [2024-07-04 01:25:25,719] INFO [GroupCoordinator 1]: Elected as the group coordinator for partition 34 in epoch 0 (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.723176896Z [2024-07-04 01:25:25,719] INFO [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-34 for epoch 0 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.723180619Z [2024-07-04 01:25:25,720] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 48 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.723184216Z [2024-07-04 01:25:25,720] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-48 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.723187905Z [2024-07-04 01:25:25,720] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 46 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.723191154Z [2024-07-04 01:25:25,720] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-46 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.723194572Z [2024-07-04 01:25:25,720] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 11 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.723205806Z [2024-07-04 01:25:25,720] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-11 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.723209509Z [2024-07-04 01:25:25,720] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 44 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.729106024Z [2024-07-04 01:25:25,723] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-44 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.729133227Z [2024-07-04 01:25:25,724] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 9 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.729137503Z [2024-07-04 01:25:25,724] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-9 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.729142014Z [2024-07-04 01:25:25,724] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 21 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.729147074Z [2024-07-04 01:25:25,724] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-21 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.729150899Z [2024-07-04 01:25:25,724] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 19 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.729160261Z [2024-07-04 01:25:25,724] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-19 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.729165357Z [2024-07-04 01:25:25,724] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 17 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.729170189Z [2024-07-04 01:25:25,724] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-17 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.729174498Z [2024-07-04 01:25:25,725] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 30 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.729178393Z [2024-07-04 01:25:25,725] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-30 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.729182585Z [2024-07-04 01:25:25,725] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 28 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.729187087Z [2024-07-04 01:25:25,725] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-28 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.729191130Z [2024-07-04 01:25:25,725] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 40 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.729195155Z [2024-07-04 01:25:25,725] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-40 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.729199132Z [2024-07-04 01:25:25,725] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 38 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.729226495Z [2024-07-04 01:25:25,725] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-38 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.729230807Z [2024-07-04 01:25:25,725] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 3 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.729250982Z [2024-07-04 01:25:25,725] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-3 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.729254823Z [2024-07-04 01:25:25,725] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 36 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.729259107Z [2024-07-04 01:25:25,725] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-36 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.729262929Z [2024-07-04 01:25:25,725] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 1 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.729286418Z [2024-07-04 01:25:25,725] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-1 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.729290911Z [2024-07-04 01:25:25,725] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 47 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.729294781Z [2024-07-04 01:25:25,725] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-47 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.729299859Z [2024-07-04 01:25:25,725] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 16 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.729304138Z [2024-07-04 01:25:25,725] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-16 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.729309549Z [2024-07-04 01:25:25,725] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 14 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.729316963Z [2024-07-04 01:25:25,725] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-14 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.729321511Z [2024-07-04 01:25:25,725] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 43 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.729326051Z [2024-07-04 01:25:25,725] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-43 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.729331105Z [2024-07-04 01:25:25,725] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 12 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.729336007Z [2024-07-04 01:25:25,725] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-12 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.729340587Z [2024-07-04 01:25:25,725] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 41 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.729344585Z [2024-07-04 01:25:25,725] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-41 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.729354787Z [2024-07-04 01:25:25,725] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 24 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.729358896Z [2024-07-04 01:25:25,725] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-24 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.729362776Z [2024-07-04 01:25:25,725] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 22 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.729366888Z [2024-07-04 01:25:25,725] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-22 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.729372432Z [2024-07-04 01:25:25,725] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 18 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.729377415Z [2024-07-04 01:25:25,725] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-18 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.729383274Z [2024-07-04 01:25:25,725] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 31 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.729388075Z [2024-07-04 01:25:25,725] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-31 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.729394041Z [2024-07-04 01:25:25,725] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 29 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.729400926Z [2024-07-04 01:25:25,725] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-29 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.729406435Z [2024-07-04 01:25:25,725] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 25 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.729412024Z [2024-07-04 01:25:25,725] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-25 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.729416783Z [2024-07-04 01:25:25,725] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 8 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.729421642Z [2024-07-04 01:25:25,725] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-8 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.729426338Z [2024-07-04 01:25:25,725] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 6 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.729431349Z [2024-07-04 01:25:25,725] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-6 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.729435897Z [2024-07-04 01:25:25,725] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 35 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.729440434Z [2024-07-04 01:25:25,725] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-35 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.729461930Z [2024-07-04 01:25:25,725] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 4 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.729466782Z [2024-07-04 01:25:25,725] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-4 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.729470704Z [2024-07-04 01:25:25,725] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 33 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.729474193Z [2024-07-04 01:25:25,725] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-33 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.729477412Z [2024-07-04 01:25:25,725] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 2 in epoch OptionalInt[0] (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:25.729480697Z [2024-07-04 01:25:25,725] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-2 (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.739097181Z [2024-07-04 01:25:25,736] INFO [DynamicConfigPublisher broker id=1] Updating topic __consumer_offsets with new configuration : cleanup.policy -> compact,segment.bytes -> 104857600,compression.type -> producer (kafka.server.metadata.DynamicConfigPublisher) 2024-07-04T01:25:25.788737587Z [2024-07-04 01:25:25,786] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-15 in 69 milliseconds for epoch 0, of which 30 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.788750674Z [2024-07-04 01:25:25,786] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-13 in 68 milliseconds for epoch 0, of which 68 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.788756254Z [2024-07-04 01:25:25,786] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-45 in 68 milliseconds for epoch 0, of which 68 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.788761095Z [2024-07-04 01:25:25,786] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-10 in 68 milliseconds for epoch 0, of which 68 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.788765550Z [2024-07-04 01:25:25,787] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-42 in 68 milliseconds for epoch 0, of which 67 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.788770165Z [2024-07-04 01:25:25,787] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-23 in 68 milliseconds for epoch 0, of which 68 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.788774911Z [2024-07-04 01:25:25,787] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-20 in 68 milliseconds for epoch 0, of which 68 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.788779581Z [2024-07-04 01:25:25,787] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-49 in 68 milliseconds for epoch 0, of which 68 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.878451503Z [2024-07-04 01:25:25,875] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-0 in 156 milliseconds for epoch 0, of which 68 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.878471743Z [2024-07-04 01:25:25,876] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-32 in 157 milliseconds for epoch 0, of which 157 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.878475397Z [2024-07-04 01:25:25,876] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-27 in 157 milliseconds for epoch 0, of which 157 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.934863430Z [2024-07-04 01:25:25,934] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-26 in 215 milliseconds for epoch 0, of which 157 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.940693801Z [2024-07-04 01:25:25,940] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-7 in 221 milliseconds for epoch 0, of which 215 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.940709399Z [2024-07-04 01:25:25,940] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-39 in 221 milliseconds for epoch 0, of which 221 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.941040799Z [2024-07-04 01:25:25,940] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-5 in 221 milliseconds for epoch 0, of which 221 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.952398051Z [2024-07-04 01:25:25,946] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-37 in 227 milliseconds for epoch 0, of which 221 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.952406156Z [2024-07-04 01:25:25,946] INFO [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-34 in 227 milliseconds for epoch 0, of which 227 milliseconds was spent in the scheduler. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:25.960779928Z [2024-07-04 01:25:25,960] INFO [GroupCoordinator 1]: Dynamic Member with unknown member id joins group nbi-server in Empty state. Created a new member id aiokafka-0.8.1-5780d57f-2760-4cf4-aca6-80ede83c47fa for this member and add to the group. (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:26.022955091Z [2024-07-04 01:25:26,022] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-48 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.038979036Z [2024-07-04 01:25:26,038] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-46 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.038995372Z [2024-07-04 01:25:26,038] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-11 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.038998961Z [2024-07-04 01:25:26,038] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-44 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.039008389Z [2024-07-04 01:25:26,038] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-9 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.039011458Z [2024-07-04 01:25:26,038] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-21 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.039014311Z [2024-07-04 01:25:26,038] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-19 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.039017347Z [2024-07-04 01:25:26,038] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-17 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.039020326Z [2024-07-04 01:25:26,038] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-30 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.039023318Z [2024-07-04 01:25:26,038] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-28 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.039026357Z [2024-07-04 01:25:26,038] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-40 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.039029492Z [2024-07-04 01:25:26,038] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-38 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.039032704Z [2024-07-04 01:25:26,038] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-3 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.039035697Z [2024-07-04 01:25:26,038] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-36 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.039038545Z [2024-07-04 01:25:26,038] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-1 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.039041582Z [2024-07-04 01:25:26,038] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-47 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.039191856Z [2024-07-04 01:25:26,038] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-16 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.039196322Z [2024-07-04 01:25:26,038] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-14 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.039199852Z [2024-07-04 01:25:26,039] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-43 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.039212706Z [2024-07-04 01:25:26,039] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-12 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.039215935Z [2024-07-04 01:25:26,039] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-41 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.039218895Z [2024-07-04 01:25:26,039] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-24 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.039221869Z [2024-07-04 01:25:26,039] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-22 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.039282922Z [2024-07-04 01:25:26,039] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-18 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.039400844Z [2024-07-04 01:25:26,039] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-31 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.039426630Z [2024-07-04 01:25:26,039] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-29 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.039430380Z [2024-07-04 01:25:26,039] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-25 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.039453241Z [2024-07-04 01:25:26,039] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-8 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.039476860Z [2024-07-04 01:25:26,039] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-6 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.039481648Z [2024-07-04 01:25:26,039] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-35 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.039493822Z [2024-07-04 01:25:26,039] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-4 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.039536217Z [2024-07-04 01:25:26,039] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-33 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.039602589Z [2024-07-04 01:25:26,039] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-2 for coordinator epoch OptionalInt[0]. Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager) 2024-07-04T01:25:26.106568772Z [2024-07-04 01:25:26,106] INFO [GroupCoordinator 1]: Preparing to rebalance group nbi-server in state PreparingRebalance with old generation 0 (__consumer_offsets-23) (reason: Adding new member aiokafka-0.8.1-5780d57f-2760-4cf4-aca6-80ede83c47fa with group instance id None; client reason: not provided) (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:28.310757784Z [2024-07-04 01:25:28,309] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='alarm_request', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:28.310769273Z [2024-07-04 01:25:28,310] INFO [QuorumController id=1] Created topic alarm_request with topic ID yWP9odLGSWKWeYfJjZwZlw. (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:28.310773168Z [2024-07-04 01:25:28,310] INFO [QuorumController id=1] Created partition alarm_request-0 with topic ID yWP9odLGSWKWeYfJjZwZlw and PartitionRegistration(replicas=[2], isr=[2], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:28.438447007Z [2024-07-04 01:25:28,438] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='alarm_request', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'alarm_request' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:28.536399654Z [2024-07-04 01:25:28,535] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='alarm_request', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'alarm_request' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:28.683489105Z [2024-07-04 01:25:28,670] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='alarm_request', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'alarm_request' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:28.956327765Z [2024-07-04 01:25:28,955] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='users', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:28.956343814Z [2024-07-04 01:25:28,955] INFO [QuorumController id=1] Created topic users with topic ID Czl2AgUJTO6bXV-Hp8-DhA. (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:28.956347853Z [2024-07-04 01:25:28,955] INFO [QuorumController id=1] Created partition users-0 with topic ID Czl2AgUJTO6bXV-Hp8-DhA and PartitionRegistration(replicas=[2], isr=[2], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:29.062058597Z [2024-07-04 01:25:29,061] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='users', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'users' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:29.271528644Z [2024-07-04 01:25:29,271] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='users', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'users' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:29.418263641Z [2024-07-04 01:25:29,415] INFO [GroupCoordinator 1]: Stabilized group nbi-server generation 1 (__consumer_offsets-23) with 1 members (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:29.446951186Z [2024-07-04 01:25:29,429] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='project', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:29.449568085Z [2024-07-04 01:25:29,448] INFO [QuorumController id=1] Created topic project with topic ID HdEWWAWmThCMDJvGNH5QbA. (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:29.449580910Z [2024-07-04 01:25:29,448] INFO [QuorumController id=1] Created partition project-0 with topic ID HdEWWAWmThCMDJvGNH5QbA and PartitionRegistration(replicas=[0], isr=[0], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:29.544169487Z [2024-07-04 01:25:29,543] INFO [GroupCoordinator 1]: Assignment received from leader aiokafka-0.8.1-5780d57f-2760-4cf4-aca6-80ede83c47fa for group nbi-server for generation 1. The group has 1 members, 0 of which are static. (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:29.677191528Z [2024-07-04 01:25:29,677] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='project', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'project' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:39.197549252Z [2024-07-04 01:25:39,197] INFO Sent auto-creation request for Set(nslcmops, vca, k8scluster, k8srepo, pla) to the active controller. (kafka.server.DefaultAutoTopicCreationManager) 2024-07-04T01:25:39.228190279Z [2024-07-04 01:25:39,228] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='nslcmops', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS, CreatableTopic(name='vca', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS, CreatableTopic(name='k8scluster', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS, CreatableTopic(name='k8srepo', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS, CreatableTopic(name='pla', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:39.232545392Z [2024-07-04 01:25:39,232] INFO [QuorumController id=1] Created topic nslcmops with topic ID s40ifeCnQtSvNtGVzZrR5A. (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:39.232711261Z [2024-07-04 01:25:39,232] INFO [QuorumController id=1] Created partition nslcmops-0 with topic ID s40ifeCnQtSvNtGVzZrR5A and PartitionRegistration(replicas=[0], isr=[0], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:39.233071352Z [2024-07-04 01:25:39,232] INFO [QuorumController id=1] Created topic vca with topic ID 9-MohdT9RRiJvImf8N2J_w. (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:39.233212918Z [2024-07-04 01:25:39,233] INFO [QuorumController id=1] Created partition vca-0 with topic ID 9-MohdT9RRiJvImf8N2J_w and PartitionRegistration(replicas=[2], isr=[2], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:39.233455905Z [2024-07-04 01:25:39,233] INFO [QuorumController id=1] Created topic k8scluster with topic ID 1fqeYiakSA660bVEP36ExA. (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:39.240273313Z [2024-07-04 01:25:39,240] INFO [QuorumController id=1] Created partition k8scluster-0 with topic ID 1fqeYiakSA660bVEP36ExA and PartitionRegistration(replicas=[0], isr=[0], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:39.240469747Z [2024-07-04 01:25:39,240] INFO [QuorumController id=1] Created topic k8srepo with topic ID vAyGnIw_ST-ZLM4DbWlbMg. (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:39.243213549Z [2024-07-04 01:25:39,243] INFO [QuorumController id=1] Created partition k8srepo-0 with topic ID vAyGnIw_ST-ZLM4DbWlbMg and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:39.243892678Z [2024-07-04 01:25:39,243] INFO [QuorumController id=1] Created topic pla with topic ID 8UYsnzqmQCuV6GDFZAcniA. (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:39.244953005Z [2024-07-04 01:25:39,244] INFO [QuorumController id=1] Created partition pla-0 with topic ID 8UYsnzqmQCuV6GDFZAcniA and PartitionRegistration(replicas=[2], isr=[2], removingReplicas=[], addingReplicas=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:25:39.248719292Z [2024-07-04 01:25:39,248] INFO [GroupCoordinator 1]: Dynamic Member with unknown member id joins group lcm-server in Empty state. Created a new member id aiokafka-0.8.1-b140c9e7-1b8d-4ae8-aed3-4d5cf51423bd for this member and add to the group. (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:39.258836795Z [2024-07-04 01:25:39,258] INFO [GroupCoordinator 1]: Preparing to rebalance group lcm-server in state PreparingRebalance with old generation 0 (__consumer_offsets-32) (reason: Adding new member aiokafka-0.8.1-b140c9e7-1b8d-4ae8-aed3-4d5cf51423bd with group instance id None; client reason: not provided) (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:39.326622511Z [2024-07-04 01:25:39,326] INFO [Broker id=1] Transitioning 1 partition(s) to local leaders. (state.change.logger) 2024-07-04T01:25:39.348352800Z [2024-07-04 01:25:39,348] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions Set(k8srepo-0) (kafka.server.ReplicaFetcherManager) 2024-07-04T01:25:39.348570475Z [2024-07-04 01:25:39,348] INFO [Broker id=1] Creating new partition k8srepo-0 with topic id vAyGnIw_ST-ZLM4DbWlbMg. (state.change.logger) 2024-07-04T01:25:39.397080939Z [2024-07-04 01:25:39,396] INFO [LogLoader partition=k8srepo-0, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) 2024-07-04T01:25:39.414573163Z [2024-07-04 01:25:39,414] INFO Created log for partition k8srepo-0 in /bitnami/kafka/data/k8srepo-0 with properties {} (kafka.log.LogManager) 2024-07-04T01:25:39.437869114Z [2024-07-04 01:25:39,437] INFO [Partition k8srepo-0 broker=1] No checkpointed highwatermark is found for partition k8srepo-0 (kafka.cluster.Partition) 2024-07-04T01:25:39.451212000Z [2024-07-04 01:25:39,451] INFO [Partition k8srepo-0 broker=1] Log loaded for partition k8srepo-0 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:25:39.457895610Z [2024-07-04 01:25:39,457] INFO [Broker id=1] Leader k8srepo-0 with topic id Some(vAyGnIw_ST-ZLM4DbWlbMg) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:25:42.264036304Z [2024-07-04 01:25:42,263] INFO [GroupCoordinator 1]: Stabilized group lcm-server generation 1 (__consumer_offsets-32) with 1 members (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:25:42.279371933Z [2024-07-04 01:25:42,279] INFO [GroupCoordinator 1]: Assignment received from leader aiokafka-0.8.1-b140c9e7-1b8d-4ae8-aed3-4d5cf51423bd for group lcm-server for generation 1. The group has 1 members, 0 of which are static. (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:30:39.272288644Z [2024-07-04 01:30:39,271] INFO [GroupCoordinator 1]: Preparing to rebalance group lcm-server in state PreparingRebalance with old generation 1 (__consumer_offsets-32) (reason: Leader aiokafka-0.8.1-b140c9e7-1b8d-4ae8-aed3-4d5cf51423bd re-joining group during Stable; client reason: not provided) (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:30:39.273759560Z [2024-07-04 01:30:39,273] INFO [GroupCoordinator 1]: Stabilized group lcm-server generation 2 (__consumer_offsets-32) with 1 members (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:30:39.278642363Z [2024-07-04 01:30:39,278] INFO [GroupCoordinator 1]: Assignment received from leader aiokafka-0.8.1-b140c9e7-1b8d-4ae8-aed3-4d5cf51423bd for group lcm-server for generation 2. The group has 1 members, 0 of which are static. (kafka.coordinator.group.GroupCoordinator) 2024-07-04T01:34:00.445601652Z [2024-07-04 01:34:00,445] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='vnfd', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:34:00.445774525Z [2024-07-04 01:34:00,445] INFO [QuorumController id=1] Created topic vnfd with topic ID JYYdbgKXQBGLlN3GVqJfig. (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:34:00.446514188Z [2024-07-04 01:34:00,446] INFO [QuorumController id=1] Created partition vnfd-0 with topic ID JYYdbgKXQBGLlN3GVqJfig and PartitionRegistration(replicas=[0], isr=[0], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:34:00.540339465Z [2024-07-04 01:34:00,540] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='vnfd', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'vnfd' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:34:00.768483330Z [2024-07-04 01:34:00,768] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='vnfd', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'vnfd' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:34:00.874517306Z [2024-07-04 01:34:00,874] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='vnfd', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): TOPIC_ALREADY_EXISTS (Topic 'vnfd' already exists.) (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:34:03.269413372Z [2024-07-04 01:34:03,269] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='nsd', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:34:03.269560744Z [2024-07-04 01:34:03,269] INFO [QuorumController id=1] Created topic nsd with topic ID aK-Gr5DkTiSO7x8AcGgzuw. (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:34:03.269644520Z [2024-07-04 01:34:03,269] INFO [QuorumController id=1] Created partition nsd-0 with topic ID aK-Gr5DkTiSO7x8AcGgzuw and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T01:34:03.315429976Z [2024-07-04 01:34:03,315] INFO [Broker id=1] Transitioning 1 partition(s) to local leaders. (state.change.logger) 2024-07-04T01:34:03.315754846Z [2024-07-04 01:34:03,315] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions Set(nsd-0) (kafka.server.ReplicaFetcherManager) 2024-07-04T01:34:03.316090391Z [2024-07-04 01:34:03,316] INFO [Broker id=1] Creating new partition nsd-0 with topic id aK-Gr5DkTiSO7x8AcGgzuw. (state.change.logger) 2024-07-04T01:34:03.322549988Z [2024-07-04 01:34:03,322] INFO [LogLoader partition=nsd-0, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) 2024-07-04T01:34:03.323289784Z [2024-07-04 01:34:03,323] INFO Created log for partition nsd-0 in /bitnami/kafka/data/nsd-0 with properties {} (kafka.log.LogManager) 2024-07-04T01:34:03.325830213Z [2024-07-04 01:34:03,325] INFO [Partition nsd-0 broker=1] No checkpointed highwatermark is found for partition nsd-0 (kafka.cluster.Partition) 2024-07-04T01:34:03.326474763Z [2024-07-04 01:34:03,326] INFO [Partition nsd-0 broker=1] Log loaded for partition nsd-0 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T01:34:03.326790332Z [2024-07-04 01:34:03,326] INFO [Broker id=1] Leader nsd-0 with topic id Some(aK-Gr5DkTiSO7x8AcGgzuw) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger) 2024-07-04T01:34:46.964694689Z [2024-07-04 01:34:46,964] INFO [RaftManager id=1] Node 0 disconnected. (org.apache.kafka.clients.NetworkClient) 2024-07-04T01:34:47.182345000Z [2024-07-04 01:34:47,182] INFO [RaftManager id=1] Node 2 disconnected. (org.apache.kafka.clients.NetworkClient) 2024-07-04T01:35:39.377807720Z [2024-07-04 01:35:39,377] INFO [BrokerToControllerChannelManager id=1 name=forwarding] Node 1 disconnected. (org.apache.kafka.clients.NetworkClient) 2024-07-04T02:24:47.807670257Z [2024-07-04 02:24:47,807] INFO [SnapshotGenerator id=1] Creating new KRaft snapshot file snapshot 00000000000000007291-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator) 2024-07-04T02:24:47.852527533Z [2024-07-04 02:24:47,852] INFO [SnapshotEmitter id=1] Successfully wrote snapshot 00000000000000007291-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter) 2024-07-04T02:53:56.232838426Z [2024-07-04 02:53:56,232] INFO [GroupCoordinator 1]: Member aiokafka-0.8.1-b140c9e7-1b8d-4ae8-aed3-4d5cf51423bd in group lcm-server has failed, removing it from the group (kafka.coordinator.group.GroupCoordinator) 2024-07-04T02:53:56.234572933Z [2024-07-04 02:53:56,234] INFO [GroupCoordinator 1]: Preparing to rebalance group lcm-server in state PreparingRebalance with old generation 2 (__consumer_offsets-32) (reason: removing member aiokafka-0.8.1-b140c9e7-1b8d-4ae8-aed3-4d5cf51423bd on heartbeat expiration) (kafka.coordinator.group.GroupCoordinator) 2024-07-04T02:53:56.235296247Z [2024-07-04 02:53:56,235] INFO [GroupCoordinator 1]: Group lcm-server with generation 3 is now empty (__consumer_offsets-32) (kafka.coordinator.group.GroupCoordinator) 2024-07-04T02:53:57.289206900Z [2024-07-04 02:53:57,289] INFO [GroupCoordinator 1]: Dynamic Member with unknown member id joins group lcm-server in Empty state. Created a new member id aiokafka-0.8.1-0053f447-a5f7-465b-af7e-f451e60a114b for this member and add to the group. (kafka.coordinator.group.GroupCoordinator) 2024-07-04T02:53:57.289689451Z [2024-07-04 02:53:57,289] INFO [GroupCoordinator 1]: Preparing to rebalance group lcm-server in state PreparingRebalance with old generation 3 (__consumer_offsets-32) (reason: Adding new member aiokafka-0.8.1-0053f447-a5f7-465b-af7e-f451e60a114b with group instance id None; client reason: not provided) (kafka.coordinator.group.GroupCoordinator) 2024-07-04T02:54:00.293204218Z [2024-07-04 02:54:00,292] INFO [GroupCoordinator 1]: Stabilized group lcm-server generation 4 (__consumer_offsets-32) with 1 members (kafka.coordinator.group.GroupCoordinator) 2024-07-04T02:54:00.312854703Z [2024-07-04 02:54:00,312] INFO [GroupCoordinator 1]: Assignment received from leader aiokafka-0.8.1-0053f447-a5f7-465b-af7e-f451e60a114b for group lcm-server for generation 4. The group has 1 members, 0 of which are static. (kafka.coordinator.group.GroupCoordinator) 2024-07-04T03:24:48.256879925Z [2024-07-04 03:24:48,255] INFO [SnapshotGenerator id=1] Creating new KRaft snapshot file snapshot 00000000000000014484-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator) 2024-07-04T03:24:48.272298188Z [2024-07-04 03:24:48,272] INFO [SnapshotEmitter id=1] Successfully wrote snapshot 00000000000000014484-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter) 2024-07-04T03:33:20.206620177Z [2024-07-04 03:33:20,205] ERROR [RaftManager id=1] The latest computed high watermark 15506 is smaller than the current value 15507, which suggests that one of the voters has lost committed data. Full voter replication state: [ReplicaState(nodeId=0, endOffset=Optional[LogOffsetMetadata(offset=15506, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=1117106)])], lastFetchTimestamp=1720063999712, lastCaughtUpTimestamp=1720063999712, hasAcknowledgedLeader=true), ReplicaState(nodeId=1, endOffset=Optional[LogOffsetMetadata(offset=15507, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=1117178)])], lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=true), ReplicaState(nodeId=2, endOffset=Optional[LogOffsetMetadata(offset=15506, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=1117106)])], lastFetchTimestamp=1720064000203, lastCaughtUpTimestamp=1720064000203, hasAcknowledgedLeader=true)] (org.apache.kafka.raft.LeaderState) 2024-07-04T03:33:20.207553072Z [2024-07-04 03:33:20,207] ERROR [RaftManager id=1] The latest computed high watermark 15506 is smaller than the current value 15507, which suggests that one of the voters has lost committed data. Full voter replication state: [ReplicaState(nodeId=0, endOffset=Optional[LogOffsetMetadata(offset=15506, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=1117106)])], lastFetchTimestamp=1720064000206, lastCaughtUpTimestamp=1720063999712, hasAcknowledgedLeader=true), ReplicaState(nodeId=1, endOffset=Optional[LogOffsetMetadata(offset=15507, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=1117178)])], lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=true), ReplicaState(nodeId=2, endOffset=Optional[LogOffsetMetadata(offset=15506, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=1117106)])], lastFetchTimestamp=1720064000203, lastCaughtUpTimestamp=1720064000203, hasAcknowledgedLeader=true)] (org.apache.kafka.raft.LeaderState) 2024-07-04T03:33:20.211445837Z [2024-07-04 03:33:20,211] ERROR [RaftManager id=1] The latest computed high watermark 15506 is smaller than the current value 15507, which suggests that one of the voters has lost committed data. Full voter replication state: [ReplicaState(nodeId=0, endOffset=Optional[LogOffsetMetadata(offset=15506, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=1117106)])], lastFetchTimestamp=1720064000206, lastCaughtUpTimestamp=1720063999712, hasAcknowledgedLeader=true), ReplicaState(nodeId=1, endOffset=Optional[LogOffsetMetadata(offset=15507, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=1117178)])], lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=true), ReplicaState(nodeId=2, endOffset=Optional[LogOffsetMetadata(offset=15506, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=1117106)])], lastFetchTimestamp=1720064000210, lastCaughtUpTimestamp=1720064000203, hasAcknowledgedLeader=true)] (org.apache.kafka.raft.LeaderState) 2024-07-04T03:49:07.578465806Z [2024-07-04 03:49:07,577] INFO [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='nst', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T03:49:07.580204769Z [2024-07-04 03:49:07,578] INFO [QuorumController id=1] Created topic nst with topic ID OFcjor1NTD2xtXbtmjz99Q. (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T03:49:07.580936929Z [2024-07-04 03:49:07,580] INFO [QuorumController id=1] Created partition nst-0 with topic ID OFcjor1NTD2xtXbtmjz99Q and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) 2024-07-04T03:49:07.613989556Z [2024-07-04 03:49:07,613] INFO [Broker id=1] Transitioning 1 partition(s) to local leaders. (state.change.logger) 2024-07-04T03:49:07.615018964Z [2024-07-04 03:49:07,614] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions Set(nst-0) (kafka.server.ReplicaFetcherManager) 2024-07-04T03:49:07.615395292Z [2024-07-04 03:49:07,615] INFO [Broker id=1] Creating new partition nst-0 with topic id OFcjor1NTD2xtXbtmjz99Q. (state.change.logger) 2024-07-04T03:49:07.639922049Z [2024-07-04 03:49:07,638] INFO [LogLoader partition=nst-0, dir=/bitnami/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) 2024-07-04T03:49:07.646836161Z [2024-07-04 03:49:07,646] INFO Created log for partition nst-0 in /bitnami/kafka/data/nst-0 with properties {} (kafka.log.LogManager) 2024-07-04T03:49:07.649324180Z [2024-07-04 03:49:07,649] INFO [Partition nst-0 broker=1] No checkpointed highwatermark is found for partition nst-0 (kafka.cluster.Partition) 2024-07-04T03:49:07.649337506Z [2024-07-04 03:49:07,649] INFO [Partition nst-0 broker=1] Log loaded for partition nst-0 with initial high watermark 0 (kafka.cluster.Partition) 2024-07-04T03:49:07.652834580Z [2024-07-04 03:49:07,651] INFO [Broker id=1] Leader nst-0 with topic id Some(OFcjor1NTD2xtXbtmjz99Q) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1], adding replicas [] and removing replicas [] . Previous leader epoch was -1. (state.change.logger)