2024-02-28 10:17:01 __ ____ __ _____ ___ __ ____ ______ 2024-02-28 10:17:01 --/ __ \/ / / / _ | / _ \/ //_/ / / / __/ 2024-02-28 10:17:01 -/ /_/ / /_/ / __ |/ , _/ ,< / /_/ /\ \ 2024-02-28 10:17:01 --\___\_\____/_/ |_/_/|_/_/|_|\____/___/ 2024-02-28 10:17:01 2024-02-28 10:17:01,800 INFO [com.oza.kaf.ser.EmbeddedKafkaBroker] (main) auto-configuring server 2024-02-28 10:17:01 metaPropertiesEnsemble=MetaPropertiesEnsemble(metadataLogDir=Optional.empty, dirs={./target/log-dir: EMPTY}) 2024-02-28 10:17:01 2024-02-28 10:17:01,802 INFO [com.oza.kaf.ser.Storage] (main) Formatting ./target/log-dir with metadata.version 3.3-IV0. 2024-02-28 10:17:01 2024-02-28 10:17:01,820 INFO [kaf.ser.ControllerServer] (main) [ControllerServer id=1] Starting controller 2024-02-28 10:17:01 2024-02-28 10:17:01,827 INFO [kaf.net.ConnectionQuotas] (main) Updated connection-accept-rate max connection creation rate to 2147483647 2024-02-28 10:17:01 2024-02-28 10:17:01,828 INFO [kaf.net.SocketServer] (main) [SocketServer listenerType=CONTROLLER, nodeId=1] Created data-plane acceptor and processors for endpoint : ListenerName(CONTROLLER) 2024-02-28 10:17:01 2024-02-28 10:17:01,829 INFO [org.apa.kaf.ser.net.EndpointReadyFutures] (main) authorizerStart completed for endpoint CONTROLLER. Endpoint is now READY. 2024-02-28 10:17:01 2024-02-28 10:17:01,829 INFO [kaf.ser.SharedServer] (main) [SharedServer id=1] Starting SharedServer 2024-02-28 10:17:01 2024-02-28 10:17:01,831 INFO [kaf.log.UnifiedLog$] (main) [LogLoader partition=__cluster_metadata-0, dir=/work/./target/log-dir] Loading producer state till offset 0 with message format version 2 2024-02-28 10:17:01 2024-02-28 10:17:01,831 INFO [kaf.log.UnifiedLog$] (main) [LogLoader partition=__cluster_metadata-0, dir=/work/./target/log-dir] Reloading from producer snapshot and rebuilding producer state from offset 0 2024-02-28 10:17:01 2024-02-28 10:17:01,831 INFO [kaf.log.UnifiedLog$] (main) [LogLoader partition=__cluster_metadata-0, dir=/work/./target/log-dir] Producer state recovery took 0ms for snapshot load and 0ms for segment recovery from offset 0 2024-02-28 10:17:01 2024-02-28 10:17:01,832 INFO [kaf.raf.KafkaMetadataLog$] (main) Initialized snapshots with IDs SortedSet() from /work/./target/log-dir/__cluster_metadata-0 2024-02-28 10:17:01 2024-02-28 10:17:01,832 INFO [kaf.raf.TimingWheelExpirationService$ExpiredOperationReaper] (raft-expiration-reaper) [raft-expiration-reaper]: Starting 2024-02-28 10:17:01 2024-02-28 10:17:01,835 INFO [org.apa.kaf.raf.QuorumState] (main) [RaftManager id=1] Completed transition to Unattached(epoch=0, voters=[1], electionTimeoutMs=1725) from null 2024-02-28 10:17:01 2024-02-28 10:17:01,838 INFO [org.apa.kaf.raf.QuorumState] (main) [RaftManager id=1] Completed transition to CandidateState(localId=1, epoch=1, retries=1, voteStates={1=GRANTED}, highWatermark=Optional.empty, electionTimeoutMs=1128) from Unattached(epoch=0, voters=[1], electionTimeoutMs=1725) 2024-02-28 10:17:01 2024-02-28 10:17:01,841 INFO [org.apa.kaf.raf.QuorumState] (main) [RaftManager id=1] Completed transition to Leader(localId=1, epoch=1, epochStartOffset=0, highWatermark=Optional.empty, voterStates={1=ReplicaState(nodeId=1, endOffset=Optional.empty, lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=true)}) from CandidateState(localId=1, epoch=1, retries=1, voteStates={1=GRANTED}, highWatermark=Optional.empty, electionTimeoutMs=1128) 2024-02-28 10:17:01 2024-02-28 10:17:01,860 INFO [kaf.raf.KafkaRaftManager$RaftIoThread] (kafka-1-raft-io-thread) [kafka-1-raft-io-thread]: Starting 2024-02-28 10:17:01 2024-02-28 10:17:01,860 INFO [org.apa.kaf.raf.KafkaNetworkChannel$SendThread] (kafka-1-raft-outbound-request-thread) [kafka-1-raft-outbound-request-thread]: Starting 2024-02-28 10:17:01 2024-02-28 10:17:01,861 INFO [org.apa.kaf.raf.LeaderState] (kafka-1-raft-io-thread) [RaftManager id=1] High watermark set to LogOffsetMetadata(offset=1, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=91)]) for the first time for epoch 1 based on indexOfHw 0 and voters [ReplicaState(nodeId=1, endOffset=Optional[LogOffsetMetadata(offset=1, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=91)])], lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=true)] 2024-02-28 10:17:01 2024-02-28 10:17:01,861 INFO [org.apa.kaf.ima.loa.MetadataLoader] (kafka-1-metadata-loader-event-handler) [MetadataLoader id=1] initializeNewPublishers: The loader is still catching up because we have loaded up to offset -1, but the high water mark is 1 2024-02-28 10:17:01 2024-02-28 10:17:01,861 INFO [kaf.ser.ControllerServer] (main) [ControllerServer id=1] Waiting for controller quorum voters future 2024-02-28 10:17:01 2024-02-28 10:17:01,861 INFO [kaf.ser.ControllerServer] (main) [ControllerServer id=1] Finished waiting for controller quorum voters future 2024-02-28 10:17:01 2024-02-28 10:17:01,861 INFO [org.apa.kaf.con.QuorumController] (main) [QuorumController id=1] Creating new QuorumController with clusterId QKtq6hG6Qq2ne5tLrN23mg. 2024-02-28 10:17:01 2024-02-28 10:17:01,862 INFO [kaf.ser.ClientQuotaManager$ThrottledChannelReaper] (controller-1-ThrottledChannelReaper-Fetch) [controller-1-ThrottledChannelReaper-Fetch]: Starting 2024-02-28 10:17:01 2024-02-28 10:17:01,862 INFO [kaf.ser.ClientQuotaManager$ThrottledChannelReaper] (controller-1-ThrottledChannelReaper-Produce) [controller-1-ThrottledChannelReaper-Produce]: Starting 2024-02-28 10:17:01 2024-02-28 10:17:01,862 INFO [kaf.ser.ClientQuotaManager$ThrottledChannelReaper] (controller-1-ThrottledChannelReaper-Request) [controller-1-ThrottledChannelReaper-Request]: Starting 2024-02-28 10:17:01 2024-02-28 10:17:01,862 INFO [kaf.ser.ClientQuotaManager$ThrottledChannelReaper] (controller-1-ThrottledChannelReaper-ControllerMutation) [controller-1-ThrottledChannelReaper-ControllerMutation]: Starting 2024-02-28 10:17:01 2024-02-28 10:17:01,862 INFO [kaf.ser.DelayedOperationPurgatory$ExpiredOperationReaper] (ExpirationReaper-1-AlterAcls) [ExpirationReaper-1-AlterAcls]: Starting 2024-02-28 10:17:01 2024-02-28 10:17:01,863 INFO [kaf.ser.ControllerServer] (main) [ControllerServer id=1] Waiting for the controller metadata publishers to be installed 2024-02-28 10:17:01 2024-02-28 10:17:01,863 INFO [kaf.ser.ControllerServer] (main) [ControllerServer id=1] Finished waiting for the controller metadata publishers to be installed 2024-02-28 10:17:01 2024-02-28 10:17:01,863 INFO [org.apa.kaf.ima.loa.MetadataLoader] (kafka-1-metadata-loader-event-handler) [MetadataLoader id=1] initializeNewPublishers: The loader is still catching up because we have loaded up to offset -1, but the high water mark is 1 2024-02-28 10:17:01 2024-02-28 10:17:01,863 INFO [org.apa.kaf.raf.KafkaRaftClient] (kafka-1-raft-io-thread) [RaftManager id=1] Registered the listener org.apache.kafka.image.loader.MetadataLoader@843292379 2024-02-28 10:17:01 2024-02-28 10:17:01,863 INFO [org.apa.kaf.raf.KafkaRaftClient] (kafka-1-raft-io-thread) [RaftManager id=1] Registered the listener org.apache.kafka.controller.QuorumController$QuorumMetaLogListener@1623395614 2024-02-28 10:17:01 2024-02-28 10:17:01,863 INFO [kaf.net.SocketServer] (main) [SocketServer listenerType=CONTROLLER, nodeId=1] Enabling request processing. 2024-02-28 10:17:01 2024-02-28 10:17:01,864 INFO [org.apa.kaf.ima.loa.MetadataLoader] (kafka-1-metadata-loader-event-handler) [MetadataLoader id=1] maybePublishMetadata(LOG_DELTA): The loader is still catching up because we have not loaded a controller record as of offset 0 and high water mark is 1 2024-02-28 10:17:01 2024-02-28 10:17:01,864 INFO [org.apa.kaf.con.QuorumController] (quorum-controller-1-event-handler) [QuorumController id=1] Becoming the active controller at epoch 1, next write offset 1. 2024-02-28 10:17:01 2024-02-28 10:17:01,864 WARN [org.apa.kaf.con.QuorumController] (quorum-controller-1-event-handler) [QuorumController id=1] Performing controller activation. The metadata log appears to be empty. Appending 1 bootstrap record(s) at metadata.version 3.3-IV0 from bootstrap source 'the binary bootstrap metadata file: ./target/log-dir/bootstrap.checkpoint'. 2024-02-28 10:17:01 2024-02-28 10:17:01,864 INFO [org.apa.kaf.con.FeatureControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] Replayed a FeatureLevelRecord setting metadata version to 3.3-IV0 2024-02-28 10:17:01 2024-02-28 10:17:01,864 INFO [kaf.net.DataPlaneAcceptor] (main) Awaiting socket connections on broker1:9094. 2024-02-28 10:17:01 2024-02-28 10:17:01,865 INFO [kaf.ser.ControllerServer] (main) [ControllerServer id=1] Waiting for all of the authorizer futures to be completed 2024-02-28 10:17:01 2024-02-28 10:17:01,865 INFO [kaf.ser.ControllerRegistrationManager] (controller-1-registration-manager-event-handler) [ControllerRegistrationManager id=1 incarnation=GcHKZq6CTLmTrXRGdFtC8A] initialized channel manager. 2024-02-28 10:17:01 2024-02-28 10:17:01,865 INFO [kaf.ser.ControllerRegistrationManager] (controller-1-registration-manager-event-handler) [ControllerRegistrationManager id=1 incarnation=GcHKZq6CTLmTrXRGdFtC8A] maybeSendControllerRegistration: cannot register yet because the metadata version is still 3.0-IV1, which does not support KIP-919 controller registration. 2024-02-28 10:17:01 2024-02-28 10:17:01,865 INFO [kaf.ser.ControllerServer] (main) [ControllerServer id=1] Finished waiting for all of the authorizer futures to be completed 2024-02-28 10:17:01 2024-02-28 10:17:01,865 INFO [kaf.ser.NodeToControllerRequestThread] (controller-1-to-controller-registration-channel-manager) [controller-1-to-controller-registration-channel-manager]: Starting 2024-02-28 10:17:01 2024-02-28 10:17:01,865 INFO [kaf.ser.ControllerServer] (main) [ControllerServer id=1] Waiting for all of the SocketServer Acceptors to be started 2024-02-28 10:17:01 2024-02-28 10:17:01,865 INFO [kaf.ser.ControllerServer] (main) [ControllerServer id=1] Finished waiting for all of the SocketServer Acceptors to be started 2024-02-28 10:17:01 2024-02-28 10:17:01,865 INFO [kaf.ser.BrokerServer] (main) [BrokerServer id=1] Transition from SHUTDOWN to STARTING 2024-02-28 10:17:01 2024-02-28 10:17:01,865 INFO [kaf.ser.BrokerServer] (main) [BrokerServer id=1] Starting broker 2024-02-28 10:17:01 2024-02-28 10:17:01,865 INFO [kaf.ser.NodeToControllerRequestThread] (controller-1-to-controller-registration-channel-manager) [controller-1-to-controller-registration-channel-manager]: Recorded new controller, from now on will use node broker1:9094 (id: 1 rack: null) 2024-02-28 10:17:01 2024-02-28 10:17:01,866 INFO [kaf.ser.ClientQuotaManager$ThrottledChannelReaper] (broker-1-ThrottledChannelReaper-Fetch) [broker-1-ThrottledChannelReaper-Fetch]: Starting 2024-02-28 10:17:01 2024-02-28 10:17:01,866 INFO [kaf.ser.ClientQuotaManager$ThrottledChannelReaper] (broker-1-ThrottledChannelReaper-Produce) [broker-1-ThrottledChannelReaper-Produce]: Starting 2024-02-28 10:17:01 2024-02-28 10:17:01,866 INFO [kaf.ser.ClientQuotaManager$ThrottledChannelReaper] (broker-1-ThrottledChannelReaper-Request) [broker-1-ThrottledChannelReaper-Request]: Starting 2024-02-28 10:17:01 2024-02-28 10:17:01,866 INFO [kaf.ser.ClientQuotaManager$ThrottledChannelReaper] (broker-1-ThrottledChannelReaper-ControllerMutation) [broker-1-ThrottledChannelReaper-ControllerMutation]: Starting 2024-02-28 10:17:01 2024-02-28 10:17:01,867 INFO [kaf.ser.BrokerServer] (main) [BrokerServer id=1] Waiting for controller quorum voters future 2024-02-28 10:17:01 2024-02-28 10:17:01,867 INFO [kaf.ser.BrokerServer] (main) [BrokerServer id=1] Finished waiting for controller quorum voters future 2024-02-28 10:17:01 2024-02-28 10:17:01,867 INFO [kaf.ser.NodeToControllerRequestThread] (broker-1-to-controller-forwarding-channel-manager) [broker-1-to-controller-forwarding-channel-manager]: Starting 2024-02-28 10:17:01 2024-02-28 10:17:01,867 INFO [kaf.ser.NodeToControllerRequestThread] (broker-1-to-controller-forwarding-channel-manager) [broker-1-to-controller-forwarding-channel-manager]: Recorded new controller, from now on will use node broker1:9094 (id: 1 rack: null) 2024-02-28 10:17:01 2024-02-28 10:17:01,875 INFO [kaf.net.ConnectionQuotas] (main) Updated connection-accept-rate max connection creation rate to 2147483647 2024-02-28 10:17:01 2024-02-28 10:17:01,876 INFO [kaf.net.SocketServer] (main) [SocketServer listenerType=BROKER, nodeId=1] Created data-plane acceptor and processors for endpoint : ListenerName(BROKER) 2024-02-28 10:17:01 2024-02-28 10:17:01,876 INFO [kaf.net.ConnectionQuotas] (main) Updated connection-accept-rate max connection creation rate to 2147483647 2024-02-28 10:17:01 2024-02-28 10:17:01,877 INFO [kaf.net.SocketServer] (main) [SocketServer listenerType=BROKER, nodeId=1] Created data-plane acceptor and processors for endpoint : ListenerName(PLAINTEXT) 2024-02-28 10:17:01 2024-02-28 10:17:01,878 INFO [kaf.ser.NodeToControllerRequestThread] (broker-1-to-controller-alter-partition-channel-manager) [broker-1-to-controller-alter-partition-channel-manager]: Starting 2024-02-28 10:17:01 2024-02-28 10:17:01,878 INFO [kaf.ser.NodeToControllerRequestThread] (broker-1-to-controller-alter-partition-channel-manager) [broker-1-to-controller-alter-partition-channel-manager]: Recorded new controller, from now on will use node broker1:9094 (id: 1 rack: null) 2024-02-28 10:17:01 2024-02-28 10:17:01,879 INFO [kaf.ser.NodeToControllerRequestThread] (broker-1-to-controller-directory-assignments-channel-manager) [broker-1-to-controller-directory-assignments-channel-manager]: Starting 2024-02-28 10:17:01 2024-02-28 10:17:01,879 INFO [kaf.ser.NodeToControllerRequestThread] (broker-1-to-controller-directory-assignments-channel-manager) [broker-1-to-controller-directory-assignments-channel-manager]: Recorded new controller, from now on will use node broker1:9094 (id: 1 rack: null) 2024-02-28 10:17:01 2024-02-28 10:17:01,879 INFO [kaf.ser.DelayedOperationPurgatory$ExpiredOperationReaper] (ExpirationReaper-1-Produce) [ExpirationReaper-1-Produce]: Starting 2024-02-28 10:17:01 2024-02-28 10:17:01,880 INFO [kaf.ser.DelayedOperationPurgatory$ExpiredOperationReaper] (ExpirationReaper-1-Fetch) [ExpirationReaper-1-Fetch]: Starting 2024-02-28 10:17:01 2024-02-28 10:17:01,880 INFO [kaf.ser.DelayedOperationPurgatory$ExpiredOperationReaper] (ExpirationReaper-1-DeleteRecords) [ExpirationReaper-1-DeleteRecords]: Starting 2024-02-28 10:17:01 2024-02-28 10:17:01,881 INFO [kaf.ser.DelayedOperationPurgatory$ExpiredOperationReaper] (ExpirationReaper-1-ElectLeader) [ExpirationReaper-1-ElectLeader]: Starting 2024-02-28 10:17:01 2024-02-28 10:17:01,881 INFO [kaf.ser.DelayedOperationPurgatory$ExpiredOperationReaper] (ExpirationReaper-1-RemoteFetch) [ExpirationReaper-1-RemoteFetch]: Starting 2024-02-28 10:17:01 2024-02-28 10:17:01,882 INFO [kaf.ser.DelayedOperationPurgatory$ExpiredOperationReaper] (ExpirationReaper-1-Heartbeat) [ExpirationReaper-1-Heartbeat]: Starting 2024-02-28 10:17:01 2024-02-28 10:17:01,882 INFO [kaf.ser.DelayedOperationPurgatory$ExpiredOperationReaper] (ExpirationReaper-1-Rebalance) [ExpirationReaper-1-Rebalance]: Starting 2024-02-28 10:17:01 2024-02-28 10:17:01,883 INFO [kaf.log.LogManager] (main) Unable to read the broker epoch in /work/./target/log-dir. 2024-02-28 10:17:01 2024-02-28 10:17:01,883 INFO [kaf.ser.BrokerLifecycleManager] (broker-1-lifecycle-manager-event-handler) [BrokerLifecycleManager id=1] Incarnation y_YvJMexQlCRgnG001F8sA of broker 1 in cluster QKtq6hG6Qq2ne5tLrN23mg is now STARTING. 2024-02-28 10:17:01 2024-02-28 10:17:01,900 INFO [kaf.ser.NodeToControllerRequestThread] (broker-1-to-controller-heartbeat-channel-manager) [broker-1-to-controller-heartbeat-channel-manager]: Starting 2024-02-28 10:17:01 2024-02-28 10:17:01,900 INFO [kaf.ser.NodeToControllerRequestThread] (broker-1-to-controller-heartbeat-channel-manager) [broker-1-to-controller-heartbeat-channel-manager]: Recorded new controller, from now on will use node broker1:9094 (id: 1 rack: null) 2024-02-28 10:17:01 2024-02-28 10:17:01,901 INFO [org.apa.kaf.ima.loa.MetadataLoader] (kafka-1-metadata-loader-event-handler) [MetadataLoader id=1] maybePublishMetadata(LOG_DELTA): The loader finished catching up to the current high water mark of 2 2024-02-28 10:17:01 2024-02-28 10:17:01,902 INFO [org.apa.kaf.ima.loa.MetadataLoader] (kafka-1-metadata-loader-event-handler) [MetadataLoader id=1] InitializeNewPublishers: initializing SnapshotGenerator with a snapshot at offset 1 2024-02-28 10:17:01 2024-02-28 10:17:01,902 INFO [org.apa.kaf.ima.loa.MetadataLoader] (kafka-1-metadata-loader-event-handler) [MetadataLoader id=1] InitializeNewPublishers: initializing KRaftMetadataCachePublisher with a snapshot at offset 1 2024-02-28 10:17:01 2024-02-28 10:17:01,902 INFO [org.apa.kaf.ima.loa.MetadataLoader] (kafka-1-metadata-loader-event-handler) [MetadataLoader id=1] InitializeNewPublishers: initializing FeaturesPublisher with a snapshot at offset 1 2024-02-28 10:17:01 2024-02-28 10:17:01,902 INFO [org.apa.kaf.met.pub.FeaturesPublisher] (kafka-1-metadata-loader-event-handler) [ControllerServer id=1] Loaded new metadata Features(version=3.3-IV0, finalizedFeatures={metadata.version=4}, finalizedFeaturesEpoch=1). 2024-02-28 10:17:01 2024-02-28 10:17:01,902 INFO [org.apa.kaf.ima.loa.MetadataLoader] (kafka-1-metadata-loader-event-handler) [MetadataLoader id=1] InitializeNewPublishers: initializing ControllerRegistrationsPublisher with a snapshot at offset 1 2024-02-28 10:17:01 2024-02-28 10:17:01,902 INFO [kaf.ser.DelayedOperationPurgatory$ExpiredOperationReaper] (ExpirationReaper-1-AlterAcls) [ExpirationReaper-1-AlterAcls]: Starting 2024-02-28 10:17:01 2024-02-28 10:17:01,902 INFO [org.apa.kaf.ima.loa.MetadataLoader] (kafka-1-metadata-loader-event-handler) [MetadataLoader id=1] InitializeNewPublishers: initializing ControllerRegistrationManager with a snapshot at offset 1 2024-02-28 10:17:01 2024-02-28 10:17:01,902 INFO [org.apa.kaf.ima.loa.MetadataLoader] (kafka-1-metadata-loader-event-handler) [MetadataLoader id=1] InitializeNewPublishers: initializing DynamicConfigPublisher controller id=1 with a snapshot at offset 1 2024-02-28 10:17:01 2024-02-28 10:17:01,902 INFO [kaf.ser.ControllerRegistrationManager] (controller-1-registration-manager-event-handler) [ControllerRegistrationManager id=1 incarnation=GcHKZq6CTLmTrXRGdFtC8A] maybeSendControllerRegistration: cannot register yet because the metadata version is still 3.3-IV0, which does not support KIP-919 controller registration. 2024-02-28 10:17:01 2024-02-28 10:17:01,902 INFO [org.apa.kaf.ima.loa.MetadataLoader] (kafka-1-metadata-loader-event-handler) [MetadataLoader id=1] InitializeNewPublishers: initializing DynamicClientQuotaPublisher controller id=1 with a snapshot at offset 1 2024-02-28 10:17:01 2024-02-28 10:17:01,902 INFO [org.apa.kaf.ima.loa.MetadataLoader] (kafka-1-metadata-loader-event-handler) [MetadataLoader id=1] InitializeNewPublishers: initializing ScramPublisher controller id=1 with a snapshot at offset 1 2024-02-28 10:17:01 2024-02-28 10:17:01,902 INFO [org.apa.kaf.ima.loa.MetadataLoader] (kafka-1-metadata-loader-event-handler) [MetadataLoader id=1] InitializeNewPublishers: initializing DelegationTokenPublisher controller id=1 with a snapshot at offset 1 2024-02-28 10:17:01 2024-02-28 10:17:01,902 INFO [org.apa.kaf.ima.loa.MetadataLoader] (kafka-1-metadata-loader-event-handler) [MetadataLoader id=1] InitializeNewPublishers: initializing ControllerMetadataMetricsPublisher with a snapshot at offset 1 2024-02-28 10:17:01 2024-02-28 10:17:01,902 INFO [org.apa.kaf.ima.loa.MetadataLoader] (kafka-1-metadata-loader-event-handler) [MetadataLoader id=1] InitializeNewPublishers: initializing AclPublisher controller id=1 with a snapshot at offset 1 2024-02-28 10:17:01 2024-02-28 10:17:01,903 INFO [org.apa.kaf.con.ClusterControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] Replayed initial RegisterBrokerRecord for broker 1: RegisterBrokerRecord(brokerId=1, isMigratingZkBroker=false, incarnationId=y_YvJMexQlCRgnG001F8sA, brokerEpoch=2, endPoints=[BrokerEndpoint(name='BROKER', host='broker1', port=9093, securityProtocol=0), BrokerEndpoint(name='PLAINTEXT', host='broker1', port=9092, securityProtocol=0)], features=[BrokerFeature(name='metadata.version', minSupportedVersion=1, maxSupportedVersion=19)], rack=null, fenced=true, inControlledShutdown=false, logDirs=[]) 2024-02-28 10:17:01 2024-02-28 10:17:01,903 INFO [kaf.ser.BrokerServer] (main) [BrokerServer id=1] Waiting for the broker metadata publishers to be installed 2024-02-28 10:17:01 2024-02-28 10:17:01,903 INFO [kaf.ser.BrokerServer] (main) [BrokerServer id=1] Finished waiting for the broker metadata publishers to be installed 2024-02-28 10:17:01 2024-02-28 10:17:01,903 INFO [kaf.ser.BrokerServer] (main) [BrokerServer id=1] Waiting for the controller to acknowledge that we are caught up 2024-02-28 10:17:01 2024-02-28 10:17:01,903 INFO [org.apa.kaf.ima.loa.MetadataLoader] (kafka-1-metadata-loader-event-handler) [MetadataLoader id=1] InitializeNewPublishers: initializing BrokerMetadataPublisher with a snapshot at offset 1 2024-02-28 10:17:01 2024-02-28 10:17:01,904 INFO [kaf.ser.met.BrokerMetadataPublisher] (kafka-1-metadata-loader-event-handler) [BrokerMetadataPublisher id=1] Publishing initial metadata at offset OffsetAndEpoch(offset=1, epoch=1) with metadata.version 3.3-IV0. 2024-02-28 10:17:01 2024-02-28 10:17:01,904 INFO [kaf.log.LogManager] (kafka-1-metadata-loader-event-handler) Loading logs from log dirs ArraySeq(/work/./target/log-dir) 2024-02-28 10:17:01 2024-02-28 10:17:01,904 INFO [kaf.log.LogManager] (kafka-1-metadata-loader-event-handler) No logs found to be loaded in /work/./target/log-dir 2024-02-28 10:17:01 2024-02-28 10:17:01,904 INFO [kaf.log.LogManager] (kafka-1-metadata-loader-event-handler) Loaded 0 logs in 0ms 2024-02-28 10:17:01 2024-02-28 10:17:01,904 INFO [kaf.log.LogManager] (kafka-1-metadata-loader-event-handler) Starting log cleanup with a period of 300000 ms. 2024-02-28 10:17:01 2024-02-28 10:17:01,904 INFO [kaf.log.LogManager] (kafka-1-metadata-loader-event-handler) Starting log flusher with a default period of 9223372036854775807 ms. 2024-02-28 10:17:01 2024-02-28 10:17:01,905 INFO [kaf.log.LogCleaner] (kafka-1-metadata-loader-event-handler) Starting the log cleaner 2024-02-28 10:17:01 2024-02-28 10:17:01,906 INFO [kaf.log.LogCleaner$CleanerThread] (kafka-log-cleaner-thread-0) [kafka-log-cleaner-thread-0]: Starting 2024-02-28 10:17:01 2024-02-28 10:17:01,907 INFO [kaf.ser.ReplicaManager$LogDirFailureHandler] (LogDirFailureHandler) [LogDirFailureHandler]: Starting 2024-02-28 10:17:01 2024-02-28 10:17:01,907 INFO [kaf.ser.AddPartitionsToTxnManager] (AddPartitionsToTxnSenderThread-1) [AddPartitionsToTxnSenderThread-1]: Starting 2024-02-28 10:17:01 2024-02-28 10:17:01,907 INFO [kaf.coo.gro.GroupCoordinator] (kafka-1-metadata-loader-event-handler) [GroupCoordinator 1]: Starting up. 2024-02-28 10:17:01 2024-02-28 10:17:01,907 INFO [kaf.coo.gro.GroupCoordinator] (kafka-1-metadata-loader-event-handler) [GroupCoordinator 1]: Startup complete. 2024-02-28 10:17:01 2024-02-28 10:17:01,907 INFO [kaf.coo.tra.TransactionCoordinator] (kafka-1-metadata-loader-event-handler) [TransactionCoordinator id=1] Starting up. 2024-02-28 10:17:01 2024-02-28 10:17:01,907 INFO [kaf.coo.tra.TransactionCoordinator] (kafka-1-metadata-loader-event-handler) [TransactionCoordinator id=1] Startup complete. 2024-02-28 10:17:01 2024-02-28 10:17:01,908 INFO [kaf.coo.tra.TransactionMarkerChannelManager] (TxnMarkerSenderThread-1) [TxnMarkerSenderThread-1]: Starting 2024-02-28 10:17:01 2024-02-28 10:17:01,908 INFO [kaf.ser.met.BrokerMetadataPublisher] (kafka-1-metadata-loader-event-handler) [BrokerMetadataPublisher id=1] Updating metadata.version to 4 at offset OffsetAndEpoch(offset=1, epoch=1). 2024-02-28 10:17:01 2024-02-28 10:17:01,929 INFO [kaf.ser.BrokerLifecycleManager] (broker-1-lifecycle-manager-event-handler) [BrokerLifecycleManager id=1] Successfully registered broker 1 with broker epoch 2 2024-02-28 10:17:01 2024-02-28 10:17:01,930 INFO [kaf.ser.BrokerLifecycleManager] (broker-1-lifecycle-manager-event-handler) [BrokerLifecycleManager id=1] The broker has caught up. Transitioning from STARTING to RECOVERY. 2024-02-28 10:17:01 2024-02-28 10:17:01,930 INFO [kaf.ser.BrokerServer] (main) [BrokerServer id=1] Finished waiting for the controller to acknowledge that we are caught up 2024-02-28 10:17:01 2024-02-28 10:17:01,930 INFO [kaf.ser.BrokerServer] (main) [BrokerServer id=1] Waiting for the initial broker metadata update to be published 2024-02-28 10:17:01 2024-02-28 10:17:01,930 INFO [kaf.ser.BrokerServer] (main) [BrokerServer id=1] Finished waiting for the initial broker metadata update to be published 2024-02-28 10:17:01 2024-02-28 10:17:01,930 INFO [kaf.ser.KafkaConfig] (main) KafkaConfig values: 2024-02-28 10:17:01 advertised.listeners = PLAINTEXT://broker1:9092,BROKER://broker1:9093 2024-02-28 10:17:01 alter.config.policy.class.name = null 2024-02-28 10:17:01 alter.log.dirs.replication.quota.window.num = 11 2024-02-28 10:17:01 alter.log.dirs.replication.quota.window.size.seconds = 1 2024-02-28 10:17:01 authorizer.class.name = 2024-02-28 10:17:01 auto.create.topics.enable = true 2024-02-28 10:17:01 auto.include.jmx.reporter = true 2024-02-28 10:17:01 auto.leader.rebalance.enable = true 2024-02-28 10:17:01 background.threads = 10 2024-02-28 10:17:01 broker.heartbeat.interval.ms = 2000 2024-02-28 10:17:01 broker.id = 1 2024-02-28 10:17:01 broker.id.generation.enable = true 2024-02-28 10:17:01 broker.rack = null 2024-02-28 10:17:01 broker.session.timeout.ms = 9000 2024-02-28 10:17:01 client.quota.callback.class = null 2024-02-28 10:17:01 compression.type = producer 2024-02-28 10:17:01 connection.failed.authentication.delay.ms = 100 2024-02-28 10:17:01 connections.max.idle.ms = 600000 2024-02-28 10:17:01 connections.max.reauth.ms = 0 2024-02-28 10:17:01 control.plane.listener.name = null 2024-02-28 10:17:01 controlled.shutdown.enable = false 2024-02-28 10:17:01 controlled.shutdown.max.retries = 3 2024-02-28 10:17:01 controlled.shutdown.retry.backoff.ms = 100 2024-02-28 10:17:01 controller.listener.names = CONTROLLER 2024-02-28 10:17:01 controller.quorum.append.linger.ms = 25 2024-02-28 10:17:01 controller.quorum.election.backoff.max.ms = 1000 2024-02-28 10:17:01 controller.quorum.election.timeout.ms = 1000 2024-02-28 10:17:01 controller.quorum.fetch.timeout.ms = 2000 2024-02-28 10:17:01 controller.quorum.request.timeout.ms = 2000 2024-02-28 10:17:01 controller.quorum.retry.backoff.ms = 20 2024-02-28 10:17:01 controller.quorum.voters = [1@broker1:9094] 2024-02-28 10:17:01 controller.quota.window.num = 11 2024-02-28 10:17:01 controller.quota.window.size.seconds = 1 2024-02-28 10:17:01 controller.socket.timeout.ms = 1000 2024-02-28 10:17:01 create.topic.policy.class.name = null 2024-02-28 10:17:01 default.replication.factor = 1 2024-02-28 10:17:01 delegation.token.expiry.check.interval.ms = 3600000 2024-02-28 10:17:01 delegation.token.expiry.time.ms = 86400000 2024-02-28 10:17:01 delegation.token.master.key = null 2024-02-28 10:17:01 delegation.token.max.lifetime.ms = 604800000 2024-02-28 10:17:01 delegation.token.secret.key = null 2024-02-28 10:17:01 delete.records.purgatory.purge.interval.requests = 1 2024-02-28 10:17:01 delete.topic.enable = true 2024-02-28 10:17:01 early.start.listeners = BROKER,CONTROLLER 2024-02-28 10:17:01 eligible.leader.replicas.enable = false 2024-02-28 10:17:01 fetch.max.bytes = 57671680 2024-02-28 10:17:01 fetch.purgatory.purge.interval.requests = 1000 2024-02-28 10:17:01 group.consumer.assignors = [org.apache.kafka.coordinator.group.assignor.UniformAssignor, org.apache.kafka.coordinator.group.assignor.RangeAssignor] 2024-02-28 10:17:01 group.consumer.heartbeat.interval.ms = 5000 2024-02-28 10:17:01 group.consumer.max.heartbeat.interval.ms = 15000 2024-02-28 10:17:01 group.consumer.max.session.timeout.ms = 60000 2024-02-28 10:17:01 group.consumer.max.size = 2147483647 2024-02-28 10:17:01 group.consumer.min.heartbeat.interval.ms = 5000 2024-02-28 10:17:01 group.consumer.min.session.timeout.ms = 45000 2024-02-28 10:17:01 group.consumer.session.timeout.ms = 45000 2024-02-28 10:17:01 group.coordinator.new.enable = false 2024-02-28 10:17:01 group.coordinator.rebalance.protocols = [classic] 2024-02-28 10:17:01 group.coordinator.threads = 1 2024-02-28 10:17:01 group.initial.rebalance.delay.ms = 0 2024-02-28 10:17:01 group.max.session.timeout.ms = 1800000 2024-02-28 10:17:01 group.max.size = 2147483647 2024-02-28 10:17:01 group.min.session.timeout.ms = 6000 2024-02-28 10:17:01 initial.broker.registration.timeout.ms = 60000 2024-02-28 10:17:01 inter.broker.listener.name = BROKER 2024-02-28 10:17:01 inter.broker.protocol.version = 3.7-IV4 2024-02-28 10:17:01 kafka.metrics.polling.interval.secs = 10 2024-02-28 10:17:01 kafka.metrics.reporters = [] 2024-02-28 10:17:01 leader.imbalance.check.interval.seconds = 300 2024-02-28 10:17:01 leader.imbalance.per.broker.percentage = 10 2024-02-28 10:17:01 listener.security.protocol.map = BROKER:PLAINTEXT,CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT 2024-02-28 10:17:01 listeners = BROKER://broker1:9093,PLAINTEXT://:9092,CONTROLLER://broker1:9094 2024-02-28 10:17:01 log.cleaner.backoff.ms = 15000 2024-02-28 10:17:01 log.cleaner.dedupe.buffer.size = 2097152 2024-02-28 10:17:01 log.cleaner.delete.retention.ms = 86400000 2024-02-28 10:17:01 log.cleaner.enable = true 2024-02-28 10:17:01 log.cleaner.io.buffer.load.factor = 0.9 2024-02-28 10:17:01 log.cleaner.io.buffer.size = 524288 2024-02-28 10:17:01 log.cleaner.io.max.bytes.per.second = 1.7976931348623157E308 2024-02-28 10:17:01 log.cleaner.max.compaction.lag.ms = 9223372036854775807 2024-02-28 10:17:01 log.cleaner.min.cleanable.ratio = 0.5 2024-02-28 10:17:01 log.cleaner.min.compaction.lag.ms = 0 2024-02-28 10:17:01 log.cleaner.threads = 1 2024-02-28 10:17:01 log.cleanup.policy = [delete] 2024-02-28 10:17:01 log.dir = ./target/log-dir 2024-02-28 10:17:01 log.dirs = null 2024-02-28 10:17:01 log.flush.interval.messages = 9223372036854775807 2024-02-28 10:17:01 log.flush.interval.ms = null 2024-02-28 10:17:01 log.flush.offset.checkpoint.interval.ms = 60000 2024-02-28 10:17:01 log.flush.scheduler.interval.ms = 9223372036854775807 2024-02-28 10:17:01 log.flush.start.offset.checkpoint.interval.ms = 60000 2024-02-28 10:17:01 log.index.interval.bytes = 4096 2024-02-28 10:17:01 log.index.size.max.bytes = 10485760 2024-02-28 10:17:01 log.local.retention.bytes = -2 2024-02-28 10:17:01 log.local.retention.ms = -2 2024-02-28 10:17:01 log.message.downconversion.enable = true 2024-02-28 10:17:01 log.message.format.version = 3.0-IV1 2024-02-28 10:17:01 log.message.timestamp.after.max.ms = 9223372036854775807 2024-02-28 10:17:01 log.message.timestamp.before.max.ms = 9223372036854775807 2024-02-28 10:17:01 log.message.timestamp.difference.max.ms = 9223372036854775807 2024-02-28 10:17:01 log.message.timestamp.type = CreateTime 2024-02-28 10:17:01 log.preallocate = false 2024-02-28 10:17:01 log.retention.bytes = -1 2024-02-28 10:17:01 log.retention.check.interval.ms = 300000 2024-02-28 10:17:01 log.retention.hours = 168 2024-02-28 10:17:01 log.retention.minutes = null 2024-02-28 10:17:01 log.retention.ms = null 2024-02-28 10:17:01 log.roll.hours = 168 2024-02-28 10:17:01 log.roll.jitter.hours = 0 2024-02-28 10:17:01 log.roll.jitter.ms = null 2024-02-28 10:17:01 log.roll.ms = null 2024-02-28 10:17:01 log.segment.bytes = 1073741824 2024-02-28 10:17:01 log.segment.delete.delay.ms = 1000 2024-02-28 10:17:01 max.connection.creation.rate = 2147483647 2024-02-28 10:17:01 max.connections = 2147483647 2024-02-28 10:17:01 max.connections.per.ip = 2147483647 2024-02-28 10:17:01 max.connections.per.ip.overrides = 2024-02-28 10:17:01 max.incremental.fetch.session.cache.slots = 1000 2024-02-28 10:17:01 message.max.bytes = 1048588 2024-02-28 10:17:01 metadata.log.dir = null 2024-02-28 10:17:01 metadata.log.max.record.bytes.between.snapshots = 20971520 2024-02-28 10:17:01 metadata.log.max.snapshot.interval.ms = 3600000 2024-02-28 10:17:01 metadata.log.segment.bytes = 1073741824 2024-02-28 10:17:01 metadata.log.segment.min.bytes = 8388608 2024-02-28 10:17:01 metadata.log.segment.ms = 604800000 2024-02-28 10:17:01 metadata.max.idle.interval.ms = 500 2024-02-28 10:17:01 metadata.max.retention.bytes = 104857600 2024-02-28 10:17:01 metadata.max.retention.ms = 604800000 2024-02-28 10:17:01 metric.reporters = [com.ozangunalp.kafka.server.metrics.Reporter] 2024-02-28 10:17:01 metrics.num.samples = 2 2024-02-28 10:17:01 metrics.recording.level = INFO 2024-02-28 10:17:01 metrics.sample.window.ms = 30000 2024-02-28 10:17:01 min.insync.replicas = 1 2024-02-28 10:17:01 node.id = 1 2024-02-28 10:17:01 num.io.threads = 8 2024-02-28 10:17:01 num.network.threads = 3 2024-02-28 10:17:01 num.partitions = 1 2024-02-28 10:17:01 num.recovery.threads.per.data.dir = 1 2024-02-28 10:17:01 num.replica.alter.log.dirs.threads = null 2024-02-28 10:17:01 num.replica.fetchers = 1 2024-02-28 10:17:01 offset.metadata.max.bytes = 4096 2024-02-28 10:17:01 offsets.commit.required.acks = -1 2024-02-28 10:17:01 offsets.commit.timeout.ms = 5000 2024-02-28 10:17:01 offsets.load.buffer.size = 5242880 2024-02-28 10:17:01 offsets.retention.check.interval.ms = 600000 2024-02-28 10:17:01 offsets.retention.minutes = 10080 2024-02-28 10:17:01 offsets.topic.compression.codec = 0 2024-02-28 10:17:01 offsets.topic.num.partitions = 5 2024-02-28 10:17:01 offsets.topic.replication.factor = 1 2024-02-28 10:17:01 offsets.topic.segment.bytes = 104857600 2024-02-28 10:17:01 password.encoder.cipher.algorithm = AES/CBC/PKCS5Padding 2024-02-28 10:17:01 password.encoder.iterations = 4096 2024-02-28 10:17:01 password.encoder.key.length = 128 2024-02-28 10:17:01 password.encoder.keyfactory.algorithm = null 2024-02-28 10:17:01 password.encoder.old.secret = null 2024-02-28 10:17:01 password.encoder.secret = null 2024-02-28 10:17:01 principal.builder.class = class org.apache.kafka.common.security.authenticator.DefaultKafkaPrincipalBuilder 2024-02-28 10:17:01 process.roles = [broker, controller] 2024-02-28 10:17:01 producer.id.expiration.check.interval.ms = 600000 2024-02-28 10:17:01 producer.id.expiration.ms = 86400000 2024-02-28 10:17:01 producer.purgatory.purge.interval.requests = 1000 2024-02-28 10:17:01 queued.max.request.bytes = -1 2024-02-28 10:17:01 queued.max.requests = 500 2024-02-28 10:17:01 quota.window.num = 11 2024-02-28 10:17:01 quota.window.size.seconds = 1 2024-02-28 10:17:01 remote.log.index.file.cache.total.size.bytes = 1073741824 2024-02-28 10:17:01 remote.log.manager.task.interval.ms = 30000 2024-02-28 10:17:01 remote.log.manager.task.retry.backoff.max.ms = 30000 2024-02-28 10:17:01 remote.log.manager.task.retry.backoff.ms = 500 2024-02-28 10:17:01 remote.log.manager.task.retry.jitter = 0.2 2024-02-28 10:17:01 remote.log.manager.thread.pool.size = 10 2024-02-28 10:17:01 remote.log.metadata.custom.metadata.max.bytes = 128 2024-02-28 10:17:01 remote.log.metadata.manager.class.name = org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager 2024-02-28 10:17:01 remote.log.metadata.manager.class.path = null 2024-02-28 10:17:01 remote.log.metadata.manager.impl.prefix = rlmm.config. 2024-02-28 10:17:01 remote.log.metadata.manager.listener.name = null 2024-02-28 10:17:01 remote.log.reader.max.pending.tasks = 100 2024-02-28 10:17:01 remote.log.reader.threads = 10 2024-02-28 10:17:01 remote.log.storage.manager.class.name = null 2024-02-28 10:17:01 remote.log.storage.manager.class.path = null 2024-02-28 10:17:01 remote.log.storage.manager.impl.prefix = rsm.config. 2024-02-28 10:17:01 remote.log.storage.system.enable = false 2024-02-28 10:17:01 replica.fetch.backoff.ms = 1000 2024-02-28 10:17:01 replica.fetch.max.bytes = 1048576 2024-02-28 10:17:01 replica.fetch.min.bytes = 1 2024-02-28 10:17:01 replica.fetch.response.max.bytes = 10485760 2024-02-28 10:17:01 replica.fetch.wait.max.ms = 500 2024-02-28 10:17:01 replica.high.watermark.checkpoint.interval.ms = 9223372036854775807 2024-02-28 10:17:01 replica.lag.time.max.ms = 30000 2024-02-28 10:17:01 replica.selector.class = null 2024-02-28 10:17:01 replica.socket.receive.buffer.bytes = 65536 2024-02-28 10:17:01 replica.socket.timeout.ms = 1000 2024-02-28 10:17:01 replication.quota.window.num = 11 2024-02-28 10:17:01 replication.quota.window.size.seconds = 1 2024-02-28 10:17:01 request.timeout.ms = 30000 2024-02-28 10:17:01 reserved.broker.max.id = 1000 2024-02-28 10:17:01 sasl.client.callback.handler.class = null 2024-02-28 10:17:01 sasl.enabled.mechanisms = [GSSAPI] 2024-02-28 10:17:01 sasl.jaas.config = null 2024-02-28 10:17:01 sasl.kerberos.kinit.cmd = /usr/bin/kinit 2024-02-28 10:17:01 sasl.kerberos.min.time.before.relogin = 60000 2024-02-28 10:17:01 sasl.kerberos.principal.to.local.rules = [DEFAULT] 2024-02-28 10:17:01 sasl.kerberos.service.name = null 2024-02-28 10:17:01 sasl.kerberos.ticket.renew.jitter = 0.05 2024-02-28 10:17:01 sasl.kerberos.ticket.renew.window.factor = 0.8 2024-02-28 10:17:01 sasl.login.callback.handler.class = null 2024-02-28 10:17:01 sasl.login.class = null 2024-02-28 10:17:01 sasl.login.connect.timeout.ms = null 2024-02-28 10:17:01 sasl.login.read.timeout.ms = null 2024-02-28 10:17:01 sasl.login.refresh.buffer.seconds = 300 2024-02-28 10:17:01 sasl.login.refresh.min.period.seconds = 60 2024-02-28 10:17:01 sasl.login.refresh.window.factor = 0.8 2024-02-28 10:17:01 sasl.login.refresh.window.jitter = 0.05 2024-02-28 10:17:01 sasl.login.retry.backoff.max.ms = 10000 2024-02-28 10:17:01 sasl.login.retry.backoff.ms = 100 2024-02-28 10:17:01 sasl.mechanism.controller.protocol = GSSAPI 2024-02-28 10:17:01 sasl.mechanism.inter.broker.protocol = GSSAPI 2024-02-28 10:17:01 sasl.oauthbearer.clock.skew.seconds = 30 2024-02-28 10:17:01 sasl.oauthbearer.expected.audience = null 2024-02-28 10:17:01 sasl.oauthbearer.expected.issuer = null 2024-02-28 10:17:01 sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 2024-02-28 10:17:01 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 2024-02-28 10:17:01 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 2024-02-28 10:17:01 sasl.oauthbearer.jwks.endpoint.url = null 2024-02-28 10:17:01 sasl.oauthbearer.scope.claim.name = scope 2024-02-28 10:17:01 sasl.oauthbearer.sub.claim.name = sub 2024-02-28 10:17:01 sasl.oauthbearer.token.endpoint.url = null 2024-02-28 10:17:01 sasl.server.callback.handler.class = null 2024-02-28 10:17:01 sasl.server.max.receive.size = 524288 2024-02-28 10:17:01 security.inter.broker.protocol = PLAINTEXT 2024-02-28 10:17:01 security.providers = null 2024-02-28 10:17:01 server.max.startup.time.ms = 9223372036854775807 2024-02-28 10:17:01 socket.connection.setup.timeout.max.ms = 30000 2024-02-28 10:17:01 socket.connection.setup.timeout.ms = 10000 2024-02-28 10:17:01 socket.listen.backlog.size = 50 2024-02-28 10:17:01 socket.receive.buffer.bytes = 102400 2024-02-28 10:17:01 socket.request.max.bytes = 104857600 2024-02-28 10:17:01 socket.send.buffer.bytes = 102400 2024-02-28 10:17:01 ssl.allow.dn.changes = false 2024-02-28 10:17:01 ssl.allow.san.changes = false 2024-02-28 10:17:01 ssl.cipher.suites = [] 2024-02-28 10:17:01 ssl.client.auth = none 2024-02-28 10:17:01 ssl.enabled.protocols = [TLSv1.2, TLSv1.3] 2024-02-28 10:17:01 ssl.endpoint.identification.algorithm = https 2024-02-28 10:17:01 ssl.engine.factory.class = null 2024-02-28 10:17:01 ssl.key.password = null 2024-02-28 10:17:01 ssl.keymanager.algorithm = SunX509 2024-02-28 10:17:01 ssl.keystore.certificate.chain = null 2024-02-28 10:17:01 ssl.keystore.key = null 2024-02-28 10:17:01 ssl.keystore.location = null 2024-02-28 10:17:01 ssl.keystore.password = null 2024-02-28 10:17:01 ssl.keystore.type = JKS 2024-02-28 10:17:01 ssl.principal.mapping.rules = DEFAULT 2024-02-28 10:17:01 ssl.protocol = TLSv1.3 2024-02-28 10:17:01 ssl.provider = null 2024-02-28 10:17:01 ssl.secure.random.implementation = null 2024-02-28 10:17:01 ssl.trustmanager.algorithm = PKIX 2024-02-28 10:17:01 ssl.truststore.certificates = null 2024-02-28 10:17:01 ssl.truststore.location = null 2024-02-28 10:17:01 ssl.truststore.password = null 2024-02-28 10:17:01 ssl.truststore.type = JKS 2024-02-28 10:17:01 telemetry.max.bytes = 1048576 2024-02-28 10:17:01 transaction.abort.timed.out.transaction.cleanup.interval.ms = 10000 2024-02-28 10:17:01 transaction.max.timeout.ms = 900000 2024-02-28 10:17:01 transaction.partition.verification.enable = true 2024-02-28 10:17:01 transaction.remove.expired.transaction.cleanup.interval.ms = 3600000 2024-02-28 10:17:01 transaction.state.log.load.buffer.size = 5242880 2024-02-28 10:17:01 transaction.state.log.min.isr = 1 2024-02-28 10:17:01 transaction.state.log.num.partitions = 50 2024-02-28 10:17:01 transaction.state.log.replication.factor = 1 2024-02-28 10:17:01 transaction.state.log.segment.bytes = 104857600 2024-02-28 10:17:01 transactional.id.expiration.ms = 604800000 2024-02-28 10:17:01 unclean.leader.election.enable = false 2024-02-28 10:17:01 unstable.api.versions.enable = false 2024-02-28 10:17:01 unstable.metadata.versions.enable = false 2024-02-28 10:17:01 zookeeper.clientCnxnSocket = null 2024-02-28 10:17:01 zookeeper.connect = null 2024-02-28 10:17:01 zookeeper.connection.timeout.ms = null 2024-02-28 10:17:01 zookeeper.max.in.flight.requests = 10 2024-02-28 10:17:01 zookeeper.metadata.migration.enable = false 2024-02-28 10:17:01 zookeeper.metadata.migration.min.batch.size = 200 2024-02-28 10:17:01 zookeeper.session.timeout.ms = 18000 2024-02-28 10:17:01 zookeeper.set.acl = false 2024-02-28 10:17:01 zookeeper.ssl.cipher.suites = null 2024-02-28 10:17:01 zookeeper.ssl.client.enable = false 2024-02-28 10:17:01 zookeeper.ssl.crl.enable = false 2024-02-28 10:17:01 zookeeper.ssl.enabled.protocols = null 2024-02-28 10:17:01 zookeeper.ssl.endpoint.identification.algorithm = HTTPS 2024-02-28 10:17:01 zookeeper.ssl.keystore.location = null 2024-02-28 10:17:01 zookeeper.ssl.keystore.password = null 2024-02-28 10:17:01 zookeeper.ssl.keystore.type = null 2024-02-28 10:17:01 zookeeper.ssl.ocsp.enable = false 2024-02-28 10:17:01 zookeeper.ssl.protocol = TLSv1.2 2024-02-28 10:17:01 zookeeper.ssl.truststore.location = null 2024-02-28 10:17:01 zookeeper.ssl.truststore.password = null 2024-02-28 10:17:01 zookeeper.ssl.truststore.type = null 2024-02-28 10:17:01 2024-02-28 10:17:01 2024-02-28 10:17:01,931 INFO [kaf.ser.BrokerServer] (main) [BrokerServer id=1] Waiting for the broker to be unfenced 2024-02-28 10:17:01 2024-02-28 10:17:01,931 INFO [org.apa.kaf.con.BrokerHeartbeatManager] (quorum-controller-1-event-handler) [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 2. 2024-02-28 10:17:01 2024-02-28 10:17:01,931 INFO [org.apa.kaf.con.ClusterControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] Replayed UnfenceBrokerRecord modifying the registration for broker 1: UnfenceBrokerRecord(id=1, epoch=2) 2024-02-28 10:17:01 2024-02-28 10:17:01,957 INFO [kaf.ser.BrokerLifecycleManager] (broker-1-lifecycle-manager-event-handler) [BrokerLifecycleManager id=1] The broker has been unfenced. Transitioning from RECOVERY to RUNNING. 2024-02-28 10:17:01 2024-02-28 10:17:01,958 INFO [kaf.ser.BrokerServer] (main) [BrokerServer id=1] Finished waiting for the broker to be unfenced 2024-02-28 10:17:01 2024-02-28 10:17:01,958 INFO [org.apa.kaf.ser.net.EndpointReadyFutures] (main) authorizerStart completed for endpoint BROKER. Endpoint is now READY. 2024-02-28 10:17:01 2024-02-28 10:17:01,958 INFO [org.apa.kaf.ser.net.EndpointReadyFutures] (main) authorizerStart completed for endpoint PLAINTEXT. Endpoint is now READY. 2024-02-28 10:17:01 2024-02-28 10:17:01,958 INFO [kaf.net.SocketServer] (main) [SocketServer listenerType=BROKER, nodeId=1] Enabling request processing. 2024-02-28 10:17:01 2024-02-28 10:17:01,958 INFO [kaf.net.DataPlaneAcceptor] (main) Awaiting socket connections on broker1:9093. 2024-02-28 10:17:01 2024-02-28 10:17:01,958 INFO [kaf.net.DataPlaneAcceptor] (main) Awaiting socket connections on 0.0.0.0:9092. 2024-02-28 10:17:01 2024-02-28 10:17:01,958 INFO [kaf.ser.BrokerServer] (main) [BrokerServer id=1] Waiting for all of the authorizer futures to be completed 2024-02-28 10:17:01 2024-02-28 10:17:01,959 INFO [kaf.ser.BrokerServer] (main) [BrokerServer id=1] Finished waiting for all of the authorizer futures to be completed 2024-02-28 10:17:01 2024-02-28 10:17:01,959 INFO [kaf.ser.BrokerServer] (main) [BrokerServer id=1] Waiting for all of the SocketServer Acceptors to be started 2024-02-28 10:17:01 2024-02-28 10:17:01,959 INFO [kaf.ser.BrokerServer] (main) [BrokerServer id=1] Finished waiting for all of the SocketServer Acceptors to be started 2024-02-28 10:17:01 2024-02-28 10:17:01,959 INFO [kaf.ser.BrokerServer] (main) [BrokerServer id=1] Transition from STARTING to STARTED 2024-02-28 10:17:01 2024-02-28 10:17:01,959 INFO [kaf.ser.KafkaRaftServer] (main) [KafkaRaftServer nodeId=1] Kafka Server started 2024-02-28 10:17:01 2024-02-28 10:17:01,959 INFO [com.oza.kaf.ser.EmbeddedKafkaBroker] (main) Kafka broker started in 159 ms with advertised listeners: PLAINTEXT://broker1:9092,BROKER://broker1:9093 2024-02-28 10:17:01 2024-02-28 10:17:01,959 INFO [io.quarkus] (main) kafka-native 0.7.0 native (powered by Quarkus 3.7.4) started in 0.170s. 2024-02-28 10:17:01 2024-02-28 10:17:01,959 INFO [io.quarkus] (main) Profile prod activated. 2024-02-28 10:17:01 2024-02-28 10:17:01,959 INFO [io.quarkus] (main) Installed features: [cdi, kafka-server-extension, smallrye-context-propagation] 2024-02-28 10:17:03 2024-02-28 10:17:03,920 INFO [org.apa.kaf.con.ReplicationControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='warmup-topic', numPartitions=-1, replicationFactor=-1, assignments=[], configs=[]): SUCCESS 2024-02-28 10:17:03 2024-02-28 10:17:03,920 INFO [org.apa.kaf.con.ReplicationControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] Replayed TopicRecord for topic warmup-topic with topic ID qpSsv50lTU2Ed0Jp8cEF_A. 2024-02-28 10:17:03 2024-02-28 10:17:03,920 INFO [org.apa.kaf.con.ReplicationControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] Replayed PartitionRecord for new partition warmup-topic-0 with topic ID qpSsv50lTU2Ed0Jp8cEF_A and PartitionRegistration(replicas=[1], directories=[AAAAAAAAAAAAAAAAAAAAAA], isr=[1], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). 2024-02-28 10:17:03 2024-02-28 10:17:03,946 INFO [sta.cha.logger] (kafka-1-metadata-loader-event-handler) [Broker id=1] Transitioning 1 partition(s) to local leaders. 2024-02-28 10:17:03 2024-02-28 10:17:03,946 INFO [kaf.ser.ReplicaFetcherManager] (kafka-1-metadata-loader-event-handler) [ReplicaFetcherManager on broker 1] Removed fetcher for partitions Set(warmup-topic-0) 2024-02-28 10:17:03 2024-02-28 10:17:03,946 INFO [sta.cha.logger] (kafka-1-metadata-loader-event-handler) [Broker id=1] Creating new partition warmup-topic-0 with topic id qpSsv50lTU2Ed0Jp8cEF_A. 2024-02-28 10:17:03 2024-02-28 10:17:03,947 INFO [kaf.log.UnifiedLog$] (kafka-1-metadata-loader-event-handler) [LogLoader partition=warmup-topic-0, dir=/work/./target/log-dir] Loading producer state till offset 0 with message format version 2 2024-02-28 10:17:03 2024-02-28 10:17:03,948 INFO [kaf.log.LogManager] (kafka-1-metadata-loader-event-handler) Created log for partition warmup-topic-0 in /work/./target/log-dir/warmup-topic-0 with properties {} 2024-02-28 10:17:03 2024-02-28 10:17:03,948 INFO [kaf.clu.Partition] (kafka-1-metadata-loader-event-handler) [Partition warmup-topic-0 broker=1] No checkpointed highwatermark is found for partition warmup-topic-0 2024-02-28 10:17:03 2024-02-28 10:17:03,948 INFO [kaf.clu.Partition] (kafka-1-metadata-loader-event-handler) [Partition warmup-topic-0 broker=1] Log loaded for partition warmup-topic-0 with initial high watermark 0 2024-02-28 10:17:03 2024-02-28 10:17:03,948 INFO [sta.cha.logger] (kafka-1-metadata-loader-event-handler) [Broker id=1] Leader warmup-topic-0 with topic id Some(qpSsv50lTU2Ed0Jp8cEF_A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1. 2024-02-28 10:17:05 2024-02-28 10:17:05,868 INFO [org.apa.kaf.con.ProducerIdControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] Replaying ProducerIdsRecord ProducerIdsRecord(brokerId=1, brokerEpoch=2, nextProducerId=1000) 2024-02-28 10:17:08 2024-02-28 10:17:08,018 INFO [kaf.ser.DefaultAutoTopicCreationManager] (data-plane-kafka-request-handler-5) Sent auto-creation request for Set(__consumer_offsets) to the active controller. 2024-02-28 10:17:08 2024-02-28 10:17:08,019 INFO [org.apa.kaf.con.ReplicationControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='__consumer_offsets', numPartitions=5, replicationFactor=1, assignments=[], configs=[CreateableTopicConfig(name='compression.type', value='producer'), CreateableTopicConfig(name='cleanup.policy', value='compact'), CreateableTopicConfig(name='segment.bytes', value='104857600')]): SUCCESS 2024-02-28 10:17:08 2024-02-28 10:17:08,019 INFO [org.apa.kaf.con.ReplicationControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] Replayed TopicRecord for topic __consumer_offsets with topic ID ERqYuHNHR8m9KqG2EkM8fw. 2024-02-28 10:17:08 2024-02-28 10:17:08,019 INFO [org.apa.kaf.con.ConfigurationControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] Replayed ConfigRecord for ConfigResource(type=TOPIC, name='__consumer_offsets') which set configuration compression.type to producer 2024-02-28 10:17:08 2024-02-28 10:17:08,019 INFO [org.apa.kaf.con.ConfigurationControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] Replayed ConfigRecord for ConfigResource(type=TOPIC, name='__consumer_offsets') which set configuration cleanup.policy to compact 2024-02-28 10:17:08 2024-02-28 10:17:08,019 INFO [org.apa.kaf.con.ConfigurationControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] Replayed ConfigRecord for ConfigResource(type=TOPIC, name='__consumer_offsets') which set configuration segment.bytes to 104857600 2024-02-28 10:17:08 2024-02-28 10:17:08,019 INFO [org.apa.kaf.con.ReplicationControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-0 with topic ID ERqYuHNHR8m9KqG2EkM8fw and PartitionRegistration(replicas=[1], directories=[AAAAAAAAAAAAAAAAAAAAAA], isr=[1], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). 2024-02-28 10:17:08 2024-02-28 10:17:08,019 INFO [org.apa.kaf.con.ReplicationControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-1 with topic ID ERqYuHNHR8m9KqG2EkM8fw and PartitionRegistration(replicas=[1], directories=[AAAAAAAAAAAAAAAAAAAAAA], isr=[1], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). 2024-02-28 10:17:08 2024-02-28 10:17:08,019 INFO [org.apa.kaf.con.ReplicationControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-2 with topic ID ERqYuHNHR8m9KqG2EkM8fw and PartitionRegistration(replicas=[1], directories=[AAAAAAAAAAAAAAAAAAAAAA], isr=[1], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). 2024-02-28 10:17:08 2024-02-28 10:17:08,019 INFO [org.apa.kaf.con.ReplicationControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-3 with topic ID ERqYuHNHR8m9KqG2EkM8fw and PartitionRegistration(replicas=[1], directories=[AAAAAAAAAAAAAAAAAAAAAA], isr=[1], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). 2024-02-28 10:17:08 2024-02-28 10:17:08,019 INFO [org.apa.kaf.con.ReplicationControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-4 with topic ID ERqYuHNHR8m9KqG2EkM8fw and PartitionRegistration(replicas=[1], directories=[AAAAAAAAAAAAAAAAAAAAAA], isr=[1], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). 2024-02-28 10:17:08 2024-02-28 10:17:08,045 INFO [sta.cha.logger] (kafka-1-metadata-loader-event-handler) [Broker id=1] Transitioning 5 partition(s) to local leaders. 2024-02-28 10:17:08 2024-02-28 10:17:08,045 INFO [kaf.ser.ReplicaFetcherManager] (kafka-1-metadata-loader-event-handler) [ReplicaFetcherManager on broker 1] Removed fetcher for partitions Set(__consumer_offsets-0, __consumer_offsets-3, __consumer_offsets-4, __consumer_offsets-1, __consumer_offsets-2) 2024-02-28 10:17:08 2024-02-28 10:17:08,045 INFO [sta.cha.logger] (kafka-1-metadata-loader-event-handler) [Broker id=1] Creating new partition __consumer_offsets-0 with topic id ERqYuHNHR8m9KqG2EkM8fw. 2024-02-28 10:17:08 2024-02-28 10:17:08,047 INFO [kaf.log.UnifiedLog$] (kafka-1-metadata-loader-event-handler) [LogLoader partition=__consumer_offsets-0, dir=/work/./target/log-dir] Loading producer state till offset 0 with message format version 2 2024-02-28 10:17:08 2024-02-28 10:17:08,047 INFO [kaf.log.LogManager] (kafka-1-metadata-loader-event-handler) Created log for partition __consumer_offsets-0 in /work/./target/log-dir/__consumer_offsets-0 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} 2024-02-28 10:17:08 2024-02-28 10:17:08,047 INFO [kaf.clu.Partition] (kafka-1-metadata-loader-event-handler) [Partition __consumer_offsets-0 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-0 2024-02-28 10:17:08 2024-02-28 10:17:08,047 INFO [kaf.clu.Partition] (kafka-1-metadata-loader-event-handler) [Partition __consumer_offsets-0 broker=1] Log loaded for partition __consumer_offsets-0 with initial high watermark 0 2024-02-28 10:17:08 2024-02-28 10:17:08,047 INFO [sta.cha.logger] (kafka-1-metadata-loader-event-handler) [Broker id=1] Leader __consumer_offsets-0 with topic id Some(ERqYuHNHR8m9KqG2EkM8fw) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1. 2024-02-28 10:17:08 2024-02-28 10:17:08,051 INFO [sta.cha.logger] (kafka-1-metadata-loader-event-handler) [Broker id=1] Creating new partition __consumer_offsets-3 with topic id ERqYuHNHR8m9KqG2EkM8fw. 2024-02-28 10:17:08 2024-02-28 10:17:08,051 INFO [kaf.log.UnifiedLog$] (kafka-1-metadata-loader-event-handler) [LogLoader partition=__consumer_offsets-3, dir=/work/./target/log-dir] Loading producer state till offset 0 with message format version 2 2024-02-28 10:17:08 2024-02-28 10:17:08,052 INFO [kaf.log.LogManager] (kafka-1-metadata-loader-event-handler) Created log for partition __consumer_offsets-3 in /work/./target/log-dir/__consumer_offsets-3 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} 2024-02-28 10:17:08 2024-02-28 10:17:08,052 INFO [kaf.clu.Partition] (kafka-1-metadata-loader-event-handler) [Partition __consumer_offsets-3 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-3 2024-02-28 10:17:08 2024-02-28 10:17:08,052 INFO [kaf.clu.Partition] (kafka-1-metadata-loader-event-handler) [Partition __consumer_offsets-3 broker=1] Log loaded for partition __consumer_offsets-3 with initial high watermark 0 2024-02-28 10:17:08 2024-02-28 10:17:08,052 INFO [sta.cha.logger] (kafka-1-metadata-loader-event-handler) [Broker id=1] Leader __consumer_offsets-3 with topic id Some(ERqYuHNHR8m9KqG2EkM8fw) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1. 2024-02-28 10:17:08 2024-02-28 10:17:08,054 INFO [sta.cha.logger] (kafka-1-metadata-loader-event-handler) [Broker id=1] Creating new partition __consumer_offsets-4 with topic id ERqYuHNHR8m9KqG2EkM8fw. 2024-02-28 10:17:08 2024-02-28 10:17:08,055 INFO [kaf.log.UnifiedLog$] (kafka-1-metadata-loader-event-handler) [LogLoader partition=__consumer_offsets-4, dir=/work/./target/log-dir] Loading producer state till offset 0 with message format version 2 2024-02-28 10:17:08 2024-02-28 10:17:08,055 INFO [kaf.log.LogManager] (kafka-1-metadata-loader-event-handler) Created log for partition __consumer_offsets-4 in /work/./target/log-dir/__consumer_offsets-4 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} 2024-02-28 10:17:08 2024-02-28 10:17:08,055 INFO [kaf.clu.Partition] (kafka-1-metadata-loader-event-handler) [Partition __consumer_offsets-4 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-4 2024-02-28 10:17:08 2024-02-28 10:17:08,055 INFO [kaf.clu.Partition] (kafka-1-metadata-loader-event-handler) [Partition __consumer_offsets-4 broker=1] Log loaded for partition __consumer_offsets-4 with initial high watermark 0 2024-02-28 10:17:08 2024-02-28 10:17:08,055 INFO [sta.cha.logger] (kafka-1-metadata-loader-event-handler) [Broker id=1] Leader __consumer_offsets-4 with topic id Some(ERqYuHNHR8m9KqG2EkM8fw) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1. 2024-02-28 10:17:08 2024-02-28 10:17:08,058 INFO [sta.cha.logger] (kafka-1-metadata-loader-event-handler) [Broker id=1] Creating new partition __consumer_offsets-1 with topic id ERqYuHNHR8m9KqG2EkM8fw. 2024-02-28 10:17:08 2024-02-28 10:17:08,059 INFO [kaf.log.UnifiedLog$] (kafka-1-metadata-loader-event-handler) [LogLoader partition=__consumer_offsets-1, dir=/work/./target/log-dir] Loading producer state till offset 0 with message format version 2 2024-02-28 10:17:08 2024-02-28 10:17:08,059 INFO [kaf.log.LogManager] (kafka-1-metadata-loader-event-handler) Created log for partition __consumer_offsets-1 in /work/./target/log-dir/__consumer_offsets-1 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} 2024-02-28 10:17:08 2024-02-28 10:17:08,060 INFO [kaf.clu.Partition] (kafka-1-metadata-loader-event-handler) [Partition __consumer_offsets-1 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-1 2024-02-28 10:17:08 2024-02-28 10:17:08,060 INFO [kaf.clu.Partition] (kafka-1-metadata-loader-event-handler) [Partition __consumer_offsets-1 broker=1] Log loaded for partition __consumer_offsets-1 with initial high watermark 0 2024-02-28 10:17:08 2024-02-28 10:17:08,060 INFO [sta.cha.logger] (kafka-1-metadata-loader-event-handler) [Broker id=1] Leader __consumer_offsets-1 with topic id Some(ERqYuHNHR8m9KqG2EkM8fw) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1. 2024-02-28 10:17:08 2024-02-28 10:17:08,075 INFO [sta.cha.logger] (kafka-1-metadata-loader-event-handler) [Broker id=1] Creating new partition __consumer_offsets-2 with topic id ERqYuHNHR8m9KqG2EkM8fw. 2024-02-28 10:17:08 2024-02-28 10:17:08,076 INFO [kaf.log.UnifiedLog$] (kafka-1-metadata-loader-event-handler) [LogLoader partition=__consumer_offsets-2, dir=/work/./target/log-dir] Loading producer state till offset 0 with message format version 2 2024-02-28 10:17:08 2024-02-28 10:17:08,076 INFO [kaf.log.LogManager] (kafka-1-metadata-loader-event-handler) Created log for partition __consumer_offsets-2 in /work/./target/log-dir/__consumer_offsets-2 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600} 2024-02-28 10:17:08 2024-02-28 10:17:08,076 INFO [kaf.clu.Partition] (kafka-1-metadata-loader-event-handler) [Partition __consumer_offsets-2 broker=1] No checkpointed highwatermark is found for partition __consumer_offsets-2 2024-02-28 10:17:08 2024-02-28 10:17:08,076 INFO [kaf.clu.Partition] (kafka-1-metadata-loader-event-handler) [Partition __consumer_offsets-2 broker=1] Log loaded for partition __consumer_offsets-2 with initial high watermark 0 2024-02-28 10:17:08 2024-02-28 10:17:08,076 INFO [sta.cha.logger] (kafka-1-metadata-loader-event-handler) [Broker id=1] Leader __consumer_offsets-2 with topic id Some(ERqYuHNHR8m9KqG2EkM8fw) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1. 2024-02-28 10:17:08 2024-02-28 10:17:08,079 INFO [kaf.coo.gro.GroupCoordinator] (kafka-1-metadata-loader-event-handler) [GroupCoordinator 1]: Elected as the group coordinator for partition 0 in epoch 0 2024-02-28 10:17:08 2024-02-28 10:17:08,079 INFO [kaf.coo.gro.GroupMetadataManager] (kafka-1-metadata-loader-event-handler) [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-0 for epoch 0 2024-02-28 10:17:08 2024-02-28 10:17:08,079 INFO [kaf.coo.gro.GroupCoordinator] (kafka-1-metadata-loader-event-handler) [GroupCoordinator 1]: Elected as the group coordinator for partition 3 in epoch 0 2024-02-28 10:17:08 2024-02-28 10:17:08,079 INFO [kaf.coo.gro.GroupMetadataManager] (kafka-1-metadata-loader-event-handler) [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-3 for epoch 0 2024-02-28 10:17:08 2024-02-28 10:17:08,079 INFO [kaf.coo.gro.GroupCoordinator] (kafka-1-metadata-loader-event-handler) [GroupCoordinator 1]: Elected as the group coordinator for partition 4 in epoch 0 2024-02-28 10:17:08 2024-02-28 10:17:08,080 INFO [kaf.coo.gro.GroupMetadataManager] (kafka-1-metadata-loader-event-handler) [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-4 for epoch 0 2024-02-28 10:17:08 2024-02-28 10:17:08,094 INFO [kaf.coo.gro.GroupMetadataManager] (group-metadata-manager-0) [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-0 in 15 milliseconds for epoch 0, of which 15 milliseconds was spent in the scheduler. 2024-02-28 10:17:08 2024-02-28 10:17:08,094 INFO [kaf.coo.gro.GroupMetadataManager] (group-metadata-manager-0) [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-3 in 15 milliseconds for epoch 0, of which 15 milliseconds was spent in the scheduler. 2024-02-28 10:17:08 2024-02-28 10:17:08,094 INFO [kaf.coo.gro.GroupCoordinator] (kafka-1-metadata-loader-event-handler) [GroupCoordinator 1]: Elected as the group coordinator for partition 1 in epoch 0 2024-02-28 10:17:08 2024-02-28 10:17:08,094 INFO [kaf.coo.gro.GroupMetadataManager] (kafka-1-metadata-loader-event-handler) [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-1 for epoch 0 2024-02-28 10:17:08 2024-02-28 10:17:08,094 INFO [kaf.coo.gro.GroupCoordinator] (kafka-1-metadata-loader-event-handler) [GroupCoordinator 1]: Elected as the group coordinator for partition 2 in epoch 0 2024-02-28 10:17:08 2024-02-28 10:17:08,094 INFO [kaf.coo.gro.GroupMetadataManager] (kafka-1-metadata-loader-event-handler) [GroupMetadataManager brokerId=1] Scheduling loading of offsets and group metadata from __consumer_offsets-2 for epoch 0 2024-02-28 10:17:08 2024-02-28 10:17:08,094 INFO [kaf.ser.met.DynamicConfigPublisher] (kafka-1-metadata-loader-event-handler) [DynamicConfigPublisher broker id=1] Updating topic __consumer_offsets with new configuration : compression.type -> producer,cleanup.policy -> compact,segment.bytes -> 104857600 2024-02-28 10:17:08 2024-02-28 10:17:08,094 INFO [kaf.coo.gro.GroupMetadataManager] (group-metadata-manager-0) [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-4 in 0 milliseconds for epoch 0, of which 0 milliseconds was spent in the scheduler. 2024-02-28 10:17:08 2024-02-28 10:17:08,094 INFO [kaf.coo.gro.GroupMetadataManager] (group-metadata-manager-0) [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-1 in 0 milliseconds for epoch 0, of which 0 milliseconds was spent in the scheduler. 2024-02-28 10:17:08 2024-02-28 10:17:08,094 INFO [kaf.coo.gro.GroupMetadataManager] (group-metadata-manager-0) [GroupMetadataManager brokerId=1] Finished loading offsets and group metadata from __consumer_offsets-2 in 0 milliseconds for epoch 0, of which 0 milliseconds was spent in the scheduler. 2024-02-28 10:17:08 2024-02-28 10:17:08,164 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-3) [GroupCoordinator 1]: Dynamic member with unknown member id joins group perf-consumer-18018 in Empty state. Created a new member id perf-consumer-client-26211342-017e-4ecc-ad8c-5e82f7398475 and request the member to rejoin with this id. 2024-02-28 10:17:08 2024-02-28 10:17:08,166 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-0) [GroupCoordinator 1]: Preparing to rebalance group perf-consumer-18018 in state PreparingRebalance with old generation 0 (__consumer_offsets-2) (reason: Adding new member perf-consumer-client-26211342-017e-4ecc-ad8c-5e82f7398475 with group instance id None; client reason: rebalance failed due to MemberIdRequiredException) 2024-02-28 10:17:08 2024-02-28 10:17:08,167 INFO [kaf.coo.gro.GroupCoordinator] (executor-Rebalance) [GroupCoordinator 1]: Stabilized group perf-consumer-18018 generation 1 (__consumer_offsets-2) with 1 members 2024-02-28 10:17:08 2024-02-28 10:17:08,179 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-1) [GroupCoordinator 1]: Assignment received from leader perf-consumer-client-26211342-017e-4ecc-ad8c-5e82f7398475 for group perf-consumer-18018 for generation 1. The group has 1 members, 0 of which are static. 2024-02-28 10:17:08 2024-02-28 10:17:08,238 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-5) [GroupCoordinator 1]: Preparing to rebalance group perf-consumer-18018 in state PreparingRebalance with old generation 1 (__consumer_offsets-2) (reason: Removing member perf-consumer-client-26211342-017e-4ecc-ad8c-5e82f7398475 on LeaveGroup; client reason: the consumer is being closed) 2024-02-28 10:17:08 2024-02-28 10:17:08,238 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-5) [GroupCoordinator 1]: Group perf-consumer-18018 with generation 2 is now empty (__consumer_offsets-2) 2024-02-28 10:17:08 2024-02-28 10:17:08,238 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-5) [GroupCoordinator 1]: Member MemberMetadata(memberId=perf-consumer-client-26211342-017e-4ecc-ad8c-5e82f7398475, groupInstanceId=None, clientId=perf-consumer-client, clientHost=/172.20.0.3, sessionTimeoutMs=45000, rebalanceTimeoutMs=300000, supportedProtocols=List(range, cooperative-sticky)) has left group perf-consumer-18018 through explicit `LeaveGroup`; client reason: the consumer is being closed 2024-02-28 10:17:10 2024-02-28 10:17:10,340 INFO [org.apa.kaf.con.ReplicationControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] Replayed RemoveTopicRecord for topic warmup-topic with ID qpSsv50lTU2Ed0Jp8cEF_A. 2024-02-28 10:17:10 2024-02-28 10:17:10,366 INFO [sta.cha.logger] (kafka-1-metadata-loader-event-handler) [Broker id=1] Deleting 1 partition(s). 2024-02-28 10:17:10 2024-02-28 10:17:10,366 INFO [kaf.ser.ReplicaFetcherManager] (kafka-1-metadata-loader-event-handler) [ReplicaFetcherManager on broker 1] Removed fetcher for partitions Set(warmup-topic-0) 2024-02-28 10:17:10 2024-02-28 10:17:10,366 INFO [kaf.ser.ReplicaAlterLogDirsManager] (kafka-1-metadata-loader-event-handler) [ReplicaAlterLogDirsManager on broker 1] Removed fetcher for partitions Set(warmup-topic-0) 2024-02-28 10:17:10 2024-02-28 10:17:10,369 INFO [kaf.log.LogManager] (kafka-1-metadata-loader-event-handler) Log for partition warmup-topic-0 is renamed to /work/./target/log-dir/warmup-topic-0.f872d9f30bb34ccb951ddc7e8a255852-delete and is scheduled for deletion 2024-02-28 10:17:10 2024-02-28 10:17:10,377 INFO [kaf.coo.gro.GroupMetadataManager] (kafka-1-metadata-loader-event-handler) [GroupMetadataManager brokerId=1] Group perf-consumer-18018 transitioned to Dead in generation 2 2024-02-28 10:17:10 2024-02-28 10:17:10,378 INFO [kaf.coo.gro.GroupCoordinator] (kafka-1-metadata-loader-event-handler) [GroupCoordinator 1]: Removed 1 offsets associated with deleted partitions: warmup-topic-0. 2024-02-28 10:17:10 2024-02-28 10:17:10,378 INFO [kaf.ser.met.DynamicConfigPublisher] (kafka-1-metadata-loader-event-handler) [DynamicConfigPublisher broker id=1] Updating topic warmup-topic with new configuration : 2024-02-28 10:17:12 2024-02-28 10:17:12,458 INFO [org.apa.kaf.con.ReplicationControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='perf-test-21697', numPartitions=-1, replicationFactor=-1, assignments=[], configs=[]): SUCCESS 2024-02-28 10:17:12 2024-02-28 10:17:12,458 INFO [org.apa.kaf.con.ReplicationControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] Replayed TopicRecord for topic perf-test-21697 with topic ID cjSzOXUQS06M8ubAZb2aKw. 2024-02-28 10:17:12 2024-02-28 10:17:12,458 INFO [org.apa.kaf.con.ReplicationControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] Replayed PartitionRecord for new partition perf-test-21697-0 with topic ID cjSzOXUQS06M8ubAZb2aKw and PartitionRegistration(replicas=[1], directories=[AAAAAAAAAAAAAAAAAAAAAA], isr=[1], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). 2024-02-28 10:17:12 2024-02-28 10:17:12,483 INFO [sta.cha.logger] (kafka-1-metadata-loader-event-handler) [Broker id=1] Transitioning 1 partition(s) to local leaders. 2024-02-28 10:17:12 2024-02-28 10:17:12,483 INFO [kaf.ser.ReplicaFetcherManager] (kafka-1-metadata-loader-event-handler) [ReplicaFetcherManager on broker 1] Removed fetcher for partitions Set(perf-test-21697-0) 2024-02-28 10:17:12 2024-02-28 10:17:12,483 INFO [sta.cha.logger] (kafka-1-metadata-loader-event-handler) [Broker id=1] Creating new partition perf-test-21697-0 with topic id cjSzOXUQS06M8ubAZb2aKw. 2024-02-28 10:17:12 2024-02-28 10:17:12,484 INFO [kaf.log.UnifiedLog$] (kafka-1-metadata-loader-event-handler) [LogLoader partition=perf-test-21697-0, dir=/work/./target/log-dir] Loading producer state till offset 0 with message format version 2 2024-02-28 10:17:12 2024-02-28 10:17:12,485 INFO [kaf.log.LogManager] (kafka-1-metadata-loader-event-handler) Created log for partition perf-test-21697-0 in /work/./target/log-dir/perf-test-21697-0 with properties {} 2024-02-28 10:17:12 2024-02-28 10:17:12,485 INFO [kaf.clu.Partition] (kafka-1-metadata-loader-event-handler) [Partition perf-test-21697-0 broker=1] No checkpointed highwatermark is found for partition perf-test-21697-0 2024-02-28 10:17:12 2024-02-28 10:17:12,485 INFO [kaf.clu.Partition] (kafka-1-metadata-loader-event-handler) [Partition perf-test-21697-0 broker=1] Log loaded for partition perf-test-21697-0 with initial high watermark 0 2024-02-28 10:17:12 2024-02-28 10:17:12,485 INFO [sta.cha.logger] (kafka-1-metadata-loader-event-handler) [Broker id=1] Leader perf-test-21697-0 with topic id Some(cjSzOXUQS06M8ubAZb2aKw) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1. 2024-02-28 10:17:16 2024-02-28 10:17:16,511 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-3) [GroupCoordinator 1]: Dynamic member with unknown member id joins group perf-consumer-15673 in Empty state. Created a new member id perf-consumer-client-9f21593e-c188-41f9-8883-331501301023 and request the member to rejoin with this id. 2024-02-28 10:17:16 2024-02-28 10:17:16,513 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-0) [GroupCoordinator 1]: Preparing to rebalance group perf-consumer-15673 in state PreparingRebalance with old generation 0 (__consumer_offsets-3) (reason: Adding new member perf-consumer-client-9f21593e-c188-41f9-8883-331501301023 with group instance id None; client reason: rebalance failed due to MemberIdRequiredException) 2024-02-28 10:17:16 2024-02-28 10:17:16,513 INFO [kaf.coo.gro.GroupCoordinator] (executor-Rebalance) [GroupCoordinator 1]: Stabilized group perf-consumer-15673 generation 1 (__consumer_offsets-3) with 1 members 2024-02-28 10:17:16 2024-02-28 10:17:16,525 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-1) [GroupCoordinator 1]: Assignment received from leader perf-consumer-client-9f21593e-c188-41f9-8883-331501301023 for group perf-consumer-15673 for generation 1. The group has 1 members, 0 of which are static. 2024-02-28 10:17:16 2024-02-28 10:17:16,588 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-3) [GroupCoordinator 1]: Preparing to rebalance group perf-consumer-15673 in state PreparingRebalance with old generation 1 (__consumer_offsets-3) (reason: Removing member perf-consumer-client-9f21593e-c188-41f9-8883-331501301023 on LeaveGroup; client reason: the consumer is being closed) 2024-02-28 10:17:16 2024-02-28 10:17:16,588 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-3) [GroupCoordinator 1]: Group perf-consumer-15673 with generation 2 is now empty (__consumer_offsets-3) 2024-02-28 10:17:16 2024-02-28 10:17:16,588 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-3) [GroupCoordinator 1]: Member MemberMetadata(memberId=perf-consumer-client-9f21593e-c188-41f9-8883-331501301023, groupInstanceId=None, clientId=perf-consumer-client, clientHost=/172.20.0.3, sessionTimeoutMs=45000, rebalanceTimeoutMs=300000, supportedProtocols=List(range, cooperative-sticky)) has left group perf-consumer-15673 through explicit `LeaveGroup`; client reason: the consumer is being closed 2024-02-28 10:17:31 2024-02-28 10:17:31,904 INFO [kaf.log.LocalLog] (kafka-scheduler-1) [LocalLog partition=warmup-topic-0, dir=/work/./target/log-dir] Deleting segments as the log has been deleted: LogSegment(baseOffset=0, size=1037087, lastModifiedTime=1709115426061, largestRecordTimestamp=1709115425927) 2024-02-28 10:17:31 2024-02-28 10:17:31,904 INFO [kaf.log.LocalLog$] (kafka-scheduler-1) [LocalLog partition=warmup-topic-0, dir=/work/./target/log-dir] Deleting segment files LogSegment(baseOffset=0, size=1037087, lastModifiedTime=1709115426061, largestRecordTimestamp=1709115425927) 2024-02-28 10:17:31 2024-02-28 10:17:31,905 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-1) Deleted log /work/./target/log-dir/warmup-topic-0.f872d9f30bb34ccb951ddc7e8a255852-delete/00000000000000000000.log.deleted. 2024-02-28 10:17:31 2024-02-28 10:17:31,905 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-1) Deleted offset index /work/./target/log-dir/warmup-topic-0.f872d9f30bb34ccb951ddc7e8a255852-delete/00000000000000000000.index.deleted. 2024-02-28 10:17:31 2024-02-28 10:17:31,906 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-1) Deleted time index /work/./target/log-dir/warmup-topic-0.f872d9f30bb34ccb951ddc7e8a255852-delete/00000000000000000000.timeindex.deleted. 2024-02-28 10:17:31 2024-02-28 10:17:31,906 INFO [kaf.log.LogManager] (kafka-scheduler-1) Deleted log for partition warmup-topic-0 in /work/./target/log-dir/warmup-topic-0.f872d9f30bb34ccb951ddc7e8a255852-delete. 2024-02-28 10:17:40 2024-02-28 10:17:40,212 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-6) [LocalLog partition=perf-test-21697-0, dir=/work/./target/log-dir] Rolled new log segment at offset 1035355 in 0 ms. 2024-02-28 10:17:40 2024-02-28 10:17:40,212 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-6) [ProducerStateManager partition=perf-test-21697-0] Wrote producer snapshot at offset 1035355 with 2 producer ids in 0 ms. 2024-02-28 10:18:03 2024-02-28 10:18:03,346 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-6) [LocalLog partition=perf-test-21697-0, dir=/work/./target/log-dir] Rolled new log segment at offset 2070715 in 0 ms. 2024-02-28 10:18:03 2024-02-28 10:18:03,346 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-6) [ProducerStateManager partition=perf-test-21697-0] Wrote producer snapshot at offset 2070715 with 2 producer ids in 0 ms. 2024-02-28 10:18:26 2024-02-28 10:18:26,715 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-6) [LocalLog partition=perf-test-21697-0, dir=/work/./target/log-dir] Rolled new log segment at offset 3106075 in 0 ms. 2024-02-28 10:18:26 2024-02-28 10:18:26,715 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-6) [ProducerStateManager partition=perf-test-21697-0] Wrote producer snapshot at offset 3106075 with 2 producer ids in 0 ms. 2024-02-28 10:18:50 2024-02-28 10:18:50,394 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-6) [LocalLog partition=perf-test-21697-0, dir=/work/./target/log-dir] Rolled new log segment at offset 4141435 in 0 ms. 2024-02-28 10:18:50 2024-02-28 10:18:50,394 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-6) [ProducerStateManager partition=perf-test-21697-0] Wrote producer snapshot at offset 4141435 with 2 producer ids in 1 ms. 2024-02-28 10:19:14 2024-02-28 10:19:14,269 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-6) [LocalLog partition=perf-test-21697-0, dir=/work/./target/log-dir] Rolled new log segment at offset 5176795 in 1 ms. 2024-02-28 10:19:14 2024-02-28 10:19:14,269 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-6) [ProducerStateManager partition=perf-test-21697-0] Wrote producer snapshot at offset 5176795 with 2 producer ids in 0 ms. 2024-02-28 10:19:37 2024-02-28 10:19:37,987 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-6) [LocalLog partition=perf-test-21697-0, dir=/work/./target/log-dir] Rolled new log segment at offset 6212155 in 0 ms. 2024-02-28 10:19:37 2024-02-28 10:19:37,987 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-6) [ProducerStateManager partition=perf-test-21697-0] Wrote producer snapshot at offset 6212155 with 2 producer ids in 0 ms. 2024-02-28 10:20:01 2024-02-28 10:20:01,841 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-6) [LocalLog partition=perf-test-21697-0, dir=/work/./target/log-dir] Rolled new log segment at offset 7247515 in 1 ms. 2024-02-28 10:20:01 2024-02-28 10:20:01,841 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-6) [ProducerStateManager partition=perf-test-21697-0] Wrote producer snapshot at offset 7247515 with 2 producer ids in 0 ms. 2024-02-28 10:20:25 2024-02-28 10:20:25,579 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-6) [LocalLog partition=perf-test-21697-0, dir=/work/./target/log-dir] Rolled new log segment at offset 8282875 in 0 ms. 2024-02-28 10:20:25 2024-02-28 10:20:25,579 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-6) [ProducerStateManager partition=perf-test-21697-0] Wrote producer snapshot at offset 8282875 with 2 producer ids in 0 ms. 2024-02-28 10:20:49 2024-02-28 10:20:49,162 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-6) [LocalLog partition=perf-test-21697-0, dir=/work/./target/log-dir] Rolled new log segment at offset 9318235 in 0 ms. 2024-02-28 10:20:49 2024-02-28 10:20:49,162 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-6) [ProducerStateManager partition=perf-test-21697-0] Wrote producer snapshot at offset 9318235 with 2 producer ids in 0 ms. 2024-02-28 10:21:07 2024-02-28 10:21:07,696 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-4) [GroupCoordinator 1]: Dynamic member with unknown member id joins group perf-consumer-27082 in Empty state. Created a new member id perf-consumer-client-0c249755-910b-470c-99ab-d09fbfda6c90 and request the member to rejoin with this id. 2024-02-28 10:21:07 2024-02-28 10:21:07,698 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-1) [GroupCoordinator 1]: Preparing to rebalance group perf-consumer-27082 in state PreparingRebalance with old generation 0 (__consumer_offsets-1) (reason: Adding new member perf-consumer-client-0c249755-910b-470c-99ab-d09fbfda6c90 with group instance id None; client reason: rebalance failed due to MemberIdRequiredException) 2024-02-28 10:21:07 2024-02-28 10:21:07,699 INFO [kaf.coo.gro.GroupCoordinator] (executor-Rebalance) [GroupCoordinator 1]: Stabilized group perf-consumer-27082 generation 1 (__consumer_offsets-1) with 1 members 2024-02-28 10:21:07 2024-02-28 10:21:07,712 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-7) [GroupCoordinator 1]: Assignment received from leader perf-consumer-client-0c249755-910b-470c-99ab-d09fbfda6c90 for group perf-consumer-27082 for generation 1. The group has 1 members, 0 of which are static. 2024-02-28 10:21:23 2024-02-28 10:21:23,327 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-6) [GroupCoordinator 1]: Preparing to rebalance group perf-consumer-27082 in state PreparingRebalance with old generation 1 (__consumer_offsets-1) (reason: Removing member perf-consumer-client-0c249755-910b-470c-99ab-d09fbfda6c90 on LeaveGroup; client reason: the consumer is being closed) 2024-02-28 10:21:23 2024-02-28 10:21:23,327 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-6) [GroupCoordinator 1]: Group perf-consumer-27082 with generation 2 is now empty (__consumer_offsets-1) 2024-02-28 10:21:23 2024-02-28 10:21:23,327 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-6) [GroupCoordinator 1]: Member MemberMetadata(memberId=perf-consumer-client-0c249755-910b-470c-99ab-d09fbfda6c90, groupInstanceId=None, clientId=perf-consumer-client, clientHost=/172.20.0.3, sessionTimeoutMs=45000, rebalanceTimeoutMs=300000, supportedProtocols=List(range, cooperative-sticky)) has left group perf-consumer-27082 through explicit `LeaveGroup`; client reason: the consumer is being closed 2024-02-28 10:21:25 2024-02-28 10:21:25,439 INFO [org.apa.kaf.con.ReplicationControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] Replayed RemoveTopicRecord for topic perf-test-21697 with ID cjSzOXUQS06M8ubAZb2aKw. 2024-02-28 10:21:25 2024-02-28 10:21:25,465 INFO [sta.cha.logger] (kafka-1-metadata-loader-event-handler) [Broker id=1] Deleting 1 partition(s). 2024-02-28 10:21:25 2024-02-28 10:21:25,465 INFO [kaf.ser.ReplicaFetcherManager] (kafka-1-metadata-loader-event-handler) [ReplicaFetcherManager on broker 1] Removed fetcher for partitions Set(perf-test-21697-0) 2024-02-28 10:21:25 2024-02-28 10:21:25,465 INFO [kaf.ser.ReplicaAlterLogDirsManager] (kafka-1-metadata-loader-event-handler) [ReplicaAlterLogDirsManager on broker 1] Removed fetcher for partitions Set(perf-test-21697-0) 2024-02-28 10:21:25 2024-02-28 10:21:25,467 INFO [kaf.log.LogManager] (kafka-1-metadata-loader-event-handler) Log for partition perf-test-21697-0 is renamed to /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete and is scheduled for deletion 2024-02-28 10:21:25 2024-02-28 10:21:25,475 INFO [kaf.coo.gro.GroupMetadataManager] (kafka-1-metadata-loader-event-handler) [GroupMetadataManager brokerId=1] Group perf-consumer-15673 transitioned to Dead in generation 2 2024-02-28 10:21:25 2024-02-28 10:21:25,475 INFO [kaf.coo.gro.GroupMetadataManager] (kafka-1-metadata-loader-event-handler) [GroupMetadataManager brokerId=1] Group perf-consumer-27082 transitioned to Dead in generation 2 2024-02-28 10:21:25 2024-02-28 10:21:25,475 INFO [kaf.coo.gro.GroupCoordinator] (kafka-1-metadata-loader-event-handler) [GroupCoordinator 1]: Removed 2 offsets associated with deleted partitions: perf-test-21697-0. 2024-02-28 10:21:25 2024-02-28 10:21:25,476 INFO [kaf.ser.met.DynamicConfigPublisher] (kafka-1-metadata-loader-event-handler) [DynamicConfigPublisher broker id=1] Updating topic perf-test-21697 with new configuration : 2024-02-28 10:21:26 2024-02-28 10:21:26,468 INFO [kaf.log.LocalLog] (kafka-scheduler-6) [LocalLog partition=perf-test-21697-0, dir=/work/./target/log-dir] Deleting segments as the log has been deleted: LogSegment(baseOffset=0, size=1073732179, lastModifiedTime=1709115460210, largestRecordTimestamp=1709115459539),LogSegment(baseOffset=1035355, size=1073737344, lastModifiedTime=1709115483343, largestRecordTimestamp=1709115482652),LogSegment(baseOffset=2070715, size=1073737344, lastModifiedTime=1709115506714, largestRecordTimestamp=1709115506030),LogSegment(baseOffset=3106075, size=1073737344, lastModifiedTime=1709115530393, largestRecordTimestamp=1709115529679),LogSegment(baseOffset=4141435, size=1073737344, lastModifiedTime=1709115554267, largestRecordTimestamp=1709115553563),LogSegment(baseOffset=5176795, size=1073737344, lastModifiedTime=1709115577985, largestRecordTimestamp=1709115577289),LogSegment(baseOffset=6212155, size=1073737344, lastModifiedTime=1709115601839, largestRecordTimestamp=1709115601144),LogSegment(baseOffset=7247515, size=1073737344, lastModifiedTime=1709115625578, largestRecordTimestamp=1709115624882),LogSegment(baseOffset=8282875, size=1073737344, lastModifiedTime=1709115649161, largestRecordTimestamp=1709115648463),LogSegment(baseOffset=9318235, size=708072843, lastModifiedTime=1709115664999, largestRecordTimestamp=1709115664316) 2024-02-28 10:21:26 2024-02-28 10:21:26,469 INFO [kaf.log.LocalLog$] (kafka-scheduler-6) [LocalLog partition=perf-test-21697-0, dir=/work/./target/log-dir] Deleting segment files LogSegment(baseOffset=0, size=1073732179, lastModifiedTime=1709115460210, largestRecordTimestamp=1709115459539),LogSegment(baseOffset=1035355, size=1073737344, lastModifiedTime=1709115483343, largestRecordTimestamp=1709115482652),LogSegment(baseOffset=2070715, size=1073737344, lastModifiedTime=1709115506714, largestRecordTimestamp=1709115506030),LogSegment(baseOffset=3106075, size=1073737344, lastModifiedTime=1709115530393, largestRecordTimestamp=1709115529679),LogSegment(baseOffset=4141435, size=1073737344, lastModifiedTime=1709115554267, largestRecordTimestamp=1709115553563),LogSegment(baseOffset=5176795, size=1073737344, lastModifiedTime=1709115577985, largestRecordTimestamp=1709115577289),LogSegment(baseOffset=6212155, size=1073737344, lastModifiedTime=1709115601839, largestRecordTimestamp=1709115601144),LogSegment(baseOffset=7247515, size=1073737344, lastModifiedTime=1709115625578, largestRecordTimestamp=1709115624882),LogSegment(baseOffset=8282875, size=1073737344, lastModifiedTime=1709115649161, largestRecordTimestamp=1709115648463),LogSegment(baseOffset=9318235, size=708072843, lastModifiedTime=1709115664999, largestRecordTimestamp=1709115664316) 2024-02-28 10:21:26 2024-02-28 10:21:26,603 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-6) Deleted log /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000000000000.log.deleted. 2024-02-28 10:21:26 2024-02-28 10:21:26,604 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-6) Deleted offset index /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000000000000.index.deleted. 2024-02-28 10:21:26 2024-02-28 10:21:26,604 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-6) Deleted time index /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000000000000.timeindex.deleted. 2024-02-28 10:21:26 2024-02-28 10:21:26,737 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-6) Deleted log /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000001035355.log.deleted. 2024-02-28 10:21:26 2024-02-28 10:21:26,738 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-6) Deleted offset index /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000001035355.index.deleted. 2024-02-28 10:21:26 2024-02-28 10:21:26,738 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-6) Deleted time index /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000001035355.timeindex.deleted. 2024-02-28 10:21:26 2024-02-28 10:21:26,872 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-6) Deleted log /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000002070715.log.deleted. 2024-02-28 10:21:26 2024-02-28 10:21:26,872 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-6) Deleted offset index /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000002070715.index.deleted. 2024-02-28 10:21:26 2024-02-28 10:21:26,872 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-6) Deleted time index /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000002070715.timeindex.deleted. 2024-02-28 10:21:27 2024-02-28 10:21:27,002 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-6) Deleted log /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000003106075.log.deleted. 2024-02-28 10:21:27 2024-02-28 10:21:27,002 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-6) Deleted offset index /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000003106075.index.deleted. 2024-02-28 10:21:27 2024-02-28 10:21:27,003 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-6) Deleted time index /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000003106075.timeindex.deleted. 2024-02-28 10:21:27 2024-02-28 10:21:27,133 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-6) Deleted log /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000004141435.log.deleted. 2024-02-28 10:21:27 2024-02-28 10:21:27,133 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-6) Deleted offset index /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000004141435.index.deleted. 2024-02-28 10:21:27 2024-02-28 10:21:27,133 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-6) Deleted time index /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000004141435.timeindex.deleted. 2024-02-28 10:21:27 2024-02-28 10:21:27,266 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-6) Deleted log /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000005176795.log.deleted. 2024-02-28 10:21:27 2024-02-28 10:21:27,267 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-6) Deleted offset index /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000005176795.index.deleted. 2024-02-28 10:21:27 2024-02-28 10:21:27,267 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-6) Deleted time index /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000005176795.timeindex.deleted. 2024-02-28 10:21:27 2024-02-28 10:21:27,398 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-6) Deleted log /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000006212155.log.deleted. 2024-02-28 10:21:27 2024-02-28 10:21:27,399 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-6) Deleted offset index /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000006212155.index.deleted. 2024-02-28 10:21:27 2024-02-28 10:21:27,399 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-6) Deleted time index /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000006212155.timeindex.deleted. 2024-02-28 10:21:27 2024-02-28 10:21:27,529 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-6) Deleted log /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000007247515.log.deleted. 2024-02-28 10:21:27 2024-02-28 10:21:27,529 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-6) Deleted offset index /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000007247515.index.deleted. 2024-02-28 10:21:27 2024-02-28 10:21:27,530 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-6) Deleted time index /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000007247515.timeindex.deleted. 2024-02-28 10:21:27 2024-02-28 10:21:27,656 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-6) Deleted log /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000008282875.log.deleted. 2024-02-28 10:21:27 2024-02-28 10:21:27,657 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-6) Deleted offset index /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000008282875.index.deleted. 2024-02-28 10:21:27 2024-02-28 10:21:27,657 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-6) Deleted time index /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000008282875.timeindex.deleted. 2024-02-28 10:21:27 2024-02-28 10:21:27,742 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-6) Deleted log /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000009318235.log.deleted. 2024-02-28 10:21:27 2024-02-28 10:21:27,742 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-6) Deleted offset index /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000009318235.index.deleted. 2024-02-28 10:21:27 2024-02-28 10:21:27,742 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-6) Deleted time index /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000009318235.timeindex.deleted. 2024-02-28 10:21:27 2024-02-28 10:21:27,743 INFO [org.apa.kaf.sto.int.log.SnapshotFile] (kafka-scheduler-6) Deleted producer state snapshot /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000001035355.snapshot.deleted 2024-02-28 10:21:27 2024-02-28 10:21:27,743 INFO [org.apa.kaf.sto.int.log.SnapshotFile] (kafka-scheduler-6) Deleted producer state snapshot /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000002070715.snapshot.deleted 2024-02-28 10:21:27 2024-02-28 10:21:27,743 INFO [org.apa.kaf.sto.int.log.SnapshotFile] (kafka-scheduler-6) Deleted producer state snapshot /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000003106075.snapshot.deleted 2024-02-28 10:21:27 2024-02-28 10:21:27,743 INFO [org.apa.kaf.sto.int.log.SnapshotFile] (kafka-scheduler-6) Deleted producer state snapshot /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000004141435.snapshot.deleted 2024-02-28 10:21:27 2024-02-28 10:21:27,743 INFO [org.apa.kaf.sto.int.log.SnapshotFile] (kafka-scheduler-6) Deleted producer state snapshot /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000005176795.snapshot.deleted 2024-02-28 10:21:27 2024-02-28 10:21:27,743 INFO [org.apa.kaf.sto.int.log.SnapshotFile] (kafka-scheduler-6) Deleted producer state snapshot /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000006212155.snapshot.deleted 2024-02-28 10:21:27 2024-02-28 10:21:27,743 INFO [org.apa.kaf.sto.int.log.SnapshotFile] (kafka-scheduler-6) Deleted producer state snapshot /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000007247515.snapshot.deleted 2024-02-28 10:21:27 2024-02-28 10:21:27,743 INFO [org.apa.kaf.sto.int.log.SnapshotFile] (kafka-scheduler-6) Deleted producer state snapshot /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000008282875.snapshot.deleted 2024-02-28 10:21:27 2024-02-28 10:21:27,743 INFO [org.apa.kaf.sto.int.log.SnapshotFile] (kafka-scheduler-6) Deleted producer state snapshot /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete/00000000000009318235.snapshot.deleted 2024-02-28 10:21:27 2024-02-28 10:21:27,743 INFO [kaf.log.LogManager] (kafka-scheduler-6) Deleted log for partition perf-test-21697-0 in /work/./target/log-dir/perf-test-21697-0.05ac0286c3b8480788affede12348a54-delete. 2024-02-28 10:21:33 2024-02-28 10:21:33,811 INFO [org.apa.kaf.con.ReplicationControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='perf-test-27296', numPartitions=-1, replicationFactor=-1, assignments=[], configs=[]): SUCCESS 2024-02-28 10:21:33 2024-02-28 10:21:33,811 INFO [org.apa.kaf.con.ReplicationControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] Replayed TopicRecord for topic perf-test-27296 with topic ID oSzf84dhQWy-GMlVNGn-bQ. 2024-02-28 10:21:33 2024-02-28 10:21:33,811 INFO [org.apa.kaf.con.ReplicationControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] Replayed PartitionRecord for new partition perf-test-27296-0 with topic ID oSzf84dhQWy-GMlVNGn-bQ and PartitionRegistration(replicas=[1], directories=[AAAAAAAAAAAAAAAAAAAAAA], isr=[1], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). 2024-02-28 10:21:33 2024-02-28 10:21:33,837 INFO [sta.cha.logger] (kafka-1-metadata-loader-event-handler) [Broker id=1] Transitioning 1 partition(s) to local leaders. 2024-02-28 10:21:33 2024-02-28 10:21:33,837 INFO [kaf.ser.ReplicaFetcherManager] (kafka-1-metadata-loader-event-handler) [ReplicaFetcherManager on broker 1] Removed fetcher for partitions Set(perf-test-27296-0) 2024-02-28 10:21:33 2024-02-28 10:21:33,837 INFO [sta.cha.logger] (kafka-1-metadata-loader-event-handler) [Broker id=1] Creating new partition perf-test-27296-0 with topic id oSzf84dhQWy-GMlVNGn-bQ. 2024-02-28 10:21:33 2024-02-28 10:21:33,839 INFO [kaf.log.UnifiedLog$] (kafka-1-metadata-loader-event-handler) [LogLoader partition=perf-test-27296-0, dir=/work/./target/log-dir] Loading producer state till offset 0 with message format version 2 2024-02-28 10:21:33 2024-02-28 10:21:33,839 INFO [kaf.log.LogManager] (kafka-1-metadata-loader-event-handler) Created log for partition perf-test-27296-0 in /work/./target/log-dir/perf-test-27296-0 with properties {} 2024-02-28 10:21:33 2024-02-28 10:21:33,839 INFO [kaf.clu.Partition] (kafka-1-metadata-loader-event-handler) [Partition perf-test-27296-0 broker=1] No checkpointed highwatermark is found for partition perf-test-27296-0 2024-02-28 10:21:33 2024-02-28 10:21:33,839 INFO [kaf.clu.Partition] (kafka-1-metadata-loader-event-handler) [Partition perf-test-27296-0 broker=1] Log loaded for partition perf-test-27296-0 with initial high watermark 0 2024-02-28 10:21:33 2024-02-28 10:21:33,839 INFO [sta.cha.logger] (kafka-1-metadata-loader-event-handler) [Broker id=1] Leader perf-test-27296-0 with topic id Some(oSzf84dhQWy-GMlVNGn-bQ) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1. 2024-02-28 10:21:38 2024-02-28 10:21:38,062 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-4) [GroupCoordinator 1]: Dynamic member with unknown member id joins group perf-consumer-5562 in Empty state. Created a new member id perf-consumer-client-844b2450-44fb-4ffa-85b6-3189c1e9c622 and request the member to rejoin with this id. 2024-02-28 10:21:38 2024-02-28 10:21:38,077 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-1) [GroupCoordinator 1]: Preparing to rebalance group perf-consumer-5562 in state PreparingRebalance with old generation 0 (__consumer_offsets-4) (reason: Adding new member perf-consumer-client-844b2450-44fb-4ffa-85b6-3189c1e9c622 with group instance id None; client reason: rebalance failed due to MemberIdRequiredException) 2024-02-28 10:21:38 2024-02-28 10:21:38,078 INFO [kaf.coo.gro.GroupCoordinator] (executor-Rebalance) [GroupCoordinator 1]: Stabilized group perf-consumer-5562 generation 1 (__consumer_offsets-4) with 1 members 2024-02-28 10:21:38 2024-02-28 10:21:38,092 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-3) [GroupCoordinator 1]: Assignment received from leader perf-consumer-client-844b2450-44fb-4ffa-85b6-3189c1e9c622 for group perf-consumer-5562 for generation 1. The group has 1 members, 0 of which are static. 2024-02-28 10:21:38 2024-02-28 10:21:38,176 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-4) [GroupCoordinator 1]: Preparing to rebalance group perf-consumer-5562 in state PreparingRebalance with old generation 1 (__consumer_offsets-4) (reason: Removing member perf-consumer-client-844b2450-44fb-4ffa-85b6-3189c1e9c622 on LeaveGroup; client reason: the consumer is being closed) 2024-02-28 10:21:38 2024-02-28 10:21:38,176 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-4) [GroupCoordinator 1]: Group perf-consumer-5562 with generation 2 is now empty (__consumer_offsets-4) 2024-02-28 10:21:38 2024-02-28 10:21:38,176 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-4) [GroupCoordinator 1]: Member MemberMetadata(memberId=perf-consumer-client-844b2450-44fb-4ffa-85b6-3189c1e9c622, groupInstanceId=None, clientId=perf-consumer-client, clientHost=/172.20.0.3, sessionTimeoutMs=45000, rebalanceTimeoutMs=300000, supportedProtocols=List(range, cooperative-sticky)) has left group perf-consumer-5562 through explicit `LeaveGroup`; client reason: the consumer is being closed 2024-02-28 10:22:02 2024-02-28 10:22:02,584 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-0) [LocalLog partition=perf-test-27296-0, dir=/work/./target/log-dir] Rolled new log segment at offset 1035355 in 0 ms. 2024-02-28 10:22:02 2024-02-28 10:22:02,584 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-0) [ProducerStateManager partition=perf-test-27296-0] Wrote producer snapshot at offset 1035355 with 2 producer ids in 0 ms. 2024-02-28 10:22:24 2024-02-28 10:22:24,166 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-2) [LocalLog partition=perf-test-27296-0, dir=/work/./target/log-dir] Rolled new log segment at offset 2070715 in 1 ms. 2024-02-28 10:22:24 2024-02-28 10:22:24,166 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-2) [ProducerStateManager partition=perf-test-27296-0] Wrote producer snapshot at offset 2070715 with 2 producer ids in 0 ms. 2024-02-28 10:22:45 2024-02-28 10:22:45,494 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-2) [LocalLog partition=perf-test-27296-0, dir=/work/./target/log-dir] Rolled new log segment at offset 3106075 in 0 ms. 2024-02-28 10:22:45 2024-02-28 10:22:45,494 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-2) [ProducerStateManager partition=perf-test-27296-0] Wrote producer snapshot at offset 3106075 with 2 producer ids in 0 ms. 2024-02-28 10:23:07 2024-02-28 10:23:07,632 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-2) [LocalLog partition=perf-test-27296-0, dir=/work/./target/log-dir] Rolled new log segment at offset 4141435 in 1 ms. 2024-02-28 10:23:07 2024-02-28 10:23:07,632 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-2) [ProducerStateManager partition=perf-test-27296-0] Wrote producer snapshot at offset 4141435 with 2 producer ids in 0 ms. 2024-02-28 10:23:29 2024-02-28 10:23:29,104 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-6) [LocalLog partition=perf-test-27296-0, dir=/work/./target/log-dir] Rolled new log segment at offset 5176795 in 0 ms. 2024-02-28 10:23:29 2024-02-28 10:23:29,104 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-6) [ProducerStateManager partition=perf-test-27296-0] Wrote producer snapshot at offset 5176795 with 2 producer ids in 0 ms. 2024-02-28 10:23:50 2024-02-28 10:23:50,937 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-6) [LocalLog partition=perf-test-27296-0, dir=/work/./target/log-dir] Rolled new log segment at offset 6212155 in 1 ms. 2024-02-28 10:23:50 2024-02-28 10:23:50,938 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-6) [ProducerStateManager partition=perf-test-27296-0] Wrote producer snapshot at offset 6212155 with 2 producer ids in 0 ms. 2024-02-28 10:24:12 2024-02-28 10:24:12,311 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-6) [LocalLog partition=perf-test-27296-0, dir=/work/./target/log-dir] Rolled new log segment at offset 7247515 in 1 ms. 2024-02-28 10:24:12 2024-02-28 10:24:12,311 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-6) [ProducerStateManager partition=perf-test-27296-0] Wrote producer snapshot at offset 7247515 with 2 producer ids in 0 ms. 2024-02-28 10:24:33 2024-02-28 10:24:33,568 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-6) [LocalLog partition=perf-test-27296-0, dir=/work/./target/log-dir] Rolled new log segment at offset 8282875 in 0 ms. 2024-02-28 10:24:33 2024-02-28 10:24:33,569 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-6) [ProducerStateManager partition=perf-test-27296-0] Wrote producer snapshot at offset 8282875 with 2 producer ids in 0 ms. 2024-02-28 10:24:55 2024-02-28 10:24:55,580 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-6) [LocalLog partition=perf-test-27296-0, dir=/work/./target/log-dir] Rolled new log segment at offset 9318235 in 0 ms. 2024-02-28 10:24:55 2024-02-28 10:24:55,580 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-6) [ProducerStateManager partition=perf-test-27296-0] Wrote producer snapshot at offset 9318235 with 2 producer ids in 0 ms. 2024-02-28 10:25:13 2024-02-28 10:25:13,625 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-0) [GroupCoordinator 1]: Dynamic member with unknown member id joins group perf-consumer-48532 in Empty state. Created a new member id perf-consumer-client-db3bb539-09f3-4412-9b12-64622dc0140c and request the member to rejoin with this id. 2024-02-28 10:25:13 2024-02-28 10:25:13,628 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-7) [GroupCoordinator 1]: Preparing to rebalance group perf-consumer-48532 in state PreparingRebalance with old generation 0 (__consumer_offsets-3) (reason: Adding new member perf-consumer-client-db3bb539-09f3-4412-9b12-64622dc0140c with group instance id None; client reason: rebalance failed due to MemberIdRequiredException) 2024-02-28 10:25:13 2024-02-28 10:25:13,628 INFO [kaf.coo.gro.GroupCoordinator] (executor-Rebalance) [GroupCoordinator 1]: Stabilized group perf-consumer-48532 generation 1 (__consumer_offsets-3) with 1 members 2024-02-28 10:25:13 2024-02-28 10:25:13,642 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-5) [GroupCoordinator 1]: Assignment received from leader perf-consumer-client-db3bb539-09f3-4412-9b12-64622dc0140c for group perf-consumer-48532 for generation 1. The group has 1 members, 0 of which are static. 2024-02-28 10:25:42 2024-02-28 10:25:42,972 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-4) [GroupCoordinator 1]: Preparing to rebalance group perf-consumer-48532 in state PreparingRebalance with old generation 1 (__consumer_offsets-3) (reason: Removing member perf-consumer-client-db3bb539-09f3-4412-9b12-64622dc0140c on LeaveGroup; client reason: the consumer is being closed) 2024-02-28 10:25:42 2024-02-28 10:25:42,972 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-4) [GroupCoordinator 1]: Group perf-consumer-48532 with generation 2 is now empty (__consumer_offsets-3) 2024-02-28 10:25:42 2024-02-28 10:25:42,972 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-4) [GroupCoordinator 1]: Member MemberMetadata(memberId=perf-consumer-client-db3bb539-09f3-4412-9b12-64622dc0140c, groupInstanceId=None, clientId=perf-consumer-client, clientHost=/172.20.0.3, sessionTimeoutMs=45000, rebalanceTimeoutMs=300000, supportedProtocols=List(range, cooperative-sticky)) has left group perf-consumer-48532 through explicit `LeaveGroup`; client reason: the consumer is being closed 2024-02-28 10:25:45 2024-02-28 10:25:45,203 INFO [org.apa.kaf.con.ReplicationControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] Replayed RemoveTopicRecord for topic perf-test-27296 with ID oSzf84dhQWy-GMlVNGn-bQ. 2024-02-28 10:25:45 2024-02-28 10:25:45,229 INFO [sta.cha.logger] (kafka-1-metadata-loader-event-handler) [Broker id=1] Deleting 1 partition(s). 2024-02-28 10:25:45 2024-02-28 10:25:45,229 INFO [kaf.ser.ReplicaFetcherManager] (kafka-1-metadata-loader-event-handler) [ReplicaFetcherManager on broker 1] Removed fetcher for partitions Set(perf-test-27296-0) 2024-02-28 10:25:45 2024-02-28 10:25:45,229 INFO [kaf.ser.ReplicaAlterLogDirsManager] (kafka-1-metadata-loader-event-handler) [ReplicaAlterLogDirsManager on broker 1] Removed fetcher for partitions Set(perf-test-27296-0) 2024-02-28 10:25:45 2024-02-28 10:25:45,233 INFO [kaf.log.LogManager] (kafka-1-metadata-loader-event-handler) Log for partition perf-test-27296-0 is renamed to /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete and is scheduled for deletion 2024-02-28 10:25:45 2024-02-28 10:25:45,243 INFO [kaf.coo.gro.GroupMetadataManager] (kafka-1-metadata-loader-event-handler) [GroupMetadataManager brokerId=1] Group perf-consumer-48532 transitioned to Dead in generation 2 2024-02-28 10:25:45 2024-02-28 10:25:45,243 INFO [kaf.coo.gro.GroupMetadataManager] (kafka-1-metadata-loader-event-handler) [GroupMetadataManager brokerId=1] Group perf-consumer-5562 transitioned to Dead in generation 2 2024-02-28 10:25:45 2024-02-28 10:25:45,244 INFO [kaf.coo.gro.GroupCoordinator] (kafka-1-metadata-loader-event-handler) [GroupCoordinator 1]: Removed 2 offsets associated with deleted partitions: perf-test-27296-0. 2024-02-28 10:25:45 2024-02-28 10:25:45,244 INFO [kaf.ser.met.DynamicConfigPublisher] (kafka-1-metadata-loader-event-handler) [DynamicConfigPublisher broker id=1] Updating topic perf-test-27296 with new configuration : 2024-02-28 10:25:46 2024-02-28 10:25:46,233 INFO [kaf.log.LocalLog] (kafka-scheduler-8) [LocalLog partition=perf-test-27296-0, dir=/work/./target/log-dir] Deleting segments as the log has been deleted: LogSegment(baseOffset=0, size=1073732179, lastModifiedTime=1709115722583, largestRecordTimestamp=1709115721930),LogSegment(baseOffset=1035355, size=1073737344, lastModifiedTime=1709115744164, largestRecordTimestamp=1709115743493),LogSegment(baseOffset=2070715, size=1073737344, lastModifiedTime=1709115765493, largestRecordTimestamp=1709115764853),LogSegment(baseOffset=3106075, size=1073737344, lastModifiedTime=1709115787629, largestRecordTimestamp=1709115786988),LogSegment(baseOffset=4141435, size=1073737344, lastModifiedTime=1709115809102, largestRecordTimestamp=1709115808452),LogSegment(baseOffset=5176795, size=1073737344, lastModifiedTime=1709115830936, largestRecordTimestamp=1709115830307),LogSegment(baseOffset=6212155, size=1073737344, lastModifiedTime=1709115852310, largestRecordTimestamp=1709115851650),LogSegment(baseOffset=7247515, size=1073737344, lastModifiedTime=1709115873567, largestRecordTimestamp=1709115872947),LogSegment(baseOffset=8282875, size=1073737344, lastModifiedTime=1709115895578, largestRecordTimestamp=1709115894796),LogSegment(baseOffset=9318235, size=708072843, lastModifiedTime=1709115910762, largestRecordTimestamp=1709115910032) 2024-02-28 10:25:46 2024-02-28 10:25:46,234 INFO [kaf.log.LocalLog$] (kafka-scheduler-8) [LocalLog partition=perf-test-27296-0, dir=/work/./target/log-dir] Deleting segment files LogSegment(baseOffset=0, size=1073732179, lastModifiedTime=1709115722583, largestRecordTimestamp=1709115721930),LogSegment(baseOffset=1035355, size=1073737344, lastModifiedTime=1709115744164, largestRecordTimestamp=1709115743493),LogSegment(baseOffset=2070715, size=1073737344, lastModifiedTime=1709115765493, largestRecordTimestamp=1709115764853),LogSegment(baseOffset=3106075, size=1073737344, lastModifiedTime=1709115787629, largestRecordTimestamp=1709115786988),LogSegment(baseOffset=4141435, size=1073737344, lastModifiedTime=1709115809102, largestRecordTimestamp=1709115808452),LogSegment(baseOffset=5176795, size=1073737344, lastModifiedTime=1709115830936, largestRecordTimestamp=1709115830307),LogSegment(baseOffset=6212155, size=1073737344, lastModifiedTime=1709115852310, largestRecordTimestamp=1709115851650),LogSegment(baseOffset=7247515, size=1073737344, lastModifiedTime=1709115873567, largestRecordTimestamp=1709115872947),LogSegment(baseOffset=8282875, size=1073737344, lastModifiedTime=1709115895578, largestRecordTimestamp=1709115894796),LogSegment(baseOffset=9318235, size=708072843, lastModifiedTime=1709115910762, largestRecordTimestamp=1709115910032) 2024-02-28 10:25:46 2024-02-28 10:25:46,380 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-8) Deleted log /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000000000000.log.deleted. 2024-02-28 10:25:46 2024-02-28 10:25:46,380 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-8) Deleted offset index /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000000000000.index.deleted. 2024-02-28 10:25:46 2024-02-28 10:25:46,380 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-8) Deleted time index /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000000000000.timeindex.deleted. 2024-02-28 10:25:46 2024-02-28 10:25:46,522 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-8) Deleted log /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000001035355.log.deleted. 2024-02-28 10:25:46 2024-02-28 10:25:46,523 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-8) Deleted offset index /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000001035355.index.deleted. 2024-02-28 10:25:46 2024-02-28 10:25:46,523 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-8) Deleted time index /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000001035355.timeindex.deleted. 2024-02-28 10:25:46 2024-02-28 10:25:46,682 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-8) Deleted log /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000002070715.log.deleted. 2024-02-28 10:25:46 2024-02-28 10:25:46,682 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-8) Deleted offset index /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000002070715.index.deleted. 2024-02-28 10:25:46 2024-02-28 10:25:46,682 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-8) Deleted time index /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000002070715.timeindex.deleted. 2024-02-28 10:25:46 2024-02-28 10:25:46,815 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-8) Deleted log /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000003106075.log.deleted. 2024-02-28 10:25:46 2024-02-28 10:25:46,815 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-8) Deleted offset index /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000003106075.index.deleted. 2024-02-28 10:25:46 2024-02-28 10:25:46,815 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-8) Deleted time index /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000003106075.timeindex.deleted. 2024-02-28 10:25:46 2024-02-28 10:25:46,944 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-8) Deleted log /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000004141435.log.deleted. 2024-02-28 10:25:46 2024-02-28 10:25:46,945 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-8) Deleted offset index /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000004141435.index.deleted. 2024-02-28 10:25:46 2024-02-28 10:25:46,945 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-8) Deleted time index /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000004141435.timeindex.deleted. 2024-02-28 10:25:47 2024-02-28 10:25:47,084 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-8) Deleted log /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000005176795.log.deleted. 2024-02-28 10:25:47 2024-02-28 10:25:47,084 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-8) Deleted offset index /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000005176795.index.deleted. 2024-02-28 10:25:47 2024-02-28 10:25:47,085 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-8) Deleted time index /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000005176795.timeindex.deleted. 2024-02-28 10:25:47 2024-02-28 10:25:47,221 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-8) Deleted log /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000006212155.log.deleted. 2024-02-28 10:25:47 2024-02-28 10:25:47,221 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-8) Deleted offset index /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000006212155.index.deleted. 2024-02-28 10:25:47 2024-02-28 10:25:47,222 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-8) Deleted time index /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000006212155.timeindex.deleted. 2024-02-28 10:25:47 2024-02-28 10:25:47,355 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-8) Deleted log /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000007247515.log.deleted. 2024-02-28 10:25:47 2024-02-28 10:25:47,356 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-8) Deleted offset index /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000007247515.index.deleted. 2024-02-28 10:25:47 2024-02-28 10:25:47,356 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-8) Deleted time index /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000007247515.timeindex.deleted. 2024-02-28 10:25:47 2024-02-28 10:25:47,511 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-8) Deleted log /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000008282875.log.deleted. 2024-02-28 10:25:47 2024-02-28 10:25:47,511 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-8) Deleted offset index /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000008282875.index.deleted. 2024-02-28 10:25:47 2024-02-28 10:25:47,511 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-8) Deleted time index /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000008282875.timeindex.deleted. 2024-02-28 10:25:47 2024-02-28 10:25:47,630 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-8) Deleted log /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000009318235.log.deleted. 2024-02-28 10:25:47 2024-02-28 10:25:47,631 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-8) Deleted offset index /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000009318235.index.deleted. 2024-02-28 10:25:47 2024-02-28 10:25:47,631 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-8) Deleted time index /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000009318235.timeindex.deleted. 2024-02-28 10:25:47 2024-02-28 10:25:47,631 INFO [org.apa.kaf.sto.int.log.SnapshotFile] (kafka-scheduler-8) Deleted producer state snapshot /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000001035355.snapshot.deleted 2024-02-28 10:25:47 2024-02-28 10:25:47,631 INFO [org.apa.kaf.sto.int.log.SnapshotFile] (kafka-scheduler-8) Deleted producer state snapshot /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000002070715.snapshot.deleted 2024-02-28 10:25:47 2024-02-28 10:25:47,631 INFO [org.apa.kaf.sto.int.log.SnapshotFile] (kafka-scheduler-8) Deleted producer state snapshot /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000003106075.snapshot.deleted 2024-02-28 10:25:47 2024-02-28 10:25:47,631 INFO [org.apa.kaf.sto.int.log.SnapshotFile] (kafka-scheduler-8) Deleted producer state snapshot /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000004141435.snapshot.deleted 2024-02-28 10:25:47 2024-02-28 10:25:47,631 INFO [org.apa.kaf.sto.int.log.SnapshotFile] (kafka-scheduler-8) Deleted producer state snapshot /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000005176795.snapshot.deleted 2024-02-28 10:25:47 2024-02-28 10:25:47,632 INFO [org.apa.kaf.sto.int.log.SnapshotFile] (kafka-scheduler-8) Deleted producer state snapshot /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000006212155.snapshot.deleted 2024-02-28 10:25:47 2024-02-28 10:25:47,632 INFO [org.apa.kaf.sto.int.log.SnapshotFile] (kafka-scheduler-8) Deleted producer state snapshot /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000007247515.snapshot.deleted 2024-02-28 10:25:47 2024-02-28 10:25:47,632 INFO [org.apa.kaf.sto.int.log.SnapshotFile] (kafka-scheduler-8) Deleted producer state snapshot /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000008282875.snapshot.deleted 2024-02-28 10:25:47 2024-02-28 10:25:47,632 INFO [org.apa.kaf.sto.int.log.SnapshotFile] (kafka-scheduler-8) Deleted producer state snapshot /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete/00000000000009318235.snapshot.deleted 2024-02-28 10:25:47 2024-02-28 10:25:47,632 INFO [kaf.log.LogManager] (kafka-scheduler-8) Deleted log for partition perf-test-27296-0 in /work/./target/log-dir/perf-test-27296-0.21d0a0c641ef42768695b8b9dc139995-delete. 2024-02-28 10:25:54 2024-02-28 10:25:54,880 INFO [org.apa.kaf.con.ReplicationControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='perf-test-3557', numPartitions=-1, replicationFactor=-1, assignments=[], configs=[]): SUCCESS 2024-02-28 10:25:54 2024-02-28 10:25:54,880 INFO [org.apa.kaf.con.ReplicationControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] Replayed TopicRecord for topic perf-test-3557 with topic ID 1eWh47gETPOahNDzcZTtjg. 2024-02-28 10:25:54 2024-02-28 10:25:54,880 INFO [org.apa.kaf.con.ReplicationControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] Replayed PartitionRecord for new partition perf-test-3557-0 with topic ID 1eWh47gETPOahNDzcZTtjg and PartitionRegistration(replicas=[1], directories=[AAAAAAAAAAAAAAAAAAAAAA], isr=[1], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). 2024-02-28 10:25:54 2024-02-28 10:25:54,906 INFO [sta.cha.logger] (kafka-1-metadata-loader-event-handler) [Broker id=1] Transitioning 1 partition(s) to local leaders. 2024-02-28 10:25:54 2024-02-28 10:25:54,906 INFO [kaf.ser.ReplicaFetcherManager] (kafka-1-metadata-loader-event-handler) [ReplicaFetcherManager on broker 1] Removed fetcher for partitions Set(perf-test-3557-0) 2024-02-28 10:25:54 2024-02-28 10:25:54,906 INFO [sta.cha.logger] (kafka-1-metadata-loader-event-handler) [Broker id=1] Creating new partition perf-test-3557-0 with topic id 1eWh47gETPOahNDzcZTtjg. 2024-02-28 10:25:54 2024-02-28 10:25:54,908 INFO [kaf.log.UnifiedLog$] (kafka-1-metadata-loader-event-handler) [LogLoader partition=perf-test-3557-0, dir=/work/./target/log-dir] Loading producer state till offset 0 with message format version 2 2024-02-28 10:25:54 2024-02-28 10:25:54,908 INFO [kaf.log.LogManager] (kafka-1-metadata-loader-event-handler) Created log for partition perf-test-3557-0 in /work/./target/log-dir/perf-test-3557-0 with properties {} 2024-02-28 10:25:54 2024-02-28 10:25:54,908 INFO [kaf.clu.Partition] (kafka-1-metadata-loader-event-handler) [Partition perf-test-3557-0 broker=1] No checkpointed highwatermark is found for partition perf-test-3557-0 2024-02-28 10:25:54 2024-02-28 10:25:54,908 INFO [kaf.clu.Partition] (kafka-1-metadata-loader-event-handler) [Partition perf-test-3557-0 broker=1] Log loaded for partition perf-test-3557-0 with initial high watermark 0 2024-02-28 10:25:54 2024-02-28 10:25:54,908 INFO [sta.cha.logger] (kafka-1-metadata-loader-event-handler) [Broker id=1] Leader perf-test-3557-0 with topic id Some(1eWh47gETPOahNDzcZTtjg) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1. 2024-02-28 10:25:59 2024-02-28 10:25:59,143 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-4) [GroupCoordinator 1]: Dynamic member with unknown member id joins group perf-consumer-66705 in Empty state. Created a new member id perf-consumer-client-a2dd3689-8daf-4846-a76b-5a464ce986e4 and request the member to rejoin with this id. 2024-02-28 10:25:59 2024-02-28 10:25:59,146 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-2) [GroupCoordinator 1]: Preparing to rebalance group perf-consumer-66705 in state PreparingRebalance with old generation 0 (__consumer_offsets-1) (reason: Adding new member perf-consumer-client-a2dd3689-8daf-4846-a76b-5a464ce986e4 with group instance id None; client reason: rebalance failed due to MemberIdRequiredException) 2024-02-28 10:25:59 2024-02-28 10:25:59,147 INFO [kaf.coo.gro.GroupCoordinator] (executor-Rebalance) [GroupCoordinator 1]: Stabilized group perf-consumer-66705 generation 1 (__consumer_offsets-1) with 1 members 2024-02-28 10:25:59 2024-02-28 10:25:59,160 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-6) [GroupCoordinator 1]: Assignment received from leader perf-consumer-client-a2dd3689-8daf-4846-a76b-5a464ce986e4 for group perf-consumer-66705 for generation 1. The group has 1 members, 0 of which are static. 2024-02-28 10:25:59 2024-02-28 10:25:59,249 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-2) [GroupCoordinator 1]: Preparing to rebalance group perf-consumer-66705 in state PreparingRebalance with old generation 1 (__consumer_offsets-1) (reason: Removing member perf-consumer-client-a2dd3689-8daf-4846-a76b-5a464ce986e4 on LeaveGroup; client reason: the consumer is being closed) 2024-02-28 10:25:59 2024-02-28 10:25:59,249 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-2) [GroupCoordinator 1]: Group perf-consumer-66705 with generation 2 is now empty (__consumer_offsets-1) 2024-02-28 10:25:59 2024-02-28 10:25:59,249 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-2) [GroupCoordinator 1]: Member MemberMetadata(memberId=perf-consumer-client-a2dd3689-8daf-4846-a76b-5a464ce986e4, groupInstanceId=None, clientId=perf-consumer-client, clientHost=/172.20.0.3, sessionTimeoutMs=45000, rebalanceTimeoutMs=300000, supportedProtocols=List(range, cooperative-sticky)) has left group perf-consumer-66705 through explicit `LeaveGroup`; client reason: the consumer is being closed 2024-02-28 10:26:23 2024-02-28 10:26:23,380 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-0) [LocalLog partition=perf-test-3557-0, dir=/work/./target/log-dir] Rolled new log segment at offset 1035355 in 0 ms. 2024-02-28 10:26:23 2024-02-28 10:26:23,380 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-0) [ProducerStateManager partition=perf-test-3557-0] Wrote producer snapshot at offset 1035355 with 0 producer ids in 0 ms. 2024-02-28 10:26:43 2024-02-28 10:26:43,866 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-0) [LocalLog partition=perf-test-3557-0, dir=/work/./target/log-dir] Rolled new log segment at offset 2070715 in 1 ms. 2024-02-28 10:26:43 2024-02-28 10:26:43,866 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-0) [ProducerStateManager partition=perf-test-3557-0] Wrote producer snapshot at offset 2070715 with 0 producer ids in 0 ms. 2024-02-28 10:27:04 2024-02-28 10:27:04,398 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-1) [LocalLog partition=perf-test-3557-0, dir=/work/./target/log-dir] Rolled new log segment at offset 3106075 in 0 ms. 2024-02-28 10:27:04 2024-02-28 10:27:04,398 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-1) [ProducerStateManager partition=perf-test-3557-0] Wrote producer snapshot at offset 3106075 with 0 producer ids in 0 ms. 2024-02-28 10:27:25 2024-02-28 10:27:25,161 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-1) [LocalLog partition=perf-test-3557-0, dir=/work/./target/log-dir] Rolled new log segment at offset 4141435 in 0 ms. 2024-02-28 10:27:25 2024-02-28 10:27:25,161 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-1) [ProducerStateManager partition=perf-test-3557-0] Wrote producer snapshot at offset 4141435 with 0 producer ids in 0 ms. 2024-02-28 10:27:45 2024-02-28 10:27:45,802 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-1) [LocalLog partition=perf-test-3557-0, dir=/work/./target/log-dir] Rolled new log segment at offset 5176795 in 0 ms. 2024-02-28 10:27:45 2024-02-28 10:27:45,802 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-1) [ProducerStateManager partition=perf-test-3557-0] Wrote producer snapshot at offset 5176795 with 0 producer ids in 0 ms. 2024-02-28 10:28:06 2024-02-28 10:28:06,080 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-1) [LocalLog partition=perf-test-3557-0, dir=/work/./target/log-dir] Rolled new log segment at offset 6212155 in 1 ms. 2024-02-28 10:28:06 2024-02-28 10:28:06,080 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-1) [ProducerStateManager partition=perf-test-3557-0] Wrote producer snapshot at offset 6212155 with 0 producer ids in 0 ms. 2024-02-28 10:28:26 2024-02-28 10:28:26,192 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-7) [LocalLog partition=perf-test-3557-0, dir=/work/./target/log-dir] Rolled new log segment at offset 7247515 in 0 ms. 2024-02-28 10:28:26 2024-02-28 10:28:26,192 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-7) [ProducerStateManager partition=perf-test-3557-0] Wrote producer snapshot at offset 7247515 with 0 producer ids in 0 ms. 2024-02-28 10:28:46 2024-02-28 10:28:46,269 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-1) [LocalLog partition=perf-test-3557-0, dir=/work/./target/log-dir] Rolled new log segment at offset 8282875 in 1 ms. 2024-02-28 10:28:46 2024-02-28 10:28:46,270 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-1) [ProducerStateManager partition=perf-test-3557-0] Wrote producer snapshot at offset 8282875 with 0 producer ids in 0 ms. 2024-02-28 10:29:06 2024-02-28 10:29:06,670 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-1) [LocalLog partition=perf-test-3557-0, dir=/work/./target/log-dir] Rolled new log segment at offset 9318235 in 0 ms. 2024-02-28 10:29:06 2024-02-28 10:29:06,670 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-1) [ProducerStateManager partition=perf-test-3557-0] Wrote producer snapshot at offset 9318235 with 0 producer ids in 1 ms. 2024-02-28 10:29:22 2024-02-28 10:29:22,968 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-0) [GroupCoordinator 1]: Dynamic member with unknown member id joins group perf-consumer-85560 in Empty state. Created a new member id perf-consumer-client-6b18e7e8-c4bc-46c5-8a7e-09e3aeeb9fc9 and request the member to rejoin with this id. 2024-02-28 10:29:22 2024-02-28 10:29:22,970 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-5) [GroupCoordinator 1]: Preparing to rebalance group perf-consumer-85560 in state PreparingRebalance with old generation 0 (__consumer_offsets-1) (reason: Adding new member perf-consumer-client-6b18e7e8-c4bc-46c5-8a7e-09e3aeeb9fc9 with group instance id None; client reason: rebalance failed due to MemberIdRequiredException) 2024-02-28 10:29:22 2024-02-28 10:29:22,970 INFO [kaf.coo.gro.GroupCoordinator] (executor-Rebalance) [GroupCoordinator 1]: Stabilized group perf-consumer-85560 generation 1 (__consumer_offsets-1) with 1 members 2024-02-28 10:29:22 2024-02-28 10:29:22,986 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-7) [GroupCoordinator 1]: Assignment received from leader perf-consumer-client-6b18e7e8-c4bc-46c5-8a7e-09e3aeeb9fc9 for group perf-consumer-85560 for generation 1. The group has 1 members, 0 of which are static. 2024-02-28 10:30:53 2024-02-28 10:30:53,848 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-1) [GroupCoordinator 1]: Preparing to rebalance group perf-consumer-85560 in state PreparingRebalance with old generation 1 (__consumer_offsets-1) (reason: Removing member perf-consumer-client-6b18e7e8-c4bc-46c5-8a7e-09e3aeeb9fc9 on LeaveGroup; client reason: the consumer is being closed) 2024-02-28 10:30:53 2024-02-28 10:30:53,848 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-1) [GroupCoordinator 1]: Group perf-consumer-85560 with generation 2 is now empty (__consumer_offsets-1) 2024-02-28 10:30:53 2024-02-28 10:30:53,848 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-1) [GroupCoordinator 1]: Member MemberMetadata(memberId=perf-consumer-client-6b18e7e8-c4bc-46c5-8a7e-09e3aeeb9fc9, groupInstanceId=None, clientId=perf-consumer-client, clientHost=/172.20.0.3, sessionTimeoutMs=45000, rebalanceTimeoutMs=300000, supportedProtocols=List(range, cooperative-sticky)) has left group perf-consumer-85560 through explicit `LeaveGroup`; client reason: the consumer is being closed 2024-02-28 10:30:55 2024-02-28 10:30:55,985 INFO [org.apa.kaf.con.ReplicationControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] Replayed RemoveTopicRecord for topic perf-test-3557 with ID 1eWh47gETPOahNDzcZTtjg. 2024-02-28 10:30:56 2024-02-28 10:30:56,011 INFO [sta.cha.logger] (kafka-1-metadata-loader-event-handler) [Broker id=1] Deleting 1 partition(s). 2024-02-28 10:30:56 2024-02-28 10:30:56,011 INFO [kaf.ser.ReplicaFetcherManager] (kafka-1-metadata-loader-event-handler) [ReplicaFetcherManager on broker 1] Removed fetcher for partitions Set(perf-test-3557-0) 2024-02-28 10:30:56 2024-02-28 10:30:56,011 INFO [kaf.ser.ReplicaAlterLogDirsManager] (kafka-1-metadata-loader-event-handler) [ReplicaAlterLogDirsManager on broker 1] Removed fetcher for partitions Set(perf-test-3557-0) 2024-02-28 10:30:56 2024-02-28 10:30:56,014 INFO [kaf.log.LogManager] (kafka-1-metadata-loader-event-handler) Log for partition perf-test-3557-0 is renamed to /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete and is scheduled for deletion 2024-02-28 10:30:56 2024-02-28 10:30:56,036 INFO [kaf.coo.gro.GroupMetadataManager] (kafka-1-metadata-loader-event-handler) [GroupMetadataManager brokerId=1] Group perf-consumer-85560 transitioned to Dead in generation 2 2024-02-28 10:30:56 2024-02-28 10:30:56,036 INFO [kaf.coo.gro.GroupMetadataManager] (kafka-1-metadata-loader-event-handler) [GroupMetadataManager brokerId=1] Group perf-consumer-66705 transitioned to Dead in generation 2 2024-02-28 10:30:56 2024-02-28 10:30:56,036 INFO [kaf.coo.gro.GroupCoordinator] (kafka-1-metadata-loader-event-handler) [GroupCoordinator 1]: Removed 2 offsets associated with deleted partitions: perf-test-3557-0. 2024-02-28 10:30:56 2024-02-28 10:30:56,036 INFO [kaf.ser.met.DynamicConfigPublisher] (kafka-1-metadata-loader-event-handler) [DynamicConfigPublisher broker id=1] Updating topic perf-test-3557 with new configuration : 2024-02-28 10:30:57 2024-02-28 10:30:57,015 INFO [kaf.log.LocalLog] (kafka-scheduler-2) [LocalLog partition=perf-test-3557-0, dir=/work/./target/log-dir] Deleting segments as the log has been deleted: LogSegment(baseOffset=0, size=1073732179, lastModifiedTime=1709115983379, largestRecordTimestamp=1709115982755),LogSegment(baseOffset=1035355, size=1073737344, lastModifiedTime=1709116003865, largestRecordTimestamp=1709116003262),LogSegment(baseOffset=2070715, size=1073737344, lastModifiedTime=1709116024396, largestRecordTimestamp=1709116023787),LogSegment(baseOffset=3106075, size=1073737344, lastModifiedTime=1709116045159, largestRecordTimestamp=1709116044508),LogSegment(baseOffset=4141435, size=1073737344, lastModifiedTime=1709116065800, largestRecordTimestamp=1709116065183),LogSegment(baseOffset=5176795, size=1073737344, lastModifiedTime=1709116086078, largestRecordTimestamp=1709116085472),LogSegment(baseOffset=6212155, size=1073737344, lastModifiedTime=1709116106191, largestRecordTimestamp=1709116105606),LogSegment(baseOffset=7247515, size=1073737344, lastModifiedTime=1709116126268, largestRecordTimestamp=1709116125683),LogSegment(baseOffset=8282875, size=1073737344, lastModifiedTime=1709116146669, largestRecordTimestamp=1709116146063),LogSegment(baseOffset=9318235, size=708072843, lastModifiedTime=1709116160311, largestRecordTimestamp=1709116159649) 2024-02-28 10:30:57 2024-02-28 10:30:57,015 INFO [kaf.log.LocalLog$] (kafka-scheduler-2) [LocalLog partition=perf-test-3557-0, dir=/work/./target/log-dir] Deleting segment files LogSegment(baseOffset=0, size=1073732179, lastModifiedTime=1709115983379, largestRecordTimestamp=1709115982755),LogSegment(baseOffset=1035355, size=1073737344, lastModifiedTime=1709116003865, largestRecordTimestamp=1709116003262),LogSegment(baseOffset=2070715, size=1073737344, lastModifiedTime=1709116024396, largestRecordTimestamp=1709116023787),LogSegment(baseOffset=3106075, size=1073737344, lastModifiedTime=1709116045159, largestRecordTimestamp=1709116044508),LogSegment(baseOffset=4141435, size=1073737344, lastModifiedTime=1709116065800, largestRecordTimestamp=1709116065183),LogSegment(baseOffset=5176795, size=1073737344, lastModifiedTime=1709116086078, largestRecordTimestamp=1709116085472),LogSegment(baseOffset=6212155, size=1073737344, lastModifiedTime=1709116106191, largestRecordTimestamp=1709116105606),LogSegment(baseOffset=7247515, size=1073737344, lastModifiedTime=1709116126268, largestRecordTimestamp=1709116125683),LogSegment(baseOffset=8282875, size=1073737344, lastModifiedTime=1709116146669, largestRecordTimestamp=1709116146063),LogSegment(baseOffset=9318235, size=708072843, lastModifiedTime=1709116160311, largestRecordTimestamp=1709116159649) 2024-02-28 10:30:57 2024-02-28 10:30:57,158 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-2) Deleted log /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000000000000.log.deleted. 2024-02-28 10:30:57 2024-02-28 10:30:57,158 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-2) Deleted offset index /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000000000000.index.deleted. 2024-02-28 10:30:57 2024-02-28 10:30:57,158 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-2) Deleted time index /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000000000000.timeindex.deleted. 2024-02-28 10:30:57 2024-02-28 10:30:57,290 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-2) Deleted log /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000001035355.log.deleted. 2024-02-28 10:30:57 2024-02-28 10:30:57,290 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-2) Deleted offset index /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000001035355.index.deleted. 2024-02-28 10:30:57 2024-02-28 10:30:57,290 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-2) Deleted time index /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000001035355.timeindex.deleted. 2024-02-28 10:30:57 2024-02-28 10:30:57,432 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-2) Deleted log /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000002070715.log.deleted. 2024-02-28 10:30:57 2024-02-28 10:30:57,434 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-2) Deleted offset index /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000002070715.index.deleted. 2024-02-28 10:30:57 2024-02-28 10:30:57,436 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-2) Deleted time index /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000002070715.timeindex.deleted. 2024-02-28 10:30:57 2024-02-28 10:30:57,589 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-2) Deleted log /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000003106075.log.deleted. 2024-02-28 10:30:57 2024-02-28 10:30:57,590 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-2) Deleted offset index /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000003106075.index.deleted. 2024-02-28 10:30:57 2024-02-28 10:30:57,590 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-2) Deleted time index /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000003106075.timeindex.deleted. 2024-02-28 10:30:57 2024-02-28 10:30:57,767 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-2) Deleted log /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000004141435.log.deleted. 2024-02-28 10:30:57 2024-02-28 10:30:57,768 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-2) Deleted offset index /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000004141435.index.deleted. 2024-02-28 10:30:57 2024-02-28 10:30:57,768 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-2) Deleted time index /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000004141435.timeindex.deleted. 2024-02-28 10:30:57 2024-02-28 10:30:57,923 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-2) Deleted log /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000005176795.log.deleted. 2024-02-28 10:30:57 2024-02-28 10:30:57,924 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-2) Deleted offset index /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000005176795.index.deleted. 2024-02-28 10:30:57 2024-02-28 10:30:57,924 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-2) Deleted time index /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000005176795.timeindex.deleted. 2024-02-28 10:30:58 2024-02-28 10:30:58,062 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-2) Deleted log /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000006212155.log.deleted. 2024-02-28 10:30:58 2024-02-28 10:30:58,062 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-2) Deleted offset index /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000006212155.index.deleted. 2024-02-28 10:30:58 2024-02-28 10:30:58,062 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-2) Deleted time index /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000006212155.timeindex.deleted. 2024-02-28 10:30:58 2024-02-28 10:30:58,202 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-2) Deleted log /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000007247515.log.deleted. 2024-02-28 10:30:58 2024-02-28 10:30:58,202 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-2) Deleted offset index /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000007247515.index.deleted. 2024-02-28 10:30:58 2024-02-28 10:30:58,203 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-2) Deleted time index /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000007247515.timeindex.deleted. 2024-02-28 10:30:58 2024-02-28 10:30:58,336 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-2) Deleted log /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000008282875.log.deleted. 2024-02-28 10:30:58 2024-02-28 10:30:58,337 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-2) Deleted offset index /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000008282875.index.deleted. 2024-02-28 10:30:58 2024-02-28 10:30:58,337 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-2) Deleted time index /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000008282875.timeindex.deleted. 2024-02-28 10:30:58 2024-02-28 10:30:58,437 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-2) Deleted log /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000009318235.log.deleted. 2024-02-28 10:30:58 2024-02-28 10:30:58,439 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-2) Deleted offset index /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000009318235.index.deleted. 2024-02-28 10:30:58 2024-02-28 10:30:58,439 INFO [org.apa.kaf.sto.int.log.LogSegment] (kafka-scheduler-2) Deleted time index /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000009318235.timeindex.deleted. 2024-02-28 10:30:58 2024-02-28 10:30:58,440 INFO [org.apa.kaf.sto.int.log.SnapshotFile] (kafka-scheduler-2) Deleted producer state snapshot /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000001035355.snapshot.deleted 2024-02-28 10:30:58 2024-02-28 10:30:58,440 INFO [org.apa.kaf.sto.int.log.SnapshotFile] (kafka-scheduler-2) Deleted producer state snapshot /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000002070715.snapshot.deleted 2024-02-28 10:30:58 2024-02-28 10:30:58,440 INFO [org.apa.kaf.sto.int.log.SnapshotFile] (kafka-scheduler-2) Deleted producer state snapshot /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000003106075.snapshot.deleted 2024-02-28 10:30:58 2024-02-28 10:30:58,440 INFO [org.apa.kaf.sto.int.log.SnapshotFile] (kafka-scheduler-2) Deleted producer state snapshot /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000004141435.snapshot.deleted 2024-02-28 10:30:58 2024-02-28 10:30:58,441 INFO [org.apa.kaf.sto.int.log.SnapshotFile] (kafka-scheduler-2) Deleted producer state snapshot /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000005176795.snapshot.deleted 2024-02-28 10:30:58 2024-02-28 10:30:58,441 INFO [org.apa.kaf.sto.int.log.SnapshotFile] (kafka-scheduler-2) Deleted producer state snapshot /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000006212155.snapshot.deleted 2024-02-28 10:30:58 2024-02-28 10:30:58,441 INFO [org.apa.kaf.sto.int.log.SnapshotFile] (kafka-scheduler-2) Deleted producer state snapshot /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000007247515.snapshot.deleted 2024-02-28 10:30:58 2024-02-28 10:30:58,441 INFO [org.apa.kaf.sto.int.log.SnapshotFile] (kafka-scheduler-2) Deleted producer state snapshot /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000008282875.snapshot.deleted 2024-02-28 10:30:58 2024-02-28 10:30:58,441 INFO [org.apa.kaf.sto.int.log.SnapshotFile] (kafka-scheduler-2) Deleted producer state snapshot /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete/00000000000009318235.snapshot.deleted 2024-02-28 10:30:58 2024-02-28 10:30:58,441 INFO [kaf.log.LogManager] (kafka-scheduler-2) Deleted log for partition perf-test-3557-0 in /work/./target/log-dir/perf-test-3557-0.2556f38f0bbd421ca0182f1b7b82aefe-delete. 2024-02-28 10:31:05 2024-02-28 10:31:05,974 INFO [org.apa.kaf.con.ReplicationControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] CreateTopics result(s): CreatableTopic(name='perf-test-1112', numPartitions=-1, replicationFactor=-1, assignments=[], configs=[]): SUCCESS 2024-02-28 10:31:05 2024-02-28 10:31:05,974 INFO [org.apa.kaf.con.ReplicationControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] Replayed TopicRecord for topic perf-test-1112 with topic ID qlXP9X_-SwCwajwiahpVwg. 2024-02-28 10:31:05 2024-02-28 10:31:05,974 INFO [org.apa.kaf.con.ReplicationControlManager] (quorum-controller-1-event-handler) [QuorumController id=1] Replayed PartitionRecord for new partition perf-test-1112-0 with topic ID qlXP9X_-SwCwajwiahpVwg and PartitionRegistration(replicas=[1], directories=[AAAAAAAAAAAAAAAAAAAAAA], isr=[1], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). 2024-02-28 10:31:06 2024-02-28 10:31:06,000 INFO [sta.cha.logger] (kafka-1-metadata-loader-event-handler) [Broker id=1] Transitioning 1 partition(s) to local leaders. 2024-02-28 10:31:06 2024-02-28 10:31:06,000 INFO [kaf.ser.ReplicaFetcherManager] (kafka-1-metadata-loader-event-handler) [ReplicaFetcherManager on broker 1] Removed fetcher for partitions Set(perf-test-1112-0) 2024-02-28 10:31:06 2024-02-28 10:31:06,000 INFO [sta.cha.logger] (kafka-1-metadata-loader-event-handler) [Broker id=1] Creating new partition perf-test-1112-0 with topic id qlXP9X_-SwCwajwiahpVwg. 2024-02-28 10:31:06 2024-02-28 10:31:06,001 INFO [kaf.log.UnifiedLog$] (kafka-1-metadata-loader-event-handler) [LogLoader partition=perf-test-1112-0, dir=/work/./target/log-dir] Loading producer state till offset 0 with message format version 2 2024-02-28 10:31:06 2024-02-28 10:31:06,001 INFO [kaf.log.LogManager] (kafka-1-metadata-loader-event-handler) Created log for partition perf-test-1112-0 in /work/./target/log-dir/perf-test-1112-0 with properties {} 2024-02-28 10:31:06 2024-02-28 10:31:06,001 INFO [kaf.clu.Partition] (kafka-1-metadata-loader-event-handler) [Partition perf-test-1112-0 broker=1] No checkpointed highwatermark is found for partition perf-test-1112-0 2024-02-28 10:31:06 2024-02-28 10:31:06,001 INFO [kaf.clu.Partition] (kafka-1-metadata-loader-event-handler) [Partition perf-test-1112-0 broker=1] Log loaded for partition perf-test-1112-0 with initial high watermark 0 2024-02-28 10:31:06 2024-02-28 10:31:06,001 INFO [sta.cha.logger] (kafka-1-metadata-loader-event-handler) [Broker id=1] Leader perf-test-1112-0 with topic id Some(qlXP9X_-SwCwajwiahpVwg) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [1], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1. 2024-02-28 10:31:10 2024-02-28 10:31:10,435 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-3) [GroupCoordinator 1]: Dynamic member with unknown member id joins group perf-consumer-80313 in Empty state. Created a new member id perf-consumer-client-81e282fd-4b4a-4b76-9331-7beb24a75df0 and request the member to rejoin with this id. 2024-02-28 10:31:10 2024-02-28 10:31:10,438 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-6) [GroupCoordinator 1]: Preparing to rebalance group perf-consumer-80313 in state PreparingRebalance with old generation 0 (__consumer_offsets-0) (reason: Adding new member perf-consumer-client-81e282fd-4b4a-4b76-9331-7beb24a75df0 with group instance id None; client reason: rebalance failed due to MemberIdRequiredException) 2024-02-28 10:31:10 2024-02-28 10:31:10,438 INFO [kaf.coo.gro.GroupCoordinator] (executor-Rebalance) [GroupCoordinator 1]: Stabilized group perf-consumer-80313 generation 1 (__consumer_offsets-0) with 1 members 2024-02-28 10:31:10 2024-02-28 10:31:10,451 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-7) [GroupCoordinator 1]: Assignment received from leader perf-consumer-client-81e282fd-4b4a-4b76-9331-7beb24a75df0 for group perf-consumer-80313 for generation 1. The group has 1 members, 0 of which are static. 2024-02-28 10:31:10 2024-02-28 10:31:10,610 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-7) [GroupCoordinator 1]: Preparing to rebalance group perf-consumer-80313 in state PreparingRebalance with old generation 1 (__consumer_offsets-0) (reason: Removing member perf-consumer-client-81e282fd-4b4a-4b76-9331-7beb24a75df0 on LeaveGroup; client reason: the consumer is being closed) 2024-02-28 10:31:10 2024-02-28 10:31:10,610 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-7) [GroupCoordinator 1]: Group perf-consumer-80313 with generation 2 is now empty (__consumer_offsets-0) 2024-02-28 10:31:10 2024-02-28 10:31:10,610 INFO [kaf.coo.gro.GroupCoordinator] (data-plane-kafka-request-handler-7) [GroupCoordinator 1]: Member MemberMetadata(memberId=perf-consumer-client-81e282fd-4b4a-4b76-9331-7beb24a75df0, groupInstanceId=None, clientId=perf-consumer-client, clientHost=/172.20.0.4, sessionTimeoutMs=45000, rebalanceTimeoutMs=300000, supportedProtocols=List(range, cooperative-sticky)) has left group perf-consumer-80313 through explicit `LeaveGroup`; client reason: the consumer is being closed 2024-02-28 10:31:35 2024-02-28 10:31:35,167 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-4) [LocalLog partition=perf-test-1112-0, dir=/work/./target/log-dir] Rolled new log segment at offset 888805 in 1 ms. 2024-02-28 10:31:35 2024-02-28 10:31:35,167 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-4) [ProducerStateManager partition=perf-test-1112-0] Wrote producer snapshot at offset 888805 with 2 producer ids in 0 ms. 2024-02-28 10:31:54 2024-02-28 10:31:54,501 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-1) [LocalLog partition=perf-test-1112-0, dir=/work/./target/log-dir] Rolled new log segment at offset 1777615 in 0 ms. 2024-02-28 10:31:54 2024-02-28 10:31:54,502 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-1) [ProducerStateManager partition=perf-test-1112-0] Wrote producer snapshot at offset 1777615 with 2 producer ids in 0 ms. 2024-02-28 10:32:13 2024-02-28 10:32:13,762 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-2) [LocalLog partition=perf-test-1112-0, dir=/work/./target/log-dir] Rolled new log segment at offset 2666425 in 0 ms. 2024-02-28 10:32:13 2024-02-28 10:32:13,763 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-2) [ProducerStateManager partition=perf-test-1112-0] Wrote producer snapshot at offset 2666425 with 2 producer ids in 0 ms. 2024-02-28 10:32:33 2024-02-28 10:32:33,095 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-0) [LocalLog partition=perf-test-1112-0, dir=/work/./target/log-dir] Rolled new log segment at offset 3555235 in 0 ms. 2024-02-28 10:32:33 2024-02-28 10:32:33,095 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-0) [ProducerStateManager partition=perf-test-1112-0] Wrote producer snapshot at offset 3555235 with 2 producer ids in 1 ms. 2024-02-28 10:32:52 2024-02-28 10:32:52,381 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-7) [LocalLog partition=perf-test-1112-0, dir=/work/./target/log-dir] Rolled new log segment at offset 4444045 in 0 ms. 2024-02-28 10:32:52 2024-02-28 10:32:52,381 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-7) [ProducerStateManager partition=perf-test-1112-0] Wrote producer snapshot at offset 4444045 with 2 producer ids in 0 ms. 2024-02-28 10:33:11 2024-02-28 10:33:11,786 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-1) [LocalLog partition=perf-test-1112-0, dir=/work/./target/log-dir] Rolled new log segment at offset 5332855 in 1 ms. 2024-02-28 10:33:11 2024-02-28 10:33:11,786 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-1) [ProducerStateManager partition=perf-test-1112-0] Wrote producer snapshot at offset 5332855 with 2 producer ids in 0 ms. 2024-02-28 10:33:31 2024-02-28 10:33:31,177 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-2) [LocalLog partition=perf-test-1112-0, dir=/work/./target/log-dir] Rolled new log segment at offset 6221665 in 0 ms. 2024-02-28 10:33:31 2024-02-28 10:33:31,177 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-2) [ProducerStateManager partition=perf-test-1112-0] Wrote producer snapshot at offset 6221665 with 2 producer ids in 1 ms. 2024-02-28 10:33:50 2024-02-28 10:33:50,497 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-5) [LocalLog partition=perf-test-1112-0, dir=/work/./target/log-dir] Rolled new log segment at offset 7110475 in 0 ms. 2024-02-28 10:33:50 2024-02-28 10:33:50,497 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-5) [ProducerStateManager partition=perf-test-1112-0] Wrote producer snapshot at offset 7110475 with 2 producer ids in 0 ms. 2024-02-28 10:34:10 2024-02-28 10:34:10,049 INFO [kaf.log.LocalLog] (data-plane-kafka-request-handler-6) [LocalLog partition=perf-test-1112-0, dir=/work/./target/log-dir] Rolled new log segment at offset 7999285 in 0 ms. 2024-02-28 10:34:10 2024-02-28 10:34:10,049 INFO [org.apa.kaf.sto.int.log.ProducerStateManager] (data-plane-kafka-request-handler-6) [ProducerStateManager partition=perf-test-1112-0] Wrote producer snapshot at offset 7999285 with 2 producer ids in 0 ms. 2024-02-28 10:34:18 2024-02-28 10:34:18 [ [ SubstrateSegfaultHandler caught a segfault in thread 0x00007f7f00000b80 ] ] 2024-02-28 10:34:18 siginfo: si_signo: 7, si_code: 2, si_addr: 0x00007f7edce2f000 2024-02-28 10:34:18 2024-02-28 10:34:18 Current timestamp: 1709116458631 2024-02-28 10:34:18 2024-02-28 10:34:18 General purpose register values: 2024-02-28 10:34:18 RAX 0x000000000002f000 is an unknown value 2024-02-28 10:34:18 RBX 0x00007f7fa861dc10 points into an aligned TLAB chunk of thread 0x00007f7f00000b80 2024-02-28 10:34:18 RCX 0x00007f7edce00000 is an unknown value 2024-02-28 10:34:18 RDX 0x0000000000dfe2b0 points into AOT compiled code 2024-02-28 10:34:18 RBP 0x00007f7fa861dbc8 points into an aligned TLAB chunk of thread 0x00007f7f00000b80 2024-02-28 10:34:18 is an object of type [Ljava.lang.Object; 2024-02-28 10:34:18 RSI 0x000000001d820500 is an unknown value 2024-02-28 10:34:18 RDI 0x00007f801430b728 points into the old generation 2024-02-28 10:34:18 is an object of type java.nio.DirectByteBuffer 2024-02-28 10:34:18 RSP 0x00007f7f24ff8630 points into the stack for thread 0x00007f7f00000b80 2024-02-28 10:34:18 R8 0x00007f7fa861dbf0 points into an aligned TLAB chunk of thread 0x00007f7f00000b80 2024-02-28 10:34:18 is an object of type java.util.OptionalInt 2024-02-28 10:34:18 R9 0x00007f7fa861db90 points into an aligned TLAB chunk of thread 0x00007f7f00000b80 2024-02-28 10:34:18 is an object of type java.lang.Long 2024-02-28 10:34:18 R10 0x0000000002d44020 is an unknown value 2024-02-28 10:34:18 R11 0x0000000001179eb0 points into AOT compiled code 2024-02-28 10:34:18 R12 0x000000000276ccb4 points into AOT compiled code sun.nio.ch.FileDispatcherImpl.write0(FileDispatcherImpl.java) 2024-02-28 10:34:18 R13 0x00007f7f24ff84d0 points into the stack for thread 0x00007f7f00000b80 2024-02-28 10:34:18 R14 0x00007f8018700000 is the heap base 2024-02-28 10:34:18 R15 0x00007f7f00000b80 is a thread 2024-02-28 10:34:18 EFL 0x0000000000010202 is an unknown value 2024-02-28 10:34:18 RIP 0x0000000000dfe2f1 points into AOT compiled code 2024-02-28 10:34:18 2024-02-28 10:34:18 Printing Instructions (ip=0x0000000000dfe2f1): 2024-02-28 10:34:18 0x0000000000dfe2d1: 0x97 0xff 0xff 0x90 0x48 0x8b 0x7c 0x24 0x08 0x80 0x7f 0x39 0x00 0x0f 0x84 0x23 2024-02-28 10:34:18 0x0000000000dfe2e1: 0x00 0x00 0x00 0x8b 0x74 0x24 0x14 0x0f 0xce 0x48 0x8b 0x4f 0x18 0x48 0x63 0xc0 2024-02-28 10:34:18 0x0000000000dfe2f1: 0x89 0x34 0x08 0x41 0x83 0x6f 0x10 0x01 0x0f 0x8e 0x0e 0x00 0x00 0x00 0x48 0x8b 2024-02-28 10:34:18 0x0000000000dfe301: 0xc7 0x48 0x83 0xc4 0x18 0xc3 0x8b 0x74 0x24 0x14 0xeb 0xdd 0xe8 0x0e 0xc8 0xa3 2024-02-28 10:34:18 2024-02-28 10:34:18 Top of stack (sp=0x00007f7f24ff8630): 2024-02-28 10:34:18 0x00007f7f24ff8630: 0x00007f7fd442e898 0x00007f801430b728 2024-02-28 10:34:18 0x00007f7f24ff8640: 0x0005821d052e9b08 0x00000000023fae7e 2024-02-28 10:34:18 0x00007f7f24ff8650: 0x00007f8018fc8d48 0x000000000276aa80 2024-02-28 10:34:18 0x00007f7f24ff8660: 0x000046c9a861d258 0x0000000001fba619 2024-02-28 10:34:18 0x00007f7f24ff8670: 0xfffffffffbc0b728 0x00007f801430b728 2024-02-28 10:34:18 0x00007f7f24ff8680: 0x0000000118fc8d48 0x00007f7ff080d6c0 2024-02-28 10:34:18 0x00007f7f24ff8690: 0x00007f7fd442e898 0x19fe14c9023ea114 2024-02-28 10:34:18 0x00007f7f24ff86a0: 0x00000000007f9152 0x00000000023e6597 2024-02-28 10:34:18 0x00007f7f24ff86b0: 0x00007f7fa861d348 0x00007f7fa861d458 2024-02-28 10:34:18 0x00007f7f24ff86c0: 0x00007f8019879eb0 0x0000000002d07d8f 2024-02-28 10:34:18 0x00007f7f24ff86d0: 0x00007f7fd44754f0 0x00007f80195846c8 2024-02-28 10:34:18 0x00007f7f24ff86e0: 0x0000000000ebcd78 0xffffffff8ff1da78 2024-02-28 10:34:18 0x00007f7f24ff86f0: 0x00007f7fa861da60 0x00007f801a1d6828 2024-02-28 10:34:18 0x00007f7f24ff8700: 0x00007f7ff04c0688 0x00007f7fd4405870 2024-02-28 10:34:18 0x00007f7f24ff8710: 0x00007f7fa861cf40 0x0000000019fe14c9 2024-02-28 10:34:18 0x00007f7f24ff8720: 0x00000000007f9152 0x00000000007f9152 2024-02-28 10:34:18 0x00007f7f24ff8730: 0x0000018def4783b4 0x000000000151e106 2024-02-28 10:34:18 0x00007f7f24ff8740: 0x0000018def4783b4 0x00007f7fa861cf40 2024-02-28 10:34:18 0x00007f7f24ff8750: 0x00007f7ff04c0688 0x00007f7fd44058e0 2024-02-28 10:34:18 0x00007f7f24ff8760: 0x0000018def4783b4 0x00000000007f9152 2024-02-28 10:34:18 0x00007f7f24ff8770: 0x00000000007f9152 0x0000000001595c4d 2024-02-28 10:34:18 0x00007f7f24ff8780: 0x00007f7fa8619be0 0x00007f7fa8619d70 2024-02-28 10:34:18 0x00007f7f24ff8790: 0xffffffff8ff1d258 0x00007f7ff04c0688 2024-02-28 10:34:18 0x00007f7f24ff87a0: 0x000000000195cf70 0x00007f7fd4405870 2024-02-28 10:34:18 0x00007f7f24ff87b0: 0x0000000001b169f8 0x0000000001b13de8 2024-02-28 10:34:18 0x00007f7f24ff87c0: 0x00000000017d8b70 0x00007f7fa861d258 2024-02-28 10:34:18 0x00007f7f24ff87d0: 0x00007f8019ed8b70 0x00007f801a213de8 2024-02-28 10:34:18 0x00007f7f24ff87e0: 0x00007f801a2169f8 0x0000000000000010 2024-02-28 10:34:18 0x00007f7f24ff87f0: 0xffffffffbbd05990 0x00007f7fd4405a40 2024-02-28 10:34:18 0x00007f7f24ff8800: 0x00007f7fd4405a60 0x00007f7fa8619de0 2024-02-28 10:34:18 0x00007f7f24ff8810: 0x00007f7fd4405a88 0x00007f7ff04c0688 2024-02-28 10:34:18 0x00007f7f24ff8820: 0x00007f7fa861b088 0x00007f7fa861ad80 2024-02-28 10:34:18 2024-02-28 10:34:18 Top frame info: 2024-02-28 10:34:18 TotalFrameSize in CodeInfoTable 32 2024-02-28 10:34:18 2024-02-28 10:34:18 Threads: 2024-02-28 10:34:18 0x00007f7f60001100 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "executor-Fetch" - 0x00007f7fd4401280, stack(0x00007f7ee5fee000,0x00007f7ee67ed000) 2024-02-28 10:34:18 0x00007f7f54001600 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "executor-Rebalance" - 0x00007f7fd4401530, stack(0x00007f7f70401000,0x00007f7f70c00000) 2024-02-28 10:34:18 0x00007f7f48000fc0 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "data-plane-kafka-socket-acceptor-ListenerName(PLAINTEXT)-PLAINTEXT-9092" - 0x00007f7fd4401950, stack(0x00007f7ee67ef000,0x00007f7ee6fee000) 2024-02-28 10:34:18 0x00007f7f4c000f80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "data-plane-kafka-network-thread-1-ListenerName(PLAINTEXT)-PLAINTEXT-5" - 0x00007f7fd4401c68, stack(0x00007f7ee6ff0000,0x00007f7ee77ef000) 2024-02-28 10:34:18 0x00007f7f40000fc0 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "data-plane-kafka-network-thread-1-ListenerName(PLAINTEXT)-PLAINTEXT-4" - 0x00007f7fd4401f80, stack(0x00007f7ee77f1000,0x00007f7ee7ff0000) 2024-02-28 10:34:18 0x00007f7f44000fc0 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "data-plane-kafka-network-thread-1-ListenerName(PLAINTEXT)-PLAINTEXT-3" - 0x00007f7fd4402298, stack(0x00007f7ee7ff2000,0x00007f7ee87f1000) 2024-02-28 10:34:18 0x00007f7f38000fc0 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "data-plane-kafka-socket-acceptor-ListenerName(BROKER)-PLAINTEXT-9093" - 0x00007f7fd4402500, stack(0x00007f7ee87f3000,0x00007f7ee8ff2000) 2024-02-28 10:34:18 0x00007f7f30000fc0 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "data-plane-kafka-network-thread-1-ListenerName(BROKER)-PLAINTEXT-2" - 0x00007f7fd4402818, stack(0x00007f7ee8ff4000,0x00007f7ee97f3000) 2024-02-28 10:34:18 0x00007f7f34000fc0 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "data-plane-kafka-network-thread-1-ListenerName(BROKER)-PLAINTEXT-1" - 0x00007f7fd4402b30, stack(0x00007f7ee97f5000,0x00007f7ee9ff4000) 2024-02-28 10:34:18 0x00007f7f28000fc0 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "data-plane-kafka-network-thread-1-ListenerName(BROKER)-PLAINTEXT-0" - 0x00007f7fd4402e48, stack(0x00007f7ee9ff6000,0x00007f7eea7f5000) 2024-02-28 10:34:18 0x00007f7f2c000fc0 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "kafka-scheduler-9" - 0x00007f7fd4402f40, daemon, stack(0x00007f7eea7f7000,0x00007f7eeaff6000) 2024-02-28 10:34:18 0x00007f7f20001140 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "TxnMarkerSenderThread-1" - 0x00007f7fd4403390, stack(0x00007f7eeaff8000,0x00007f7eeb7f7000) 2024-02-28 10:34:18 0x00007f7f1c000fc0 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "transaction-log-manager-0" - 0x00007f7fd4403520, daemon, stack(0x00007f7eeb7f9000,0x00007f7eebff8000) 2024-02-28 10:34:18 0x00007f7f18000fc0 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "group-metadata-manager-0" - 0x00007f7fd44037a0, daemon, stack(0x00007f7eebffa000,0x00007f7eec7f9000) 2024-02-28 10:34:18 0x00007f7f14000fc0 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "AddPartitionsToTxnSenderThread-1" - 0x00007f7fd4403bf0, stack(0x00007f7eec7fb000,0x00007f7eecffa000) 2024-02-28 10:34:18 0x00007f7f0c000fc0 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "LogDirFailureHandler" - 0x00007f7fd4403d80, stack(0x00007f7eecffc000,0x00007f7eed7fb000) 2024-02-28 10:34:18 0x00007f7f10000fc0 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "kafka-scheduler-6" - 0x00007f7fd4403f70, daemon, stack(0x00007f7eedffe000,0x00007f7eee7fd000) 2024-02-28 10:34:18 0x00007f7f04000fc0 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "kafka-scheduler-7" - 0x00007f7fd44040f8, daemon, stack(0x00007f7eee7ff000,0x00007f7eeeffe000) 2024-02-28 10:34:18 0x00007f7f00000fc0 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "kafka-scheduler-8" - 0x00007f7fd4404280, daemon, stack(0x00007f7eed7fd000,0x00007f7eedffc000) 2024-02-28 10:34:18 0x00007f7ef8000fc0 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "kafka-scheduler-5" - 0x00007f7fd4404408, daemon, stack(0x00007f7eef000000,0x00007f7eef7ff000) 2024-02-28 10:34:18 0x00007f7efc000fc0 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "kafka-log-cleaner-thread-0" - 0x00007f7fd4404590, stack(0x00007f7eef801000,0x00007f7ef0000000) 2024-02-28 10:34:18 0x00007f7ef0000fc0 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "kafka-scheduler-4" - 0x00007f7fd4404770, daemon, stack(0x00007f7f087fb000,0x00007f7f08ffa000) 2024-02-28 10:34:18 0x00007f7ef4000fc0 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "kafka-scheduler-3" - 0x00007f7fd44048f8, daemon, stack(0x00007f7f08ffc000,0x00007f7f097fb000) 2024-02-28 10:34:18 0x00000000062e6bc0 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "kafka-scheduler-2" - 0x00007f7fd4404a80, daemon, stack(0x00007f7f097fd000,0x00007f7f09ffc000) 2024-02-28 10:34:18 0x00007f7ef4000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "kafka-scheduler-1" - 0x00007f7fd4404c08, daemon, stack(0x00007f7f09ffe000,0x00007f7f0a7fd000) 2024-02-28 10:34:18 0x00007f7ef0000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "kafka-scheduler-0" - 0x00007f7fd4404d90, daemon, stack(0x00007f7f0a7ff000,0x00007f7f0affe000) 2024-02-28 10:34:18 0x00007f7efc000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "data-plane-kafka-request-handler-7" - 0x00007f7fd4404f18, daemon, stack(0x00007f7f0b000000,0x00007f7f0b7ff000) 2024-02-28 10:34:18 0x00007f7ef8000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "data-plane-kafka-request-handler-6" - 0x00007f7fd44051a8, daemon, stack(0x00007f7f0b801000,0x00007f7f0c000000) 2024-02-28 10:34:18 0x00007f7f00000b80 STATUS_IN_JAVA (PREVENT_VM_FROM_REACHING_SAFEPOINT) "data-plane-kafka-request-handler-5" - 0x00007f7fd4405340, daemon, stack(0x00007f7f247fb000,0x00007f7f24ffa000) 2024-02-28 10:34:18 0x00007f7f04000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "data-plane-kafka-request-handler-1" - 0x00007f7fd44054d8, daemon, stack(0x00007f7f267ff000,0x00007f7f26ffe000) 2024-02-28 10:34:18 0x00007f7f0c000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "data-plane-kafka-request-handler-2" - 0x00007f7fd4406130, daemon, stack(0x00007f7f25ffe000,0x00007f7f267fd000) 2024-02-28 10:34:18 0x00007f7f10000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "data-plane-kafka-request-handler-4" - 0x00007f7fd4406228, daemon, stack(0x00007f7f24ffc000,0x00007f7f257fb000) 2024-02-28 10:34:18 0x00007f7f14000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "data-plane-kafka-request-handler-0" - 0x00007f7fd44063c0, daemon, stack(0x00007f7f27000000,0x00007f7f277ff000) 2024-02-28 10:34:18 0x00007f7f18000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "data-plane-kafka-request-handler-3" - 0x00007f7fd4406558, daemon, stack(0x00007f7f257fd000,0x00007f7f25ffc000) 2024-02-28 10:34:18 0x00007f7f1c000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "ExpirationReaper-1-AlterAcls" - 0x00007f7fd44066f0, stack(0x00007f7f27801000,0x00007f7f28000000) 2024-02-28 10:34:18 0x00007f7f20000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "broker-1-to-controller-heartbeat-channel-manager" - 0x00007f7fd4406b58, stack(0x00007f7f3ca01000,0x00007f7f3d200000) 2024-02-28 10:34:18 0x00007f7f2c000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "ExpirationReaper-1-Rebalance" - 0x00007f7fd4406cd8, stack(0x00007f7f3d601000,0x00007f7f3de00000) 2024-02-28 10:34:18 0x00007f7f28000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "ExpirationReaper-1-Heartbeat" - 0x00007f7fd4406f70, stack(0x00007f7f3dffe000,0x00007f7f3e7fd000) 2024-02-28 10:34:18 0x00007f7f34000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "ExpirationReaper-1-RemoteFetch" - 0x00007f7fd4407208, stack(0x00007f7f3e7ff000,0x00007f7f3effe000) 2024-02-28 10:34:18 0x00007f7f30000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "ExpirationReaper-1-ElectLeader" - 0x00007f7fd44074a0, stack(0x00007f7f3f000000,0x00007f7f3f7ff000) 2024-02-28 10:34:18 0x00007f7f38000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "ExpirationReaper-1-DeleteRecords" - 0x00007f7fd4407738, stack(0x00007f7f3f801000,0x00007f7f40000000) 2024-02-28 10:34:18 0x00007f7f44000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "ExpirationReaper-1-Fetch" - 0x00007f7fd44079d0, stack(0x00007f7f58a01000,0x00007f7f59200000) 2024-02-28 10:34:18 0x00007f7f40000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "ExpirationReaper-1-Produce" - 0x00007f7fd4407c68, stack(0x00007f7f59401000,0x00007f7f59c00000) 2024-02-28 10:34:18 0x00007f7f4c000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "broker-1-to-controller-directory-assignments-channel-manager" - 0x00007f7fd44080d0, stack(0x00007f7f5a000000,0x00007f7f5a7ff000) 2024-02-28 10:34:18 0x00007f7f48000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "broker-1-directory-assignments-manager-event-handler" - 0x00007f7fd4408250, stack(0x00007f7f5a801000,0x00007f7f5b000000) 2024-02-28 10:34:18 0x00007f7f50000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "broker-1-to-controller-alter-partition-channel-manager" - 0x00007f7fd44085c0, stack(0x00007f7f5b201000,0x00007f7f5ba00000) 2024-02-28 10:34:18 0x00007f7f54000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "broker-1-to-controller-forwarding-channel-manager" - 0x00007f7fd4408910, stack(0x00007f7f70e01000,0x00007f7f71600000) 2024-02-28 10:34:18 0x00007f7f60000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "broker-1-lifecycle-manager-event-handler" - 0x00007f7fd4408a90, stack(0x00007f7f717fd000,0x00007f7f71ffc000) 2024-02-28 10:34:18 0x00007f7f5c000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "broker-1-ThrottledChannelReaper-ControllerMutation" - 0x00007f7fd4408c30, stack(0x00007f7f71ffe000,0x00007f7f727fd000) 2024-02-28 10:34:18 0x00007f7f68000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "broker-1-ThrottledChannelReaper-Request" - 0x00007f7fd4408e18, stack(0x00007f7f727ff000,0x00007f7f72ffe000) 2024-02-28 10:34:18 0x00007f7f64000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "broker-1-ThrottledChannelReaper-Produce" - 0x00007f7fd4409000, stack(0x00007f7f73000000,0x00007f7f737ff000) 2024-02-28 10:34:18 0x00007f7f6c000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "broker-1-ThrottledChannelReaper-Fetch" - 0x00007f7fd44091e8, stack(0x00007f7f73801000,0x00007f7f74000000) 2024-02-28 10:34:18 0x00007f7f78000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "controller-1-to-controller-registration-channel-manager" - 0x00007f7fd44095a0, stack(0x00007f7fa87fb000,0x00007f7fa8ffa000) 2024-02-28 10:34:18 0x00007f7f74000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "data-plane-kafka-socket-acceptor-ListenerName(CONTROLLER)-PLAINTEXT-9094" - 0x00007f7fd4409890, stack(0x00007f7fa8ffc000,0x00007f7fa97fb000) 2024-02-28 10:34:18 0x00007f7f80000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "data-plane-kafka-network-thread-1-ListenerName(CONTROLLER)-PLAINTEXT-2" - 0x00007f7fd4409ba8, stack(0x00007f7fa97fd000,0x00007f7fa9ffc000) 2024-02-28 10:34:18 0x00007f7f7c000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "data-plane-kafka-network-thread-1-ListenerName(CONTROLLER)-PLAINTEXT-1" - 0x00007f7fd4409ec0, stack(0x00007f7fa9ffe000,0x00007f7faa7fd000) 2024-02-28 10:34:18 0x00007f7f88000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "data-plane-kafka-network-thread-1-ListenerName(CONTROLLER)-PLAINTEXT-0" - 0x00007f7fd440a1d8, stack(0x00007f7faa7ff000,0x00007f7faaffe000) 2024-02-28 10:34:18 0x00007f7f84000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "controller-1-registration-manager-event-handler" - 0x00007f7fd440a2d0, stack(0x00007f7fab000000,0x00007f7fab7ff000) 2024-02-28 10:34:18 0x00007f7f90000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "data-plane-kafka-request-handler-7" - 0x00007f7fd440a470, daemon, stack(0x00007f7fab801000,0x00007f7fac000000) 2024-02-28 10:34:18 0x00007f7f8c000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "data-plane-kafka-request-handler-6" - 0x00007f7fd440a608, daemon, stack(0x00007f7fd47fb000,0x00007f7fd4ffa000) 2024-02-28 10:34:18 0x00007f7f98000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "data-plane-kafka-request-handler-5" - 0x00007f7fd4401188, daemon, stack(0x00007f7fd4ffc000,0x00007f7fd57fb000) 2024-02-28 10:34:18 0x00007f7f94000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "data-plane-kafka-request-handler-4" - 0x00007f7fd440a7a0, daemon, stack(0x00007f7fd57fd000,0x00007f7fd5ffc000) 2024-02-28 10:34:18 0x00007f7f9c000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "data-plane-kafka-request-handler-1" - 0x00007f7fd440a938, daemon, stack(0x00007f7fd7000000,0x00007f7fd77ff000) 2024-02-28 10:34:18 0x00007f7fa0000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "data-plane-kafka-request-handler-3" - 0x00007f7fd440aad0, daemon, stack(0x00007f7fd5ffe000,0x00007f7fd67fd000) 2024-02-28 10:34:18 0x00007f7fa4000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "data-plane-kafka-request-handler-2" - 0x00007f7fd440ac68, daemon, stack(0x00007f7fd67ff000,0x00007f7fd6ffe000) 2024-02-28 10:34:18 0x00007f7fb0000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "data-plane-kafka-request-handler-0" - 0x00007f7fd440ae00, daemon, stack(0x00007f7fdc7fb000,0x00007f7fdcffa000) 2024-02-28 10:34:18 0x00007f7fac000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "ExpirationReaper-1-AlterAcls" - 0x00007f7fd440af98, stack(0x00007f7fdcffc000,0x00007f7fdd7fb000) 2024-02-28 10:34:18 0x00007f7fb8000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "controller-1-ThrottledChannelReaper-ControllerMutation" - 0x00007f7fd440b230, stack(0x00007f7fdd7fd000,0x00007f7fddffc000) 2024-02-28 10:34:18 0x00007f7fb4000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "controller-1-ThrottledChannelReaper-Request" - 0x00007f7fd440b418, stack(0x00007f7fddffe000,0x00007f7fde7fd000) 2024-02-28 10:34:18 0x00007f7fc0000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "controller-1-ThrottledChannelReaper-Produce" - 0x00007f7fd440b600, stack(0x00007f8005ffe000,0x00007f80067fd000) 2024-02-28 10:34:18 0x00007f7fbc000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "controller-1-ThrottledChannelReaper-Fetch" - 0x00007f7fd440b7e8, stack(0x00007f80067ff000,0x00007f8006ffe000) 2024-02-28 10:34:18 0x00007f7fc8000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "quorum-controller-1-event-handler" - 0x00007f7fd440b9d0, stack(0x00007f8007000000,0x00007f80077ff000) 2024-02-28 10:34:18 0x00007f7fc4000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "kafka-1-snapshot-generator-event-handler" - 0x00007f7fd440bb70, stack(0x00007f8016901000,0x00007f8017100000) 2024-02-28 10:34:18 0x00007f7fd8000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "kafka-1-raft-outbound-request-thread" - 0x00007f7fd440bee0, stack(0x00007f7fdf000000,0x00007f7fdf7ff000) 2024-02-28 10:34:18 0x00007f7fcc000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "kafka-1-metadata-loader-event-handler" - 0x00007f7fd440c018, stack(0x00007f7fd7801000,0x00007f7fd8000000) 2024-02-28 10:34:18 0x00007f7fd0000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "kafka-1-raft-io-thread" - 0x00007f7fd440c1b8, stack(0x00007f7fde7ff000,0x00007f7fdeffe000) 2024-02-28 10:34:18 0x00007f7fe4000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "raft-expiration-reaper" - 0x00007f7fd440c4b8, stack(0x00007f7ff0a01000,0x00007f7ff1200000) 2024-02-28 10:34:18 0x00007f7fe0000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "kafka-1-raft-scheduler0" - 0x00007f7fd440c6e8, daemon, stack(0x00007f7ff1401000,0x00007f7ff1c00000) 2024-02-28 10:34:18 0x00007f7fe8000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "metrics-meter-tick-thread-2" - 0x00007f7fd440c968, daemon, stack(0x00007f7ff3401000,0x00007f7ff3c00000) 2024-02-28 10:34:18 0x00007f7fec000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "metrics-meter-tick-thread-1" - 0x00007f7fd440cbe0, daemon, stack(0x00007f8004201000,0x00007f8004a00000) 2024-02-28 10:34:18 0x00007f7ff8000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "SensorExpiryThread" - 0x00007f7fd440cd60, daemon, stack(0x00007f80057fd000,0x00007f8005ffc000) 2024-02-28 10:34:18 0x00007f800c000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "executor-thread-2" - 0x00007f7fd440cfe0, daemon, stack(0x00007f8007801000,0x00007f8008000000) 2024-02-28 10:34:18 0x00007f7ff4000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "Reference Reaper #3" - 0x00007f7fd440d178, daemon, stack(0x00007f8014b01000,0x00007f8015300000) 2024-02-28 10:34:18 0x00007f8000000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "Reference Reaper #1" - 0x00007f7fd440d2d0, daemon, stack(0x00007f8015f01000,0x00007f8016700000) 2024-02-28 10:34:18 0x00007f7ffc000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "Reference Reaper #2" - 0x00007f7fd440d3f8, daemon, stack(0x00007f8015700000,0x00007f8015eff000) 2024-02-28 10:34:18 0x00007f8008000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "Signal Dispatcher" - 0x00007f7fd440d4e8, daemon, stack(0x00007f8017301000,0x00007f8017b00000) 2024-02-28 10:34:18 0x00007f8010000b80 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "Reference Handler" - 0x00007f8019b65888, daemon, stack(0x00007f8017d01000,0x00007f8018500000) 2024-02-28 10:34:18 0x00000000062a1340 STATUS_IN_NATIVE (ALLOW_SAFEPOINT) "main" - 0x00007f8019b657d0, stack(0x00007ffdec87d000,0x00007ffded07d000) 2024-02-28 10:34:18 2024-02-28 10:34:18 VM thread locals for the failing thread 0x00007f7f00000b80: 2024-02-28 10:34:18 0 (8 bytes): JNIThreadLocalEnvironment.jniFunctions = (bytes) 2024-02-28 10:34:18 0x00007f7f00000b80: 0x00007f80194a6010 2024-02-28 10:34:18 8 (8 bytes): StackOverflowCheckImpl.stackBoundaryTL = (Word) 1 (0x0000000000000001) 2024-02-28 10:34:18 16 (4 bytes): Safepoint.safepointRequested = (int) 2147394744 (0x7ffea4b8) 2024-02-28 10:34:18 20 (4 bytes): StatusSupport.statusTL = (int) 1 (0x00000001) 2024-02-28 10:34:18 24 (32 bytes): ThreadLocalAllocation.regularTLAB = (bytes) 2024-02-28 10:34:18 0x00007f7f00000b98: 0x00007f7fa8600000 0x00007f7fa8700000 2024-02-28 10:34:18 0x00007f7f00000ba8: 0x00007f7fa861dc10 0x0000000000000000 2024-02-28 10:34:18 56 (8 bytes): PlatformThreads.currentThread = (Object) org.apache.kafka.common.utils.KafkaThread (0x00007f7fd4405340) 2024-02-28 10:34:18 64 (8 bytes): JavaFrameAnchors.lastAnchor = (Word) 0 (0x0000000000000000) 2024-02-28 10:34:18 72 (8 bytes): AccessControlContextStack = (Object) java.util.ArrayDeque (0x00007f7fd440de68) 2024-02-28 10:34:18 80 (8 bytes): ExceptionUnwind.currentException = (Object) null 2024-02-28 10:34:18 88 (8 bytes): IdentityHashCodeSupport.hashCodeGeneratorTL = (Object) java.util.SplittableRandom (0x00007f7fd440de90) 2024-02-28 10:34:18 96 (8 bytes): IsolatedCompileClient.currentClient = (Object) null 2024-02-28 10:34:18 104 (8 bytes): IsolatedCompileContext.currentContext = (Object) null 2024-02-28 10:34:18 112 (8 bytes): JNIObjectHandles.handles = (Object) com.oracle.svm.core.handles.ThreadLocalHandles (0x00007f7fd440dec0) 2024-02-28 10:34:18 120 (8 bytes): JNIThreadLocalPendingException.pendingException = (Object) null 2024-02-28 10:34:18 128 (8 bytes): JNIThreadLocalPinnedObjects.pinnedObjectsListHead = (Object) null 2024-02-28 10:34:18 136 (8 bytes): JNIThreadOwnedMonitors.ownedMonitors = (Object) null 2024-02-28 10:34:18 144 (8 bytes): NoAllocationVerifier.openVerifiers = (Object) null 2024-02-28 10:34:18 152 (8 bytes): ThreadingSupportImpl.activeTimer = (Object) null 2024-02-28 10:34:18 160 (8 bytes): SubstrateDiagnostics.threadOnlyAttachedForCrashHandler = (bytes) 2024-02-28 10:34:18 0x00007f7f00000c20: 0x0000000000000000 2024-02-28 10:34:18 168 (8 bytes): ThreadLocalAllocation.allocatedBytes = (Word) 7346977440 (0x00000001b5e9faa0) 2024-02-28 10:34:18 176 (8 bytes): VMThreads.IsolateTL = (Word) 140188142534656 (0x00007f8018700000) 2024-02-28 10:34:18 184 (8 bytes): VMThreads.OSThreadHandleTL = (Word) 140184058304256 (0x00007f7f24ff9700) 2024-02-28 10:34:18 192 (8 bytes): VMThreads.OSThreadIdTL = (Word) 140184058304256 (0x00007f7f24ff9700) 2024-02-28 10:34:18 200 (8 bytes): VMThreads.StackBase = (Word) 140184058306560 (0x00007f7f24ffa000) 2024-02-28 10:34:18 208 (8 bytes): VMThreads.StackEnd = (Word) 140184049922048 (0x00007f7f247fb000) 2024-02-28 10:34:18 216 (8 bytes): VMThreads.StartedByCurrentIsolate = (bytes) 2024-02-28 10:34:18 0x00007f7f00000c58: 0x0000000000000001 2024-02-28 10:34:18 224 (8 bytes): VMThreads.nextTL = (Word) 140183504685952 (0x00007f7f04000b80) 2024-02-28 10:34:18 232 (8 bytes): VMThreads.unalignedIsolateThreadMemoryTL = (Word) 140183437577056 (0x00007f7f00000b60) 2024-02-28 10:34:18 240 (4 bytes): ActionOnExitSafepointSupport.actionTL = (int) 0 (0x00000000) 2024-02-28 10:34:18 244 (4 bytes): ActionOnTransitionToJavaSupport.actionTL = (int) 0 (0x00000000) 2024-02-28 10:34:18 248 (4 bytes): ImplicitExceptions.implicitExceptionsAreFatal = (int) 0 (0x00000000) 2024-02-28 10:34:18 252 (4 bytes): StackOverflowCheckImpl.yellowZoneStateTL = (int) 2130640638 (0x7efefefe) 2024-02-28 10:34:18 256 (4 bytes): StatusSupport.safepointBehaviorTL = (int) 1 (0x00000001) 2024-02-28 10:34:18 260 (4 bytes): ThreadingSupportImpl.currentPauseDepth = (int) 0 (0x00000000) 2024-02-28 10:34:18 2024-02-28 10:34:18 No VMOperation in progress 2024-02-28 10:34:18 2024-02-28 10:34:18 The 15 most recent VM operation status changes (oldest first): 2024-02-28 10:34:18 1709116458264 - Finished Garbage collection (safepoint: true, queueingThread: 0x00007f7fb0000b80, executingThread: 0x00007f7fb0000b80, safepointId: 22985) 2024-02-28 10:34:18 1709116458318 - Started Garbage collection (safepoint: true, queueingThread: 0x00007f7f9c000b80, executingThread: 0x00007f7f9c000b80, safepointId: 22986) 2024-02-28 10:34:18 1709116458319 - Finished Garbage collection (safepoint: true, queueingThread: 0x00007f7f9c000b80, executingThread: 0x00007f7f9c000b80, safepointId: 22986) 2024-02-28 10:34:18 1709116458402 - Started Garbage collection (safepoint: true, queueingThread: 0x00007f7f80000b80, executingThread: 0x00007f7f80000b80, safepointId: 22987) 2024-02-28 10:34:18 1709116458403 - Finished Garbage collection (safepoint: true, queueingThread: 0x00007f7f80000b80, executingThread: 0x00007f7f80000b80, safepointId: 22987) 2024-02-28 10:34:18 1709116458433 - Started Garbage collection (safepoint: true, queueingThread: 0x00007f7f8c000b80, executingThread: 0x00007f7f8c000b80, safepointId: 22988) 2024-02-28 10:34:18 1709116458433 - Finished Garbage collection (safepoint: true, queueingThread: 0x00007f7f8c000b80, executingThread: 0x00007f7f8c000b80, safepointId: 22988) 2024-02-28 10:34:18 1709116458482 - Started Garbage collection (safepoint: true, queueingThread: 0x00007f7f2c000b80, executingThread: 0x00007f7f2c000b80, safepointId: 22989) 2024-02-28 10:34:18 1709116458483 - Finished Garbage collection (safepoint: true, queueingThread: 0x00007f7f2c000b80, executingThread: 0x00007f7f2c000b80, safepointId: 22989) 2024-02-28 10:34:18 1709116458511 - Started Garbage collection (safepoint: true, queueingThread: 0x00007f7f44000fc0, executingThread: 0x00007f7f44000fc0, safepointId: 22990) 2024-02-28 10:34:18 1709116458512 - Finished Garbage collection (safepoint: true, queueingThread: 0x00007f7f44000fc0, executingThread: 0x00007f7f44000fc0, safepointId: 22990) 2024-02-28 10:34:18 1709116458556 - Started Garbage collection (safepoint: true, queueingThread: 0x00007f7f44000fc0, executingThread: 0x00007f7f44000fc0, safepointId: 22991) 2024-02-28 10:34:18 1709116458557 - Finished Garbage collection (safepoint: true, queueingThread: 0x00007f7f44000fc0, executingThread: 0x00007f7f44000fc0, safepointId: 22991) 2024-02-28 10:34:18 1709116458619 - Started Garbage collection (safepoint: true, queueingThread: 0x00007f7f9c000b80, executingThread: 0x00007f7f9c000b80, safepointId: 22992) 2024-02-28 10:34:18 1709116458620 - Finished Garbage collection (safepoint: true, queueingThread: 0x00007f7f9c000b80, executingThread: 0x00007f7f9c000b80, safepointId: 22992) 2024-02-28 10:34:18 2024-02-28 10:34:18 Counters: 2024-02-28 10:34:18 2024-02-28 10:34:18 Java frame anchors for the failing thread 0x00007f7f00000b80: 2024-02-28 10:34:18 No anchors 2024-02-28 10:34:18 2024-02-28 10:34:18 Stacktrace for the failing thread 0x00007f7f00000b80: 2024-02-28 10:34:18 SP 0x00007f7f24ff8630 IP 0x0000000000dfe2f1 com.oracle.svm.core.code.CodeInfo@0x7f8019a6c8d8 name = image code 2024-02-28 10:34:18 SP 0x00007f7f24ff8650 IP 0x00000000023fae7e [image code] org.apache.kafka.storage.internals.log.OffsetIndex.append(OffsetIndex.java:151) 2024-02-28 10:34:18 SP 0x00007f7f24ff86b0 IP 0x00000000023e6597 [image code] org.apache.kafka.storage.internals.log.LogSegment.append(LogSegment.java:267) 2024-02-28 10:34:18 SP 0x00007f7f24ff8740 IP 0x000000000151e106 [image code] kafka.log.LocalLog.append(LocalLog.scala:410) 2024-02-28 10:34:18 SP 0x00007f7f24ff8780 IP 0x0000000001595c4d [image code] kafka.log.UnifiedLog.append(UnifiedLog.scala:906) 2024-02-28 10:34:18 SP 0x00007f7f24ff8890 IP 0x00000000015990ec [image code] kafka.log.UnifiedLog.appendAsLeader(UnifiedLog.scala:722) 2024-02-28 10:34:18 SP 0x00007f7f24ff88f0 IP 0x000000000134655b [image code] kafka.cluster.Partition.$anonfun$appendRecordsToLeader$1(Partition.scala:1364) 2024-02-28 10:34:18 SP 0x00007f7f24ff8970 IP 0x000000000135a676 [image code] kafka.cluster.Partition.appendRecordsToLeader(Partition.scala:1352) 2024-02-28 10:34:18 SP 0x00007f7f24ff89d0 IP 0x0000000001838ed0 [image code] kafka.server.ReplicaManager.$anonfun$appendToLocalLog$6(ReplicaManager.scala:1529) 2024-02-28 10:34:18 SP 0x00007f7f24ff8a80 IP 0x00000000018327c9 [image code] kafka.server.ReplicaManager$$Lambda$f4a93bcaae8878dda4af003cd9ae7d643a6b6b6f.apply(Unknown Source) 2024-02-28 10:34:18 SP 0x00007f7f24ff8aa0 IP 0x0000000002d32b73 [image code] scala.collection.StrictOptimizedMapOps.map(StrictOptimizedMapOps.scala:28) 2024-02-28 10:34:18 SP 0x00007f7f24ff8b00 IP 0x00000000026b0753 [image code] scala.collection.StrictOptimizedMapOps.map$(StrictOptimizedMapOps.scala:27) 2024-02-28 10:34:18 SP 0x00007f7f24ff8b00 IP 0x00000000026b0753 [image code] scala.collection.mutable.HashMap.map(HashMap.scala:35) 2024-02-28 10:34:18 SP 0x00007f7f24ff8b10 IP 0x00000000018619f1 [image code] kafka.server.ReplicaManager.appendToLocalLog(ReplicaManager.scala:1515) 2024-02-28 10:34:18 SP 0x00007f7f24ff8b60 IP 0x0000000001860c0b [image code] kafka.server.ReplicaManager.appendRecords(ReplicaManager.scala:860) 2024-02-28 10:34:18 SP 0x00007f7f24ff8c40 IP 0x00000000017a32d3 [image code] kafka.server.KafkaApis.handleProduceRequest(KafkaApis.scala:720) 2024-02-28 10:34:18 SP 0x00007f7f24ff8d20 IP 0x0000000001784dfd [image code] kafka.server.KafkaApis.handle(KafkaApis.scala:184) 2024-02-28 10:34:18 SP 0x00007f7f24ff8d80 IP 0x00000000017dcac1 [image code] kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:160) 2024-02-28 10:34:18 SP 0x00007f7f24ff8e40 IP 0x0000000000c848b4 [image code] java.lang.Thread.run(Thread.java:833) 2024-02-28 10:34:18 SP 0x00007f7f24ff8e50 IP 0x000000000083982d [image code] com.oracle.svm.core.thread.PlatformThreads.threadStartRoutine(PlatformThreads.java:775) 2024-02-28 10:34:18 SP 0x00007f7f24ff8e80 IP 0x0000000000803827 [image code] com.oracle.svm.core.posix.thread.PosixPlatformThreads.pthreadStartRoutine(PosixPlatformThreads.java:203) 2024-02-28 10:34:18 SP 0x00007f7f24ff8ea0 IP 0x00000000007592bf [image code] com.oracle.svm.core.code.IsolateEnterStub.PosixPlatformThreads_pthreadStartRoutine_cf47bd191b082a3631657d369b9255c828b9a95c(IsolateEnterStub.java:0) 2024-02-28 10:34:18 2024-02-28 10:34:18 VM mutexes: 2024-02-28 10:34:18 mutex "thread" is unlocked. 2024-02-28 10:34:18 mutex "mainVMOperationControlWorkQueue" is unlocked. 2024-02-28 10:34:18 mutex "referencePendingList" is unlocked. 2024-02-28 10:34:18 2024-02-28 10:34:18 AOT compiled code is mapped at 0x0000000000407000 - 0x0000000002d3d12f 2024-02-28 10:34:18 2024-02-28 10:34:18 Heap settings and statistics: 2024-02-28 10:34:18 Supports isolates: true 2024-02-28 10:34:18 Heap base: 0x00007f8018700000 2024-02-28 10:34:18 Object reference size: 8 2024-02-28 10:34:18 Aligned chunk size: 1048576 2024-02-28 10:34:18 Incremental collections: 22992 2024-02-28 10:34:18 Complete collections: 854 2024-02-28 10:34:18 2024-02-28 10:34:18 Native image heap boundaries: 2024-02-28 10:34:18 ReadOnly Primitives: 0x00007f8018801028 - 0x00007f8018fc2528 2024-02-28 10:34:18 ReadOnly References: 0x00007f8018fc2528 - 0x00007f80194a5128 2024-02-28 10:34:18 ReadOnly Relocatables: 0x00007f80194a6000 - 0x00007f801997a938 2024-02-28 10:34:18 Writable Primitives: 0x00007f801997b000 - 0x00007f8019aabdc8 2024-02-28 10:34:18 Writable References: 0x00007f8019aabdc8 - 0x00007f801a23d400 2024-02-28 10:34:18 Writable Huge: 0x00007f801a300030 - 0x00007f801a42a900 2024-02-28 10:34:18 ReadOnly Huge: 0x00007f801a42b030 - 0x00007f801af5c910 2024-02-28 10:34:18 2024-02-28 10:34:18 Heap: 2024-02-28 10:34:18 Young generation: 2024-02-28 10:34:18 Eden: 2024-02-28 10:34:18 edenSpace: 2024-02-28 10:34:18 aligned: 0/0 unaligned: 0/0 2024-02-28 10:34:18 Survivors: 2024-02-28 10:34:18 Survivor-1 From: 2024-02-28 10:34:18 aligned: 0/0 unaligned: 0/0 2024-02-28 10:34:18 Survivor-1 To: 2024-02-28 10:34:18 aligned: 0/0 unaligned: 0/0 2024-02-28 10:34:18 Survivor-2 From: 2024-02-28 10:34:18 aligned: 0/0 unaligned: 0/0 2024-02-28 10:34:18 Survivor-2 To: 2024-02-28 10:34:18 aligned: 0/0 unaligned: 0/0 2024-02-28 10:34:18 Survivor-3 From: 2024-02-28 10:34:18 aligned: 0/0 unaligned: 0/0 2024-02-28 10:34:18 Survivor-3 To: 2024-02-28 10:34:18 aligned: 0/0 unaligned: 0/0 2024-02-28 10:34:18 Survivor-4 From: 2024-02-28 10:34:18 aligned: 0/0 unaligned: 0/0 2024-02-28 10:34:18 Survivor-4 To: 2024-02-28 10:34:18 aligned: 0/0 unaligned: 0/0 2024-02-28 10:34:18 Survivor-5 From: 2024-02-28 10:34:18 aligned: 0/0 unaligned: 0/0 2024-02-28 10:34:18 Survivor-5 To: 2024-02-28 10:34:18 aligned: 0/0 unaligned: 0/0 2024-02-28 10:34:18 Survivor-6 From: 2024-02-28 10:34:18 aligned: 0/0 unaligned: 0/0 2024-02-28 10:34:18 Survivor-6 To: 2024-02-28 10:34:18 aligned: 0/0 unaligned: 0/0 2024-02-28 10:34:18 Survivor-7 From: 2024-02-28 10:34:18 aligned: 0/0 unaligned: 0/0 2024-02-28 10:34:18 Survivor-7 To: 2024-02-28 10:34:18 aligned: 0/0 unaligned: 0/0 2024-02-28 10:34:18 Survivor-8 From: 2024-02-28 10:34:18 aligned: 0/0 unaligned: 0/0 2024-02-28 10:34:18 Survivor-8 To: 2024-02-28 10:34:18 aligned: 0/0 unaligned: 0/0 2024-02-28 10:34:18 Survivor-9 From: 2024-02-28 10:34:18 aligned: 0/0 unaligned: 0/0 2024-02-28 10:34:18 Survivor-9 To: 2024-02-28 10:34:18 aligned: 0/0 unaligned: 0/0 2024-02-28 10:34:18 Survivor-10 From: 2024-02-28 10:34:18 aligned: 0/0 unaligned: 0/0 2024-02-28 10:34:18 Survivor-10 To: 2024-02-28 10:34:18 aligned: 0/0 unaligned: 0/0 2024-02-28 10:34:18 Survivor-11 From: 2024-02-28 10:34:18 aligned: 0/0 unaligned: 0/0 2024-02-28 10:34:18 Survivor-11 To: 2024-02-28 10:34:18 aligned: 0/0 unaligned: 0/0 2024-02-28 10:34:18 Survivor-12 From: 2024-02-28 10:34:18 aligned: 0/0 unaligned: 0/0 2024-02-28 10:34:18 Survivor-12 To: 2024-02-28 10:34:18 aligned: 0/0 unaligned: 0/0 2024-02-28 10:34:18 Survivor-13 From: 2024-02-28 10:34:18 aligned: 0/0 unaligned: 0/0 2024-02-28 10:34:18 Survivor-13 To: 2024-02-28 10:34:18 aligned: 0/0 unaligned: 0/0 2024-02-28 10:34:18 Survivor-14 From: 2024-02-28 10:34:18 aligned: 0/0 unaligned: 0/0 2024-02-28 10:34:18 Survivor-14 To: 2024-02-28 10:34:18 aligned: 0/0 unaligned: 0/0 2024-02-28 10:34:18 Survivor-15 From: 2024-02-28 10:34:18 aligned: 0/0 unaligned: 0/0 2024-02-28 10:34:18 Survivor-15 To: 2024-02-28 10:34:18 aligned: 0/0 unaligned: 0/0 2024-02-28 10:34:18 Old generation: 2024-02-28 10:34:18 oldFromSpace: 2024-02-28 10:34:18 aligned: 14680064/14 unaligned: 11010112/4 2024-02-28 10:34:18 aligned chunks: 2024-02-28 10:34:18 0x00007f7fd4400000 (0x00007f7fd4401028-0x00007f7fd44ffc50) 2024-02-28 10:34:18 0x00007f7ff0800000 (0x00007f7ff0801028-0x00007f7ff08fffe0) 2024-02-28 10:34:18 0x00007f8014300000 (0x00007f8014301028-0x00007f80143fffc8) 2024-02-28 10:34:18 0x00007f8005200000 (0x00007f8005201028-0x00007f80052ffff8) 2024-02-28 10:34:18 0x00007f8015300000 (0x00007f8015301028-0x00007f80153fffc0) 2024-02-28 10:34:18 0x00007f7ff0600000 (0x00007f7ff0601028-0x00007f7ff06fffe8) 2024-02-28 10:34:18 0x00007f7fd4200000 (0x00007f7fd4201028-0x00007f7fd42ffff0) 2024-02-28 10:34:18 0x00007f8005000000 (0x00007f8005001028-0x00007f80050fffd0) 2024-02-28 10:34:18 0x00007f7ff3200000 (0x00007f7ff3201028-0x00007f7ff32fffd8) 2024-02-28 10:34:18 0x00007f7fa8400000 (0x00007f7fa8401028-0x00007f7fa84fffe8) 2024-02-28 10:34:18 0x00007f7f58200000 (0x00007f7f58201028-0x00007f7f582ffff8) 2024-02-28 10:34:18 0x00007f7fd4600000 (0x00007f7fd4601028-0x00007f7fd46ffff8) 2024-02-28 10:34:18 0x00007f7ff0000000 (0x00007f7ff0001028-0x00007f7ff00fd000) 2024-02-28 10:34:18 0x00007f7ff0200000 (0x00007f7ff0201028-0x00007f7ff0264b78) 2024-02-28 10:34:18 unaligned chunks: 2024-02-28 10:34:18 0x00007f801bd7a000 (0x00007f801bd7a030-0x00007f801bdba040) 2024-02-28 10:34:18 0x00007f801bd39000 (0x00007f801bd39030-0x00007f801bd79040) 2024-02-28 10:34:18 0x00007f7f245f8000 (0x00007f7f245f8030-0x00007f7f247f8040) 2024-02-28 10:34:18 0x00007f7fdf7ff000 (0x00007f7fdf7ff030-0x00007f7fdffff040) 2024-02-28 10:34:18 oldToSpace: 2024-02-28 10:34:18 aligned: 0/0 unaligned: 0/0 2024-02-28 10:34:18 2024-02-28 10:34:18 Unused: 2024-02-28 10:34:18 aligned: 10485760/10 2024-02-28 10:34:18 aligned chunks: 2024-02-28 10:34:18 0x00007f7fdc600000 (0x00007f7fdc601028-0x00007f7fdc601028) 2024-02-28 10:34:18 0x00007f7f70200000 (0x00007f7f70201028-0x00007f7f70201028) 2024-02-28 10:34:18 0x00007f7fdc000000 (0x00007f7fdc001028-0x00007f7fdc001028) 2024-02-28 10:34:18 0x00007f7fa8200000 (0x00007f7fa8201028-0x00007f7fa8201028) 2024-02-28 10:34:18 0x00007f7fd4000000 (0x00007f7fd4001028-0x00007f7fd4001028) 2024-02-28 10:34:18 0x00007f8004a00000 (0x00007f8004a01028-0x00007f8004a01028) 2024-02-28 10:34:18 0x00007f8014500000 (0x00007f8014501028-0x00007f8014501028) 2024-02-28 10:34:18 0x00007f8014100000 (0x00007f8014101028-0x00007f8014101028) 2024-02-28 10:34:18 0x00007f8015500000 (0x00007f8015501028-0x00007f8015501028) 2024-02-28 10:34:18 0x00007f7fa8000000 (0x00007f7fa8001028-0x00007f7fa8001028) 2024-02-28 10:34:18 2024-02-28 10:34:18 Segfault detected, aborting process. Use runtime option -R:-InstallSegfaultHandler if you don't want to use SubstrateSegfaultHandler. 2024-02-28 10:34:18