06:23:45.053 [Test worker] INFO org.springframework.test.context.support.AnnotationConfigContextLoaderUtils -- Could not detect default configuration classes for test class [com.maybeitssquid.kafkaguaranteeslab.LanguagePreferenceProducerTest]: LanguagePreferenceProducerTest does not declare any static, non-private, non-final, nested classes annotated with @Configuration.
06:23:45.294 [Test worker] INFO org.springframework.boot.test.context.SpringBootTestContextBootstrapper -- Found @SpringBootConfiguration com.maybeitssquid.kafkaguaranteeslab.KafkaGuaranteesLabApplication for test class com.maybeitssquid.kafkaguaranteeslab.LanguagePreferenceProducerTest
06:23:45.481 [Test worker] INFO org.springframework.test.context.support.AnnotationConfigContextLoaderUtils -- Could not detect default configuration classes for test class [com.maybeitssquid.kafkaguaranteeslab.LanguagePreferenceProducerTest]: LanguagePreferenceProducerTest does not declare any static, non-private, non-final, nested classes annotated with @Configuration.
06:23:45.484 [Test worker] INFO org.springframework.boot.test.context.SpringBootTestContextBootstrapper -- Found @SpringBootConfiguration com.maybeitssquid.kafkaguaranteeslab.KafkaGuaranteesLabApplication for test class com.maybeitssquid.kafkaguaranteeslab.LanguagePreferenceProducerTest
. ____ _ __ _ _
/\\ / ___'_ __ _ _(_)_ __ __ _ \ \ \ \
( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
\\/ ___)| |_)| | | | | || (_| | ) ) ) )
' |____| .__|_| |_|_| |_\__, | / / / /
=========|_|==============|___/=/_/_/_/
:: Spring Boot :: (v4.0.6)
2026-05-31T06:23:46.404Z INFO 2655 --- [ Test worker] o.a.k.server.logger.LoggingController : No supported logging implementation found. Logging configuration endpoint will be disabled.
2026-05-31T06:23:46.918Z INFO 2655 --- [ Test worker] k.utils.Log4jControllerRegistration$ : Registered `kafka:type=kafka.Log4jController` MBean
Formatting metadata directory /tmp/kafka-9691995952731394900/combined_0_0 with metadata.version 4.2-IV1.
2026-05-31T06:23:47.379Z INFO 2655 --- [ster-test-kit-4] kafka.server.BrokerServer : [BrokerServer id=0] Transition from SHUTDOWN to STARTING
2026-05-31T06:23:47.379Z INFO 2655 --- [ster-test-kit-3] kafka.server.ControllerServer : [ControllerServer id=0] Starting controller
2026-05-31T06:23:47.385Z INFO 2655 --- [ster-test-kit-4] kafka.server.SharedServer : [SharedServer id=0] Starting SharedServer
2026-05-31T06:23:47.499Z INFO 2655 --- [ster-test-kit-4] o.a.k.storage.internals.log.UnifiedLog : [LogLoader partition=__cluster_metadata-0, dir=/tmp/kafka-9691995952731394900/combined_0_0] Loading producer state till offset 0
2026-05-31T06:23:47.500Z INFO 2655 --- [ster-test-kit-4] o.a.k.storage.internals.log.UnifiedLog : [LogLoader partition=__cluster_metadata-0, dir=/tmp/kafka-9691995952731394900/combined_0_0] Reloading from producer snapshot and rebuilding producer state from offset 0
2026-05-31T06:23:47.501Z INFO 2655 --- [ster-test-kit-4] o.a.k.storage.internals.log.UnifiedLog : [LogLoader partition=__cluster_metadata-0, dir=/tmp/kafka-9691995952731394900/combined_0_0] Producer state recovery took 0ms for snapshot load and 0ms for segment recovery from offset 0
2026-05-31T06:23:47.544Z INFO 2655 --- [ster-test-kit-4] kafka.raft.KafkaMetadataLog$ : Initialized snapshots with IDs SortedSet() from /tmp/kafka-9691995952731394900/combined_0_0/__cluster_metadata-0
2026-05-31T06:23:47.579Z INFO 2655 --- [piration-reaper] ExpirationService$ExpiredOperationReaper : [raft-expiration-reaper]: Starting
2026-05-31T06:23:47.598Z INFO 2655 --- [ster-test-kit-4] org.apache.kafka.raft.KafkaRaftClient : [RaftManager id=0] Reading KRaft snapshot and log as part of the initialization
2026-05-31T06:23:47.601Z INFO 2655 --- [ster-test-kit-4] org.apache.kafka.raft.KafkaRaftClient : [RaftManager id=0] Starting voters are VoterSet(voters={0=VoterNode(voterKey=ReplicaKey(id=0, directoryId=<undefined>), listeners=Endpoints(endpoints={ListenerName(CONTROLLER)=localhost/127.0.0.1:41413}), supportedKRaftVersion=SupportedVersionRange[min_version:0, max_version:0])})
2026-05-31T06:23:47.604Z INFO 2655 --- [ster-test-kit-4] org.apache.kafka.raft.KafkaRaftClient : [RaftManager id=0] Starting request manager with static voters: [localhost:41413 (id: 0 rack: null isFenced: false)]
2026-05-31T06:23:47.611Z INFO 2655 --- [ster-test-kit-4] org.apache.kafka.raft.QuorumState : [RaftManager id=0] Attempting durable transition to UnattachedState(epoch=0, leaderId=OptionalInt.empty, votedKey=Optional.empty, voters=[0], electionTimeoutMs=1599, highWatermark=Optional.empty) from null
2026-05-31T06:23:47.657Z INFO 2655 --- [ster-test-kit-4] org.apache.kafka.raft.QuorumState : [RaftManager id=0] Completed transition to UnattachedState(epoch=0, leaderId=OptionalInt.empty, votedKey=Optional.empty, voters=[0], electionTimeoutMs=1599, highWatermark=Optional.empty) from null
2026-05-31T06:23:47.665Z INFO 2655 --- [ster-test-kit-4] org.apache.kafka.raft.QuorumState : [RaftManager id=0] Completed transition to ProspectiveState(epoch=0, leaderId=OptionalInt.empty, votedKey=Optional.empty, epochElection=EpochElection(voterStates={0=VoterState(replicaKey=ReplicaKey(id=0, directoryId=<undefined>), state=GRANTED)}), electionTimeoutMs=1167, highWatermark=Optional.empty) from UnattachedState(epoch=0, leaderId=OptionalInt.empty, votedKey=Optional.empty, voters=[0], electionTimeoutMs=1599, highWatermark=Optional.empty)
2026-05-31T06:23:47.668Z INFO 2655 --- [ster-test-kit-4] org.apache.kafka.raft.QuorumState : [RaftManager id=0] Attempting durable transition to CandidateState(localId=0, localDirectoryId=tUXNKYKq8RakLhHAWLLfJQ, epoch=1, epochElection=EpochElection(voterStates={0=VoterState(replicaKey=ReplicaKey(id=0, directoryId=<undefined>), state=GRANTED)}), highWatermark=Optional.empty, electionTimeoutMs=1701) from ProspectiveState(epoch=0, leaderId=OptionalInt.empty, votedKey=Optional.empty, epochElection=EpochElection(voterStates={0=VoterState(replicaKey=ReplicaKey(id=0, directoryId=<undefined>), state=GRANTED)}), electionTimeoutMs=1167, highWatermark=Optional.empty)
2026-05-31T06:23:47.672Z INFO 2655 --- [ster-test-kit-4] org.apache.kafka.raft.QuorumState : [RaftManager id=0] Completed transition to CandidateState(localId=0, localDirectoryId=tUXNKYKq8RakLhHAWLLfJQ, epoch=1, epochElection=EpochElection(voterStates={0=VoterState(replicaKey=ReplicaKey(id=0, directoryId=<undefined>), state=GRANTED)}), highWatermark=Optional.empty, electionTimeoutMs=1701) from ProspectiveState(epoch=0, leaderId=OptionalInt.empty, votedKey=Optional.empty, epochElection=EpochElection(voterStates={0=VoterState(replicaKey=ReplicaKey(id=0, directoryId=<undefined>), state=GRANTED)}), electionTimeoutMs=1167, highWatermark=Optional.empty)
2026-05-31T06:23:47.680Z INFO 2655 --- [ster-test-kit-4] org.apache.kafka.raft.QuorumState : [RaftManager id=0] Attempting durable transition to Leader(localVoterNode=VoterNode(voterKey=ReplicaKey(id=0, directoryId=tUXNKYKq8RakLhHAWLLfJQ), listeners=Endpoints(endpoints={}), supportedKRaftVersion=SupportedVersionRange[min_version:0, max_version:1]), epoch=1, epochStartOffset=0, highWatermark=Optional.empty, voterStates={0=ReplicaState(replicaKey=ReplicaKey(id=0, directoryId=<undefined>), endOffset=Optional.empty, lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=true)}) from CandidateState(localId=0, localDirectoryId=tUXNKYKq8RakLhHAWLLfJQ, epoch=1, epochElection=EpochElection(voterStates={0=VoterState(replicaKey=ReplicaKey(id=0, directoryId=<undefined>), state=GRANTED)}), highWatermark=Optional.empty, electionTimeoutMs=1701)
2026-05-31T06:23:47.682Z INFO 2655 --- [ster-test-kit-4] org.apache.kafka.raft.QuorumState : [RaftManager id=0] Completed transition to Leader(localVoterNode=VoterNode(voterKey=ReplicaKey(id=0, directoryId=tUXNKYKq8RakLhHAWLLfJQ), listeners=Endpoints(endpoints={}), supportedKRaftVersion=SupportedVersionRange[min_version:0, max_version:1]), epoch=1, epochStartOffset=0, highWatermark=Optional.empty, voterStates={0=ReplicaState(replicaKey=ReplicaKey(id=0, directoryId=<undefined>), endOffset=Optional.empty, lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=true)}) from CandidateState(localId=0, localDirectoryId=tUXNKYKq8RakLhHAWLLfJQ, epoch=1, epochElection=EpochElection(voterStates={0=VoterState(replicaKey=ReplicaKey(id=0, directoryId=<undefined>), state=GRANTED)}), highWatermark=Optional.empty, electionTimeoutMs=1701)
2026-05-31T06:23:47.693Z INFO 2655 --- [-request-thread] o.a.k.r.KafkaNetworkChannel$SendThread : [kafka-0-raft-outbound-request-thread]: Starting
2026-05-31T06:23:47.694Z INFO 2655 --- [-raft-io-thread] o.a.kafka.raft.KafkaRaftClientDriver : [kafka-0-raft-io-thread]: Starting
2026-05-31T06:23:47.714Z INFO 2655 --- [r-event-handler] o.a.kafka.image.loader.MetadataLoader : [MetadataLoader id=0] initializeNewPublishers: the loader is still catching up because we still don't know the high water mark yet.
2026-05-31T06:23:47.717Z INFO 2655 --- [ster-test-kit-4] kafka.server.BrokerServer : [BrokerServer id=0] Starting broker
2026-05-31T06:23:47.726Z INFO 2655 --- [-raft-io-thread] org.apache.kafka.raft.LeaderState : [RaftManager id=0] 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(replicaKey=ReplicaKey(id=0, directoryId=<undefined>), endOffset=Optional[LogOffsetMetadata(offset=1, metadata=Optional[(segmentBaseOffset=0,relativePositionInSegment=91)])], lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=true)]
2026-05-31T06:23:47.739Z INFO 2655 --- [-raft-io-thread] org.apache.kafka.raft.KafkaRaftClient : [RaftManager id=0] Registered the listener org.apache.kafka.image.loader.MetadataLoader@311109688
2026-05-31T06:23:47.742Z INFO 2655 --- [nelReaper-Fetch] lientQuotaManager$ThrottledChannelReaper : [broker-0-ThrottledChannelReaper-Fetch]: Starting
2026-05-31T06:23:47.742Z INFO 2655 --- [-raft-io-thread] org.apache.kafka.raft.KafkaRaftClient : [RaftManager id=0] Setting the next offset of org.apache.kafka.image.loader.MetadataLoader@311109688 to 0 since there are no snapshots
2026-05-31T06:23:47.745Z INFO 2655 --- [lReaper-Produce] lientQuotaManager$ThrottledChannelReaper : [broker-0-ThrottledChannelReaper-Produce]: Starting
2026-05-31T06:23:47.746Z INFO 2655 --- [lReaper-Request] lientQuotaManager$ThrottledChannelReaper : [broker-0-ThrottledChannelReaper-Request]: Starting
2026-05-31T06:23:47.749Z INFO 2655 --- [r-event-handler] o.a.kafka.image.loader.MetadataLoader : [MetadataLoader id=0] 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
2026-05-31T06:23:47.750Z INFO 2655 --- [trollerMutation] lientQuotaManager$ThrottledChannelReaper : [broker-0-ThrottledChannelReaper-ControllerMutation]: Starting
2026-05-31T06:23:47.815Z INFO 2655 --- [r-event-handler] o.a.kafka.image.loader.MetadataLoader : [MetadataLoader id=0] initializeNewPublishers: The loader is still catching up because we have not loaded a controller record as of offset 0 and high water mark is 1
2026-05-31T06:23:47.825Z INFO 2655 --- [ster-test-kit-4] kafka.server.BrokerServer : [BrokerServer id=0] Waiting for controller quorum voters future
2026-05-31T06:23:47.825Z INFO 2655 --- [ster-test-kit-4] kafka.server.BrokerServer : [BrokerServer id=0] Finished waiting for controller quorum voters future
2026-05-31T06:23:47.842Z INFO 2655 --- [channel-manager] k.server.NodeToControllerRequestThread : [broker-0-to-controller-forwarding-channel-manager]: Starting
2026-05-31T06:23:47.843Z INFO 2655 --- [channel-manager] k.server.NodeToControllerRequestThread : [broker-0-to-controller-forwarding-channel-manager]: Recorded new KRaft controller, from now on will use node localhost:41413 (id: 0 rack: null isFenced: false)
2026-05-31T06:23:47.867Z INFO 2655 --- [-metrics-reaper] o.a.k.s.u.t.SystemTimerReaper$Reaper : [client-metrics-reaper]: Starting
2026-05-31T06:23:47.916Z INFO 2655 --- [r-event-handler] o.a.kafka.image.loader.MetadataLoader : [MetadataLoader id=0] initializeNewPublishers: The loader is still catching up because we have not loaded a controller record as of offset 0 and high water mark is 1
2026-05-31T06:23:48.000Z INFO 2655 --- [ster-test-kit-4] kafka.network.ConnectionQuotas : Updated connection-accept-rate max connection creation rate to 2147483647
2026-05-31T06:23:48.001Z INFO 2655 --- [ster-test-kit-3] kafka.network.ConnectionQuotas : Updated connection-accept-rate max connection creation rate to 2147483647
2026-05-31T06:23:48.005Z INFO 2655 --- [ster-test-kit-4] kafka.network.DataPlaneAcceptor : Awaiting socket connections on localhost:38377.
2026-05-31T06:23:48.005Z INFO 2655 --- [ster-test-kit-3] kafka.network.DataPlaneAcceptor : Awaiting socket connections on localhost:41413.
2026-05-31T06:23:48.006Z INFO 2655 --- [ster-test-kit-4] kafka.network.DataPlaneAcceptor : Opened wildcard endpoint localhost:38377
2026-05-31T06:23:48.006Z INFO 2655 --- [ster-test-kit-3] kafka.network.DataPlaneAcceptor : Opened wildcard endpoint localhost:41413
2026-05-31T06:23:48.016Z INFO 2655 --- [r-event-handler] o.a.kafka.image.loader.MetadataLoader : [MetadataLoader id=0] initializeNewPublishers: The loader is still catching up because we have not loaded a controller record as of offset 0 and high water mark is 1
2026-05-31T06:23:48.031Z INFO 2655 --- [ster-test-kit-3] kafka.network.SocketServer : [SocketServer listenerType=CONTROLLER, nodeId=0] Created data-plane acceptor and processors for endpoint : ListenerName(CONTROLLER)
2026-05-31T06:23:48.031Z INFO 2655 --- [ster-test-kit-4] kafka.network.SocketServer : [SocketServer listenerType=BROKER, nodeId=0] Created data-plane acceptor and processors for endpoint : ListenerName(EXTERNAL)
2026-05-31T06:23:48.036Z INFO 2655 --- [ster-test-kit-3] org.apache.kafka.metadata.ListenerInfo : CONTROLLER: resolved ephemeral port to 41413
2026-05-31T06:23:48.036Z INFO 2655 --- [ster-test-kit-4] org.apache.kafka.metadata.ListenerInfo : EXTERNAL: resolved ephemeral port to 38377
2026-05-31T06:23:48.045Z INFO 2655 --- [channel-manager] k.server.NodeToControllerRequestThread : [broker-0-to-controller-alter-partition-channel-manager]: Starting
2026-05-31T06:23:48.045Z INFO 2655 --- [channel-manager] k.server.NodeToControllerRequestThread : [broker-0-to-controller-alter-partition-channel-manager]: Recorded new KRaft controller, from now on will use node localhost:41413 (id: 0 rack: null isFenced: false)
2026-05-31T06:23:48.047Z INFO 2655 --- [ster-test-kit-3] o.a.k.s.network.EndpointReadyFutures : authorizerStart completed for endpoint CONTROLLER. Endpoint is now READY.
2026-05-31T06:23:48.049Z INFO 2655 --- [ster-test-kit-3] kafka.server.ControllerServer : [ControllerServer id=0] Waiting for controller quorum voters future
2026-05-31T06:23:48.049Z INFO 2655 --- [ster-test-kit-3] kafka.server.ControllerServer : [ControllerServer id=0] Finished waiting for controller quorum voters future
2026-05-31T06:23:48.051Z INFO 2655 --- [channel-manager] k.server.NodeToControllerRequestThread : [broker-0-to-controller-directory-assignments-channel-manager]: Starting
2026-05-31T06:23:48.053Z INFO 2655 --- [channel-manager] k.server.NodeToControllerRequestThread : [broker-0-to-controller-directory-assignments-channel-manager]: Recorded new KRaft controller, from now on will use node localhost:41413 (id: 0 rack: null isFenced: false)
2026-05-31T06:23:48.101Z INFO 2655 --- [eaper-0-Produce] perationPurgatory$ExpiredOperationReaper : [ExpirationReaper-0-Produce]: Starting
2026-05-31T06:23:48.102Z INFO 2655 --- [nReaper-0-Fetch] perationPurgatory$ExpiredOperationReaper : [ExpirationReaper-0-Fetch]: Starting
2026-05-31T06:23:48.104Z INFO 2655 --- [0-DeleteRecords] perationPurgatory$ExpiredOperationReaper : [ExpirationReaper-0-DeleteRecords]: Starting
2026-05-31T06:23:48.106Z INFO 2655 --- [r-0-RemoteFetch] perationPurgatory$ExpiredOperationReaper : [ExpirationReaper-0-RemoteFetch]: Starting
2026-05-31T06:23:48.108Z INFO 2655 --- [er-0-ShareFetch] perationPurgatory$ExpiredOperationReaper : [ExpirationReaper-0-ShareFetch]: Starting
2026-05-31T06:23:48.107Z INFO 2655 --- [moteListOffsets] perationPurgatory$ExpiredOperationReaper : [ExpirationReaper-0-RemoteListOffsets]: Starting
2026-05-31T06:23:48.117Z INFO 2655 --- [r-event-handler] o.a.kafka.image.loader.MetadataLoader : [MetadataLoader id=0] initializeNewPublishers: The loader is still catching up because we have not loaded a controller record as of offset 0 and high water mark is 1
2026-05-31T06:23:48.119Z INFO 2655 --- [ster-test-kit-3] o.a.k.c.PeriodicTaskControlManager : [QuorumController id=0] Registering periodic task writeNoOpRecord to run every 500 ms
2026-05-31T06:23:48.120Z INFO 2655 --- [ster-test-kit-3] o.a.k.c.PeriodicTaskControlManager : [QuorumController id=0] Registering periodic task maybeFenceStaleBroker to run every 1125 ms
2026-05-31T06:23:48.120Z INFO 2655 --- [ster-test-kit-3] o.a.k.c.PeriodicTaskControlManager : [QuorumController id=0] Registering periodic task electPreferred to run every 300000 ms
2026-05-31T06:23:48.121Z INFO 2655 --- [ster-test-kit-3] o.a.k.c.PeriodicTaskControlManager : [QuorumController id=0] Registering periodic task electUnclean to run every 300000 ms
2026-05-31T06:23:48.121Z INFO 2655 --- [ster-test-kit-3] o.a.k.c.PeriodicTaskControlManager : [QuorumController id=0] Registering periodic task expireDelegationTokens to run every 3600000 ms
2026-05-31T06:23:48.121Z INFO 2655 --- [ster-test-kit-3] o.a.k.c.PeriodicTaskControlManager : [QuorumController id=0] Registering periodic task generatePeriodicPerformanceMessage to run every 60000 ms
2026-05-31T06:23:48.123Z INFO 2655 --- [ster-test-kit-3] o.a.kafka.controller.QuorumController : [QuorumController id=0] Creating new QuorumController with clusterId zhF9nUh7RXCEHoJbFueUig
2026-05-31T06:23:48.124Z INFO 2655 --- [-raft-io-thread] org.apache.kafka.raft.KafkaRaftClient : [RaftManager id=0] Registered the listener org.apache.kafka.controller.QuorumController$QuorumMetaLogListener@1375733095
2026-05-31T06:23:48.125Z INFO 2655 --- [-raft-io-thread] org.apache.kafka.raft.KafkaRaftClient : [RaftManager id=0] Setting the next offset of org.apache.kafka.controller.QuorumController$QuorumMetaLogListener@1375733095 to 0 since there are no snapshots
2026-05-31T06:23:48.127Z INFO 2655 --- [nelReaper-Fetch] lientQuotaManager$ThrottledChannelReaper : [controller-0-ThrottledChannelReaper-Fetch]: Starting
2026-05-31T06:23:48.129Z INFO 2655 --- [0-event-handler] o.a.kafka.controller.QuorumController : [QuorumController id=0] Becoming the active controller at epoch 1, next write offset 1.
2026-05-31T06:23:48.130Z INFO 2655 --- [lReaper-Produce] lientQuotaManager$ThrottledChannelReaper : [controller-0-ThrottledChannelReaper-Produce]: Starting
2026-05-31T06:23:48.131Z INFO 2655 --- [lReaper-Request] lientQuotaManager$ThrottledChannelReaper : [controller-0-ThrottledChannelReaper-Request]: Starting
2026-05-31T06:23:48.132Z INFO 2655 --- [trollerMutation] lientQuotaManager$ThrottledChannelReaper : [controller-0-ThrottledChannelReaper-ControllerMutation]: Starting
2026-05-31T06:23:48.152Z WARN 2655 --- [0-event-handler] o.a.kafka.controller.QuorumController : [QuorumController id=0] Performing controller activation. The metadata log appears to be empty. Appending 6 bootstrap record(s) in metadata transaction at metadata.version 4.2-IV1 from bootstrap source 'testkit'.
2026-05-31T06:23:48.158Z INFO 2655 --- [rdinator-reaper] o.a.k.s.u.t.SystemTimerReaper$Reaper : [share-coordinator-reaper]: Starting
2026-05-31T06:23:48.160Z INFO 2655 --- [0-event-handler] o.a.k.controller.OffsetControlManager : [QuorumController id=0] Replayed BeginTransactionRecord(name='Bootstrap records') at offset 1.
2026-05-31T06:23:48.165Z INFO 2655 --- [0-event-handler] o.a.k.controller.FeatureControlManager : [QuorumController id=0] Replayed a FeatureLevelRecord setting metadata.version to 4.2-IV1
2026-05-31T06:23:48.166Z INFO 2655 --- [0-event-handler] o.a.k.controller.FeatureControlManager : [QuorumController id=0] Replayed a FeatureLevelRecord setting feature eligible.leader.replicas.version to 1
2026-05-31T06:23:48.167Z INFO 2655 --- [0-event-handler] o.a.k.controller.FeatureControlManager : [QuorumController id=0] Replayed a FeatureLevelRecord setting feature group.version to 1
2026-05-31T06:23:48.167Z INFO 2655 --- [0-event-handler] o.a.k.controller.FeatureControlManager : [QuorumController id=0] Replayed a FeatureLevelRecord setting feature share.version to 1
2026-05-31T06:23:48.167Z INFO 2655 --- [0-event-handler] o.a.k.controller.FeatureControlManager : [QuorumController id=0] Replayed a FeatureLevelRecord setting feature streams.version to 1
2026-05-31T06:23:48.167Z INFO 2655 --- [0-event-handler] o.a.k.controller.FeatureControlManager : [QuorumController id=0] Replayed a FeatureLevelRecord setting feature transaction.version to 2
2026-05-31T06:23:48.168Z INFO 2655 --- [0-event-handler] o.a.k.c.ConfigurationControlManager : [QuorumController id=0] Replayed ConfigRecord for ConfigResource(type=BROKER, name='') which set configuration min.insync.replicas to 1
2026-05-31T06:23:48.168Z INFO 2655 --- [0-event-handler] o.a.k.controller.OffsetControlManager : [QuorumController id=0] Replayed EndTransactionRecord() at offset 9.
2026-05-31T06:23:48.168Z INFO 2655 --- [per-0-AlterAcls] perationPurgatory$ExpiredOperationReaper : [ExpirationReaper-0-AlterAcls]: Starting
2026-05-31T06:23:48.170Z INFO 2655 --- [0-event-handler] o.a.k.c.PeriodicTaskControlManager : [QuorumController id=0] Activated periodic tasks: electPreferred, electUnclean, expireDelegationTokens, generatePeriodicPerformanceMessage, maybeFenceStaleBroker, writeNoOpRecord
2026-05-31T06:23:48.195Z INFO 2655 --- [ster-test-kit-3] kafka.server.ControllerServer : [ControllerServer id=0] Waiting for the controller metadata publishers to be installed
2026-05-31T06:23:48.200Z INFO 2655 --- [r-event-handler] o.a.kafka.image.loader.MetadataLoader : [MetadataLoader id=0] maybePublishMetadata(LOG_DELTA): The loader finished catching up to the current high water mark of 10
2026-05-31T06:23:48.201Z INFO 2655 --- [ent-processor-0] eadedEventProcessor$EventProcessorThread : [share-coordinator-event-processor-0]: Starting
2026-05-31T06:23:48.215Z INFO 2655 --- [r-event-handler] o.a.kafka.image.loader.MetadataLoader : [MetadataLoader id=0] InitializeNewPublishers: initializing SnapshotGenerator with a snapshot at offset 9
2026-05-31T06:23:48.218Z INFO 2655 --- [ster-test-kit-3] kafka.server.ControllerServer : [ControllerServer id=0] Finished waiting for the controller metadata publishers to be installed
2026-05-31T06:23:48.220Z INFO 2655 --- [r-event-handler] o.a.kafka.image.loader.MetadataLoader : [MetadataLoader id=0] InitializeNewPublishers: initializing KRaftMetadataCachePublisher with a snapshot at offset 9
2026-05-31T06:23:48.220Z INFO 2655 --- [r-event-handler] o.a.kafka.image.loader.MetadataLoader : [MetadataLoader id=0] InitializeNewPublishers: initializing FeaturesPublisher with a snapshot at offset 9
2026-05-31T06:23:48.223Z INFO 2655 --- [ster-test-kit-3] kafka.network.SocketServer : [SocketServer listenerType=CONTROLLER, nodeId=0] Enabling request processing.
2026-05-31T06:23:48.227Z INFO 2655 --- [r-event-handler] o.a.k.m.publisher.FeaturesPublisher : [ControllerServer id=0] Loaded new metadata FinalizedFeatures[metadataVersion=4.2-IV1, finalizedFeatures={group.version=1, streams.version=1, transaction.version=2, eligible.leader.replicas.version=1, share.version=1, metadata.version=29}, finalizedFeaturesEpoch=9].
2026-05-31T06:23:48.228Z INFO 2655 --- [r-event-handler] o.a.kafka.image.loader.MetadataLoader : [MetadataLoader id=0] InitializeNewPublishers: initializing ControllerRegistrationsPublisher with a snapshot at offset 9
2026-05-31T06:23:48.229Z INFO 2655 --- [r-event-handler] o.a.kafka.image.loader.MetadataLoader : [MetadataLoader id=0] InitializeNewPublishers: initializing ControllerRegistrationManager with a snapshot at offset 9
2026-05-31T06:23:48.231Z INFO 2655 --- [-manager-reaper] o.a.k.s.u.t.SystemTimerReaper$Reaper : [persister-state-manager-reaper]: Starting
2026-05-31T06:23:48.233Z INFO 2655 --- [r-event-handler] o.a.kafka.image.loader.MetadataLoader : [MetadataLoader id=0] InitializeNewPublishers: initializing DynamicConfigPublisher controller id=0 with a snapshot at offset 9
2026-05-31T06:23:48.238Z INFO 2655 --- [terStateManager] k.s.s.p.PersisterStateManager$SendThread : [PersisterStateManager]: Starting
2026-05-31T06:23:48.243Z INFO 2655 --- [rdinator-reaper] o.a.k.s.u.t.SystemTimerReaper$Reaper : [group-coordinator-reaper]: Starting
2026-05-31T06:23:48.250Z INFO 2655 --- [r-event-handler] k.s.metadata.DynamicConfigPublisher : [DynamicConfigPublisher controller id=0] Updating cluster configuration : min.insync.replicas -> 1
2026-05-31T06:23:48.272Z INFO 2655 --- [r-event-handler] o.a.kafka.common.config.AbstractConfig : KafkaConfig values:
add.partitions.to.txn.retry.backoff.max.ms = 100
add.partitions.to.txn.retry.backoff.ms = 20
advertised.listeners = null
alter.config.policy.class.name = null
alter.log.dirs.replication.quota.window.num = 11
alter.log.dirs.replication.quota.window.size.seconds = 1
authorizer.class.name =
auto.create.topics.enable = true
auto.leader.rebalance.enable = true
background.threads = 10
broker.heartbeat.interval.ms = 2000
broker.id = 0
broker.rack = null
broker.session.timeout.ms = 9000
client.quota.callback.class = null
compression.gzip.level = -1
compression.lz4.level = 9
compression.type = producer
compression.zstd.level = 3
connection.failed.authentication.delay.ms = 100
connections.max.idle.ms = 600000
connections.max.reauth.ms = 0
controlled.shutdown.enable = true
controller.listener.names = CONTROLLER
controller.performance.always.log.threshold.ms = 2000
controller.performance.sample.period.ms = 60000
controller.quorum.append.linger.ms = 25
controller.quorum.bootstrap.servers = []
controller.quorum.election.backoff.max.ms = 1000
controller.quorum.election.timeout.ms = 1000
controller.quorum.fetch.timeout.ms = 2000
controller.quorum.request.timeout.ms = 2000
controller.quorum.retry.backoff.ms = 20
controller.quorum.voters = [0@localhost:41413]
controller.quota.window.num = 11
controller.quota.window.size.seconds = 1
controller.socket.timeout.ms = 30000
create.topic.policy.class.name = null
default.replication.factor = 1
delegation.token.expiry.check.interval.ms = 3600000
delegation.token.expiry.time.ms = 86400000
delegation.token.max.lifetime.ms = 604800000
delegation.token.secret.key = null
delete.records.purgatory.purge.interval.requests = 1
delete.topic.enable = true
early.start.listeners = null
fetch.max.bytes = 57671680
fetch.purgatory.purge.interval.requests = 1000
group.consumer.assignors = [uniform, range]
group.consumer.heartbeat.interval.ms = 5000
group.consumer.max.heartbeat.interval.ms = 15000
group.consumer.max.session.timeout.ms = 60000
group.consumer.max.size = 2147483647
group.consumer.migration.policy = bidirectional
group.consumer.min.heartbeat.interval.ms = 5000
group.consumer.min.session.timeout.ms = 45000
group.consumer.regex.refresh.interval.ms = 600000
group.consumer.session.timeout.ms = 45000
group.coordinator.append.linger.ms = 5
group.coordinator.rebalance.protocols = [classic, consumer, streams]
group.coordinator.threads = 4
group.initial.rebalance.delay.ms = 0
group.max.session.timeout.ms = 1800000
group.max.size = 2147483647
group.min.session.timeout.ms = 6000
group.share.assignors = [simple]
group.share.delivery.count.limit = 5
group.share.enable = false
group.share.heartbeat.interval.ms = 5000
group.share.max.heartbeat.interval.ms = 15000
group.share.max.record.lock.duration.ms = 60000
group.share.max.session.timeout.ms = 60000
group.share.max.share.sessions = 2000
group.share.max.size = 200
group.share.min.heartbeat.interval.ms = 5000
group.share.min.record.lock.duration.ms = 15000
group.share.min.session.timeout.ms = 45000
group.share.partition.max.record.locks = 2000
group.share.persister.class.name = org.apache.kafka.server.share.persister.DefaultStatePersister
group.share.record.lock.duration.ms = 30000
group.share.session.timeout.ms = 45000
group.streams.heartbeat.interval.ms = 5000
group.streams.max.heartbeat.interval.ms = 15000
group.streams.max.session.timeout.ms = 60000
group.streams.max.size = 2147483647
group.streams.max.standby.replicas = 2
group.streams.min.heartbeat.interval.ms = 5000
group.streams.min.session.timeout.ms = 45000
group.streams.num.standby.replicas = 0
group.streams.session.timeout.ms = 45000
initial.broker.registration.timeout.ms = 60000
inter.broker.listener.name = EXTERNAL
internal.metadata.delete.delay.millis = 60000
internal.metadata.log.segment.bytes = null
internal.metadata.max.batch.size.in.bytes = 8388608
internal.metadata.max.fetch.size.in.bytes = 8388608
kafka.metrics.polling.interval.secs = 10
kafka.metrics.reporters = []
leader.imbalance.check.interval.seconds = 300
listener.security.protocol.map = EXTERNAL:PLAINTEXT,CONTROLLER:PLAINTEXT
listeners = EXTERNAL://localhost:0,CONTROLLER://localhost:0
log.cleaner.backoff.ms = 15000
log.cleaner.dedupe.buffer.size = 2097152
log.cleaner.delete.retention.ms = 86400000
log.cleaner.enable = true
log.cleaner.io.buffer.load.factor = 0.9
log.cleaner.io.buffer.size = 524288
log.cleaner.io.max.bytes.per.second = 1.7976931348623157E308
log.cleaner.max.compaction.lag.ms = 9223372036854775807
log.cleaner.min.cleanable.ratio = 0.5
log.cleaner.min.compaction.lag.ms = 0
log.cleaner.threads = 1
log.cleanup.policy = [delete]
log.dir = /tmp/kafka-logs
log.dir.failure.timeout.ms = 30000
log.dirs = /tmp/kafka-9691995952731394900/combined_0_0
log.flush.interval.messages = 9223372036854775807
log.flush.interval.ms = null
log.flush.offset.checkpoint.interval.ms = 60000
log.flush.scheduler.interval.ms = 9223372036854775807
log.flush.start.offset.checkpoint.interval.ms = 60000
log.index.interval.bytes = 4096
log.index.size.max.bytes = 10485760
log.initial.task.delay.ms = 30000
log.local.retention.bytes = -2
log.local.retention.ms = -2
log.message.timestamp.after.max.ms = 3600000
log.message.timestamp.before.max.ms = 9223372036854775807
log.message.timestamp.type = CreateTime
log.preallocate = false
log.retention.bytes = -1
log.retention.check.interval.ms = 300000
log.retention.hours = 168
log.retention.minutes = null
log.retention.ms = null
log.roll.hours = 168
log.roll.jitter.hours = 0
log.roll.jitter.ms = null
log.roll.ms = null
log.segment.bytes = 1073741824
log.segment.delete.delay.ms = 60000
max.connection.creation.rate = 2147483647
max.connections = 2147483647
max.connections.per.ip = 2147483647
max.connections.per.ip.overrides =
max.incremental.fetch.session.cache.slots = 1000
max.request.partition.size.limit = 2000
message.max.bytes = 1048588
metadata.log.dir = /tmp/kafka-9691995952731394900/combined_0_0
metadata.log.max.record.bytes.between.snapshots = 20971520
metadata.log.max.snapshot.interval.ms = 3600000
metadata.log.segment.bytes = 1073741824
metadata.log.segment.ms = 604800000
metadata.max.idle.interval.ms = 500
metadata.max.retention.bytes = 104857600
metadata.max.retention.ms = 604800000
metric.reporters = [org.apache.kafka.common.metrics.JmxReporter]
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
min.insync.replicas = 1
node.id = 0
num.io.threads = 8
num.network.threads = 3
num.partitions = 1
num.recovery.threads.per.data.dir = 2
num.replica.alter.log.dirs.threads = null
num.replica.fetchers = 1
offset.metadata.max.bytes = 4096
offsets.commit.timeout.ms = 5000
offsets.load.buffer.size = 5242880
offsets.retention.check.interval.ms = 600000
offsets.retention.minutes = 10080
offsets.topic.compression.codec = 0
offsets.topic.num.partitions = 50
offsets.topic.replication.factor = 1
offsets.topic.segment.bytes = 104857600
principal.builder.class = class org.apache.kafka.common.security.authenticator.DefaultKafkaPrincipalBuilder
process.roles = [broker, controller]
producer.id.expiration.check.interval.ms = 600000
producer.id.expiration.ms = 86400000
producer.purgatory.purge.interval.requests = 1000
queued.max.request.bytes = -1
queued.max.requests = 500
quota.window.num = 11
quota.window.size.seconds = 1
remote.fetch.max.wait.ms = 500
remote.list.offsets.request.timeout.ms = 30000
remote.log.index.file.cache.total.size.bytes = 1073741824
remote.log.manager.copier.thread.pool.size = 10
remote.log.manager.copy.max.bytes.per.second = 9223372036854775807
remote.log.manager.copy.quota.window.num = 11
remote.log.manager.copy.quota.window.size.seconds = 1
remote.log.manager.expiration.thread.pool.size = 10
remote.log.manager.fetch.max.bytes.per.second = 9223372036854775807
remote.log.manager.fetch.quota.window.num = 11
remote.log.manager.fetch.quota.window.size.seconds = 1
remote.log.manager.task.interval.ms = 30000
remote.log.manager.task.retry.backoff.max.ms = 30000
remote.log.manager.task.retry.backoff.ms = 500
remote.log.manager.task.retry.jitter = 0.2
remote.log.manager.thread.pool.size = 2
remote.log.metadata.custom.metadata.max.bytes = 128
remote.log.metadata.manager.class.name = org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager
remote.log.metadata.manager.class.path = null
remote.log.metadata.manager.impl.prefix = rlmm.config.
remote.log.metadata.manager.listener.name = null
remote.log.reader.max.pending.tasks = 100
remote.log.reader.threads = 10
remote.log.storage.manager.class.name = null
remote.log.storage.manager.class.path = null
remote.log.storage.manager.impl.prefix = rsm.config.
remote.log.storage.system.enable = false
replica.fetch.backoff.ms = 1000
replica.fetch.max.bytes = 1048576
replica.fetch.min.bytes = 1
replica.fetch.response.max.bytes = 10485760
replica.fetch.wait.max.ms = 500
replica.high.watermark.checkpoint.interval.ms = 5000
replica.lag.time.max.ms = 30000
replica.selector.class = null
replica.socket.receive.buffer.bytes = 65536
replica.socket.timeout.ms = 30000
replication.quota.window.num = 11
replication.quota.window.size.seconds = 1
request.timeout.ms = 30000
sasl.client.callback.handler.class = null
sasl.enabled.mechanisms = [GSSAPI]
sasl.jaas.config = null
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.min.time.before.relogin = 60000
sasl.kerberos.principal.to.local.rules = [DEFAULT]
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
sasl.kerberos.ticket.renew.window.factor = 0.8
sasl.login.callback.handler.class = null
sasl.login.class = null
sasl.login.connect.timeout.ms = null
sasl.login.read.timeout.ms = null
sasl.login.refresh.buffer.seconds = 300
sasl.login.refresh.min.period.seconds = 60
sasl.login.refresh.window.factor = 0.8
sasl.login.refresh.window.jitter = 0.05
sasl.login.retry.backoff.max.ms = 10000
sasl.login.retry.backoff.ms = 100
sasl.mechanism.controller.protocol = GSSAPI
sasl.mechanism.inter.broker.protocol = GSSAPI
sasl.oauthbearer.assertion.algorithm = RS256
sasl.oauthbearer.assertion.claim.aud = null
sasl.oauthbearer.assertion.claim.exp.seconds = 300
sasl.oauthbearer.assertion.claim.iss = null
sasl.oauthbearer.assertion.claim.jti.include = false
sasl.oauthbearer.assertion.claim.nbf.seconds = 60
sasl.oauthbearer.assertion.claim.sub = null
sasl.oauthbearer.assertion.file = null
sasl.oauthbearer.assertion.private.key.file = null
sasl.oauthbearer.assertion.private.key.passphrase = null
sasl.oauthbearer.assertion.template.file = null
sasl.oauthbearer.client.credentials.client.id = null
sasl.oauthbearer.client.credentials.client.secret = null
sasl.oauthbearer.clock.skew.seconds = 30
sasl.oauthbearer.expected.audience = null
sasl.oauthbearer.expected.issuer = null
sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
sasl.oauthbearer.jwks.endpoint.url = null
sasl.oauthbearer.jwt.retriever.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtRetriever
sasl.oauthbearer.jwt.validator.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtValidator
sasl.oauthbearer.scope = null
sasl.oauthbearer.scope.claim.name = scope
sasl.oauthbearer.sub.claim.name = sub
sasl.oauthbearer.token.endpoint.url = null
sasl.server.callback.handler.class = null
sasl.server.max.receive.size = 524288
security.inter.broker.protocol = PLAINTEXT
security.providers = null
server.max.startup.time.ms = 600000
share.coordinator.append.linger.ms = 5
share.coordinator.cold.partition.snapshot.interval.ms = 300000
share.coordinator.load.buffer.size = 5242880
share.coordinator.snapshot.update.records.per.snapshot = 500
share.coordinator.state.topic.compression.codec = 0
share.coordinator.state.topic.min.isr = 2
share.coordinator.state.topic.num.partitions = 50
share.coordinator.state.topic.prune.interval.ms = 300000
share.coordinator.state.topic.replication.factor = 3
share.coordinator.state.topic.segment.bytes = 104857600
share.coordinator.threads = 1
share.coordinator.write.timeout.ms = 5000
share.fetch.purgatory.purge.interval.requests = 1000
socket.connection.setup.timeout.max.ms = 30000
socket.connection.setup.timeout.ms = 10000
socket.listen.backlog.size = 50
socket.receive.buffer.bytes = 102400
socket.request.max.bytes = 104857600
socket.send.buffer.bytes = 102400
ssl.allow.dn.changes = false
ssl.allow.san.changes = false
ssl.cipher.suites = []
ssl.client.auth = none
ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
ssl.endpoint.identification.algorithm = https
ssl.engine.factory.class = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.certificate.chain = null
ssl.keystore.key = null
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.principal.mapping.rules = DEFAULT
ssl.protocol = TLSv1.3
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.certificates = null
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
telemetry.max.bytes = 1048576
transaction.abort.timed.out.transaction.cleanup.interval.ms = 10000
transaction.max.timeout.ms = 900000
transaction.partition.verification.enable = true
transaction.remove.expired.transaction.cleanup.interval.ms = 3600000
transaction.state.log.load.buffer.size = 5242880
transaction.state.log.min.isr = 2
transaction.state.log.num.partitions = 50
transaction.state.log.replication.factor = 1
transaction.state.log.segment.bytes = 104857600
transaction.two.phase.commit.enable = false
transactional.id.expiration.ms = 604800000
unclean.leader.election.enable = false
unclean.leader.election.interval.ms = 300000
unstable.api.versions.enable = true
unstable.feature.versions.enable = true
2026-05-31T06:23:48.281Z INFO 2655 --- [ent-processor-1] eadedEventProcessor$EventProcessorThread : [group-coordinator-event-processor-1]: Starting
2026-05-31T06:23:48.281Z INFO 2655 --- [ent-processor-2] eadedEventProcessor$EventProcessorThread : [group-coordinator-event-processor-2]: Starting
2026-05-31T06:23:48.282Z INFO 2655 --- [ent-processor-0] eadedEventProcessor$EventProcessorThread : [group-coordinator-event-processor-0]: Starting
2026-05-31T06:23:48.300Z INFO 2655 --- [ent-processor-3] eadedEventProcessor$EventProcessorThread : [group-coordinator-event-processor-3]: Starting
2026-05-31T06:23:48.314Z INFO 2655 --- [r-event-handler] k.server.ControllerRegistrationManager : [ControllerRegistrationManager id=0 incarnation=_qscfsszR3-0YqgrMQgj2Q] initialized channel manager.
2026-05-31T06:23:48.314Z INFO 2655 --- [channel-manager] k.server.NodeToControllerRequestThread : [controller-0-to-controller-registration-channel-manager]: Starting
2026-05-31T06:23:48.316Z INFO 2655 --- [channel-manager] k.server.NodeToControllerRequestThread : [controller-0-to-controller-registration-channel-manager]: Recorded new KRaft controller, from now on will use node localhost:41413 (id: 0 rack: null isFenced: false)
2026-05-31T06:23:48.318Z INFO 2655 --- [ster-test-kit-3] kafka.server.ControllerServer : [ControllerServer id=0] Waiting for all of the authorizer futures to be completed
2026-05-31T06:23:48.318Z INFO 2655 --- [ster-test-kit-3] kafka.server.ControllerServer : [ControllerServer id=0] Finished waiting for all of the authorizer futures to be completed
2026-05-31T06:23:48.318Z INFO 2655 --- [ster-test-kit-3] kafka.server.ControllerServer : [ControllerServer id=0] Waiting for all of the SocketServer Acceptors to be started
2026-05-31T06:23:48.318Z INFO 2655 --- [ster-test-kit-3] kafka.server.ControllerServer : [ControllerServer id=0] Finished waiting for all of the SocketServer Acceptors to be started
2026-05-31T06:23:48.327Z INFO 2655 --- [r-event-handler] k.server.ControllerRegistrationManager : [ControllerRegistrationManager id=0 incarnation=_qscfsszR3-0YqgrMQgj2Q] sendControllerRegistration: attempting to send ControllerRegistrationRequestData(controllerId=0, incarnationId=_qscfsszR3-0YqgrMQgj2Q, zkMigrationReady=false, listeners=[Listener(name='CONTROLLER', host='localhost', port=41413, securityProtocol=0)], features=[Feature(name='group.version', minSupportedVersion=0, maxSupportedVersion=1), Feature(name='kraft.version', minSupportedVersion=0, maxSupportedVersion=1), Feature(name='metadata.version', minSupportedVersion=7, maxSupportedVersion=29), Feature(name='share.version', minSupportedVersion=0, maxSupportedVersion=1), Feature(name='streams.version', minSupportedVersion=0, maxSupportedVersion=1), Feature(name='transaction.version', minSupportedVersion=0, maxSupportedVersion=2), Feature(name='eligible.leader.replicas.version', minSupportedVersion=0, maxSupportedVersion=1)])
2026-05-31T06:23:48.332Z INFO 2655 --- [r-event-handler] o.a.kafka.image.loader.MetadataLoader : [MetadataLoader id=0] InitializeNewPublishers: initializing DynamicClientQuotaPublisher controller id=0 with a snapshot at offset 9
2026-05-31T06:23:48.337Z INFO 2655 --- [r-event-handler] o.a.kafka.image.loader.MetadataLoader : [MetadataLoader id=0] InitializeNewPublishers: initializing DynamicTopicClusterQuotaPublisher controller id=0 with a snapshot at offset 9
2026-05-31T06:23:48.338Z INFO 2655 --- [r-event-handler] o.a.kafka.image.loader.MetadataLoader : [MetadataLoader id=0] InitializeNewPublishers: initializing ScramPublisher controller id=0 with a snapshot at offset 9
2026-05-31T06:23:48.341Z INFO 2655 --- [r-event-handler] o.a.kafka.image.loader.MetadataLoader : [MetadataLoader id=0] InitializeNewPublishers: initializing DelegationTokenPublisher controller id=0 with a snapshot at offset 9
2026-05-31T06:23:48.344Z INFO 2655 --- [r-event-handler] o.a.kafka.image.loader.MetadataLoader : [MetadataLoader id=0] InitializeNewPublishers: initializing ControllerMetadataMetricsPublisher with a snapshot at offset 9
2026-05-31T06:23:48.346Z INFO 2655 --- [r-event-handler] o.a.kafka.image.loader.MetadataLoader : [MetadataLoader id=0] InitializeNewPublishers: initializing AclPublisher controller id=0 with a snapshot at offset 9
2026-05-31T06:23:48.349Z INFO 2655 --- [ster-test-kit-4] kafka.log.LogManager : Unable to read the broker epoch in /tmp/kafka-9691995952731394900/combined_0_0.
2026-05-31T06:23:48.352Z INFO 2655 --- [channel-manager] k.server.NodeToControllerRequestThread : [broker-0-to-controller-heartbeat-channel-manager]: Starting
2026-05-31T06:23:48.352Z INFO 2655 --- [channel-manager] k.server.NodeToControllerRequestThread : [broker-0-to-controller-heartbeat-channel-manager]: Recorded new KRaft controller, from now on will use node localhost:41413 (id: 0 rack: null isFenced: false)
2026-05-31T06:23:48.359Z INFO 2655 --- [r-event-handler] kafka.server.BrokerLifecycleManager : [BrokerLifecycleManager id=0] Incarnation UEn_rxb2RsunOjc4qeTwtg of broker 0 in cluster zhF9nUh7RXCEHoJbFueUig is now STARTING.
2026-05-31T06:23:48.416Z INFO 2655 --- [-timeout-reaper] o.a.k.s.u.t.SystemTimerReaper$Reaper : [share-group-lock-timeout-reaper]: Starting
2026-05-31T06:23:48.456Z INFO 2655 --- [per-0-AlterAcls] perationPurgatory$ExpiredOperationReaper : [ExpirationReaper-0-AlterAcls]: Starting
2026-05-31T06:23:48.502Z INFO 2655 --- [0-event-handler] o.a.k.controller.ClusterControlManager : [QuorumController id=0] No previous registration found for broker 0. New incarnation ID is UEn_rxb2RsunOjc4qeTwtg. Generated 0 record(s) to clean up previous incarnations. New broker epoch is 10.
2026-05-31T06:23:48.508Z INFO 2655 --- [ster-test-kit-4] kafka.server.BrokerServer : [BrokerServer id=0] Waiting for the broker metadata publishers to be installed
2026-05-31T06:23:48.511Z INFO 2655 --- [0-event-handler] o.a.k.controller.ClusterControlManager : [QuorumController id=0] Replayed initial RegisterBrokerRecord for broker 0: RegisterBrokerRecord(brokerId=0, isMigratingZkBroker=false, incarnationId=UEn_rxb2RsunOjc4qeTwtg, brokerEpoch=10, endPoints=[BrokerEndpoint(name='EXTERNAL', host='localhost', port=38377, securityProtocol=0)], features=[BrokerFeature(name='group.version', minSupportedVersion=0, maxSupportedVersion=1), BrokerFeature(name='kraft.version', minSupportedVersion=0, maxSupportedVersion=1), BrokerFeature(name='metadata.version', minSupportedVersion=7, maxSupportedVersion=29), BrokerFeature(name='share.version', minSupportedVersion=0, maxSupportedVersion=1), BrokerFeature(name='streams.version', minSupportedVersion=0, maxSupportedVersion=1), BrokerFeature(name='transaction.version', minSupportedVersion=0, maxSupportedVersion=2), BrokerFeature(name='eligible.leader.replicas.version', minSupportedVersion=0, maxSupportedVersion=1)], rack=null, fenced=true, inControlledShutdown=false, logDirs=[s3mqEJ0-w8Uv5hhZPQVF0w])
2026-05-31T06:23:48.511Z INFO 2655 --- [r-event-handler] o.a.kafka.image.loader.MetadataLoader : [MetadataLoader id=0] InitializeNewPublishers: initializing MetadataVersionPublisher(id=0) with a snapshot at offset 9
2026-05-31T06:23:48.512Z INFO 2655 --- [r-event-handler] o.a.kafka.image.loader.MetadataLoader : [MetadataLoader id=0] InitializeNewPublishers: initializing BrokerMetadataPublisher with a snapshot at offset 9
2026-05-31T06:23:48.514Z INFO 2655 --- [r-event-handler] k.s.metadata.BrokerMetadataPublisher : [BrokerMetadataPublisher id=0] Publishing initial metadata at offset OffsetAndEpoch[offset=9, epoch=1] with metadata.version Optional[4.2-IV1].
2026-05-31T06:23:48.512Z INFO 2655 --- [ster-test-kit-4] kafka.server.BrokerServer : [BrokerServer id=0] Finished waiting for the broker metadata publishers to be installed
2026-05-31T06:23:48.514Z INFO 2655 --- [ster-test-kit-4] kafka.server.BrokerServer : [BrokerServer id=0] Waiting for the controller to acknowledge that we are caught up
2026-05-31T06:23:48.515Z INFO 2655 --- [r-event-handler] kafka.log.LogManager : Loading logs from log dirs ArrayBuffer(/tmp/kafka-9691995952731394900/combined_0_0)
2026-05-31T06:23:48.522Z INFO 2655 --- [r-event-handler] kafka.log.LogManager : No logs found to be loaded in /tmp/kafka-9691995952731394900/combined_0_0
2026-05-31T06:23:48.527Z INFO 2655 --- [0-event-handler] o.a.k.controller.ClusterControlManager : [QuorumController id=0] Replayed RegisterControllerRecord containing ControllerRegistration(id=0, incarnationId=_qscfsszR3-0YqgrMQgj2Q, zkMigrationReady=false, listeners=[Endpoint(listenerName='CONTROLLER', securityProtocol=PLAINTEXT, host='localhost', port=41413)], supportedFeatures={eligible.leader.replicas.version: 0-1, group.version: 0-1, kraft.version: 0-1, metadata.version: 7-29, share.version: 0-1, streams.version: 0-1, transaction.version: 0-2}).
2026-05-31T06:23:48.534Z INFO 2655 --- [r-event-handler] kafka.log.LogManager : Loaded 0 logs in 17ms
2026-05-31T06:23:48.535Z INFO 2655 --- [r-event-handler] kafka.log.LogManager : Starting log cleanup with a period of 300000 ms.
2026-05-31T06:23:48.536Z INFO 2655 --- [r-event-handler] kafka.log.LogManager : Starting log flusher with a default period of 9223372036854775807 ms.
2026-05-31T06:23:48.539Z INFO 2655 --- [r-event-handler] kafka.server.BrokerLifecycleManager : [BrokerLifecycleManager id=0] Successfully registered broker 0 with broker epoch 10
2026-05-31T06:23:48.540Z INFO 2655 --- [channel-manager] k.server.ControllerRegistrationManager : [ControllerRegistrationManager id=0 incarnation=_qscfsszR3-0YqgrMQgj2Q] RegistrationResponseHandler: controller acknowledged ControllerRegistrationRequest.
2026-05-31T06:23:48.549Z INFO 2655 --- [r-event-handler] o.a.k.storage.internals.log.LogCleaner : Starting the log cleaner
2026-05-31T06:23:48.565Z INFO 2655 --- [leaner-thread-0] o.a.k.s.i.log.LogCleaner$CleanerThread : [kafka-log-cleaner-thread-0]: Starting
2026-05-31T06:23:48.573Z INFO 2655 --- [rFailureHandler] k.s.ReplicaManager$LogDirFailureHandler : [LogDirFailureHandler]: Starting
2026-05-31T06:23:48.576Z INFO 2655 --- [nSenderThread-0] o.a.k.s.t.AddPartitionsToTxnManager : [AddPartitionsToTxnSenderThread-0]: Starting
2026-05-31T06:23:48.580Z INFO 2655 --- [r-event-handler] o.a.k.c.group.GroupCoordinatorService : [GroupCoordinator id=0] Starting up.
2026-05-31T06:23:48.581Z INFO 2655 --- [r-event-handler] o.a.k.c.group.GroupCoordinatorService : [GroupCoordinator id=0] Startup complete.
2026-05-31T06:23:48.582Z INFO 2655 --- [r-event-handler] k.c.transaction.TransactionCoordinator : [TransactionCoordinator id=0] Starting up.
2026-05-31T06:23:48.583Z INFO 2655 --- [rSenderThread-0] k.c.t.TransactionMarkerChannelManager : [TxnMarkerSenderThread-0]: Starting
2026-05-31T06:23:48.583Z INFO 2655 --- [r-event-handler] k.c.transaction.TransactionCoordinator : [TransactionCoordinator id=0] Startup complete.
2026-05-31T06:23:48.583Z INFO 2655 --- [r-event-handler] o.a.k.c.share.ShareCoordinatorService : [ShareCoordinator id=0] Starting up.
2026-05-31T06:23:48.584Z INFO 2655 --- [r-event-handler] o.a.k.c.share.ShareCoordinatorService : [ShareCoordinator id=0] Startup complete.
2026-05-31T06:23:48.592Z INFO 2655 --- [r-event-handler] k.s.metadata.DynamicConfigPublisher : [DynamicConfigPublisher broker id=0] Updating cluster configuration : min.insync.replicas -> 1
2026-05-31T06:23:48.595Z INFO 2655 --- [r-event-handler] o.a.kafka.common.config.AbstractConfig : KafkaConfig values:
add.partitions.to.txn.retry.backoff.max.ms = 100
add.partitions.to.txn.retry.backoff.ms = 20
advertised.listeners = null
alter.config.policy.class.name = null
alter.log.dirs.replication.quota.window.num = 11
alter.log.dirs.replication.quota.window.size.seconds = 1
authorizer.class.name =
auto.create.topics.enable = true
auto.leader.rebalance.enable = true
background.threads = 10
broker.heartbeat.interval.ms = 2000
broker.id = 0
broker.rack = null
broker.session.timeout.ms = 9000
client.quota.callback.class = null
compression.gzip.level = -1
compression.lz4.level = 9
compression.type = producer
compression.zstd.level = 3
connection.failed.authentication.delay.ms = 100
connections.max.idle.ms = 600000
connections.max.reauth.ms = 0
controlled.shutdown.enable = true
controller.listener.names = CONTROLLER
controller.performance.always.log.threshold.ms = 2000
controller.performance.sample.period.ms = 60000
controller.quorum.append.linger.ms = 25
controller.quorum.bootstrap.servers = []
controller.quorum.election.backoff.max.ms = 1000
controller.quorum.election.timeout.ms = 1000
controller.quorum.fetch.timeout.ms = 2000
controller.quorum.request.timeout.ms = 2000
controller.quorum.retry.backoff.ms = 20
controller.quorum.voters = [0@localhost:41413]
controller.quota.window.num = 11
controller.quota.window.size.seconds = 1
controller.socket.timeout.ms = 30000
create.topic.policy.class.name = null
default.replication.factor = 1
delegation.token.expiry.check.interval.ms = 3600000
delegation.token.expiry.time.ms = 86400000
delegation.token.max.lifetime.ms = 604800000
delegation.token.secret.key = null
delete.records.purgatory.purge.interval.requests = 1
delete.topic.enable = true
early.start.listeners = null
fetch.max.bytes = 57671680
fetch.purgatory.purge.interval.requests = 1000
group.consumer.assignors = [uniform, range]
group.consumer.heartbeat.interval.ms = 5000
group.consumer.max.heartbeat.interval.ms = 15000
group.consumer.max.session.timeout.ms = 60000
group.consumer.max.size = 2147483647
group.consumer.migration.policy = bidirectional
group.consumer.min.heartbeat.interval.ms = 5000
group.consumer.min.session.timeout.ms = 45000
group.consumer.regex.refresh.interval.ms = 600000
group.consumer.session.timeout.ms = 45000
group.coordinator.append.linger.ms = 5
group.coordinator.rebalance.protocols = [classic, consumer, streams]
group.coordinator.threads = 4
group.initial.rebalance.delay.ms = 0
group.max.session.timeout.ms = 1800000
group.max.size = 2147483647
group.min.session.timeout.ms = 6000
group.share.assignors = [simple]
group.share.delivery.count.limit = 5
group.share.enable = false
group.share.heartbeat.interval.ms = 5000
group.share.max.heartbeat.interval.ms = 15000
group.share.max.record.lock.duration.ms = 60000
group.share.max.session.timeout.ms = 60000
group.share.max.share.sessions = 2000
group.share.max.size = 200
group.share.min.heartbeat.interval.ms = 5000
group.share.min.record.lock.duration.ms = 15000
group.share.min.session.timeout.ms = 45000
group.share.partition.max.record.locks = 2000
group.share.persister.class.name = org.apache.kafka.server.share.persister.DefaultStatePersister
group.share.record.lock.duration.ms = 30000
group.share.session.timeout.ms = 45000
group.streams.heartbeat.interval.ms = 5000
group.streams.max.heartbeat.interval.ms = 15000
group.streams.max.session.timeout.ms = 60000
group.streams.max.size = 2147483647
group.streams.max.standby.replicas = 2
group.streams.min.heartbeat.interval.ms = 5000
group.streams.min.session.timeout.ms = 45000
group.streams.num.standby.replicas = 0
group.streams.session.timeout.ms = 45000
initial.broker.registration.timeout.ms = 60000
inter.broker.listener.name = EXTERNAL
internal.metadata.delete.delay.millis = 60000
internal.metadata.log.segment.bytes = null
internal.metadata.max.batch.size.in.bytes = 8388608
internal.metadata.max.fetch.size.in.bytes = 8388608
kafka.metrics.polling.interval.secs = 10
kafka.metrics.reporters = []
leader.imbalance.check.interval.seconds = 300
listener.security.protocol.map = EXTERNAL:PLAINTEXT,CONTROLLER:PLAINTEXT
listeners = EXTERNAL://localhost:0,CONTROLLER://localhost:0
log.cleaner.backoff.ms = 15000
log.cleaner.dedupe.buffer.size = 2097152
log.cleaner.delete.retention.ms = 86400000
log.cleaner.enable = true
log.cleaner.io.buffer.load.factor = 0.9
log.cleaner.io.buffer.size = 524288
log.cleaner.io.max.bytes.per.second = 1.7976931348623157E308
log.cleaner.max.compaction.lag.ms = 9223372036854775807
log.cleaner.min.cleanable.ratio = 0.5
log.cleaner.min.compaction.lag.ms = 0
log.cleaner.threads = 1
log.cleanup.policy = [delete]
log.dir = /tmp/kafka-logs
log.dir.failure.timeout.ms = 30000
log.dirs = /tmp/kafka-9691995952731394900/combined_0_0
log.flush.interval.messages = 9223372036854775807
log.flush.interval.ms = null
log.flush.offset.checkpoint.interval.ms = 60000
log.flush.scheduler.interval.ms = 9223372036854775807
log.flush.start.offset.checkpoint.interval.ms = 60000
log.index.interval.bytes = 4096
log.index.size.max.bytes = 10485760
log.initial.task.delay.ms = 30000
log.local.retention.bytes = -2
log.local.retention.ms = -2
log.message.timestamp.after.max.ms = 3600000
log.message.timestamp.before.max.ms = 9223372036854775807
log.message.timestamp.type = CreateTime
log.preallocate = false
log.retention.bytes = -1
log.retention.check.interval.ms = 300000
log.retention.hours = 168
log.retention.minutes = null
log.retention.ms = null
log.roll.hours = 168
log.roll.jitter.hours = 0
log.roll.jitter.ms = null
log.roll.ms = null
log.segment.bytes = 1073741824
log.segment.delete.delay.ms = 60000
max.connection.creation.rate = 2147483647
max.connections = 2147483647
max.connections.per.ip = 2147483647
max.connections.per.ip.overrides =
max.incremental.fetch.session.cache.slots = 1000
max.request.partition.size.limit = 2000
message.max.bytes = 1048588
metadata.log.dir = /tmp/kafka-9691995952731394900/combined_0_0
metadata.log.max.record.bytes.between.snapshots = 20971520
metadata.log.max.snapshot.interval.ms = 3600000
metadata.log.segment.bytes = 1073741824
metadata.log.segment.ms = 604800000
metadata.max.idle.interval.ms = 500
metadata.max.retention.bytes = 104857600
metadata.max.retention.ms = 604800000
metric.reporters = [org.apache.kafka.common.metrics.JmxReporter]
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
min.insync.replicas = 1
node.id = 0
num.io.threads = 8
num.network.threads = 3
num.partitions = 1
num.recovery.threads.per.data.dir = 2
num.replica.alter.log.dirs.threads = null
num.replica.fetchers = 1
offset.metadata.max.bytes = 4096
offsets.commit.timeout.ms = 5000
offsets.load.buffer.size = 5242880
offsets.retention.check.interval.ms = 600000
offsets.retention.minutes = 10080
offsets.topic.compression.codec = 0
offsets.topic.num.partitions = 50
offsets.topic.replication.factor = 1
offsets.topic.segment.bytes = 104857600
principal.builder.class = class org.apache.kafka.common.security.authenticator.DefaultKafkaPrincipalBuilder
process.roles = [broker, controller]
producer.id.expiration.check.interval.ms = 600000
producer.id.expiration.ms = 86400000
producer.purgatory.purge.interval.requests = 1000
queued.max.request.bytes = -1
queued.max.requests = 500
quota.window.num = 11
quota.window.size.seconds = 1
remote.fetch.max.wait.ms = 500
remote.list.offsets.request.timeout.ms = 30000
remote.log.index.file.cache.total.size.bytes = 1073741824
remote.log.manager.copier.thread.pool.size = 10
remote.log.manager.copy.max.bytes.per.second = 9223372036854775807
remote.log.manager.copy.quota.window.num = 11
remote.log.manager.copy.quota.window.size.seconds = 1
remote.log.manager.expiration.thread.pool.size = 10
remote.log.manager.fetch.max.bytes.per.second = 9223372036854775807
remote.log.manager.fetch.quota.window.num = 11
remote.log.manager.fetch.quota.window.size.seconds = 1
remote.log.manager.task.interval.ms = 30000
remote.log.manager.task.retry.backoff.max.ms = 30000
remote.log.manager.task.retry.backoff.ms = 500
remote.log.manager.task.retry.jitter = 0.2
remote.log.manager.thread.pool.size = 2
remote.log.metadata.custom.metadata.max.bytes = 128
remote.log.metadata.manager.class.name = org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager
remote.log.metadata.manager.class.path = null
remote.log.metadata.manager.impl.prefix = rlmm.config.
remote.log.metadata.manager.listener.name = null
remote.log.reader.max.pending.tasks = 100
remote.log.reader.threads = 10
remote.log.storage.manager.class.name = null
remote.log.storage.manager.class.path = null
remote.log.storage.manager.impl.prefix = rsm.config.
remote.log.storage.system.enable = false
replica.fetch.backoff.ms = 1000
replica.fetch.max.bytes = 1048576
replica.fetch.min.bytes = 1
replica.fetch.response.max.bytes = 10485760
replica.fetch.wait.max.ms = 500
replica.high.watermark.checkpoint.interval.ms = 5000
replica.lag.time.max.ms = 30000
replica.selector.class = null
replica.socket.receive.buffer.bytes = 65536
replica.socket.timeout.ms = 30000
replication.quota.window.num = 11
replication.quota.window.size.seconds = 1
request.timeout.ms = 30000
sasl.client.callback.handler.class = null
sasl.enabled.mechanisms = [GSSAPI]
sasl.jaas.config = null
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.min.time.before.relogin = 60000
sasl.kerberos.principal.to.local.rules = [DEFAULT]
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
sasl.kerberos.ticket.renew.window.factor = 0.8
sasl.login.callback.handler.class = null
sasl.login.class = null
sasl.login.connect.timeout.ms = null
sasl.login.read.timeout.ms = null
sasl.login.refresh.buffer.seconds = 300
sasl.login.refresh.min.period.seconds = 60
sasl.login.refresh.window.factor = 0.8
sasl.login.refresh.window.jitter = 0.05
sasl.login.retry.backoff.max.ms = 10000
sasl.login.retry.backoff.ms = 100
sasl.mechanism.controller.protocol = GSSAPI
sasl.mechanism.inter.broker.protocol = GSSAPI
sasl.oauthbearer.assertion.algorithm = RS256
sasl.oauthbearer.assertion.claim.aud = null
sasl.oauthbearer.assertion.claim.exp.seconds = 300
sasl.oauthbearer.assertion.claim.iss = null
sasl.oauthbearer.assertion.claim.jti.include = false
sasl.oauthbearer.assertion.claim.nbf.seconds = 60
sasl.oauthbearer.assertion.claim.sub = null
sasl.oauthbearer.assertion.file = null
sasl.oauthbearer.assertion.private.key.file = null
sasl.oauthbearer.assertion.private.key.passphrase = null
sasl.oauthbearer.assertion.template.file = null
sasl.oauthbearer.client.credentials.client.id = null
sasl.oauthbearer.client.credentials.client.secret = null
sasl.oauthbearer.clock.skew.seconds = 30
sasl.oauthbearer.expected.audience = null
sasl.oauthbearer.expected.issuer = null
sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
sasl.oauthbearer.jwks.endpoint.url = null
sasl.oauthbearer.jwt.retriever.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtRetriever
sasl.oauthbearer.jwt.validator.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtValidator
sasl.oauthbearer.scope = null
sasl.oauthbearer.scope.claim.name = scope
sasl.oauthbearer.sub.claim.name = sub
sasl.oauthbearer.token.endpoint.url = null
sasl.server.callback.handler.class = null
sasl.server.max.receive.size = 524288
security.inter.broker.protocol = PLAINTEXT
security.providers = null
server.max.startup.time.ms = 600000
share.coordinator.append.linger.ms = 5
share.coordinator.cold.partition.snapshot.interval.ms = 300000
share.coordinator.load.buffer.size = 5242880
share.coordinator.snapshot.update.records.per.snapshot = 500
share.coordinator.state.topic.compression.codec = 0
share.coordinator.state.topic.min.isr = 2
share.coordinator.state.topic.num.partitions = 50
share.coordinator.state.topic.prune.interval.ms = 300000
share.coordinator.state.topic.replication.factor = 3
share.coordinator.state.topic.segment.bytes = 104857600
share.coordinator.threads = 1
share.coordinator.write.timeout.ms = 5000
share.fetch.purgatory.purge.interval.requests = 1000
socket.connection.setup.timeout.max.ms = 30000
socket.connection.setup.timeout.ms = 10000
socket.listen.backlog.size = 50
socket.receive.buffer.bytes = 102400
socket.request.max.bytes = 104857600
socket.send.buffer.bytes = 102400
ssl.allow.dn.changes = false
ssl.allow.san.changes = false
ssl.cipher.suites = []
ssl.client.auth = none
ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
ssl.endpoint.identification.algorithm = https
ssl.engine.factory.class = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.certificate.chain = null
ssl.keystore.key = null
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.principal.mapping.rules = DEFAULT
ssl.protocol = TLSv1.3
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.certificates = null
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
telemetry.max.bytes = 1048576
transaction.abort.timed.out.transaction.cleanup.interval.ms = 10000
transaction.max.timeout.ms = 900000
transaction.partition.verification.enable = true
transaction.remove.expired.transaction.cleanup.interval.ms = 3600000
transaction.state.log.load.buffer.size = 5242880
transaction.state.log.min.isr = 2
transaction.state.log.num.partitions = 50
transaction.state.log.replication.factor = 1
transaction.state.log.segment.bytes = 104857600
transaction.two.phase.commit.enable = false
transactional.id.expiration.ms = 604800000
unclean.leader.election.enable = false
unclean.leader.election.interval.ms = 300000
unstable.api.versions.enable = true
unstable.feature.versions.enable = true
2026-05-31T06:23:48.607Z INFO 2655 --- [r-event-handler] k.s.metadata.BrokerMetadataPublisher : [BrokerMetadataPublisher id=0] Feature share.version has been updated to version 1
2026-05-31T06:23:48.607Z INFO 2655 --- [r-event-handler] o.a.kafka.image.loader.MetadataLoader : [MetadataLoader id=0] InitializeNewPublishers: initializing BrokerRegistrationTracker(id=0) with a snapshot at offset 9
2026-05-31T06:23:48.608Z INFO 2655 --- [r-event-handler] k.server.ControllerRegistrationManager : [ControllerRegistrationManager id=0 incarnation=_qscfsszR3-0YqgrMQgj2Q] Our registration has been persisted to the metadata log.
2026-05-31T06:23:48.632Z INFO 2655 --- [r-event-handler] kafka.server.BrokerLifecycleManager : [BrokerLifecycleManager id=0] The broker has caught up. Transitioning from STARTING to RECOVERY.
2026-05-31T06:23:48.632Z INFO 2655 --- [ster-test-kit-4] kafka.server.BrokerServer : [BrokerServer id=0] Finished waiting for the controller to acknowledge that we are caught up
2026-05-31T06:23:48.632Z INFO 2655 --- [ster-test-kit-4] kafka.server.BrokerServer : [BrokerServer id=0] Waiting for the initial broker metadata update to be published
2026-05-31T06:23:48.632Z INFO 2655 --- [ster-test-kit-4] kafka.server.BrokerServer : [BrokerServer id=0] Finished waiting for the initial broker metadata update to be published
2026-05-31T06:23:48.634Z INFO 2655 --- [ster-test-kit-4] o.a.kafka.common.config.AbstractConfig : KafkaConfig values:
add.partitions.to.txn.retry.backoff.max.ms = 100
add.partitions.to.txn.retry.backoff.ms = 20
advertised.listeners = null
alter.config.policy.class.name = null
alter.log.dirs.replication.quota.window.num = 11
alter.log.dirs.replication.quota.window.size.seconds = 1
authorizer.class.name =
auto.create.topics.enable = true
auto.leader.rebalance.enable = true
background.threads = 10
broker.heartbeat.interval.ms = 2000
broker.id = 0
broker.rack = null
broker.session.timeout.ms = 9000
client.quota.callback.class = null
compression.gzip.level = -1
compression.lz4.level = 9
compression.type = producer
compression.zstd.level = 3
connection.failed.authentication.delay.ms = 100
connections.max.idle.ms = 600000
connections.max.reauth.ms = 0
controlled.shutdown.enable = true
controller.listener.names = CONTROLLER
controller.performance.always.log.threshold.ms = 2000
controller.performance.sample.period.ms = 60000
controller.quorum.append.linger.ms = 25
controller.quorum.bootstrap.servers = []
controller.quorum.election.backoff.max.ms = 1000
controller.quorum.election.timeout.ms = 1000
controller.quorum.fetch.timeout.ms = 2000
controller.quorum.request.timeout.ms = 2000
controller.quorum.retry.backoff.ms = 20
controller.quorum.voters = [0@localhost:41413]
controller.quota.window.num = 11
controller.quota.window.size.seconds = 1
controller.socket.timeout.ms = 30000
create.topic.policy.class.name = null
default.replication.factor = 1
delegation.token.expiry.check.interval.ms = 3600000
delegation.token.expiry.time.ms = 86400000
delegation.token.max.lifetime.ms = 604800000
delegation.token.secret.key = null
delete.records.purgatory.purge.interval.requests = 1
delete.topic.enable = true
early.start.listeners = null
fetch.max.bytes = 57671680
fetch.purgatory.purge.interval.requests = 1000
group.consumer.assignors = [uniform, range]
group.consumer.heartbeat.interval.ms = 5000
group.consumer.max.heartbeat.interval.ms = 15000
group.consumer.max.session.timeout.ms = 60000
group.consumer.max.size = 2147483647
group.consumer.migration.policy = bidirectional
group.consumer.min.heartbeat.interval.ms = 5000
group.consumer.min.session.timeout.ms = 45000
group.consumer.regex.refresh.interval.ms = 600000
group.consumer.session.timeout.ms = 45000
group.coordinator.append.linger.ms = 5
group.coordinator.rebalance.protocols = [classic, consumer, streams]
group.coordinator.threads = 4
group.initial.rebalance.delay.ms = 0
group.max.session.timeout.ms = 1800000
group.max.size = 2147483647
group.min.session.timeout.ms = 6000
group.share.assignors = [simple]
group.share.delivery.count.limit = 5
group.share.enable = false
group.share.heartbeat.interval.ms = 5000
group.share.max.heartbeat.interval.ms = 15000
group.share.max.record.lock.duration.ms = 60000
group.share.max.session.timeout.ms = 60000
group.share.max.share.sessions = 2000
group.share.max.size = 200
group.share.min.heartbeat.interval.ms = 5000
group.share.min.record.lock.duration.ms = 15000
group.share.min.session.timeout.ms = 45000
group.share.partition.max.record.locks = 2000
group.share.persister.class.name = org.apache.kafka.server.share.persister.DefaultStatePersister
group.share.record.lock.duration.ms = 30000
group.share.session.timeout.ms = 45000
group.streams.heartbeat.interval.ms = 5000
group.streams.max.heartbeat.interval.ms = 15000
group.streams.max.session.timeout.ms = 60000
group.streams.max.size = 2147483647
group.streams.max.standby.replicas = 2
group.streams.min.heartbeat.interval.ms = 5000
group.streams.min.session.timeout.ms = 45000
group.streams.num.standby.replicas = 0
group.streams.session.timeout.ms = 45000
initial.broker.registration.timeout.ms = 60000
inter.broker.listener.name = EXTERNAL
internal.metadata.delete.delay.millis = 60000
internal.metadata.log.segment.bytes = null
internal.metadata.max.batch.size.in.bytes = 8388608
internal.metadata.max.fetch.size.in.bytes = 8388608
kafka.metrics.polling.interval.secs = 10
kafka.metrics.reporters = []
leader.imbalance.check.interval.seconds = 300
listener.security.protocol.map = EXTERNAL:PLAINTEXT,CONTROLLER:PLAINTEXT
listeners = EXTERNAL://localhost:0,CONTROLLER://localhost:0
log.cleaner.backoff.ms = 15000
log.cleaner.dedupe.buffer.size = 2097152
log.cleaner.delete.retention.ms = 86400000
log.cleaner.enable = true
log.cleaner.io.buffer.load.factor = 0.9
log.cleaner.io.buffer.size = 524288
log.cleaner.io.max.bytes.per.second = 1.7976931348623157E308
log.cleaner.max.compaction.lag.ms = 9223372036854775807
log.cleaner.min.cleanable.ratio = 0.5
log.cleaner.min.compaction.lag.ms = 0
log.cleaner.threads = 1
log.cleanup.policy = [delete]
log.dir = /tmp/kafka-logs
log.dir.failure.timeout.ms = 30000
log.dirs = /tmp/kafka-9691995952731394900/combined_0_0
log.flush.interval.messages = 9223372036854775807
log.flush.interval.ms = null
log.flush.offset.checkpoint.interval.ms = 60000
log.flush.scheduler.interval.ms = 9223372036854775807
log.flush.start.offset.checkpoint.interval.ms = 60000
log.index.interval.bytes = 4096
log.index.size.max.bytes = 10485760
log.initial.task.delay.ms = 30000
log.local.retention.bytes = -2
log.local.retention.ms = -2
log.message.timestamp.after.max.ms = 3600000
log.message.timestamp.before.max.ms = 9223372036854775807
log.message.timestamp.type = CreateTime
log.preallocate = false
log.retention.bytes = -1
log.retention.check.interval.ms = 300000
log.retention.hours = 168
log.retention.minutes = null
log.retention.ms = null
log.roll.hours = 168
log.roll.jitter.hours = 0
log.roll.jitter.ms = null
log.roll.ms = null
log.segment.bytes = 1073741824
log.segment.delete.delay.ms = 60000
max.connection.creation.rate = 2147483647
max.connections = 2147483647
max.connections.per.ip = 2147483647
max.connections.per.ip.overrides =
max.incremental.fetch.session.cache.slots = 1000
max.request.partition.size.limit = 2000
message.max.bytes = 1048588
metadata.log.dir = /tmp/kafka-9691995952731394900/combined_0_0
metadata.log.max.record.bytes.between.snapshots = 20971520
metadata.log.max.snapshot.interval.ms = 3600000
metadata.log.segment.bytes = 1073741824
metadata.log.segment.ms = 604800000
metadata.max.idle.interval.ms = 500
metadata.max.retention.bytes = 104857600
metadata.max.retention.ms = 604800000
metric.reporters = [org.apache.kafka.common.metrics.JmxReporter]
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
min.insync.replicas = 1
node.id = 0
num.io.threads = 8
num.network.threads = 3
num.partitions = 1
num.recovery.threads.per.data.dir = 2
num.replica.alter.log.dirs.threads = null
num.replica.fetchers = 1
offset.metadata.max.bytes = 4096
offsets.commit.timeout.ms = 5000
offsets.load.buffer.size = 5242880
offsets.retention.check.interval.ms = 600000
offsets.retention.minutes = 10080
offsets.topic.compression.codec = 0
offsets.topic.num.partitions = 50
offsets.topic.replication.factor = 1
offsets.topic.segment.bytes = 104857600
principal.builder.class = class org.apache.kafka.common.security.authenticator.DefaultKafkaPrincipalBuilder
process.roles = [broker, controller]
producer.id.expiration.check.interval.ms = 600000
producer.id.expiration.ms = 86400000
producer.purgatory.purge.interval.requests = 1000
queued.max.request.bytes = -1
queued.max.requests = 500
quota.window.num = 11
quota.window.size.seconds = 1
remote.fetch.max.wait.ms = 500
remote.list.offsets.request.timeout.ms = 30000
remote.log.index.file.cache.total.size.bytes = 1073741824
remote.log.manager.copier.thread.pool.size = 10
remote.log.manager.copy.max.bytes.per.second = 9223372036854775807
remote.log.manager.copy.quota.window.num = 11
remote.log.manager.copy.quota.window.size.seconds = 1
remote.log.manager.expiration.thread.pool.size = 10
remote.log.manager.fetch.max.bytes.per.second = 9223372036854775807
remote.log.manager.fetch.quota.window.num = 11
remote.log.manager.fetch.quota.window.size.seconds = 1
remote.log.manager.task.interval.ms = 30000
remote.log.manager.task.retry.backoff.max.ms = 30000
remote.log.manager.task.retry.backoff.ms = 500
remote.log.manager.task.retry.jitter = 0.2
remote.log.manager.thread.pool.size = 2
remote.log.metadata.custom.metadata.max.bytes = 128
remote.log.metadata.manager.class.name = org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager
remote.log.metadata.manager.class.path = null
remote.log.metadata.manager.impl.prefix = rlmm.config.
remote.log.metadata.manager.listener.name = null
remote.log.reader.max.pending.tasks = 100
remote.log.reader.threads = 10
remote.log.storage.manager.class.name = null
remote.log.storage.manager.class.path = null
remote.log.storage.manager.impl.prefix = rsm.config.
remote.log.storage.system.enable = false
replica.fetch.backoff.ms = 1000
replica.fetch.max.bytes = 1048576
replica.fetch.min.bytes = 1
replica.fetch.response.max.bytes = 10485760
replica.fetch.wait.max.ms = 500
replica.high.watermark.checkpoint.interval.ms = 5000
replica.lag.time.max.ms = 30000
replica.selector.class = null
replica.socket.receive.buffer.bytes = 65536
replica.socket.timeout.ms = 30000
replication.quota.window.num = 11
replication.quota.window.size.seconds = 1
request.timeout.ms = 30000
sasl.client.callback.handler.class = null
sasl.enabled.mechanisms = [GSSAPI]
sasl.jaas.config = null
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.min.time.before.relogin = 60000
sasl.kerberos.principal.to.local.rules = [DEFAULT]
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
sasl.kerberos.ticket.renew.window.factor = 0.8
sasl.login.callback.handler.class = null
sasl.login.class = null
sasl.login.connect.timeout.ms = null
sasl.login.read.timeout.ms = null
sasl.login.refresh.buffer.seconds = 300
sasl.login.refresh.min.period.seconds = 60
sasl.login.refresh.window.factor = 0.8
sasl.login.refresh.window.jitter = 0.05
sasl.login.retry.backoff.max.ms = 10000
sasl.login.retry.backoff.ms = 100
sasl.mechanism.controller.protocol = GSSAPI
sasl.mechanism.inter.broker.protocol = GSSAPI
sasl.oauthbearer.assertion.algorithm = RS256
sasl.oauthbearer.assertion.claim.aud = null
sasl.oauthbearer.assertion.claim.exp.seconds = 300
sasl.oauthbearer.assertion.claim.iss = null
sasl.oauthbearer.assertion.claim.jti.include = false
sasl.oauthbearer.assertion.claim.nbf.seconds = 60
sasl.oauthbearer.assertion.claim.sub = null
sasl.oauthbearer.assertion.file = null
sasl.oauthbearer.assertion.private.key.file = null
sasl.oauthbearer.assertion.private.key.passphrase = null
sasl.oauthbearer.assertion.template.file = null
sasl.oauthbearer.client.credentials.client.id = null
sasl.oauthbearer.client.credentials.client.secret = null
sasl.oauthbearer.clock.skew.seconds = 30
sasl.oauthbearer.expected.audience = null
sasl.oauthbearer.expected.issuer = null
sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
sasl.oauthbearer.jwks.endpoint.url = null
sasl.oauthbearer.jwt.retriever.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtRetriever
sasl.oauthbearer.jwt.validator.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtValidator
sasl.oauthbearer.scope = null
sasl.oauthbearer.scope.claim.name = scope
sasl.oauthbearer.sub.claim.name = sub
sasl.oauthbearer.token.endpoint.url = null
sasl.server.callback.handler.class = null
sasl.server.max.receive.size = 524288
security.inter.broker.protocol = PLAINTEXT
security.providers = null
server.max.startup.time.ms = 600000
share.coordinator.append.linger.ms = 5
share.coordinator.cold.partition.snapshot.interval.ms = 300000
share.coordinator.load.buffer.size = 5242880
share.coordinator.snapshot.update.records.per.snapshot = 500
share.coordinator.state.topic.compression.codec = 0
share.coordinator.state.topic.min.isr = 2
share.coordinator.state.topic.num.partitions = 50
share.coordinator.state.topic.prune.interval.ms = 300000
share.coordinator.state.topic.replication.factor = 3
share.coordinator.state.topic.segment.bytes = 104857600
share.coordinator.threads = 1
share.coordinator.write.timeout.ms = 5000
share.fetch.purgatory.purge.interval.requests = 1000
socket.connection.setup.timeout.max.ms = 30000
socket.connection.setup.timeout.ms = 10000
socket.listen.backlog.size = 50
socket.receive.buffer.bytes = 102400
socket.request.max.bytes = 104857600
socket.send.buffer.bytes = 102400
ssl.allow.dn.changes = false
ssl.allow.san.changes = false
ssl.cipher.suites = []
ssl.client.auth = none
ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
ssl.endpoint.identification.algorithm = https
ssl.engine.factory.class = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.certificate.chain = null
ssl.keystore.key = null
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.principal.mapping.rules = DEFAULT
ssl.protocol = TLSv1.3
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.certificates = null
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
telemetry.max.bytes = 1048576
transaction.abort.timed.out.transaction.cleanup.interval.ms = 10000
transaction.max.timeout.ms = 900000
transaction.partition.verification.enable = true
transaction.remove.expired.transaction.cleanup.interval.ms = 3600000
transaction.state.log.load.buffer.size = 5242880
transaction.state.log.min.isr = 2
transaction.state.log.num.partitions = 50
transaction.state.log.replication.factor = 1
transaction.state.log.segment.bytes = 104857600
transaction.two.phase.commit.enable = false
transactional.id.expiration.ms = 604800000
unclean.leader.election.enable = false
unclean.leader.election.interval.ms = 300000
unstable.api.versions.enable = true
unstable.feature.versions.enable = true
2026-05-31T06:23:48.639Z INFO 2655 --- [ster-test-kit-4] kafka.server.BrokerServer : [BrokerServer id=0] Waiting for the broker to be unfenced
2026-05-31T06:23:48.640Z INFO 2655 --- [0-event-handler] o.a.k.controller.BrokerHeartbeatManager : [QuorumController id=0] The request from broker 0 to unfence has been granted because it has caught up with the offset of its register broker record 10.
2026-05-31T06:23:48.650Z INFO 2655 --- [0-event-handler] o.a.k.controller.ClusterControlManager : [QuorumController id=0] Replayed BrokerRegistrationChangeRecord modifying the registration for broker 0: BrokerRegistrationChangeRecord(brokerId=0, brokerEpoch=10, fenced=-1, inControlledShutdown=0, logDirs=[])
2026-05-31T06:23:48.674Z INFO 2655 --- [r-event-handler] kafka.server.BrokerLifecycleManager : [BrokerLifecycleManager id=0] The broker has been unfenced. Transitioning from RECOVERY to RUNNING.
2026-05-31T06:23:48.675Z INFO 2655 --- [ster-test-kit-4] kafka.server.BrokerServer : [BrokerServer id=0] Finished waiting for the broker to be unfenced
2026-05-31T06:23:48.675Z INFO 2655 --- [ster-test-kit-4] o.a.k.s.network.EndpointReadyFutures : authorizerStart completed for endpoint EXTERNAL. Endpoint is now READY.
2026-05-31T06:23:48.676Z INFO 2655 --- [ster-test-kit-4] kafka.network.SocketServer : [SocketServer listenerType=BROKER, nodeId=0] Enabling request processing.
2026-05-31T06:23:48.677Z INFO 2655 --- [ster-test-kit-4] kafka.server.BrokerServer : [BrokerServer id=0] Waiting for all of the authorizer futures to be completed
2026-05-31T06:23:48.677Z INFO 2655 --- [ster-test-kit-4] kafka.server.BrokerServer : [BrokerServer id=0] Finished waiting for all of the authorizer futures to be completed
2026-05-31T06:23:48.677Z INFO 2655 --- [ster-test-kit-4] kafka.server.BrokerServer : [BrokerServer id=0] Waiting for all of the SocketServer Acceptors to be started
2026-05-31T06:23:48.677Z INFO 2655 --- [ster-test-kit-4] kafka.server.BrokerServer : [BrokerServer id=0] Finished waiting for all of the SocketServer Acceptors to be started
2026-05-31T06:23:48.678Z INFO 2655 --- [ster-test-kit-4] kafka.server.BrokerServer : [BrokerServer id=0] Transition from STARTING to STARTED
2026-05-31T06:23:48.691Z INFO 2655 --- [ Test worker] o.a.kafka.common.config.AbstractConfig : AdminClientConfig values:
bootstrap.controllers = []
bootstrap.servers = [localhost:38377]
client.dns.lookup = use_all_dns_ips
client.id =
connections.max.idle.ms = 300000
default.api.timeout.ms = 60000
enable.metrics.push = false
metadata.max.age.ms = 300000
metadata.recovery.rebootstrap.trigger.ms = 300000
metadata.recovery.strategy = rebootstrap
metric.reporters = [org.apache.kafka.common.metrics.JmxReporter]
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
receive.buffer.bytes = 65536
reconnect.backoff.max.ms = 1000
reconnect.backoff.ms = 50
request.timeout.ms = 30000
retries = 2147483647
retry.backoff.max.ms = 1000
retry.backoff.ms = 100
sasl.client.callback.handler.class = null
sasl.jaas.config = null
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.min.time.before.relogin = 60000
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
sasl.kerberos.ticket.renew.window.factor = 0.8
sasl.login.callback.handler.class = null
sasl.login.class = null
sasl.login.connect.timeout.ms = null
sasl.login.read.timeout.ms = null
sasl.login.refresh.buffer.seconds = 300
sasl.login.refresh.min.period.seconds = 60
sasl.login.refresh.window.factor = 0.8
sasl.login.refresh.window.jitter = 0.05
sasl.login.retry.backoff.max.ms = 10000
sasl.login.retry.backoff.ms = 100
sasl.mechanism = GSSAPI
sasl.oauthbearer.assertion.algorithm = RS256
sasl.oauthbearer.assertion.claim.aud = null
sasl.oauthbearer.assertion.claim.exp.seconds = 300
sasl.oauthbearer.assertion.claim.iss = null
sasl.oauthbearer.assertion.claim.jti.include = false
sasl.oauthbearer.assertion.claim.nbf.seconds = 60
sasl.oauthbearer.assertion.claim.sub = null
sasl.oauthbearer.assertion.file = null
sasl.oauthbearer.assertion.private.key.file = null
sasl.oauthbearer.assertion.private.key.passphrase = null
sasl.oauthbearer.assertion.template.file = null
sasl.oauthbearer.client.credentials.client.id = null
sasl.oauthbearer.client.credentials.client.secret = null
sasl.oauthbearer.clock.skew.seconds = 30
sasl.oauthbearer.expected.audience = null
sasl.oauthbearer.expected.issuer = null
sasl.oauthbearer.header.urlencode = false
sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
sasl.oauthbearer.jwks.endpoint.url = null
sasl.oauthbearer.jwt.retriever.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtRetriever
sasl.oauthbearer.jwt.validator.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtValidator
sasl.oauthbearer.scope = null
sasl.oauthbearer.scope.claim.name = scope
sasl.oauthbearer.sub.claim.name = sub
sasl.oauthbearer.token.endpoint.url = null
security.protocol = PLAINTEXT
security.providers = null
send.buffer.bytes = 131072
socket.connection.setup.timeout.max.ms = 30000
socket.connection.setup.timeout.ms = 10000
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
ssl.endpoint.identification.algorithm = https
ssl.engine.factory.class = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.certificate.chain = null
ssl.keystore.key = null
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLSv1.3
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.certificates = null
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
2026-05-31T06:23:48.737Z INFO 2655 --- [ Test worker] o.a.kafka.common.utils.AppInfoParser : Kafka version: 4.1.2
2026-05-31T06:23:48.737Z INFO 2655 --- [ Test worker] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: c82fd9b934b4c1e6
2026-05-31T06:23:48.738Z INFO 2655 --- [ Test worker] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1780208628737
2026-05-31T06:23:48.803Z INFO 2655 --- [0-event-handler] o.a.k.c.ReplicationControlManager : [QuorumController id=0] CreateTopics result(s): CreatableTopic(name='language-preferences', numPartitions=1, replicationFactor=1, assignments=[], configs=[]): SUCCESS
2026-05-31T06:23:48.804Z INFO 2655 --- [0-event-handler] o.a.k.c.ReplicationControlManager : [QuorumController id=0] Replayed TopicRecord for topic language-preferences with topic ID PfGZQe5rQeWohDTt5DnpQw.
2026-05-31T06:23:48.806Z INFO 2655 --- [0-event-handler] o.a.k.c.ReplicationControlManager : [QuorumController id=0] Replayed PartitionRecord for new partition language-preferences-0 with topic ID PfGZQe5rQeWohDTt5DnpQw and PartitionRegistration(replicas=[0], directories=[s3mqEJ0-w8Uv5hhZPQVF0w], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-05-31T06:23:48.836Z INFO 2655 --- [r-event-handler] state.change.logger : [Broker id=0] Transitioning 1 partition(s) to local leaders.
2026-05-31T06:23:48.837Z INFO 2655 --- [r-event-handler] kafka.server.ReplicaFetcherManager : [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(language-preferences-0)
2026-05-31T06:23:48.840Z INFO 2655 --- [r-event-handler] state.change.logger : [Broker id=0] Creating new partition language-preferences-0 with topic id PfGZQe5rQeWohDTt5DnpQw.
2026-05-31T06:23:48.840Z INFO 2655 --- [ Test worker] o.apache.kafka.common.metrics.Metrics : Metrics scheduler closed
2026-05-31T06:23:48.840Z INFO 2655 --- [ Test worker] o.apache.kafka.common.metrics.Metrics : Closing reporter org.apache.kafka.common.metrics.JmxReporter
2026-05-31T06:23:48.841Z INFO 2655 --- [ Test worker] o.apache.kafka.common.metrics.Metrics : Metrics reporters closed
2026-05-31T06:23:48.841Z INFO 2655 --- [| adminclient-1] o.a.kafka.common.utils.AppInfoParser : App info kafka.admin.client for adminclient-1 unregistered
2026-05-31T06:23:48.845Z INFO 2655 --- [| adminclient-1] o.apache.kafka.common.metrics.Metrics : Metrics scheduler closed
2026-05-31T06:23:48.845Z INFO 2655 --- [| adminclient-1] o.apache.kafka.common.metrics.Metrics : Closing reporter org.apache.kafka.common.metrics.JmxReporter
2026-05-31T06:23:48.845Z INFO 2655 --- [| adminclient-1] o.apache.kafka.common.metrics.Metrics : Metrics reporters closed
2026-05-31T06:23:48.862Z INFO 2655 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog : [LogLoader partition=language-preferences-0, dir=/tmp/kafka-9691995952731394900/combined_0_0] Loading producer state till offset 0
2026-05-31T06:23:48.865Z INFO 2655 --- [r-event-handler] kafka.log.LogManager : Created log for partition language-preferences-0 in /tmp/kafka-9691995952731394900/combined_0_0/language-preferences-0 with properties {}
2026-05-31T06:23:48.867Z INFO 2655 --- [r-event-handler] kafka.cluster.Partition : [Partition language-preferences-0 broker=0] No checkpointed highwatermark is found for partition language-preferences-0
2026-05-31T06:23:48.869Z INFO 2655 --- [r-event-handler] kafka.cluster.Partition : [Partition language-preferences-0 broker=0] Log loaded for partition language-preferences-0 with initial high watermark 0
2026-05-31T06:23:48.872Z INFO 2655 --- [ Test worker] c.m.k.LanguagePreferenceProducerTest : Starting LanguagePreferenceProducerTest using Java 25.0.3 with PID 2655 (started by runner in /home/runner/work/KafkaGuaranteesLab/KafkaGuaranteesLab)
2026-05-31T06:23:48.873Z INFO 2655 --- [ Test worker] c.m.k.LanguagePreferenceProducerTest : No active profile set, falling back to 1 default profile: "default"
2026-05-31T06:23:48.874Z INFO 2655 --- [r-event-handler] state.change.logger : [Broker id=0] Leader language-preferences-0 with topic id Some(PfGZQe5rQeWohDTt5DnpQw) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-05-31T06:23:52.515Z INFO 2655 --- [ Test worker] o.s.b.a.e.web.EndpointLinksResolver : Exposing 5 endpoints beneath base path '/actuator'
2026-05-31T06:23:52.610Z INFO 2655 --- [ Test worker] c.m.k.LanguagePreferenceProducerTest : Started LanguagePreferenceProducerTest in 7.022 seconds (process running for 9.76)
2026-05-31T06:23:53.807Z INFO 2655 --- [ Test worker] o.a.k.clients.producer.KafkaProducer : [Producer clientId=producer-1] Closing the Kafka producer with timeoutMillis = 30000 ms.
2026-05-31T06:23:53.817Z INFO 2655 --- [ Test worker] o.apache.kafka.common.metrics.Metrics : Metrics scheduler closed
2026-05-31T06:23:53.817Z INFO 2655 --- [ Test worker] o.apache.kafka.common.metrics.Metrics : Closing reporter org.apache.kafka.common.metrics.JmxReporter
2026-05-31T06:23:53.817Z INFO 2655 --- [ Test worker] o.apache.kafka.common.metrics.Metrics : Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter
2026-05-31T06:23:53.817Z INFO 2655 --- [ Test worker] o.apache.kafka.common.metrics.Metrics : Metrics reporters closed
2026-05-31T06:23:53.819Z INFO 2655 --- [ Test worker] o.a.kafka.common.utils.AppInfoParser : App info kafka.producer for producer-1 unregistered
2026-05-31T06:23:53.825Z INFO 2655 --- [ster-test-kit-2] kafka.server.BrokerServer : [BrokerServer id=0] Transition from STARTED to SHUTTING_DOWN
2026-05-31T06:23:53.825Z INFO 2655 --- [ster-test-kit-2] kafka.server.BrokerServer : [BrokerServer id=0] shutting down
2026-05-31T06:23:53.827Z INFO 2655 --- [r-event-handler] kafka.server.BrokerLifecycleManager : [BrokerLifecycleManager id=0] Beginning controlled shutdown.
2026-05-31T06:23:53.829Z INFO 2655 --- [0-event-handler] o.a.k.controller.BrokerHeartbeatManager : [QuorumController id=0] Unfenced broker 0 has requested and been granted a controlled shutdown.
2026-05-31T06:23:53.835Z INFO 2655 --- [0-event-handler] o.a.k.c.ReplicationControlManager : [QuorumController id=0] enterControlledShutdown[0]: changing 1 partition(s)
2026-05-31T06:23:53.836Z INFO 2655 --- [0-event-handler] o.a.k.controller.ClusterControlManager : [QuorumController id=0] Replayed BrokerRegistrationChangeRecord modifying the registration for broker 0: BrokerRegistrationChangeRecord(brokerId=0, brokerEpoch=10, fenced=0, inControlledShutdown=1, logDirs=[])
2026-05-31T06:23:53.863Z INFO 2655 --- [r-event-handler] state.change.logger : [Broker id=0] Transitioning 1 partition(s) to local followers.
2026-05-31T06:23:53.867Z INFO 2655 --- [r-event-handler] kafka.server.BrokerLifecycleManager : [BrokerLifecycleManager id=0] The broker is in PENDING_CONTROLLED_SHUTDOWN state, still waiting for the active controller.
2026-05-31T06:23:53.870Z INFO 2655 --- [r-event-handler] state.change.logger : [Broker id=0] Follower language-preferences-0 starts at leader epoch 1 from offset 1 with partition epoch 1 and high watermark 1. Current leader is -1. Previous leader Some(-1) and previous leader epoch was 1.
2026-05-31T06:23:53.872Z INFO 2655 --- [r-event-handler] kafka.server.ReplicaFetcherManager : [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(language-preferences-0)
2026-05-31T06:23:53.872Z INFO 2655 --- [r-event-handler] k.server.ReplicaAlterLogDirsManager : [ReplicaAlterLogDirsManager on broker 0] Removed fetcher for partitions Set(language-preferences-0)
2026-05-31T06:23:53.873Z INFO 2655 --- [r-event-handler] state.change.logger : [Broker id=0] Stopped fetchers as part of controlled shutdown for 1 partitions
2026-05-31T06:23:53.919Z INFO 2655 --- [0-event-handler] o.a.k.controller.BrokerHeartbeatManager : [QuorumController id=0] The request from broker 0 to shut down has been granted since the lowest active offset 9223372036854775807 is now greater than the broker's controlled shutdown offset 28.
2026-05-31T06:23:53.919Z INFO 2655 --- [0-event-handler] o.a.k.controller.ClusterControlManager : [QuorumController id=0] Replayed BrokerRegistrationChangeRecord modifying the registration for broker 0: BrokerRegistrationChangeRecord(brokerId=0, brokerEpoch=10, fenced=1, inControlledShutdown=0, logDirs=[])
2026-05-31T06:23:53.947Z INFO 2655 --- [r-event-handler] kafka.server.BrokerLifecycleManager : [BrokerLifecycleManager id=0] The controller has asked us to exit controlled shutdown.
2026-05-31T06:23:53.947Z INFO 2655 --- [r-event-handler] org.apache.kafka.queue.KafkaEventQueue : [BrokerLifecycleManager id=0] beginShutdown: shutting down event queue.
2026-05-31T06:23:53.948Z INFO 2655 --- [r-event-handler] kafka.server.BrokerLifecycleManager : [BrokerLifecycleManager id=0] Transitioning from PENDING_CONTROLLED_SHUTDOWN to SHUTTING_DOWN.
2026-05-31T06:23:53.948Z INFO 2655 --- [r-event-handler] k.server.NodeToControllerRequestThread : [broker-0-to-controller-heartbeat-channel-manager]: Shutting down
2026-05-31T06:23:53.948Z INFO 2655 --- [ster-test-kit-2] kafka.network.SocketServer : [SocketServer listenerType=BROKER, nodeId=0] Stopping socket server request processors
2026-05-31T06:23:53.948Z INFO 2655 --- [channel-manager] k.server.NodeToControllerRequestThread : [broker-0-to-controller-heartbeat-channel-manager]: Stopped
2026-05-31T06:23:53.949Z INFO 2655 --- [r-event-handler] k.server.NodeToControllerRequestThread : [broker-0-to-controller-heartbeat-channel-manager]: Shutdown completed
2026-05-31T06:23:53.958Z INFO 2655 --- [ster-test-kit-2] kafka.network.SocketServer : [SocketServer listenerType=BROKER, nodeId=0] Stopped socket server request processors
2026-05-31T06:23:53.960Z INFO 2655 --- [r-event-handler] k.s.NodeToControllerChannelManagerImpl : Node to controller channel manager for heartbeat shutdown
2026-05-31T06:23:53.960Z INFO 2655 --- [ster-test-kit-2] kafka.server.KafkaRequestHandlerPool : [data-plane Kafka Request Handler on Broker 0] shutting down
2026-05-31T06:23:53.963Z INFO 2655 --- [ster-test-kit-2] kafka.server.KafkaRequestHandlerPool : [data-plane Kafka Request Handler on Broker 0] shut down completely
2026-05-31T06:23:53.964Z INFO 2655 --- [ster-test-kit-2] perationPurgatory$ExpiredOperationReaper : [ExpirationReaper-0-AlterAcls]: Shutting down
2026-05-31T06:23:53.965Z INFO 2655 --- [per-0-AlterAcls] perationPurgatory$ExpiredOperationReaper : [ExpirationReaper-0-AlterAcls]: Stopped
2026-05-31T06:23:53.965Z INFO 2655 --- [ster-test-kit-2] perationPurgatory$ExpiredOperationReaper : [ExpirationReaper-0-AlterAcls]: Shutdown completed
2026-05-31T06:23:53.966Z INFO 2655 --- [ster-test-kit-2] kafka.server.KafkaApis : [KafkaApi-0] Shutdown complete.
2026-05-31T06:23:53.969Z INFO 2655 --- [ster-test-kit-2] k.c.transaction.TransactionCoordinator : [TransactionCoordinator id=0] Shutting down.
2026-05-31T06:23:53.969Z INFO 2655 --- [ster-test-kit-2] k.c.transaction.TransactionStateManager : [Transaction State Manager 0]: Shutdown complete
2026-05-31T06:23:53.969Z INFO 2655 --- [ster-test-kit-2] k.c.t.TransactionMarkerChannelManager : [TxnMarkerSenderThread-0]: Shutting down
2026-05-31T06:23:53.969Z INFO 2655 --- [rSenderThread-0] k.c.t.TransactionMarkerChannelManager : [TxnMarkerSenderThread-0]: Stopped
2026-05-31T06:23:53.970Z INFO 2655 --- [ster-test-kit-2] k.c.t.TransactionMarkerChannelManager : [TxnMarkerSenderThread-0]: Shutdown completed
2026-05-31T06:23:53.972Z INFO 2655 --- [ster-test-kit-2] k.c.transaction.TransactionCoordinator : [TransactionCoordinator id=0] Shutdown complete.
2026-05-31T06:23:53.973Z INFO 2655 --- [ster-test-kit-2] o.a.k.c.group.GroupCoordinatorService : [GroupCoordinator id=0] Shutting down.
2026-05-31T06:23:53.973Z INFO 2655 --- [ster-test-kit-2] o.a.k.c.c.runtime.CoordinatorRuntime : [GroupCoordinator id=0] Closing coordinator runtime.
2026-05-31T06:23:53.973Z INFO 2655 --- [ster-test-kit-2] o.a.k.s.u.t.SystemTimerReaper$Reaper : [group-coordinator-reaper]: Shutting down
2026-05-31T06:23:53.973Z INFO 2655 --- [ster-test-kit-2] o.a.k.s.u.t.SystemTimerReaper$Reaper : [group-coordinator-reaper]: Shutdown completed
2026-05-31T06:23:53.973Z INFO 2655 --- [ster-test-kit-2] o.a.k.c.c.r.MultiThreadedEventProcessor : [GroupCoordinator id=0] Shutting down event processor.
2026-05-31T06:23:53.973Z INFO 2655 --- [ent-processor-0] eadedEventProcessor$EventProcessorThread : [group-coordinator-event-processor-0]: Shutting down. Draining the remaining events.
2026-05-31T06:23:53.973Z INFO 2655 --- [ent-processor-0] eadedEventProcessor$EventProcessorThread : [group-coordinator-event-processor-0]: Shutdown completed
2026-05-31T06:23:53.974Z INFO 2655 --- [ent-processor-1] eadedEventProcessor$EventProcessorThread : [group-coordinator-event-processor-1]: Shutting down. Draining the remaining events.
2026-05-31T06:23:53.974Z INFO 2655 --- [ent-processor-1] eadedEventProcessor$EventProcessorThread : [group-coordinator-event-processor-1]: Shutdown completed
2026-05-31T06:23:53.974Z INFO 2655 --- [rdinator-reaper] o.a.k.s.u.t.SystemTimerReaper$Reaper : [group-coordinator-reaper]: Stopped
2026-05-31T06:23:53.975Z INFO 2655 --- [ent-processor-3] eadedEventProcessor$EventProcessorThread : [group-coordinator-event-processor-3]: Shutting down. Draining the remaining events.
2026-05-31T06:23:53.975Z INFO 2655 --- [ent-processor-3] eadedEventProcessor$EventProcessorThread : [group-coordinator-event-processor-3]: Shutdown completed
2026-05-31T06:23:53.975Z INFO 2655 --- [ent-processor-2] eadedEventProcessor$EventProcessorThread : [group-coordinator-event-processor-2]: Shutting down. Draining the remaining events.
2026-05-31T06:23:53.975Z INFO 2655 --- [ent-processor-2] eadedEventProcessor$EventProcessorThread : [group-coordinator-event-processor-2]: Shutdown completed
2026-05-31T06:23:53.975Z INFO 2655 --- [ster-test-kit-2] o.a.k.c.c.r.MultiThreadedEventProcessor : [GroupCoordinator id=0] Event processor closed.
2026-05-31T06:23:53.977Z INFO 2655 --- [ster-test-kit-2] o.a.k.c.c.runtime.CoordinatorRuntime : [GroupCoordinator id=0] Coordinator runtime closed.
2026-05-31T06:23:53.978Z INFO 2655 --- [ster-test-kit-2] o.a.k.c.group.GroupCoordinatorService : [GroupCoordinator id=0] Shutdown complete.
2026-05-31T06:23:53.978Z INFO 2655 --- [ster-test-kit-2] o.a.k.c.share.ShareCoordinatorService : [ShareCoordinator id=0] Shutting down.
2026-05-31T06:23:53.979Z INFO 2655 --- [ster-test-kit-2] o.a.k.c.c.runtime.CoordinatorRuntime : [ShareCoordinator id=0] Closing coordinator runtime.
2026-05-31T06:23:53.979Z INFO 2655 --- [ster-test-kit-2] o.a.k.s.u.t.SystemTimerReaper$Reaper : [share-coordinator-reaper]: Shutting down
2026-05-31T06:23:53.979Z INFO 2655 --- [rdinator-reaper] o.a.k.s.u.t.SystemTimerReaper$Reaper : [share-coordinator-reaper]: Stopped
2026-05-31T06:23:53.979Z INFO 2655 --- [ster-test-kit-2] o.a.k.s.u.t.SystemTimerReaper$Reaper : [share-coordinator-reaper]: Shutdown completed
2026-05-31T06:23:53.979Z INFO 2655 --- [ster-test-kit-2] o.a.k.c.c.r.MultiThreadedEventProcessor : [ShareCoordinator id=0] Shutting down event processor.
2026-05-31T06:23:53.979Z INFO 2655 --- [ent-processor-0] eadedEventProcessor$EventProcessorThread : [share-coordinator-event-processor-0]: Shutting down. Draining the remaining events.
2026-05-31T06:23:53.979Z INFO 2655 --- [ent-processor-0] eadedEventProcessor$EventProcessorThread : [share-coordinator-event-processor-0]: Shutdown completed
2026-05-31T06:23:53.979Z INFO 2655 --- [ster-test-kit-2] o.a.k.c.c.r.MultiThreadedEventProcessor : [ShareCoordinator id=0] Event processor closed.
2026-05-31T06:23:53.980Z INFO 2655 --- [ster-test-kit-2] o.a.k.c.c.runtime.CoordinatorRuntime : [ShareCoordinator id=0] Coordinator runtime closed.
2026-05-31T06:23:53.980Z INFO 2655 --- [ster-test-kit-2] o.a.k.c.share.ShareCoordinatorService : [ShareCoordinator id=0] Shutdown complete.
2026-05-31T06:23:53.981Z INFO 2655 --- [ster-test-kit-2] org.apache.kafka.queue.KafkaEventQueue : [AssignmentsManager id=0]KafkaEventQueue#close: shutting down event queue.
2026-05-31T06:23:53.981Z INFO 2655 --- [r-event-handler] o.a.kafka.server.AssignmentsManager : [AssignmentsManager id=0] shutting down.
2026-05-31T06:23:53.981Z INFO 2655 --- [r-event-handler] k.server.NodeToControllerRequestThread : [broker-0-to-controller-directory-assignments-channel-manager]: Shutting down
2026-05-31T06:23:53.982Z INFO 2655 --- [channel-manager] k.server.NodeToControllerRequestThread : [broker-0-to-controller-directory-assignments-channel-manager]: Stopped
2026-05-31T06:23:53.982Z INFO 2655 --- [r-event-handler] k.server.NodeToControllerRequestThread : [broker-0-to-controller-directory-assignments-channel-manager]: Shutdown completed
2026-05-31T06:23:53.982Z INFO 2655 --- [r-event-handler] k.s.NodeToControllerChannelManagerImpl : Node to controller channel manager for directory-assignments shutdown
2026-05-31T06:23:53.983Z INFO 2655 --- [ster-test-kit-2] org.apache.kafka.queue.KafkaEventQueue : [AssignmentsManager id=0]closed event queue.
2026-05-31T06:23:53.983Z INFO 2655 --- [ster-test-kit-2] kafka.server.ReplicaManager : [ReplicaManager broker=0] Shutting down
2026-05-31T06:23:53.984Z INFO 2655 --- [ster-test-kit-2] k.s.ReplicaManager$LogDirFailureHandler : [LogDirFailureHandler]: Shutting down
2026-05-31T06:23:53.984Z INFO 2655 --- [rFailureHandler] k.s.ReplicaManager$LogDirFailureHandler : [LogDirFailureHandler]: Stopped
2026-05-31T06:23:53.984Z INFO 2655 --- [ster-test-kit-2] k.s.ReplicaManager$LogDirFailureHandler : [LogDirFailureHandler]: Shutdown completed
2026-05-31T06:23:53.984Z INFO 2655 --- [ster-test-kit-2] kafka.server.ReplicaFetcherManager : [ReplicaFetcherManager on broker 0] shutting down
2026-05-31T06:23:53.985Z INFO 2655 --- [ster-test-kit-2] kafka.server.ReplicaFetcherManager : [ReplicaFetcherManager on broker 0] shutdown completed
2026-05-31T06:23:53.986Z INFO 2655 --- [ster-test-kit-2] k.server.ReplicaAlterLogDirsManager : [ReplicaAlterLogDirsManager on broker 0] shutting down
2026-05-31T06:23:53.986Z INFO 2655 --- [ster-test-kit-2] k.server.ReplicaAlterLogDirsManager : [ReplicaAlterLogDirsManager on broker 0] shutdown completed
2026-05-31T06:23:53.986Z INFO 2655 --- [ster-test-kit-2] perationPurgatory$ExpiredOperationReaper : [ExpirationReaper-0-Fetch]: Shutting down
2026-05-31T06:23:53.987Z INFO 2655 --- [nReaper-0-Fetch] perationPurgatory$ExpiredOperationReaper : [ExpirationReaper-0-Fetch]: Stopped
2026-05-31T06:23:53.987Z INFO 2655 --- [ster-test-kit-2] perationPurgatory$ExpiredOperationReaper : [ExpirationReaper-0-Fetch]: Shutdown completed
2026-05-31T06:23:53.987Z INFO 2655 --- [ster-test-kit-2] perationPurgatory$ExpiredOperationReaper : [ExpirationReaper-0-RemoteFetch]: Shutting down
2026-05-31T06:23:53.987Z INFO 2655 --- [r-0-RemoteFetch] perationPurgatory$ExpiredOperationReaper : [ExpirationReaper-0-RemoteFetch]: Stopped
2026-05-31T06:23:53.988Z INFO 2655 --- [ster-test-kit-2] perationPurgatory$ExpiredOperationReaper : [ExpirationReaper-0-RemoteFetch]: Shutdown completed
2026-05-31T06:23:53.988Z INFO 2655 --- [ster-test-kit-2] perationPurgatory$ExpiredOperationReaper : [ExpirationReaper-0-RemoteListOffsets]: Shutting down
2026-05-31T06:23:53.988Z INFO 2655 --- [moteListOffsets] perationPurgatory$ExpiredOperationReaper : [ExpirationReaper-0-RemoteListOffsets]: Stopped
2026-05-31T06:23:53.988Z INFO 2655 --- [ster-test-kit-2] perationPurgatory$ExpiredOperationReaper : [ExpirationReaper-0-RemoteListOffsets]: Shutdown completed
2026-05-31T06:23:53.989Z INFO 2655 --- [ster-test-kit-2] perationPurgatory$ExpiredOperationReaper : [ExpirationReaper-0-Produce]: Shutting down
2026-05-31T06:23:53.989Z INFO 2655 --- [eaper-0-Produce] perationPurgatory$ExpiredOperationReaper : [ExpirationReaper-0-Produce]: Stopped
2026-05-31T06:23:53.989Z INFO 2655 --- [ster-test-kit-2] perationPurgatory$ExpiredOperationReaper : [ExpirationReaper-0-Produce]: Shutdown completed
2026-05-31T06:23:53.990Z INFO 2655 --- [ster-test-kit-2] perationPurgatory$ExpiredOperationReaper : [ExpirationReaper-0-DeleteRecords]: Shutting down
2026-05-31T06:23:53.991Z INFO 2655 --- [0-DeleteRecords] perationPurgatory$ExpiredOperationReaper : [ExpirationReaper-0-DeleteRecords]: Stopped
2026-05-31T06:23:53.991Z INFO 2655 --- [ster-test-kit-2] perationPurgatory$ExpiredOperationReaper : [ExpirationReaper-0-DeleteRecords]: Shutdown completed
2026-05-31T06:23:53.991Z INFO 2655 --- [ster-test-kit-2] perationPurgatory$ExpiredOperationReaper : [ExpirationReaper-0-ShareFetch]: Shutting down
2026-05-31T06:23:53.992Z INFO 2655 --- [er-0-ShareFetch] perationPurgatory$ExpiredOperationReaper : [ExpirationReaper-0-ShareFetch]: Stopped
2026-05-31T06:23:53.992Z INFO 2655 --- [ster-test-kit-2] perationPurgatory$ExpiredOperationReaper : [ExpirationReaper-0-ShareFetch]: Shutdown completed
2026-05-31T06:23:53.995Z INFO 2655 --- [ster-test-kit-2] o.a.k.s.t.AddPartitionsToTxnManager : [AddPartitionsToTxnSenderThread-0]: Shutting down
2026-05-31T06:23:53.995Z INFO 2655 --- [nSenderThread-0] o.a.k.s.t.AddPartitionsToTxnManager : [AddPartitionsToTxnSenderThread-0]: Stopped
2026-05-31T06:23:53.995Z INFO 2655 --- [ster-test-kit-2] o.a.k.s.t.AddPartitionsToTxnManager : [AddPartitionsToTxnSenderThread-0]: Shutdown completed
2026-05-31T06:23:53.996Z INFO 2655 --- [ster-test-kit-2] kafka.server.ReplicaManager : [ReplicaManager broker=0] Shut down completely
2026-05-31T06:23:53.996Z INFO 2655 --- [ster-test-kit-2] k.server.NodeToControllerRequestThread : [broker-0-to-controller-alter-partition-channel-manager]: Shutting down
2026-05-31T06:23:53.996Z INFO 2655 --- [channel-manager] k.server.NodeToControllerRequestThread : [broker-0-to-controller-alter-partition-channel-manager]: Stopped
2026-05-31T06:23:53.996Z INFO 2655 --- [ster-test-kit-2] k.server.NodeToControllerRequestThread : [broker-0-to-controller-alter-partition-channel-manager]: Shutdown completed
2026-05-31T06:23:53.997Z INFO 2655 --- [ster-test-kit-2] k.s.NodeToControllerChannelManagerImpl : Node to controller channel manager for alter-partition shutdown
2026-05-31T06:23:53.997Z INFO 2655 --- [ster-test-kit-2] k.server.NodeToControllerRequestThread : [broker-0-to-controller-forwarding-channel-manager]: Shutting down
2026-05-31T06:23:53.997Z INFO 2655 --- [ster-test-kit-2] k.server.NodeToControllerRequestThread : [broker-0-to-controller-forwarding-channel-manager]: Shutdown completed
2026-05-31T06:23:53.998Z INFO 2655 --- [ster-test-kit-2] k.s.NodeToControllerChannelManagerImpl : Node to controller channel manager for forwarding shutdown
2026-05-31T06:23:53.998Z INFO 2655 --- [channel-manager] k.server.NodeToControllerRequestThread : [broker-0-to-controller-forwarding-channel-manager]: Stopped
2026-05-31T06:23:53.999Z INFO 2655 --- [ster-test-kit-2] kafka.log.LogManager : Shutting down.
2026-05-31T06:23:54.000Z INFO 2655 --- [ster-test-kit-2] o.a.k.storage.internals.log.LogCleaner : Shutting down the log cleaner.
2026-05-31T06:23:54.000Z INFO 2655 --- [ster-test-kit-2] o.a.k.s.i.log.LogCleaner$CleanerThread : [kafka-log-cleaner-thread-0]: Shutting down
2026-05-31T06:23:54.001Z INFO 2655 --- [ster-test-kit-2] o.a.k.s.i.log.LogCleaner$CleanerThread : [kafka-log-cleaner-thread-0]: Shutdown completed
2026-05-31T06:23:54.001Z INFO 2655 --- [leaner-thread-0] o.a.k.s.i.log.LogCleaner$CleanerThread : [kafka-log-cleaner-thread-0]: Stopped
2026-05-31T06:23:54.008Z INFO 2655 --- [00/combined_0_0] o.a.k.s.i.log.ProducerStateManager : [ProducerStateManager partition=language-preferences-0] Wrote producer snapshot at offset 1 with 1 producer ids in 3 ms.
2026-05-31T06:23:54.050Z INFO 2655 --- [ster-test-kit-2] kafka.log.LogManager : Shutdown complete.
2026-05-31T06:23:54.050Z INFO 2655 --- [ster-test-kit-2] lientQuotaManager$ThrottledChannelReaper : [broker-0-ThrottledChannelReaper-Fetch]: Shutting down
2026-05-31T06:23:54.052Z INFO 2655 --- [ster-test-kit-2] lientQuotaManager$ThrottledChannelReaper : [broker-0-ThrottledChannelReaper-Fetch]: Shutdown completed
2026-05-31T06:23:54.052Z INFO 2655 --- [nelReaper-Fetch] lientQuotaManager$ThrottledChannelReaper : [broker-0-ThrottledChannelReaper-Fetch]: Stopped
2026-05-31T06:23:54.052Z INFO 2655 --- [ster-test-kit-2] lientQuotaManager$ThrottledChannelReaper : [broker-0-ThrottledChannelReaper-Produce]: Shutting down
2026-05-31T06:23:54.052Z INFO 2655 --- [lReaper-Produce] lientQuotaManager$ThrottledChannelReaper : [broker-0-ThrottledChannelReaper-Produce]: Stopped
2026-05-31T06:23:54.052Z INFO 2655 --- [ster-test-kit-2] lientQuotaManager$ThrottledChannelReaper : [broker-0-ThrottledChannelReaper-Produce]: Shutdown completed
2026-05-31T06:23:54.052Z INFO 2655 --- [ster-test-kit-2] lientQuotaManager$ThrottledChannelReaper : [broker-0-ThrottledChannelReaper-Request]: Shutting down
2026-05-31T06:23:54.052Z INFO 2655 --- [lReaper-Request] lientQuotaManager$ThrottledChannelReaper : [broker-0-ThrottledChannelReaper-Request]: Stopped
2026-05-31T06:23:54.052Z INFO 2655 --- [ster-test-kit-2] lientQuotaManager$ThrottledChannelReaper : [broker-0-ThrottledChannelReaper-Request]: Shutdown completed
2026-05-31T06:23:54.052Z INFO 2655 --- [ster-test-kit-2] lientQuotaManager$ThrottledChannelReaper : [broker-0-ThrottledChannelReaper-ControllerMutation]: Shutting down
2026-05-31T06:23:54.052Z INFO 2655 --- [trollerMutation] lientQuotaManager$ThrottledChannelReaper : [broker-0-ThrottledChannelReaper-ControllerMutation]: Stopped
2026-05-31T06:23:54.052Z INFO 2655 --- [ster-test-kit-2] lientQuotaManager$ThrottledChannelReaper : [broker-0-ThrottledChannelReaper-ControllerMutation]: Shutdown completed
2026-05-31T06:23:54.053Z INFO 2655 --- [ster-test-kit-2] kafka.network.SocketServer : [SocketServer listenerType=BROKER, nodeId=0] Shutting down socket server
2026-05-31T06:23:54.065Z INFO 2655 --- [ster-test-kit-2] kafka.network.SocketServer : [SocketServer listenerType=BROKER, nodeId=0] Shutdown completed
2026-05-31T06:23:54.065Z INFO 2655 --- [ster-test-kit-2] o.a.k.s.log.metrics.BrokerTopicStats : Broker and topic stats closed
2026-05-31T06:23:54.065Z INFO 2655 --- [ster-test-kit-2] o.a.k.s.u.t.SystemTimerReaper$Reaper : [share-group-lock-timeout-reaper]: Shutting down
2026-05-31T06:23:54.066Z INFO 2655 --- [-timeout-reaper] o.a.k.s.u.t.SystemTimerReaper$Reaper : [share-group-lock-timeout-reaper]: Stopped
2026-05-31T06:23:54.066Z INFO 2655 --- [ster-test-kit-2] o.a.k.s.u.t.SystemTimerReaper$Reaper : [share-group-lock-timeout-reaper]: Shutdown completed
2026-05-31T06:23:54.067Z INFO 2655 --- [ster-test-kit-2] k.s.s.p.PersisterStateManager$SendThread : [PersisterStateManager]: Shutting down
2026-05-31T06:23:54.067Z INFO 2655 --- [terStateManager] k.s.s.p.PersisterStateManager$SendThread : [PersisterStateManager]: Stopped
2026-05-31T06:23:54.067Z INFO 2655 --- [ster-test-kit-2] k.s.s.p.PersisterStateManager$SendThread : [PersisterStateManager]: Shutdown completed
2026-05-31T06:23:54.067Z INFO 2655 --- [ster-test-kit-2] o.a.k.s.u.t.SystemTimerReaper$Reaper : [persister-state-manager-reaper]: Shutting down
2026-05-31T06:23:54.068Z INFO 2655 --- [-manager-reaper] o.a.k.s.u.t.SystemTimerReaper$Reaper : [persister-state-manager-reaper]: Stopped
2026-05-31T06:23:54.068Z INFO 2655 --- [ster-test-kit-2] o.a.k.s.u.t.SystemTimerReaper$Reaper : [persister-state-manager-reaper]: Shutdown completed
2026-05-31T06:23:54.069Z INFO 2655 --- [ster-test-kit-2] org.apache.kafka.queue.KafkaEventQueue : [BrokerLifecycleManager id=0] closed event queue.
2026-05-31T06:23:54.071Z INFO 2655 --- [ster-test-kit-2] o.a.k.s.u.t.SystemTimerReaper$Reaper : [client-metrics-reaper]: Shutting down
2026-05-31T06:23:54.072Z INFO 2655 --- [ster-test-kit-2] o.a.k.s.u.t.SystemTimerReaper$Reaper : [client-metrics-reaper]: Shutdown completed
2026-05-31T06:23:54.072Z INFO 2655 --- [-metrics-reaper] o.a.k.s.u.t.SystemTimerReaper$Reaper : [client-metrics-reaper]: Stopped
2026-05-31T06:23:54.072Z INFO 2655 --- [ster-test-kit-2] kafka.server.BrokerServer : [BrokerServer id=0] shut down completed
2026-05-31T06:23:54.072Z INFO 2655 --- [ster-test-kit-2] kafka.server.BrokerServer : [BrokerServer id=0] Transition from SHUTTING_DOWN to SHUTDOWN
2026-05-31T06:23:54.073Z INFO 2655 --- [ster-test-kit-1] kafka.server.ControllerServer : [ControllerServer id=0] shutting down
2026-05-31T06:23:54.073Z INFO 2655 --- [ster-test-kit-1] ExpirationService$ExpiredOperationReaper : [raft-expiration-reaper]: Shutting down
2026-05-31T06:23:54.194Z INFO 2655 --- [ster-test-kit-1] ExpirationService$ExpiredOperationReaper : [raft-expiration-reaper]: Shutdown completed
2026-05-31T06:23:54.195Z INFO 2655 --- [ster-test-kit-1] o.a.kafka.raft.KafkaRaftClientDriver : [kafka-0-raft-io-thread]: Shutting down
2026-05-31T06:23:54.195Z INFO 2655 --- [ster-test-kit-1] org.apache.kafka.raft.KafkaRaftClient : [RaftManager id=0] Beginning graceful shutdown
2026-05-31T06:23:54.194Z INFO 2655 --- [piration-reaper] ExpirationService$ExpiredOperationReaper : [raft-expiration-reaper]: Stopped
2026-05-31T06:23:54.196Z INFO 2655 --- [-raft-io-thread] org.apache.kafka.raft.KafkaRaftClient : [RaftManager id=0] Graceful shutdown completed
2026-05-31T06:23:54.196Z INFO 2655 --- [-raft-io-thread] o.a.kafka.raft.KafkaRaftClientDriver : [RaftManager id=0] Completed graceful shutdown of RaftClient
2026-05-31T06:23:54.196Z INFO 2655 --- [-raft-io-thread] o.a.kafka.raft.KafkaRaftClientDriver : [kafka-0-raft-io-thread]: Stopped
2026-05-31T06:23:54.196Z INFO 2655 --- [ster-test-kit-1] o.a.kafka.raft.KafkaRaftClientDriver : [kafka-0-raft-io-thread]: Shutdown completed
2026-05-31T06:23:54.197Z INFO 2655 --- [ster-test-kit-1] o.a.k.r.KafkaNetworkChannel$SendThread : [kafka-0-raft-outbound-request-thread]: Shutting down
2026-05-31T06:23:54.198Z INFO 2655 --- [-request-thread] o.a.k.r.KafkaNetworkChannel$SendThread : [kafka-0-raft-outbound-request-thread]: Stopped
2026-05-31T06:23:54.198Z INFO 2655 --- [ster-test-kit-1] o.a.k.r.KafkaNetworkChannel$SendThread : [kafka-0-raft-outbound-request-thread]: Shutdown completed
2026-05-31T06:23:54.199Z INFO 2655 --- [ster-test-kit-1] o.a.k.s.i.log.ProducerStateManager : [ProducerStateManager partition=__cluster_metadata-0] Wrote producer snapshot at offset 30 with 0 producer ids in 1 ms.
2026-05-31T06:23:54.201Z INFO 2655 --- [ster-test-kit-1] org.apache.kafka.queue.KafkaEventQueue : [ControllerRegistrationManager id=0 incarnation=_qscfsszR3-0YqgrMQgj2Q] beginShutdown: shutting down event queue.
2026-05-31T06:23:54.201Z INFO 2655 --- [r-event-handler] k.server.ControllerRegistrationManager : [ControllerRegistrationManager id=0 incarnation=_qscfsszR3-0YqgrMQgj2Q] shutting down.
2026-05-31T06:23:54.201Z INFO 2655 --- [r-event-handler] k.server.NodeToControllerRequestThread : [controller-0-to-controller-registration-channel-manager]: Shutting down
2026-05-31T06:23:54.202Z INFO 2655 --- [channel-manager] k.server.NodeToControllerRequestThread : [controller-0-to-controller-registration-channel-manager]: Stopped
2026-05-31T06:23:54.202Z INFO 2655 --- [r-event-handler] k.server.NodeToControllerRequestThread : [controller-0-to-controller-registration-channel-manager]: Shutdown completed
2026-05-31T06:23:54.203Z INFO 2655 --- [r-event-handler] k.s.NodeToControllerChannelManagerImpl : Node to controller channel manager for registration shutdown
2026-05-31T06:23:54.203Z INFO 2655 --- [ster-test-kit-1] org.apache.kafka.queue.KafkaEventQueue : [ControllerRegistrationManager id=0 incarnation=_qscfsszR3-0YqgrMQgj2Q] closed event queue.
2026-05-31T06:23:54.203Z INFO 2655 --- [ster-test-kit-1] k.server.NodeToControllerRequestThread : [controller-0-to-controller-registration-channel-manager]: Shutdown completed
2026-05-31T06:23:54.203Z WARN 2655 --- [ster-test-kit-1] org.apache.kafka.clients.NetworkClient : [NodeToControllerChannelManager id=0 name=registration] Attempting to close NetworkClient that has already been closed.
2026-05-31T06:23:54.203Z INFO 2655 --- [ster-test-kit-1] k.s.NodeToControllerChannelManagerImpl : Node to controller channel manager for registration shutdown
2026-05-31T06:23:54.204Z INFO 2655 --- [r-event-handler] org.apache.kafka.queue.KafkaEventQueue : [ControllerRegistrationManager id=0 incarnation=_qscfsszR3-0YqgrMQgj2Q] closed event queue.
2026-05-31T06:23:54.206Z INFO 2655 --- [ster-test-kit-1] kafka.network.SocketServer : [SocketServer listenerType=CONTROLLER, nodeId=0] Stopping socket server request processors
2026-05-31T06:23:54.209Z INFO 2655 --- [ster-test-kit-1] kafka.network.SocketServer : [SocketServer listenerType=CONTROLLER, nodeId=0] Stopped socket server request processors
2026-05-31T06:23:54.209Z INFO 2655 --- [ster-test-kit-1] org.apache.kafka.queue.KafkaEventQueue : [QuorumController id=0] QuorumController#beginShutdown: shutting down event queue.
2026-05-31T06:23:54.209Z INFO 2655 --- [ster-test-kit-1] kafka.network.SocketServer : [SocketServer listenerType=CONTROLLER, nodeId=0] Shutting down socket server
2026-05-31T06:23:54.211Z INFO 2655 --- [0-event-handler] o.a.kafka.controller.QuorumController : [QuorumController id=0] writeNoOpRecord: event unable to start processing because of RejectedExecutionException (treated as TimeoutException). Exception message: The event queue is shutting down
2026-05-31T06:23:54.211Z INFO 2655 --- [0-event-handler] o.a.kafka.controller.QuorumController : [QuorumController id=0] maybeFenceStaleBroker: event unable to start processing because of RejectedExecutionException (treated as TimeoutException). Exception message: The event queue is shutting down
2026-05-31T06:23:54.211Z INFO 2655 --- [0-event-handler] o.a.kafka.controller.QuorumController : [QuorumController id=0] generatePeriodicPerformanceMessage: event unable to start processing because of RejectedExecutionException (treated as TimeoutException). Exception message: The event queue is shutting down
2026-05-31T06:23:54.212Z INFO 2655 --- [0-event-handler] o.a.kafka.controller.QuorumController : [QuorumController id=0] electPreferred: event unable to start processing because of RejectedExecutionException (treated as TimeoutException). Exception message: The event queue is shutting down
2026-05-31T06:23:54.212Z INFO 2655 --- [0-event-handler] o.a.kafka.controller.QuorumController : [QuorumController id=0] electUnclean: event unable to start processing because of RejectedExecutionException (treated as TimeoutException). Exception message: The event queue is shutting down
2026-05-31T06:23:54.212Z INFO 2655 --- [0-event-handler] o.a.kafka.controller.QuorumController : [QuorumController id=0] expireDelegationTokens: event unable to start processing because of RejectedExecutionException (treated as TimeoutException). Exception message: The event queue is shutting down
2026-05-31T06:23:54.218Z INFO 2655 --- [ster-test-kit-1] kafka.network.SocketServer : [SocketServer listenerType=CONTROLLER, nodeId=0] Shutdown completed
2026-05-31T06:23:54.218Z INFO 2655 --- [ster-test-kit-1] kafka.server.KafkaRequestHandlerPool : [data-plane Kafka Request Handler on Controller 0] shutting down
2026-05-31T06:23:54.220Z INFO 2655 --- [ster-test-kit-1] kafka.server.KafkaRequestHandlerPool : [data-plane Kafka Request Handler on Controller 0] shut down completely
2026-05-31T06:23:54.221Z INFO 2655 --- [ster-test-kit-1] perationPurgatory$ExpiredOperationReaper : [ExpirationReaper-0-AlterAcls]: Shutting down
2026-05-31T06:23:54.221Z INFO 2655 --- [per-0-AlterAcls] perationPurgatory$ExpiredOperationReaper : [ExpirationReaper-0-AlterAcls]: Stopped
2026-05-31T06:23:54.221Z INFO 2655 --- [ster-test-kit-1] perationPurgatory$ExpiredOperationReaper : [ExpirationReaper-0-AlterAcls]: Shutdown completed
2026-05-31T06:23:54.222Z INFO 2655 --- [ster-test-kit-1] lientQuotaManager$ThrottledChannelReaper : [controller-0-ThrottledChannelReaper-Fetch]: Shutting down
2026-05-31T06:23:54.222Z INFO 2655 --- [nelReaper-Fetch] lientQuotaManager$ThrottledChannelReaper : [controller-0-ThrottledChannelReaper-Fetch]: Stopped
2026-05-31T06:23:54.223Z INFO 2655 --- [ster-test-kit-1] lientQuotaManager$ThrottledChannelReaper : [controller-0-ThrottledChannelReaper-Fetch]: Shutdown completed
2026-05-31T06:23:54.223Z INFO 2655 --- [ster-test-kit-1] lientQuotaManager$ThrottledChannelReaper : [controller-0-ThrottledChannelReaper-Produce]: Shutting down
2026-05-31T06:23:54.223Z INFO 2655 --- [lReaper-Produce] lientQuotaManager$ThrottledChannelReaper : [controller-0-ThrottledChannelReaper-Produce]: Stopped
2026-05-31T06:23:54.223Z INFO 2655 --- [ster-test-kit-1] lientQuotaManager$ThrottledChannelReaper : [controller-0-ThrottledChannelReaper-Produce]: Shutdown completed
2026-05-31T06:23:54.223Z INFO 2655 --- [ster-test-kit-1] lientQuotaManager$ThrottledChannelReaper : [controller-0-ThrottledChannelReaper-Request]: Shutting down
2026-05-31T06:23:54.223Z INFO 2655 --- [lReaper-Request] lientQuotaManager$ThrottledChannelReaper : [controller-0-ThrottledChannelReaper-Request]: Stopped
2026-05-31T06:23:54.224Z INFO 2655 --- [ster-test-kit-1] lientQuotaManager$ThrottledChannelReaper : [controller-0-ThrottledChannelReaper-Request]: Shutdown completed
2026-05-31T06:23:54.224Z INFO 2655 --- [ster-test-kit-1] lientQuotaManager$ThrottledChannelReaper : [controller-0-ThrottledChannelReaper-ControllerMutation]: Shutting down
2026-05-31T06:23:54.224Z INFO 2655 --- [trollerMutation] lientQuotaManager$ThrottledChannelReaper : [controller-0-ThrottledChannelReaper-ControllerMutation]: Stopped
2026-05-31T06:23:54.224Z INFO 2655 --- [ster-test-kit-1] lientQuotaManager$ThrottledChannelReaper : [controller-0-ThrottledChannelReaper-ControllerMutation]: Shutdown completed
2026-05-31T06:23:54.224Z INFO 2655 --- [ster-test-kit-1] org.apache.kafka.queue.KafkaEventQueue : [QuorumController id=0] closed event queue.
2026-05-31T06:23:54.225Z INFO 2655 --- [ster-test-kit-1] kafka.server.SharedServer : [SharedServer id=0] Stopping SharedServer
2026-05-31T06:23:54.226Z INFO 2655 --- [ster-test-kit-1] org.apache.kafka.queue.KafkaEventQueue : [MetadataLoader id=0] beginShutdown: shutting down event queue.
2026-05-31T06:23:54.226Z INFO 2655 --- [r-event-handler] org.apache.kafka.queue.KafkaEventQueue : [SnapshotGenerator id=0] close: shutting down event queue.
2026-05-31T06:23:54.226Z INFO 2655 --- [r-event-handler] org.apache.kafka.queue.KafkaEventQueue : [SnapshotGenerator id=0] closed event queue.
2026-05-31T06:23:54.227Z INFO 2655 --- [ster-test-kit-1] org.apache.kafka.queue.KafkaEventQueue : [MetadataLoader id=0] closed event queue.
2026-05-31T06:23:54.227Z INFO 2655 --- [ster-test-kit-1] org.apache.kafka.queue.KafkaEventQueue : [SnapshotGenerator id=0] closed event queue.
2026-05-31T06:23:54.228Z INFO 2655 --- [ster-test-kit-1] o.apache.kafka.common.metrics.Metrics : Metrics scheduler closed
2026-05-31T06:23:54.228Z INFO 2655 --- [ster-test-kit-1] o.apache.kafka.common.metrics.Metrics : Closing reporter org.apache.kafka.common.metrics.JmxReporter
2026-05-31T06:23:54.228Z INFO 2655 --- [ster-test-kit-1] o.apache.kafka.common.metrics.Metrics : Metrics reporters closed
2026-05-31T06:23:54.228Z INFO 2655 --- [ster-test-kit-1] o.a.kafka.common.utils.AppInfoParser : App info kafka.server for 0 unregistered