Standard Output
[2023-11-28 23:18:43,877] DEBUG Creating in-memory snapshot -1 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:18:43,879] DEBUG Creating in-memory snapshot 9 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:18:43,880] INFO Replayed BeginTransactionRecord(name=null) at offset 10. (org.apache.kafka.controller.OffsetControlManager:387)
[2023-11-28 23:18:43,880] DEBUG Deleting in-memory snapshot -1 (org.apache.kafka.timeline.SnapshotRegistry:247)
[2023-11-28 23:18:43,936] INFO Elected new leader: LeaderAndEpoch(leaderId=OptionalInt[0], epoch=1). (org.apache.kafka.metalog.LocalLogManager$SharedLogData:300)
[2023-11-28 23:18:43,945] DEBUG append(batch=LeaderChangeBatch(newLeader=LeaderAndEpoch(leaderId=OptionalInt[0], epoch=1)), nextEndOffset=0) (org.apache.kafka.metalog.LocalLogManager$SharedLogData:276)
[2023-11-28 23:18:43,949] DEBUG [LocalLogManager 0] Node 0: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:18:44,002] DEBUG [LocalLogManager 1] initialized local log manager for node 1 (org.apache.kafka.metalog.LocalLogManager:685)
[2023-11-28 23:18:44,020] DEBUG [LocalLogManager 0] initialized local log manager for node 0 (org.apache.kafka.metalog.LocalLogManager:685)
[2023-11-28 23:18:44,021] DEBUG [LocalLogManager 2] initialized local log manager for node 2 (org.apache.kafka.metalog.LocalLogManager:685)
[2023-11-28 23:18:44,023] DEBUG [QuorumController id=0] Creating in-memory snapshot -1 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:18:44,043] INFO [QuorumController id=0] Creating new QuorumController with clusterId vsMQs3RnS4OnwObvn-GoSQ. ZK migration mode is enabled. (org.apache.kafka.controller.QuorumController:1912)
[2023-11-28 23:18:44,045] INFO [LocalLogManager 0] Node 0: registered MetaLogListener 1021142116 (org.apache.kafka.metalog.LocalLogManager:703)
[2023-11-28 23:18:44,047] DEBUG [LocalLogManager 0] Node 0: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:18:44,049] DEBUG [LocalLogManager 0] Node 0: Executing handleLeaderChange LeaderAndEpoch(leaderId=OptionalInt[0], epoch=1) (org.apache.kafka.metalog.LocalLogManager:578)
[2023-11-28 23:18:44,077] DEBUG [QuorumController id=1] Creating in-memory snapshot -1 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:18:44,078] INFO [QuorumController id=1] Creating new QuorumController with clusterId vsMQs3RnS4OnwObvn-GoSQ. ZK migration mode is enabled. (org.apache.kafka.controller.QuorumController:1912)
[2023-11-28 23:18:44,078] INFO [LocalLogManager 1] Node 1: registered MetaLogListener 915267697 (org.apache.kafka.metalog.LocalLogManager:703)
[2023-11-28 23:18:44,078] DEBUG [LocalLogManager 1] Node 1: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:18:44,079] DEBUG [LocalLogManager 1] Node 1: Executing handleLeaderChange LeaderAndEpoch(leaderId=OptionalInt[0], epoch=1) (org.apache.kafka.metalog.LocalLogManager:578)
[2023-11-28 23:18:44,054] DEBUG [QuorumController id=0] Executing handleLeaderChange[1]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,098] INFO [QuorumController id=0] In the new epoch 1, the leader is (none). (org.apache.kafka.controller.QuorumController:1179)
[2023-11-28 23:18:44,098] DEBUG [QuorumController id=0] Processed handleLeaderChange[1] in 44745 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,098] DEBUG [QuorumController id=0] Executing handleLeaderChange[1]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,099] INFO [QuorumController id=0] Becoming the active controller at epoch 1, next write offset 1. (org.apache.kafka.controller.QuorumController:1175)
[2023-11-28 23:18:44,085] DEBUG [QuorumController id=1] Executing handleLeaderChange[1]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,099] INFO [QuorumController id=1] In the new epoch 1, the leader is (none). (org.apache.kafka.controller.QuorumController:1179)
[2023-11-28 23:18:44,100] DEBUG [QuorumController id=1] Processed handleLeaderChange[1] in 14723 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,100] DEBUG [QuorumController id=1] Executing handleLeaderChange[1]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,100] INFO [QuorumController id=1] In the new epoch 1, the leader is 0. (org.apache.kafka.controller.QuorumController:1179)
[2023-11-28 23:18:44,100] DEBUG [QuorumController id=1] Processed handleLeaderChange[1] in 394 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,097] DEBUG [QuorumController id=2] Creating in-memory snapshot -1 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:18:44,101] INFO [QuorumController id=2] Creating new QuorumController with clusterId vsMQs3RnS4OnwObvn-GoSQ. ZK migration mode is enabled. (org.apache.kafka.controller.QuorumController:1912)
[2023-11-28 23:18:44,102] INFO [LocalLogManager 2] Node 2: registered MetaLogListener 1009544729 (org.apache.kafka.metalog.LocalLogManager:703)
[2023-11-28 23:18:44,102] DEBUG [LocalLogManager 2] Node 2: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:18:44,102] DEBUG [LocalLogManager 2] Node 2: Executing handleLeaderChange LeaderAndEpoch(leaderId=OptionalInt[0], epoch=1) (org.apache.kafka.metalog.LocalLogManager:578)
[2023-11-28 23:18:44,110] DEBUG [QuorumController id=0] Processed handleLeaderChange[1] in 11898 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,112] WARN [QuorumController id=0] Performing controller activation. The metadata log appears to be empty. Appending 1 bootstrap record(s) in metadata transaction at metadata.version 3.6-IV1 from bootstrap source 'test'. Putting the controller into pre-migration mode. No metadata updates will be allowed until the ZK metadata has been migrated. (org.apache.kafka.controller.QuorumController:108)
[2023-11-28 23:18:44,122] DEBUG [QuorumController id=0] Creating in-memory snapshot 0 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:18:44,124] INFO [QuorumController id=0] Replayed BeginTransactionRecord(name='Bootstrap records') at offset 1. (org.apache.kafka.controller.OffsetControlManager:387)
[2023-11-28 23:18:44,125] DEBUG [QuorumController id=2] Executing handleLeaderChange[1]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,138] INFO [QuorumController id=0] Replayed a FeatureLevelRecord setting metadata version to 3.6-IV1 (org.apache.kafka.controller.FeatureControlManager:400)
[2023-11-28 23:18:44,148] INFO [QuorumController id=0] Replayed a ZkMigrationStateRecord changing the migration state from NONE to PRE_MIGRATION. (org.apache.kafka.controller.FeatureControlManager:421)
[2023-11-28 23:18:44,151] INFO [QuorumController id=0] Replayed EndTransactionRecord() at offset 4. (org.apache.kafka.controller.OffsetControlManager:399)
[2023-11-28 23:18:44,152] DEBUG append(batch=LocalRecordBatch(leaderEpoch=1, appendTimestamp=10, records=[ApiMessageAndVersion(BeginTransactionRecord(name='Bootstrap records') at version 0), ApiMessageAndVersion(FeatureLevelRecord(name='metadata.version', featureLevel=13) at version 0), ApiMessageAndVersion(ZkMigrationStateRecord(zkMigrationState=2) at version 0), ApiMessageAndVersion(EndTransactionRecord() at version 0)]), nextEndOffset=4) (org.apache.kafka.metalog.LocalLogManager$SharedLogData:276)
[2023-11-28 23:18:44,156] DEBUG [QuorumController id=0] Creating in-memory snapshot 4 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:18:44,156] DEBUG [LocalLogManager 1] Node 1: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:18:44,157] DEBUG [LocalLogManager 0] Node 0: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:18:44,156] DEBUG [LocalLogManager 2] Node 2: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:18:44,160] DEBUG [QuorumController id=0] Read-write operation completeActivation[1](300942443) will be completed when the log reaches offset 4. (org.apache.kafka.controller.QuorumController:849)
[2023-11-28 23:18:44,163] INFO [QuorumController id=2] In the new epoch 1, the leader is (none). (org.apache.kafka.controller.QuorumController:1179)
[2023-11-28 23:18:44,177] DEBUG [QuorumController id=2] Processed handleLeaderChange[1] in 73095 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,178] DEBUG [QuorumController id=2] Executing handleLeaderChange[1]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,179] INFO [QuorumController id=2] In the new epoch 1, the leader is 0. (org.apache.kafka.controller.QuorumController:1179)
[2023-11-28 23:18:44,179] DEBUG [QuorumController id=2] Processed handleLeaderChange[1] in 1300 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,180] DEBUG [QuorumController id=2] Executing handleCommit[baseOffset=1]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,181] DEBUG [QuorumController id=2] Replaying commits from the active node up to offset 4 and epoch 1. (org.apache.kafka.controller.QuorumController:1079)
[2023-11-28 23:18:44,182] DEBUG [QuorumController id=2] Creating in-memory snapshot 0 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:18:44,182] INFO [QuorumController id=2] Replayed BeginTransactionRecord(name='Bootstrap records') at offset 1. (org.apache.kafka.controller.OffsetControlManager:387)
[2023-11-28 23:18:44,176] DEBUG [QuorumController id=0] Processed wait for activation(840144506) in 12530 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,171] DEBUG [QuorumController id=1] Executing handleCommit[baseOffset=1]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,183] DEBUG [QuorumController id=0] Executing handleCommit[baseOffset=1]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,184] DEBUG [QuorumController id=1] Replaying commits from the active node up to offset 4 and epoch 1. (org.apache.kafka.controller.QuorumController:1079)
[2023-11-28 23:18:44,184] INFO [QuorumController id=0] Starting migration of ZooKeeper metadata to KRaft. (org.apache.kafka.controller.QuorumController:1001)
[2023-11-28 23:18:44,184] DEBUG [QuorumController id=0] Completing purgatory items up to offset 4 and epoch 1. (org.apache.kafka.controller.QuorumController:1065)
[2023-11-28 23:18:44,184] DEBUG [QuorumController id=1] Creating in-memory snapshot 0 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:18:44,184] INFO [QuorumController id=1] Replayed BeginTransactionRecord(name='Bootstrap records') at offset 1. (org.apache.kafka.controller.OffsetControlManager:387)
[2023-11-28 23:18:44,185] INFO [QuorumController id=1] Replayed a FeatureLevelRecord setting metadata version to 3.6-IV1 (org.apache.kafka.controller.FeatureControlManager:400)
[2023-11-28 23:18:44,185] INFO [QuorumController id=1] Replayed a ZkMigrationStateRecord changing the migration state from NONE to PRE_MIGRATION. (org.apache.kafka.controller.FeatureControlManager:421)
[2023-11-28 23:18:44,185] INFO [QuorumController id=1] Replayed EndTransactionRecord() at offset 4. (org.apache.kafka.controller.OffsetControlManager:399)
[2023-11-28 23:18:44,185] DEBUG [QuorumController id=1] Deleting in-memory snapshot -1 (org.apache.kafka.timeline.SnapshotRegistry:247)
[2023-11-28 23:18:44,186] DEBUG [QuorumController id=1] Deleting in-memory snapshot 0 (org.apache.kafka.timeline.SnapshotRegistry:247)
[2023-11-28 23:18:44,186] DEBUG [QuorumController id=1] Creating in-memory snapshot 4 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:18:44,186] DEBUG [QuorumController id=1] Processed handleCommit[baseOffset=1] in 15232 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,185] DEBUG [QuorumController id=0] Deleting in-memory snapshot -1 (org.apache.kafka.timeline.SnapshotRegistry:247)
[2023-11-28 23:18:44,187] DEBUG [QuorumController id=0] Deleting in-memory snapshot 0 (org.apache.kafka.timeline.SnapshotRegistry:247)
[2023-11-28 23:18:44,187] DEBUG [QuorumController id=0] completeUpTo(4): successfully completing completeActivation[1](300942443) (org.apache.kafka.deferred.DeferredEventQueue:61)
[2023-11-28 23:18:44,187] DEBUG [QuorumController id=0] Processed completeActivation[1](300942443) in 76411 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,187] DEBUG [QuorumController id=0] Processed handleCommit[baseOffset=1] in 4093 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,189] INFO [QuorumController id=0] Replayed BeginTransactionRecord(name='ZK Migration') at offset 5. (org.apache.kafka.controller.OffsetControlManager:387)
[2023-11-28 23:18:44,189] DEBUG append(batch=LocalRecordBatch(leaderEpoch=1, appendTimestamp=50, records=[ApiMessageAndVersion(BeginTransactionRecord(name='ZK Migration') at version 0)]), nextEndOffset=5) (org.apache.kafka.metalog.LocalLogManager$SharedLogData:276)
[2023-11-28 23:18:44,189] DEBUG [LocalLogManager 0] Node 0: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:18:44,189] DEBUG [LocalLogManager 2] Node 2: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:18:44,190] INFO [QuorumController id=2] Replayed a FeatureLevelRecord setting metadata version to 3.6-IV1 (org.apache.kafka.controller.FeatureControlManager:400)
[2023-11-28 23:18:44,190] INFO [QuorumController id=2] Replayed a ZkMigrationStateRecord changing the migration state from NONE to PRE_MIGRATION. (org.apache.kafka.controller.FeatureControlManager:421)
[2023-11-28 23:18:44,190] INFO [QuorumController id=2] Replayed EndTransactionRecord() at offset 4. (org.apache.kafka.controller.OffsetControlManager:399)
[2023-11-28 23:18:44,190] DEBUG [QuorumController id=2] Deleting in-memory snapshot -1 (org.apache.kafka.timeline.SnapshotRegistry:247)
[2023-11-28 23:18:44,191] DEBUG [QuorumController id=2] Deleting in-memory snapshot 0 (org.apache.kafka.timeline.SnapshotRegistry:247)
[2023-11-28 23:18:44,191] DEBUG [QuorumController id=2] Creating in-memory snapshot 4 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:18:44,191] DEBUG [QuorumController id=2] Processed handleCommit[baseOffset=1] in 10935 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,192] DEBUG [QuorumController id=2] Executing handleCommit[baseOffset=5]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,192] DEBUG [QuorumController id=2] Replaying commits from the active node up to offset 5 and epoch 1. (org.apache.kafka.controller.QuorumController:1079)
[2023-11-28 23:18:44,192] INFO [QuorumController id=2] Replayed BeginTransactionRecord(name='ZK Migration') at offset 5. (org.apache.kafka.controller.OffsetControlManager:387)
[2023-11-28 23:18:44,193] DEBUG [QuorumController id=2] Processed handleCommit[baseOffset=5] in 1484 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,189] DEBUG [QuorumController id=0] Creating in-memory snapshot 5 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:18:44,189] DEBUG [LocalLogManager 1] Node 1: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:18:44,194] DEBUG [QuorumController id=1] Executing handleCommit[baseOffset=5]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,194] DEBUG [QuorumController id=1] Replaying commits from the active node up to offset 5 and epoch 1. (org.apache.kafka.controller.QuorumController:1079)
[2023-11-28 23:18:44,195] INFO [QuorumController id=1] Replayed BeginTransactionRecord(name='ZK Migration') at offset 5. (org.apache.kafka.controller.OffsetControlManager:387)
[2023-11-28 23:18:44,195] DEBUG [QuorumController id=1] Processed handleCommit[baseOffset=5] in 490 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,196] DEBUG [QuorumController id=0] Read-write operation Begin ZK Migration Transaction(449694225) will be completed when the log reaches offset 5. (org.apache.kafka.controller.QuorumController:849)
[2023-11-28 23:18:44,196] DEBUG [QuorumController id=0] Executing handleCommit[baseOffset=5]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,196] DEBUG [QuorumController id=0] Completing purgatory items up to offset 5 and epoch 1. (org.apache.kafka.controller.QuorumController:1065)
[2023-11-28 23:18:44,196] DEBUG [QuorumController id=0] completeUpTo(5): successfully completing Begin ZK Migration Transaction(449694225) (org.apache.kafka.deferred.DeferredEventQueue:61)
[2023-11-28 23:18:44,197] DEBUG [QuorumController id=0] Processed Begin ZK Migration Transaction(449694225) in 8912 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,198] DEBUG [QuorumController id=0] Processed handleCommit[baseOffset=5] in 2105 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,211] INFO [QuorumController id=0] Replayed TopicRecord for topic spam with topic ID qvRJLpDYRHmgEi8_TPBYTQ. (org.apache.kafka.controller.ReplicationControlManager:438)
[2023-11-28 23:18:44,230] INFO [QuorumController id=0] Replayed PartitionRecord for new partition spam-0 with topic ID qvRJLpDYRHmgEi8_TPBYTQ and PartitionRegistration(replicas=[0, 1, 2], directories=[AAAAAAAAAAAAAAAAAAAAAA, AAAAAAAAAAAAAAAAAAAAAA, AAAAAAAAAAAAAAAAAAAAAA], isr=[0, 1, 2], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager:452)
[2023-11-28 23:18:44,232] INFO [QuorumController id=0] Replayed PartitionRecord for new partition spam-1 with topic ID qvRJLpDYRHmgEi8_TPBYTQ and PartitionRegistration(replicas=[1, 2, 0], directories=[AAAAAAAAAAAAAAAAAAAAAA, AAAAAAAAAAAAAAAAAAAAAA, AAAAAAAAAAAAAAAAAAAAAA], isr=[1, 2, 0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager:452)
[2023-11-28 23:18:44,233] DEBUG append(batch=LocalRecordBatch(leaderEpoch=1, appendTimestamp=60, records=[ApiMessageAndVersion(TopicRecord(name='spam', topicId=qvRJLpDYRHmgEi8_TPBYTQ) at version 0), ApiMessageAndVersion(PartitionRecord(partitionId=0, topicId=qvRJLpDYRHmgEi8_TPBYTQ, replicas=[0, 1, 2], isr=[0, 1, 2], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=0, leaderEpoch=0, partitionEpoch=0, eligibleLeaderReplicas=null, lastKnownELR=null, directories=[]) at version 0), ApiMessageAndVersion(PartitionRecord(partitionId=1, topicId=qvRJLpDYRHmgEi8_TPBYTQ, replicas=[1, 2, 0], isr=[1, 2, 0], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=0, leaderEpoch=0, partitionEpoch=0, eligibleLeaderReplicas=null, lastKnownELR=null, directories=[]) at version 0)]), nextEndOffset=8) (org.apache.kafka.metalog.LocalLogManager$SharedLogData:276)
[2023-11-28 23:18:44,239] DEBUG [LocalLogManager 0] Node 0: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:18:44,239] DEBUG [LocalLogManager 1] Node 1: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:18:44,241] DEBUG [QuorumController id=1] Executing handleCommit[baseOffset=6]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,241] DEBUG [QuorumController id=1] Replaying commits from the active node up to offset 8 and epoch 1. (org.apache.kafka.controller.QuorumController:1079)
[2023-11-28 23:18:44,241] INFO [QuorumController id=1] Replayed TopicRecord for topic spam with topic ID qvRJLpDYRHmgEi8_TPBYTQ. (org.apache.kafka.controller.ReplicationControlManager:438)
[2023-11-28 23:18:44,242] INFO [QuorumController id=1] Replayed PartitionRecord for new partition spam-0 with topic ID qvRJLpDYRHmgEi8_TPBYTQ and PartitionRegistration(replicas=[0, 1, 2], directories=[AAAAAAAAAAAAAAAAAAAAAA, AAAAAAAAAAAAAAAAAAAAAA, AAAAAAAAAAAAAAAAAAAAAA], isr=[0, 1, 2], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager:452)
[2023-11-28 23:18:44,242] INFO [QuorumController id=1] Replayed PartitionRecord for new partition spam-1 with topic ID qvRJLpDYRHmgEi8_TPBYTQ and PartitionRegistration(replicas=[1, 2, 0], directories=[AAAAAAAAAAAAAAAAAAAAAA, AAAAAAAAAAAAAAAAAAAAAA, AAAAAAAAAAAAAAAAAAAAAA], isr=[1, 2, 0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager:452)
[2023-11-28 23:18:44,243] DEBUG [QuorumController id=1] Processed handleCommit[baseOffset=6] in 2069 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,239] DEBUG [QuorumController id=0] Creating in-memory snapshot 8 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:18:44,239] DEBUG [LocalLogManager 2] Node 2: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:18:44,244] DEBUG [QuorumController id=2] Executing handleCommit[baseOffset=6]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,244] DEBUG [QuorumController id=2] Replaying commits from the active node up to offset 8 and epoch 1. (org.apache.kafka.controller.QuorumController:1079)
[2023-11-28 23:18:44,245] INFO [QuorumController id=2] Replayed TopicRecord for topic spam with topic ID qvRJLpDYRHmgEi8_TPBYTQ. (org.apache.kafka.controller.ReplicationControlManager:438)
[2023-11-28 23:18:44,245] INFO [QuorumController id=2] Replayed PartitionRecord for new partition spam-0 with topic ID qvRJLpDYRHmgEi8_TPBYTQ and PartitionRegistration(replicas=[0, 1, 2], directories=[AAAAAAAAAAAAAAAAAAAAAA, AAAAAAAAAAAAAAAAAAAAAA, AAAAAAAAAAAAAAAAAAAAAA], isr=[0, 1, 2], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager:452)
[2023-11-28 23:18:44,245] INFO [QuorumController id=2] Replayed PartitionRecord for new partition spam-1 with topic ID qvRJLpDYRHmgEi8_TPBYTQ and PartitionRegistration(replicas=[1, 2, 0], directories=[AAAAAAAAAAAAAAAAAAAAAA, AAAAAAAAAAAAAAAAAAAAAA, AAAAAAAAAAAAAAAAAAAAAA], isr=[1, 2, 0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager:452)
[2023-11-28 23:18:44,246] DEBUG [QuorumController id=2] Processed handleCommit[baseOffset=6] in 1367 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,248] DEBUG [QuorumController id=0] Read-write operation ZK Migration Batch(590435508) will be completed when the log reaches offset 8. (org.apache.kafka.controller.QuorumController:849)
[2023-11-28 23:18:44,248] DEBUG [QuorumController id=0] Executing handleCommit[baseOffset=6]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,249] DEBUG [QuorumController id=0] Completing purgatory items up to offset 8 and epoch 1. (org.apache.kafka.controller.QuorumController:1065)
[2023-11-28 23:18:44,249] DEBUG [QuorumController id=0] completeUpTo(8): successfully completing ZK Migration Batch(590435508) (org.apache.kafka.deferred.DeferredEventQueue:61)
[2023-11-28 23:18:44,250] DEBUG [QuorumController id=0] Processed ZK Migration Batch(590435508) in 51472 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,252] DEBUG [QuorumController id=0] Processed handleCommit[baseOffset=6] in 4020 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,253] DEBUG [QuorumController id=0] Executing forceRenounce. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,254] DEBUG append(batch=LeaderChangeBatch(newLeader=LeaderAndEpoch(leaderId=OptionalInt.empty, epoch=2)), nextEndOffset=9) (org.apache.kafka.metalog.LocalLogManager$SharedLogData:276)
[2023-11-28 23:18:44,254] DEBUG [LocalLogManager 0] Node 0: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:18:44,255] DEBUG [LocalLogManager 1] Node 1: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:18:44,256] DEBUG [LocalLogManager 2] Node 2: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:18:44,256] INFO Elected new leader: LeaderAndEpoch(leaderId=OptionalInt[0], epoch=3). (org.apache.kafka.metalog.LocalLogManager$SharedLogData:300)
[2023-11-28 23:18:44,257] DEBUG append(batch=LeaderChangeBatch(newLeader=LeaderAndEpoch(leaderId=OptionalInt[0], epoch=3)), nextEndOffset=10) (org.apache.kafka.metalog.LocalLogManager$SharedLogData:276)
[2023-11-28 23:18:44,258] DEBUG [LocalLogManager 2] Node 2: Ignoring LeaderAndEpoch(leaderId=OptionalInt.empty, epoch=2) since it doesn't match the latest known leader LeaderAndEpoch(leaderId=OptionalInt[0], epoch=3) (org.apache.kafka.metalog.LocalLogManager:585)
[2023-11-28 23:18:44,258] DEBUG [LocalLogManager 2] Node 2: Executing handleLeaderChange LeaderAndEpoch(leaderId=OptionalInt[0], epoch=3) (org.apache.kafka.metalog.LocalLogManager:578)
[2023-11-28 23:18:44,258] DEBUG [LocalLogManager 2] Node 2: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:18:44,258] DEBUG [LocalLogManager 1] Node 1: Ignoring LeaderAndEpoch(leaderId=OptionalInt.empty, epoch=2) since it doesn't match the latest known leader LeaderAndEpoch(leaderId=OptionalInt[0], epoch=3) (org.apache.kafka.metalog.LocalLogManager:585)
[2023-11-28 23:18:44,259] DEBUG [LocalLogManager 1] Node 1: Executing handleLeaderChange LeaderAndEpoch(leaderId=OptionalInt[0], epoch=3) (org.apache.kafka.metalog.LocalLogManager:578)
[2023-11-28 23:18:44,259] DEBUG [LocalLogManager 1] Node 1: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:18:44,259] DEBUG [LocalLogManager 0] Node 0: Ignoring LeaderAndEpoch(leaderId=OptionalInt.empty, epoch=2) since it doesn't match the latest known leader LeaderAndEpoch(leaderId=OptionalInt[0], epoch=3) (org.apache.kafka.metalog.LocalLogManager:585)
[2023-11-28 23:18:44,259] DEBUG [LocalLogManager 0] Node 0: Executing handleLeaderChange LeaderAndEpoch(leaderId=OptionalInt[0], epoch=3) (org.apache.kafka.metalog.LocalLogManager:578)
[2023-11-28 23:18:44,260] DEBUG [LocalLogManager 0] Node 0: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:18:44,260] DEBUG [QuorumController id=2] Executing handleLeaderChange[3]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,260] INFO [QuorumController id=2] In the new epoch 3, the leader is (none). (org.apache.kafka.controller.QuorumController:1179)
[2023-11-28 23:18:44,260] DEBUG [QuorumController id=2] Processed handleLeaderChange[3] in 288 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,260] DEBUG [QuorumController id=2] Executing handleLeaderChange[3]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,260] INFO [QuorumController id=2] In the new epoch 3, the leader is 0. (org.apache.kafka.controller.QuorumController:1179)
[2023-11-28 23:18:44,261] DEBUG [QuorumController id=2] Processed handleLeaderChange[3] in 257 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,261] DEBUG [QuorumController id=1] Executing handleLeaderChange[3]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,261] INFO [QuorumController id=1] In the new epoch 3, the leader is (none). (org.apache.kafka.controller.QuorumController:1179)
[2023-11-28 23:18:44,261] DEBUG [QuorumController id=1] Processed handleLeaderChange[3] in 338 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,261] DEBUG [QuorumController id=1] Executing handleLeaderChange[3]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,261] INFO [QuorumController id=1] In the new epoch 3, the leader is 0. (org.apache.kafka.controller.QuorumController:1179)
[2023-11-28 23:18:44,262] DEBUG [QuorumController id=1] Processed handleLeaderChange[3] in 254 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,265] DEBUG [QuorumController id=0] Reverting to in-memory snapshot 4 (org.apache.kafka.timeline.SnapshotRegistry:213)
[2023-11-28 23:18:44,271] DEBUG [QuorumController id=0] Deleting in-memory snapshot 5 because we are reverting to 4 (org.apache.kafka.timeline.SnapshotRegistry:219)
[2023-11-28 23:18:44,271] DEBUG [QuorumController id=0] Deleting in-memory snapshot 5 (org.apache.kafka.timeline.SnapshotRegistry:247)
[2023-11-28 23:18:44,272] DEBUG [QuorumController id=0] Deleting in-memory snapshot 8 because we are reverting to 4 (org.apache.kafka.timeline.SnapshotRegistry:219)
[2023-11-28 23:18:44,273] DEBUG [QuorumController id=0] Deleting in-memory snapshot 8 (org.apache.kafka.timeline.SnapshotRegistry:247)
[2023-11-28 23:18:44,274] DEBUG [QuorumController id=0] Processed forceRenounce in 20474 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,274] DEBUG [QuorumController id=0] Executing handleLeaderChange[3]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,274] INFO [QuorumController id=0] In the new epoch 3, the leader is (none). (org.apache.kafka.controller.QuorumController:1179)
[2023-11-28 23:18:44,275] DEBUG [QuorumController id=0] Processed handleLeaderChange[3] in 626 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,275] DEBUG [QuorumController id=0] Executing handleLeaderChange[3]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,275] INFO [QuorumController id=0] Becoming the active controller at epoch 3, next write offset 11. (org.apache.kafka.controller.QuorumController:1175)
[2023-11-28 23:18:44,275] DEBUG [QuorumController id=0] Processed handleLeaderChange[3] in 525 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,276] WARN [QuorumController id=0] Performing controller activation. Aborting in-progress metadata transaction at offset 5. Loaded ZK migration state of PRE_MIGRATION. (org.apache.kafka.controller.QuorumController:204)
[2023-11-28 23:18:44,276] DEBUG [QuorumController id=0] Reverting to in-memory snapshot 4 (org.apache.kafka.timeline.SnapshotRegistry:213)
[2023-11-28 23:18:44,277] INFO [QuorumController id=0] Replayed AbortTransactionRecord(reason='Controller failover') at offset 11. Reverted to offset 4. (org.apache.kafka.controller.OffsetControlManager:413)
[2023-11-28 23:18:44,277] DEBUG append(batch=LocalRecordBatch(leaderEpoch=3, appendTimestamp=110, records=[ApiMessageAndVersion(AbortTransactionRecord(reason='Controller failover') at version 0)]), nextEndOffset=11) (org.apache.kafka.metalog.LocalLogManager$SharedLogData:276)
[2023-11-28 23:18:44,286] DEBUG [LocalLogManager 0] Node 0: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:18:44,286] DEBUG [LocalLogManager 1] Node 1: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:18:44,287] DEBUG [LocalLogManager 2] Node 2: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:18:44,288] DEBUG [QuorumController id=2] Executing handleCommit[baseOffset=11]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,288] DEBUG [QuorumController id=2] Replaying commits from the active node up to offset 11 and epoch 3. (org.apache.kafka.controller.QuorumController:1079)
[2023-11-28 23:18:44,288] DEBUG [QuorumController id=2] Reverting to in-memory snapshot 4 (org.apache.kafka.timeline.SnapshotRegistry:213)
[2023-11-28 23:18:44,288] DEBUG [QuorumController id=1] Executing handleCommit[baseOffset=11]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,289] DEBUG [QuorumController id=1] Replaying commits from the active node up to offset 11 and epoch 3. (org.apache.kafka.controller.QuorumController:1079)
[2023-11-28 23:18:44,289] DEBUG [QuorumController id=1] Reverting to in-memory snapshot 4 (org.apache.kafka.timeline.SnapshotRegistry:213)
[2023-11-28 23:18:44,289] INFO [QuorumController id=1] Replayed AbortTransactionRecord(reason='Controller failover') at offset 11. Reverted to offset 4. (org.apache.kafka.controller.OffsetControlManager:413)
[2023-11-28 23:18:44,289] DEBUG [QuorumController id=1] Deleting in-memory snapshot 4 (org.apache.kafka.timeline.SnapshotRegistry:247)
[2023-11-28 23:18:44,290] DEBUG [QuorumController id=1] Creating in-memory snapshot 11 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:18:44,290] DEBUG [QuorumController id=1] Processed handleCommit[baseOffset=11] in 1506 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,290] INFO [QuorumController id=2] Replayed AbortTransactionRecord(reason='Controller failover') at offset 11. Reverted to offset 4. (org.apache.kafka.controller.OffsetControlManager:413)
[2023-11-28 23:18:44,290] DEBUG [QuorumController id=2] Deleting in-memory snapshot 4 (org.apache.kafka.timeline.SnapshotRegistry:247)
[2023-11-28 23:18:44,290] DEBUG [QuorumController id=2] Creating in-memory snapshot 11 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:18:44,291] DEBUG [QuorumController id=2] Processed handleCommit[baseOffset=11] in 3175 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,291] DEBUG [QuorumController id=0] Creating in-memory snapshot 11 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:18:44,292] DEBUG [QuorumController id=0] Read-write operation completeActivation[3](765322183) will be completed when the log reaches offset 11. (org.apache.kafka.controller.QuorumController:849)
[2023-11-28 23:18:44,292] DEBUG [QuorumController id=0] Processed wait for activation(77633076) in 16 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,295] DEBUG [QuorumController id=0] Executing handleCommit[baseOffset=11]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,295] DEBUG [QuorumController id=0] Completing purgatory items up to offset 11 and epoch 3. (org.apache.kafka.controller.QuorumController:1065)
[2023-11-28 23:18:44,296] DEBUG [QuorumController id=0] Deleting in-memory snapshot 4 (org.apache.kafka.timeline.SnapshotRegistry:247)
[2023-11-28 23:18:44,296] DEBUG [QuorumController id=0] completeUpTo(11): successfully completing completeActivation[3](765322183) (org.apache.kafka.deferred.DeferredEventQueue:61)
[2023-11-28 23:18:44,296] DEBUG [QuorumController id=0] Processed completeActivation[3](765322183) in 20485 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,296] DEBUG [QuorumController id=0] Processed handleCommit[baseOffset=11] in 1379 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,298] DEBUG [QuorumController id=0] Processed findTopicIds(1702597216) in 1232 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,299] DEBUG [QuorumController id=0] Processed read migration state(666552019) in 46 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,299] INFO [QuorumController id=0] Starting migration of ZooKeeper metadata to KRaft. (org.apache.kafka.controller.QuorumController:1001)
[2023-11-28 23:18:44,300] INFO [QuorumController id=0] Replayed BeginTransactionRecord(name='ZK Migration') at offset 12. (org.apache.kafka.controller.OffsetControlManager:387)
[2023-11-28 23:18:44,300] DEBUG append(batch=LocalRecordBatch(leaderEpoch=3, appendTimestamp=120, records=[ApiMessageAndVersion(BeginTransactionRecord(name='ZK Migration') at version 0)]), nextEndOffset=12) (org.apache.kafka.metalog.LocalLogManager$SharedLogData:276)
[2023-11-28 23:18:44,300] DEBUG [LocalLogManager 0] Node 0: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:18:44,301] DEBUG [LocalLogManager 1] Node 1: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:18:44,301] DEBUG [LocalLogManager 2] Node 2: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:18:44,301] DEBUG [QuorumController id=2] Executing handleCommit[baseOffset=12]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,302] DEBUG [QuorumController id=2] Replaying commits from the active node up to offset 12 and epoch 3. (org.apache.kafka.controller.QuorumController:1079)
[2023-11-28 23:18:44,302] INFO [QuorumController id=2] Replayed BeginTransactionRecord(name='ZK Migration') at offset 12. (org.apache.kafka.controller.OffsetControlManager:387)
[2023-11-28 23:18:44,302] DEBUG [QuorumController id=2] Processed handleCommit[baseOffset=12] in 420 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,302] DEBUG [QuorumController id=1] Executing handleCommit[baseOffset=12]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,303] DEBUG [QuorumController id=1] Replaying commits from the active node up to offset 12 and epoch 3. (org.apache.kafka.controller.QuorumController:1079)
[2023-11-28 23:18:44,303] INFO [QuorumController id=1] Replayed BeginTransactionRecord(name='ZK Migration') at offset 12. (org.apache.kafka.controller.OffsetControlManager:387)
[2023-11-28 23:18:44,303] DEBUG [QuorumController id=1] Processed handleCommit[baseOffset=12] in 609 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,303] DEBUG [QuorumController id=0] Creating in-memory snapshot 12 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:18:44,304] DEBUG [QuorumController id=0] Read-write operation Begin ZK Migration Transaction(665576742) will be completed when the log reaches offset 12. (org.apache.kafka.controller.QuorumController:849)
[2023-11-28 23:18:44,304] DEBUG [QuorumController id=0] Executing handleCommit[baseOffset=12]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,304] DEBUG [QuorumController id=0] Completing purgatory items up to offset 12 and epoch 3. (org.apache.kafka.controller.QuorumController:1065)
[2023-11-28 23:18:44,304] DEBUG [QuorumController id=0] completeUpTo(12): successfully completing Begin ZK Migration Transaction(665576742) (org.apache.kafka.deferred.DeferredEventQueue:61)
[2023-11-28 23:18:44,304] DEBUG [QuorumController id=0] Processed Begin ZK Migration Transaction(665576742) in 4929 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,308] DEBUG [QuorumController id=0] Processed handleCommit[baseOffset=12] in 4301 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,309] INFO [QuorumController id=0] Replayed TopicRecord for topic spam with topic ID qvRJLpDYRHmgEi8_TPBYTQ. (org.apache.kafka.controller.ReplicationControlManager:438)
[2023-11-28 23:18:44,309] INFO [QuorumController id=0] Replayed PartitionRecord for new partition spam-0 with topic ID qvRJLpDYRHmgEi8_TPBYTQ and PartitionRegistration(replicas=[0, 1, 2], directories=[AAAAAAAAAAAAAAAAAAAAAA, AAAAAAAAAAAAAAAAAAAAAA, AAAAAAAAAAAAAAAAAAAAAA], isr=[0, 1, 2], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager:452)
[2023-11-28 23:18:44,310] INFO [QuorumController id=0] Replayed PartitionRecord for new partition spam-1 with topic ID qvRJLpDYRHmgEi8_TPBYTQ and PartitionRegistration(replicas=[1, 2, 0], directories=[AAAAAAAAAAAAAAAAAAAAAA, AAAAAAAAAAAAAAAAAAAAAA, AAAAAAAAAAAAAAAAAAAAAA], isr=[1, 2, 0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager:452)
[2023-11-28 23:18:44,311] DEBUG append(batch=LocalRecordBatch(leaderEpoch=3, appendTimestamp=130, records=[ApiMessageAndVersion(TopicRecord(name='spam', topicId=qvRJLpDYRHmgEi8_TPBYTQ) at version 0), ApiMessageAndVersion(PartitionRecord(partitionId=0, topicId=qvRJLpDYRHmgEi8_TPBYTQ, replicas=[0, 1, 2], isr=[0, 1, 2], removingReplicas=[], addingReplicas=[], leader=0, leaderRecoveryState=0, leaderEpoch=0, partitionEpoch=0, eligibleLeaderReplicas=null, lastKnownELR=null, directories=[]) at version 0), ApiMessageAndVersion(PartitionRecord(partitionId=1, topicId=qvRJLpDYRHmgEi8_TPBYTQ, replicas=[1, 2, 0], isr=[1, 2, 0], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=0, leaderEpoch=0, partitionEpoch=0, eligibleLeaderReplicas=null, lastKnownELR=null, directories=[]) at version 0)]), nextEndOffset=15) (org.apache.kafka.metalog.LocalLogManager$SharedLogData:276)
[2023-11-28 23:18:44,311] DEBUG [LocalLogManager 0] Node 0: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:18:44,311] DEBUG [LocalLogManager 1] Node 1: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:18:44,312] DEBUG [LocalLogManager 2] Node 2: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:18:44,313] DEBUG [QuorumController id=2] Executing handleCommit[baseOffset=13]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,313] DEBUG [QuorumController id=2] Replaying commits from the active node up to offset 15 and epoch 3. (org.apache.kafka.controller.QuorumController:1079)
[2023-11-28 23:18:44,313] INFO [QuorumController id=2] Replayed TopicRecord for topic spam with topic ID qvRJLpDYRHmgEi8_TPBYTQ. (org.apache.kafka.controller.ReplicationControlManager:438)
[2023-11-28 23:18:44,314] INFO [QuorumController id=2] Replayed PartitionRecord for new partition spam-0 with topic ID qvRJLpDYRHmgEi8_TPBYTQ and PartitionRegistration(replicas=[0, 1, 2], directories=[AAAAAAAAAAAAAAAAAAAAAA, AAAAAAAAAAAAAAAAAAAAAA, AAAAAAAAAAAAAAAAAAAAAA], isr=[0, 1, 2], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager:452)
[2023-11-28 23:18:44,314] INFO [QuorumController id=2] Replayed PartitionRecord for new partition spam-1 with topic ID qvRJLpDYRHmgEi8_TPBYTQ and PartitionRegistration(replicas=[1, 2, 0], directories=[AAAAAAAAAAAAAAAAAAAAAA, AAAAAAAAAAAAAAAAAAAAAA, AAAAAAAAAAAAAAAAAAAAAA], isr=[1, 2, 0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager:452)
[2023-11-28 23:18:44,314] DEBUG [QuorumController id=2] Processed handleCommit[baseOffset=13] in 1256 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,314] DEBUG [QuorumController id=1] Executing handleCommit[baseOffset=13]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,315] DEBUG [QuorumController id=1] Replaying commits from the active node up to offset 15 and epoch 3. (org.apache.kafka.controller.QuorumController:1079)
[2023-11-28 23:18:44,315] INFO [QuorumController id=1] Replayed TopicRecord for topic spam with topic ID qvRJLpDYRHmgEi8_TPBYTQ. (org.apache.kafka.controller.ReplicationControlManager:438)
[2023-11-28 23:18:44,315] INFO [QuorumController id=1] Replayed PartitionRecord for new partition spam-0 with topic ID qvRJLpDYRHmgEi8_TPBYTQ and PartitionRegistration(replicas=[0, 1, 2], directories=[AAAAAAAAAAAAAAAAAAAAAA, AAAAAAAAAAAAAAAAAAAAAA, AAAAAAAAAAAAAAAAAAAAAA], isr=[0, 1, 2], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager:452)
[2023-11-28 23:18:44,315] INFO [QuorumController id=1] Replayed PartitionRecord for new partition spam-1 with topic ID qvRJLpDYRHmgEi8_TPBYTQ and PartitionRegistration(replicas=[1, 2, 0], directories=[AAAAAAAAAAAAAAAAAAAAAA, AAAAAAAAAAAAAAAAAAAAAA, AAAAAAAAAAAAAAAAAAAAAA], isr=[1, 2, 0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager:452)
[2023-11-28 23:18:44,315] DEBUG [QuorumController id=1] Processed handleCommit[baseOffset=13] in 1040 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,316] DEBUG [QuorumController id=0] Creating in-memory snapshot 15 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:18:44,316] DEBUG [QuorumController id=0] Read-write operation ZK Migration Batch(633367343) will be completed when the log reaches offset 15. (org.apache.kafka.controller.QuorumController:849)
[2023-11-28 23:18:44,316] DEBUG [QuorumController id=0] Executing handleCommit[baseOffset=13]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,316] DEBUG [QuorumController id=0] Completing purgatory items up to offset 15 and epoch 3. (org.apache.kafka.controller.QuorumController:1065)
[2023-11-28 23:18:44,317] DEBUG [QuorumController id=0] completeUpTo(15): successfully completing ZK Migration Batch(633367343) (org.apache.kafka.deferred.DeferredEventQueue:61)
[2023-11-28 23:18:44,317] DEBUG [QuorumController id=0] Processed ZK Migration Batch(633367343) in 8236 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,317] INFO [QuorumController id=0] Completing migration of ZooKeeper metadata to KRaft. (org.apache.kafka.controller.QuorumController:1028)
[2023-11-28 23:18:44,318] DEBUG [QuorumController id=0] Processed handleCommit[baseOffset=13] in 2306 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,319] INFO [QuorumController id=0] Replayed a ZkMigrationStateRecord changing the migration state from PRE_MIGRATION to MIGRATION. (org.apache.kafka.controller.FeatureControlManager:421)
[2023-11-28 23:18:44,319] INFO [QuorumController id=0] Replayed EndTransactionRecord() at offset 17. (org.apache.kafka.controller.OffsetControlManager:399)
[2023-11-28 23:18:44,319] DEBUG append(batch=LocalRecordBatch(leaderEpoch=3, appendTimestamp=160, records=[ApiMessageAndVersion(ZkMigrationStateRecord(zkMigrationState=1) at version 0), ApiMessageAndVersion(EndTransactionRecord() at version 0)]), nextEndOffset=17) (org.apache.kafka.metalog.LocalLogManager$SharedLogData:276)
[2023-11-28 23:18:44,320] DEBUG [LocalLogManager 0] Node 0: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:18:44,320] DEBUG [LocalLogManager 1] Node 1: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:18:44,320] DEBUG [LocalLogManager 2] Node 2: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:18:44,321] DEBUG [QuorumController id=1] Executing handleCommit[baseOffset=16]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,321] DEBUG [QuorumController id=1] Replaying commits from the active node up to offset 17 and epoch 3. (org.apache.kafka.controller.QuorumController:1079)
[2023-11-28 23:18:44,321] INFO [QuorumController id=1] Replayed a ZkMigrationStateRecord changing the migration state from PRE_MIGRATION to MIGRATION. (org.apache.kafka.controller.FeatureControlManager:421)
[2023-11-28 23:18:44,321] INFO [QuorumController id=1] Replayed EndTransactionRecord() at offset 17. (org.apache.kafka.controller.OffsetControlManager:399)
[2023-11-28 23:18:44,321] DEBUG [QuorumController id=1] Deleting in-memory snapshot 11 (org.apache.kafka.timeline.SnapshotRegistry:247)
[2023-11-28 23:18:44,322] DEBUG [QuorumController id=1] Creating in-memory snapshot 17 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:18:44,322] DEBUG [QuorumController id=1] Processed handleCommit[baseOffset=16] in 857 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,322] DEBUG [QuorumController id=2] Executing handleCommit[baseOffset=16]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,322] DEBUG [QuorumController id=2] Replaying commits from the active node up to offset 17 and epoch 3. (org.apache.kafka.controller.QuorumController:1079)
[2023-11-28 23:18:44,322] INFO [QuorumController id=2] Replayed a ZkMigrationStateRecord changing the migration state from PRE_MIGRATION to MIGRATION. (org.apache.kafka.controller.FeatureControlManager:421)
[2023-11-28 23:18:44,322] INFO [QuorumController id=2] Replayed EndTransactionRecord() at offset 17. (org.apache.kafka.controller.OffsetControlManager:399)
[2023-11-28 23:18:44,323] DEBUG [QuorumController id=2] Deleting in-memory snapshot 11 (org.apache.kafka.timeline.SnapshotRegistry:247)
[2023-11-28 23:18:44,324] DEBUG [QuorumController id=2] Creating in-memory snapshot 17 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:18:44,324] DEBUG [QuorumController id=2] Processed handleCommit[baseOffset=16] in 1714 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:18:44,324] DEBUG [QuorumController id=0] Creating in-memory snapshot 17 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:18:44,324] DEBUG [QuorumController id=0] Read-write operation Complete ZK Migration(2010487464) will be completed when the log reaches offset 17. (org.apache.kafka.controller.QuorumController:849)
[2023-11-28 23:18:44,324] DEBUG [QuorumController id=0] Executing handleCommit[baseOffset=16]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:18:44,325] DEBUG [QuorumController id=0] Completing purgatory items up to offset 17 and epoch 3. (org.apache.kafka.controller.QuorumController:1065)
[2023-11-28 23:18:44,325] DEBUG [QuorumController id=0] Deleting in-memory snapshot 11 (org.apa
...[truncated 2289845 chars]...
r=false, incarnationId=AAAAAAAAAAAAAAAAAAAAAA, brokerEpoch=5, endPoints=[], features=[BrokerFeature(name='metadata.version', minSupportedVersion=1, maxSupportedVersion=16)], rack='', fenced=true, inControlledShutdown=false, logDirs=[]) (org.apache.kafka.controller.ClusterControlManager:469)
[2023-11-28 23:19:30,387] DEBUG append(batch=LocalRecordBatch(leaderEpoch=1, appendTimestamp=50, records=[ApiMessageAndVersion(RegisterBrokerRecord(brokerId=0, isMigratingZkBroker=false, incarnationId=AAAAAAAAAAAAAAAAAAAAAA, brokerEpoch=5, endPoints=[], features=[BrokerFeature(name='metadata.version', minSupportedVersion=1, maxSupportedVersion=16)], rack='', fenced=true, inControlledShutdown=false, logDirs=[]) at version 2)]), nextEndOffset=5) (org.apache.kafka.metalog.LocalLogManager$SharedLogData:276)
[2023-11-28 23:19:30,387] DEBUG [QuorumController id=0] Creating in-memory snapshot 5 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:19:30,387] DEBUG [LocalLogManager 0] Node 0: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:19:30,387] DEBUG [QuorumController id=0] Read-write operation registerBroker(728887431) will be completed when the log reaches offset 5. (org.apache.kafka.controller.QuorumController:849)
[2023-11-28 23:19:30,387] DEBUG [QuorumController id=0] Executing handleCommit[baseOffset=5]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:19:30,387] DEBUG [QuorumController id=0] Completing purgatory items up to offset 5 and epoch 1. (org.apache.kafka.controller.QuorumController:1065)
[2023-11-28 23:19:30,387] DEBUG [QuorumController id=0] Deleting in-memory snapshot 4 (org.apache.kafka.timeline.SnapshotRegistry:247)
[2023-11-28 23:19:30,387] DEBUG [QuorumController id=0] completeUpTo(5): successfully completing registerBroker(728887431) (org.apache.kafka.deferred.DeferredEventQueue:61)
[2023-11-28 23:19:30,388] DEBUG [QuorumController id=0] Processed registerBroker(728887431) in 882 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:19:30,388] DEBUG [QuorumController id=0] Processed handleCommit[baseOffset=5] in 278 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:19:30,389] DEBUG [LocalLogManager 0] Node 0: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:19:30,392] INFO [QuorumController id=0] Replayed ConfigRecord for ConfigResource(type=BROKER, name='0') which set configuration baz to 123 (org.apache.kafka.controller.ConfigurationControlManager:423)
[2023-11-28 23:19:30,392] DEBUG append(batch=LocalRecordBatch(leaderEpoch=1, appendTimestamp=60, records=[ApiMessageAndVersion(ConfigRecord(resourceType=4, resourceName='0', name='baz', value='123') at version 0)]), nextEndOffset=6) (org.apache.kafka.metalog.LocalLogManager$SharedLogData:276)
[2023-11-28 23:19:30,392] DEBUG [QuorumController id=0] Creating in-memory snapshot 6 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:19:30,392] DEBUG [LocalLogManager 0] Node 0: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:19:30,392] DEBUG [QuorumController id=0] Read-write operation incrementalAlterConfigs(1030269060) will be completed when the log reaches offset 6. (org.apache.kafka.controller.QuorumController:849)
[2023-11-28 23:19:30,392] DEBUG [QuorumController id=0] Processed describeConfigs(1587831050) in 118 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:19:30,393] DEBUG [LocalLogManager 0] Node 0: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:19:30,393] DEBUG [QuorumController id=0] Executing handleCommit[baseOffset=6]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:19:30,393] DEBUG [QuorumController id=0] Completing purgatory items up to offset 6 and epoch 1. (org.apache.kafka.controller.QuorumController:1065)
[2023-11-28 23:19:30,393] DEBUG [QuorumController id=0] Deleting in-memory snapshot 5 (org.apache.kafka.timeline.SnapshotRegistry:247)
[2023-11-28 23:19:30,393] DEBUG [QuorumController id=0] completeUpTo(6): successfully completing incrementalAlterConfigs(1030269060) (org.apache.kafka.deferred.DeferredEventQueue:61)
[2023-11-28 23:19:30,393] DEBUG [QuorumController id=0] Processed incrementalAlterConfigs(1030269060) in 2269 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:19:30,393] DEBUG [QuorumController id=0] Processed handleCommit[baseOffset=6] in 298 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:19:30,413] INFO [QuorumController id=0] QuorumController#beginShutdown: shutting down event queue. (org.apache.kafka.queue.KafkaEventQueue:492)
[2023-11-28 23:19:30,413] DEBUG [QuorumController id=0] KafkaEventQueue#close: Event queue is already shutting down. (org.apache.kafka.queue.KafkaEventQueue:489)
[2023-11-28 23:19:30,414] INFO [QuorumController id=0] closed event queue. (org.apache.kafka.queue.KafkaEventQueue:514)
[2023-11-28 23:19:30,414] INFO [LocalLogManager 0] beginShutdown: shutting down event queue. (org.apache.kafka.queue.KafkaEventQueue:492)
[2023-11-28 23:19:30,414] DEBUG [LocalLogManager 0] Node 0: closing. (org.apache.kafka.metalog.LocalLogManager:653)
[2023-11-28 23:19:30,414] DEBUG [LocalLogManager 0] Node 0: beginning shutdown. (org.apache.kafka.metalog.LocalLogManager:637)
[2023-11-28 23:19:30,414] DEBUG [LocalLogManager 0] beginShutdown: Event queue is already shutting down. (org.apache.kafka.queue.KafkaEventQueue:489)
[2023-11-28 23:19:30,414] DEBUG [LocalLogManager 0] KafkaEventQueue#close: Event queue is already shutting down. (org.apache.kafka.queue.KafkaEventQueue:489)
[2023-11-28 23:19:30,414] DEBUG append(batch=LeaderChangeBatch(newLeader=LeaderAndEpoch(leaderId=OptionalInt.empty, epoch=2)), nextEndOffset=7) (org.apache.kafka.metalog.LocalLogManager$SharedLogData:276)
[2023-11-28 23:19:30,415] INFO Elected new leader: LeaderAndEpoch(leaderId=OptionalInt[0], epoch=3). (org.apache.kafka.metalog.LocalLogManager$SharedLogData:300)
[2023-11-28 23:19:30,415] DEBUG append(batch=LeaderChangeBatch(newLeader=LeaderAndEpoch(leaderId=OptionalInt[0], epoch=3)), nextEndOffset=8) (org.apache.kafka.metalog.LocalLogManager$SharedLogData:276)
[2023-11-28 23:19:30,415] DEBUG [QuorumController id=0] MetaLogManager.Listener: Event queue is already shutting down. (org.apache.kafka.queue.KafkaEventQueue:489)
[2023-11-28 23:19:30,415] INFO [LocalLogManager 0] closed event queue. (org.apache.kafka.queue.KafkaEventQueue:514)
[2023-11-28 23:19:30,418] INFO Elected new leader: LeaderAndEpoch(leaderId=OptionalInt[0], epoch=1). (org.apache.kafka.metalog.LocalLogManager$SharedLogData:300)
[2023-11-28 23:19:30,418] DEBUG append(batch=LeaderChangeBatch(newLeader=LeaderAndEpoch(leaderId=OptionalInt[0], epoch=1)), nextEndOffset=0) (org.apache.kafka.metalog.LocalLogManager$SharedLogData:276)
[2023-11-28 23:19:30,418] DEBUG [LocalLogManager 0] Node 0: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:19:30,418] DEBUG [LocalLogManager 0] initialized local log manager for node 0 (org.apache.kafka.metalog.LocalLogManager:685)
[2023-11-28 23:19:30,419] DEBUG [QuorumController id=0] Creating in-memory snapshot -1 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:19:30,419] INFO [QuorumController id=0] Creating new QuorumController with clusterId Mc36jzsJRY2gtjj4xi1NwQ. (org.apache.kafka.controller.QuorumController:1912)
[2023-11-28 23:19:30,419] INFO [LocalLogManager 0] Node 0: registered MetaLogListener 561551143 (org.apache.kafka.metalog.LocalLogManager:703)
[2023-11-28 23:19:30,420] DEBUG [LocalLogManager 0] Node 0: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:19:30,420] DEBUG [LocalLogManager 0] Node 0: Executing handleLeaderChange LeaderAndEpoch(leaderId=OptionalInt[0], epoch=1) (org.apache.kafka.metalog.LocalLogManager:578)
[2023-11-28 23:19:30,420] DEBUG [QuorumController id=0] Executing handleLeaderChange[1]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:19:30,420] INFO [QuorumController id=0] In the new epoch 1, the leader is (none). (org.apache.kafka.controller.QuorumController:1179)
[2023-11-28 23:19:30,420] DEBUG [QuorumController id=0] Processed handleLeaderChange[1] in 145 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:19:30,420] DEBUG [QuorumController id=0] Executing handleLeaderChange[1]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:19:30,420] INFO [QuorumController id=0] Becoming the active controller at epoch 1, next write offset 1. (org.apache.kafka.controller.QuorumController:1175)
[2023-11-28 23:19:30,421] DEBUG [QuorumController id=0] Processed handleLeaderChange[1] in 121 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:19:30,421] WARN [QuorumController id=0] Performing controller activation. The metadata log appears to be empty. Appending 1 bootstrap record(s) in metadata transaction at metadata.version 3.7-IV1 from bootstrap source 'test-provided version'. Setting the ZK migration state to NONE since this is a de-novo KRaft cluster. (org.apache.kafka.controller.QuorumController:108)
[2023-11-28 23:19:30,421] DEBUG [QuorumController id=0] Creating in-memory snapshot 0 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:19:30,421] INFO [QuorumController id=0] Replayed BeginTransactionRecord(name='Bootstrap records') at offset 1. (org.apache.kafka.controller.OffsetControlManager:387)
[2023-11-28 23:19:30,421] INFO [QuorumController id=0] Replayed a FeatureLevelRecord setting metadata version to 3.7-IV1 (org.apache.kafka.controller.FeatureControlManager:400)
[2023-11-28 23:19:30,421] DEBUG [QuorumController id=0] Replayed a ZkMigrationStateRecord which did not alter the state from NONE. (org.apache.kafka.controller.FeatureControlManager:417)
[2023-11-28 23:19:30,421] INFO [QuorumController id=0] Replayed EndTransactionRecord() at offset 4. (org.apache.kafka.controller.OffsetControlManager:399)
[2023-11-28 23:19:30,421] DEBUG append(batch=LocalRecordBatch(leaderEpoch=1, appendTimestamp=10, records=[ApiMessageAndVersion(BeginTransactionRecord(name='Bootstrap records') at version 0), ApiMessageAndVersion(FeatureLevelRecord(name='metadata.version', featureLevel=16) at version 0), ApiMessageAndVersion(ZkMigrationStateRecord(zkMigrationState=0) at version 0), ApiMessageAndVersion(EndTransactionRecord() at version 0)]), nextEndOffset=4) (org.apache.kafka.metalog.LocalLogManager$SharedLogData:276)
[2023-11-28 23:19:30,421] DEBUG [QuorumController id=0] Creating in-memory snapshot 4 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:19:30,421] DEBUG [LocalLogManager 0] Node 0: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:19:30,421] DEBUG [QuorumController id=0] Read-write operation completeActivation[1](1638202090) will be completed when the log reaches offset 4. (org.apache.kafka.controller.QuorumController:849)
[2023-11-28 23:19:30,421] DEBUG [QuorumController id=0] Executing handleCommit[baseOffset=1]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:19:30,421] DEBUG [QuorumController id=0] Completing purgatory items up to offset 4 and epoch 1. (org.apache.kafka.controller.QuorumController:1065)
[2023-11-28 23:19:30,421] DEBUG [QuorumController id=0] Deleting in-memory snapshot -1 (org.apache.kafka.timeline.SnapshotRegistry:247)
[2023-11-28 23:19:30,422] DEBUG [QuorumController id=0] Deleting in-memory snapshot 0 (org.apache.kafka.timeline.SnapshotRegistry:247)
[2023-11-28 23:19:30,422] DEBUG [QuorumController id=0] completeUpTo(4): successfully completing completeActivation[1](1638202090) (org.apache.kafka.deferred.DeferredEventQueue:61)
[2023-11-28 23:19:30,422] DEBUG [QuorumController id=0] Processed completeActivation[1](1638202090) in 1050 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:19:30,422] DEBUG [QuorumController id=0] Processed handleCommit[baseOffset=1] in 300 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:19:30,423] DEBUG [QuorumController id=0] Received an unclean shutdown request (org.apache.kafka.controller.ClusterControlManager:333)
[2023-11-28 23:19:30,424] INFO [QuorumController id=0] Replayed initial RegisterBrokerRecord for broker 0: RegisterBrokerRecord(brokerId=0, isMigratingZkBroker=false, incarnationId=AAAAAAAAAAAAAAAAAAAAAA, brokerEpoch=5, endPoints=[], features=[BrokerFeature(name='metadata.version', minSupportedVersion=1, maxSupportedVersion=16)], rack='', fenced=true, inControlledShutdown=false, logDirs=[]) (org.apache.kafka.controller.ClusterControlManager:469)
[2023-11-28 23:19:30,424] DEBUG append(batch=LocalRecordBatch(leaderEpoch=1, appendTimestamp=50, records=[ApiMessageAndVersion(RegisterBrokerRecord(brokerId=0, isMigratingZkBroker=false, incarnationId=AAAAAAAAAAAAAAAAAAAAAA, brokerEpoch=5, endPoints=[], features=[BrokerFeature(name='metadata.version', minSupportedVersion=1, maxSupportedVersion=16)], rack='', fenced=true, inControlledShutdown=false, logDirs=[]) at version 2)]), nextEndOffset=5) (org.apache.kafka.metalog.LocalLogManager$SharedLogData:276)
[2023-11-28 23:19:30,424] DEBUG [QuorumController id=0] Creating in-memory snapshot 5 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:19:30,424] DEBUG [QuorumController id=0] Read-write operation registerBroker(1472656669) will be completed when the log reaches offset 5. (org.apache.kafka.controller.QuorumController:849)
[2023-11-28 23:19:30,424] DEBUG [LocalLogManager 0] Node 0: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:19:30,424] DEBUG [QuorumController id=0] Executing handleCommit[baseOffset=5]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:19:30,424] DEBUG [QuorumController id=0] Completing purgatory items up to offset 5 and epoch 1. (org.apache.kafka.controller.QuorumController:1065)
[2023-11-28 23:19:30,424] DEBUG [QuorumController id=0] Deleting in-memory snapshot 4 (org.apache.kafka.timeline.SnapshotRegistry:247)
[2023-11-28 23:19:30,424] DEBUG [QuorumController id=0] completeUpTo(5): successfully completing registerBroker(1472656669) (org.apache.kafka.deferred.DeferredEventQueue:61)
[2023-11-28 23:19:30,424] DEBUG [QuorumController id=0] Processed registerBroker(1472656669) in 997 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:19:30,424] DEBUG [QuorumController id=0] Processed handleCommit[baseOffset=5] in 291 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:19:30,426] DEBUG [QuorumController id=0] Completing read-only operation incrementalAlterConfigs(301151909) immediately because the purgatory is empty. (org.apache.kafka.controller.QuorumController:802)
[2023-11-28 23:19:30,426] DEBUG [QuorumController id=0] Processed incrementalAlterConfigs(301151909) in 191 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:19:30,426] DEBUG [QuorumController id=0] Processed describeConfigs(1085673374) in 83 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:19:30,426] INFO [QuorumController id=0] Replayed ConfigRecord for ConfigResource(type=BROKER, name='0') which set configuration baz to 123 (org.apache.kafka.controller.ConfigurationControlManager:423)
[2023-11-28 23:19:30,426] DEBUG append(batch=LocalRecordBatch(leaderEpoch=1, appendTimestamp=60, records=[ApiMessageAndVersion(ConfigRecord(resourceType=4, resourceName='0', name='baz', value='123') at version 0)]), nextEndOffset=6) (org.apache.kafka.metalog.LocalLogManager$SharedLogData:276)
[2023-11-28 23:19:30,426] DEBUG [QuorumController id=0] Creating in-memory snapshot 6 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:19:30,426] DEBUG [LocalLogManager 0] Node 0: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:19:30,426] DEBUG [QuorumController id=0] Read-write operation incrementalAlterConfigs(678836276) will be completed when the log reaches offset 6. (org.apache.kafka.controller.QuorumController:849)
[2023-11-28 23:19:30,427] DEBUG [QuorumController id=0] Executing handleCommit[baseOffset=6]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:19:30,427] DEBUG [QuorumController id=0] Completing purgatory items up to offset 6 and epoch 1. (org.apache.kafka.controller.QuorumController:1065)
[2023-11-28 23:19:30,427] DEBUG [QuorumController id=0] Deleting in-memory snapshot 5 (org.apache.kafka.timeline.SnapshotRegistry:247)
[2023-11-28 23:19:30,427] DEBUG [QuorumController id=0] completeUpTo(6): successfully completing incrementalAlterConfigs(678836276) (org.apache.kafka.deferred.DeferredEventQueue:61)
[2023-11-28 23:19:30,427] DEBUG [QuorumController id=0] Processed incrementalAlterConfigs(678836276) in 633 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:19:30,427] DEBUG [QuorumController id=0] Processed handleCommit[baseOffset=6] in 205 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:19:30,427] DEBUG [QuorumController id=0] Processed describeConfigs(876773488) in 73 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:19:30,445] INFO [QuorumController id=0] QuorumController#beginShutdown: shutting down event queue. (org.apache.kafka.queue.KafkaEventQueue:492)
[2023-11-28 23:19:30,446] DEBUG [QuorumController id=0] KafkaEventQueue#close: Event queue is already shutting down. (org.apache.kafka.queue.KafkaEventQueue:489)
[2023-11-28 23:19:30,446] INFO [QuorumController id=0] closed event queue. (org.apache.kafka.queue.KafkaEventQueue:514)
[2023-11-28 23:19:30,446] INFO [LocalLogManager 0] beginShutdown: shutting down event queue. (org.apache.kafka.queue.KafkaEventQueue:492)
[2023-11-28 23:19:30,446] DEBUG [LocalLogManager 0] Node 0: closing. (org.apache.kafka.metalog.LocalLogManager:653)
[2023-11-28 23:19:30,446] DEBUG [LocalLogManager 0] beginShutdown: Event queue is already shutting down. (org.apache.kafka.queue.KafkaEventQueue:489)
[2023-11-28 23:19:30,446] DEBUG [LocalLogManager 0] KafkaEventQueue#close: Event queue is already shutting down. (org.apache.kafka.queue.KafkaEventQueue:489)
[2023-11-28 23:19:30,446] DEBUG [LocalLogManager 0] Node 0: beginning shutdown. (org.apache.kafka.metalog.LocalLogManager:637)
[2023-11-28 23:19:30,447] DEBUG append(batch=LeaderChangeBatch(newLeader=LeaderAndEpoch(leaderId=OptionalInt.empty, epoch=2)), nextEndOffset=7) (org.apache.kafka.metalog.LocalLogManager$SharedLogData:276)
[2023-11-28 23:19:30,447] INFO Elected new leader: LeaderAndEpoch(leaderId=OptionalInt[0], epoch=3). (org.apache.kafka.metalog.LocalLogManager$SharedLogData:300)
[2023-11-28 23:19:30,447] DEBUG append(batch=LeaderChangeBatch(newLeader=LeaderAndEpoch(leaderId=OptionalInt[0], epoch=3)), nextEndOffset=8) (org.apache.kafka.metalog.LocalLogManager$SharedLogData:276)
[2023-11-28 23:19:30,447] DEBUG [QuorumController id=0] MetaLogManager.Listener: Event queue is already shutting down. (org.apache.kafka.queue.KafkaEventQueue:489)
[2023-11-28 23:19:30,447] INFO [LocalLogManager 0] closed event queue. (org.apache.kafka.queue.KafkaEventQueue:514)
[2023-11-28 23:20:24,840] INFO Elected new leader: LeaderAndEpoch(leaderId=OptionalInt[0], epoch=1). (org.apache.kafka.metalog.LocalLogManager$SharedLogData:300)
[2023-11-28 23:20:24,850] DEBUG append(batch=LeaderChangeBatch(newLeader=LeaderAndEpoch(leaderId=OptionalInt[0], epoch=1)), nextEndOffset=0) (org.apache.kafka.metalog.LocalLogManager$SharedLogData:276)
[2023-11-28 23:20:24,873] DEBUG [LocalLogManager 0] Node 0: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:20:24,886] DEBUG [LocalLogManager 0] initialized local log manager for node 0 (org.apache.kafka.metalog.LocalLogManager:685)
[2023-11-28 23:20:24,886] DEBUG [LocalLogManager 2] initialized local log manager for node 2 (org.apache.kafka.metalog.LocalLogManager:685)
[2023-11-28 23:20:24,901] DEBUG [LocalLogManager 1] initialized local log manager for node 1 (org.apache.kafka.metalog.LocalLogManager:685)
[2023-11-28 23:20:25,211] DEBUG [QuorumController id=0] Creating in-memory snapshot -1 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:20:25,259] INFO [QuorumController id=0] Creating new QuorumController with clusterId E3kV7fukTtyuvzhBAJ1wcw. (org.apache.kafka.controller.QuorumController:1912)
[2023-11-28 23:20:25,274] INFO [LocalLogManager 0] Node 0: registered MetaLogListener 1650721856 (org.apache.kafka.metalog.LocalLogManager:703)
[2023-11-28 23:20:25,275] DEBUG [LocalLogManager 0] Node 0: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:20:25,276] DEBUG [QuorumController id=1] Creating in-memory snapshot -1 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:20:25,277] INFO [QuorumController id=1] Creating new QuorumController with clusterId E3kV7fukTtyuvzhBAJ1wcw. (org.apache.kafka.controller.QuorumController:1912)
[2023-11-28 23:20:25,276] DEBUG [LocalLogManager 0] Node 0: Executing handleLeaderChange LeaderAndEpoch(leaderId=OptionalInt[0], epoch=1) (org.apache.kafka.metalog.LocalLogManager:578)
[2023-11-28 23:20:25,282] INFO [LocalLogManager 1] Node 1: registered MetaLogListener 1364336646 (org.apache.kafka.metalog.LocalLogManager:703)
[2023-11-28 23:20:25,282] DEBUG [QuorumController id=0] Executing handleLeaderChange[1]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:20:25,283] INFO [QuorumController id=0] In the new epoch 1, the leader is (none). (org.apache.kafka.controller.QuorumController:1179)
[2023-11-28 23:20:25,283] DEBUG [QuorumController id=0] Processed handleLeaderChange[1] in 1631 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:20:25,283] DEBUG [QuorumController id=0] Executing handleLeaderChange[1]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:20:25,284] INFO [QuorumController id=0] Becoming the active controller at epoch 1, next write offset 1. (org.apache.kafka.controller.QuorumController:1175)
[2023-11-28 23:20:25,282] DEBUG [LocalLogManager 1] Node 1: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:20:25,286] DEBUG [LocalLogManager 1] Node 1: Executing handleLeaderChange LeaderAndEpoch(leaderId=OptionalInt[0], epoch=1) (org.apache.kafka.metalog.LocalLogManager:578)
[2023-11-28 23:20:25,295] DEBUG [QuorumController id=0] Processed handleLeaderChange[1] in 11419 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:20:25,297] DEBUG [QuorumController id=2] Creating in-memory snapshot -1 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:20:25,297] INFO [QuorumController id=2] Creating new QuorumController with clusterId E3kV7fukTtyuvzhBAJ1wcw. (org.apache.kafka.controller.QuorumController:1912)
[2023-11-28 23:20:25,298] INFO [LocalLogManager 2] Node 2: registered MetaLogListener 1875950366 (org.apache.kafka.metalog.LocalLogManager:703)
[2023-11-28 23:20:25,298] WARN [QuorumController id=0] Performing controller activation. The metadata log appears to be empty. Appending 1 bootstrap record(s) in metadata transaction at metadata.version 3.7-IV1 from bootstrap source 'test-provided version'. Setting the ZK migration state to NONE since this is a de-novo KRaft cluster. (org.apache.kafka.controller.QuorumController:108)
[2023-11-28 23:20:25,298] DEBUG [QuorumController id=1] Executing handleLeaderChange[1]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:20:25,299] DEBUG [LocalLogManager 2] Node 2: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:20:25,303] DEBUG [LocalLogManager 2] Node 2: Executing handleLeaderChange LeaderAndEpoch(leaderId=OptionalInt[0], epoch=1) (org.apache.kafka.metalog.LocalLogManager:578)
[2023-11-28 23:20:25,303] DEBUG [QuorumController id=2] Executing handleLeaderChange[1]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:20:25,304] INFO [QuorumController id=2] In the new epoch 1, the leader is (none). (org.apache.kafka.controller.QuorumController:1179)
[2023-11-28 23:20:25,304] DEBUG [QuorumController id=2] Processed handleLeaderChange[1] in 674 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:20:25,304] DEBUG [QuorumController id=2] Executing handleLeaderChange[1]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:20:25,304] INFO [QuorumController id=2] In the new epoch 1, the leader is 0. (org.apache.kafka.controller.QuorumController:1179)
[2023-11-28 23:20:25,305] DEBUG [QuorumController id=2] Processed handleLeaderChange[1] in 482 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:20:25,302] INFO [QuorumController id=1] In the new epoch 1, the leader is (none). (org.apache.kafka.controller.QuorumController:1179)
[2023-11-28 23:20:25,309] DEBUG [QuorumController id=1] Processed handleLeaderChange[1] in 10520 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:20:25,301] DEBUG [QuorumController id=0] Creating in-memory snapshot 0 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:20:25,309] DEBUG [QuorumController id=1] Executing handleLeaderChange[1]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:20:25,310] INFO [QuorumController id=0] Replayed BeginTransactionRecord(name='Bootstrap records') at offset 1. (org.apache.kafka.controller.OffsetControlManager:387)
[2023-11-28 23:20:25,310] INFO [QuorumController id=1] In the new epoch 1, the leader is 0. (org.apache.kafka.controller.QuorumController:1179)
[2023-11-28 23:20:25,311] DEBUG [QuorumController id=1] Processed handleLeaderChange[1] in 2013 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:20:25,317] INFO [QuorumController id=0] Replayed a FeatureLevelRecord setting metadata version to 3.7-IV1 (org.apache.kafka.controller.FeatureControlManager:400)
[2023-11-28 23:20:25,318] DEBUG [QuorumController id=0] Replayed a ZkMigrationStateRecord which did not alter the state from NONE. (org.apache.kafka.controller.FeatureControlManager:417)
[2023-11-28 23:20:25,319] INFO [QuorumController id=0] Replayed EndTransactionRecord() at offset 4. (org.apache.kafka.controller.OffsetControlManager:399)
[2023-11-28 23:20:25,319] DEBUG append(batch=LocalRecordBatch(leaderEpoch=1, appendTimestamp=10, records=[ApiMessageAndVersion(BeginTransactionRecord(name='Bootstrap records') at version 0), ApiMessageAndVersion(FeatureLevelRecord(name='metadata.version', featureLevel=16) at version 0), ApiMessageAndVersion(ZkMigrationStateRecord(zkMigrationState=0) at version 0), ApiMessageAndVersion(EndTransactionRecord() at version 0)]), nextEndOffset=4) (org.apache.kafka.metalog.LocalLogManager$SharedLogData:276)
[2023-11-28 23:20:25,320] DEBUG [LocalLogManager 2] Node 2: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:20:25,320] DEBUG [LocalLogManager 0] Node 0: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:20:25,320] DEBUG [QuorumController id=0] Creating in-memory snapshot 4 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:20:25,320] DEBUG [LocalLogManager 1] Node 1: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:20:25,323] DEBUG [QuorumController id=0] Read-write operation completeActivation[1](1744804930) will be completed when the log reaches offset 4. (org.apache.kafka.controller.QuorumController:849)
[2023-11-28 23:20:25,355] DEBUG [QuorumController id=1] Executing handleCommit[baseOffset=1]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:20:25,358] DEBUG [QuorumController id=1] Replaying commits from the active node up to offset 4 and epoch 1. (org.apache.kafka.controller.QuorumController:1079)
[2023-11-28 23:20:25,358] DEBUG [QuorumController id=1] Creating in-memory snapshot 0 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:20:25,358] INFO [QuorumController id=1] Replayed BeginTransactionRecord(name='Bootstrap records') at offset 1. (org.apache.kafka.controller.OffsetControlManager:387)
[2023-11-28 23:20:25,363] DEBUG [QuorumController id=2] Executing handleCommit[baseOffset=1]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:20:25,363] DEBUG [QuorumController id=2] Replaying commits from the active node up to offset 4 and epoch 1. (org.apache.kafka.controller.QuorumController:1079)
[2023-11-28 23:20:25,363] DEBUG [QuorumController id=2] Creating in-memory snapshot 0 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:20:25,364] INFO [QuorumController id=2] Replayed BeginTransactionRecord(name='Bootstrap records') at offset 1. (org.apache.kafka.controller.OffsetControlManager:387)
[2023-11-28 23:20:25,362] ERROR Encountered fatalFaultHandler fault: Unable to apply ConfigRecord record at offset 5 on active controller, from the batch with baseOffset 5 (org.apache.kafka.server.fault.MockFaultHandler:44)
java.lang.NullPointerException: name should not be null
	at java.base/java.util.Objects.requireNonNull(Objects.java:246)
	at org.apache.kafka.common.config.ConfigResource.<init>(ConfigResource.java:68)
	at org.apache.kafka.controller.ConfigurationControlManager.replay(ConfigurationControlManager.java:405)
	at org.apache.kafka.controller.QuorumController.replay(QuorumController.java:1504)
	at org.apache.kafka.controller.QuorumController.access$1600(QuorumController.java:177)
	at org.apache.kafka.controller.QuorumController$ControllerWriteEvent$1.apply(QuorumController.java:827)
	at org.apache.kafka.controller.QuorumController$ControllerWriteEvent$1.apply(QuorumController.java:816)
	at org.apache.kafka.controller.QuorumController.appendRecords(QuorumController.java:934)
	at org.apache.kafka.controller.QuorumController$ControllerWriteEvent.run(QuorumController.java:815)
	at org.apache.kafka.queue.KafkaEventQueue$EventContext.run(KafkaEventQueue.java:127)
	at org.apache.kafka.queue.KafkaEventQueue$EventHandler.handleEvents(KafkaEventQueue.java:210)
	at org.apache.kafka.queue.KafkaEventQueue$EventHandler.run(KafkaEventQueue.java:181)
	at java.base/java.lang.Thread.run(Thread.java:829)
[2023-11-28 23:20:25,368] INFO [QuorumController id=1] Replayed a FeatureLevelRecord setting metadata version to 3.7-IV1 (org.apache.kafka.controller.FeatureControlManager:400)
[2023-11-28 23:20:25,364] INFO [QuorumController id=2] Replayed a FeatureLevelRecord setting metadata version to 3.7-IV1 (org.apache.kafka.controller.FeatureControlManager:400)
[2023-11-28 23:20:25,370] DEBUG [QuorumController id=2] Replayed a ZkMigrationStateRecord which did not alter the state from NONE. (org.apache.kafka.controller.FeatureControlManager:417)
[2023-11-28 23:20:25,371] INFO [QuorumController id=2] Replayed EndTransactionRecord() at offset 4. (org.apache.kafka.controller.OffsetControlManager:399)
[2023-11-28 23:20:25,372] DEBUG [QuorumController id=2] Deleting in-memory snapshot -1 (org.apache.kafka.timeline.SnapshotRegistry:247)
[2023-11-28 23:20:25,372] DEBUG [QuorumController id=2] Deleting in-memory snapshot 0 (org.apache.kafka.timeline.SnapshotRegistry:247)
[2023-11-28 23:20:25,372] DEBUG [QuorumController id=2] Creating in-memory snapshot 4 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:20:25,372] DEBUG [QuorumController id=2] Processed handleCommit[baseOffset=1] in 9576 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:20:25,373] DEBUG [QuorumController id=0] Got exception while running errorEvent(349457813). Invoking handleException. (org.apache.kafka.queue.KafkaEventQueue:132)
org.apache.kafka.server.fault.FaultHandlerException: fatalFaultHandler: Unable to apply ConfigRecord record at offset 5 on active controller, from the batch with baseOffset 5: name should not be null
	at java.base/java.util.Objects.requireNonNull(Objects.java:246)
	at org.apache.kafka.common.config.ConfigResource.<init>(ConfigResource.java:68)
	at org.apache.kafka.controller.ConfigurationControlManager.replay(ConfigurationControlManager.java:405)
	at org.apache.kafka.controller.QuorumController.replay(QuorumController.java:1504)
	at org.apache.kafka.controller.QuorumController.access$1600(QuorumController.java:177)
	at org.apache.kafka.controller.QuorumController$ControllerWriteEvent$1.apply(QuorumController.java:827)
	at org.apache.kafka.controller.QuorumController$ControllerWriteEvent$1.apply(QuorumController.java:816)
	at org.apache.kafka.controller.QuorumController.appendRecords(QuorumController.java:934)
	at org.apache.kafka.controller.QuorumController$ControllerWriteEvent.run(QuorumController.java:815)
	at org.apache.kafka.queue.KafkaEventQueue$EventContext.run(KafkaEventQueue.java:127)
	at org.apache.kafka.queue.KafkaEventQueue$EventHandler.handleEvents(KafkaEventQueue.java:210)
	at org.apache.kafka.queue.KafkaEventQueue$EventHandler.run(KafkaEventQueue.java:181)
	at java.base/java.lang.Thread.run(Thread.java:829)
Caused by: java.lang.NullPointerException: name should not be null
	... 13 more
[2023-11-28 23:20:25,370] DEBUG [QuorumController id=1] Replayed a ZkMigrationStateRecord which did not alter the state from NONE. (org.apache.kafka.controller.FeatureControlManager:417)
[2023-11-28 23:20:25,379] INFO [QuorumController id=1] Replayed EndTransactionRecord() at offset 4. (org.apache.kafka.controller.OffsetControlManager:399)
[2023-11-28 23:20:25,379] DEBUG [QuorumController id=1] Deleting in-memory snapshot -1 (org.apache.kafka.timeline.SnapshotRegistry:247)
[2023-11-28 23:20:25,380] DEBUG [QuorumController id=1] Deleting in-memory snapshot 0 (org.apache.kafka.timeline.SnapshotRegistry:247)
[2023-11-28 23:20:25,380] DEBUG [QuorumController id=1] Creating in-memory snapshot 4 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:20:25,380] DEBUG [QuorumController id=1] Processed handleCommit[baseOffset=1] in 25223 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:20:25,383] ERROR Encountered nonFatalFaultHandler fault: errorEvent: event failed with FaultHandlerException (treated as UnknownServerException) at epoch 1 in 56509 microseconds. Renouncing leadership and reverting to the last committed offset -1. (org.apache.kafka.server.fault.MockFaultHandler:44)
org.apache.kafka.server.fault.FaultHandlerException: fatalFaultHandler: Unable to apply ConfigRecord record at offset 5 on active controller, from the batch with baseOffset 5: name should not be null
	at java.base/java.util.Objects.requireNonNull(Objects.java:246)
	at org.apache.kafka.common.config.ConfigResource.<init>(ConfigResource.java:68)
	at org.apache.kafka.controller.ConfigurationControlManager.replay(ConfigurationControlManager.java:405)
	at org.apache.kafka.controller.QuorumController.replay(QuorumController.java:1504)
	at org.apache.kafka.controller.QuorumController.access$1600(QuorumController.java:177)
	at org.apache.kafka.controller.QuorumController$ControllerWriteEvent$1.apply(QuorumController.java:827)
	at org.apache.kafka.controller.QuorumController$ControllerWriteEvent$1.apply(QuorumController.java:816)
	at org.apache.kafka.controller.QuorumController.appendRecords(QuorumController.java:934)
	at org.apache.kafka.controller.QuorumController$ControllerWriteEvent.run(QuorumController.java:815)
	at org.apache.kafka.queue.KafkaEventQueue$EventContext.run(KafkaEventQueue.java:127)
	at org.apache.kafka.queue.KafkaEventQueue$EventHandler.handleEvents(KafkaEventQueue.java:210)
	at org.apache.kafka.queue.KafkaEventQueue$EventHandler.run(KafkaEventQueue.java:181)
	at java.base/java.lang.Thread.run(Thread.java:829)
Caused by: java.lang.NullPointerException: name should not be null
	... 13 more
[2023-11-28 23:20:25,389] DEBUG append(batch=LeaderChangeBatch(newLeader=LeaderAndEpoch(leaderId=OptionalInt.empty, epoch=2)), nextEndOffset=5) (org.apache.kafka.metalog.LocalLogManager$SharedLogData:276)
[2023-11-28 23:20:25,389] DEBUG [LocalLogManager 1] Node 1: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:20:25,389] INFO Elected new leader: LeaderAndEpoch(leaderId=OptionalInt[2], epoch=3). (org.apache.kafka.metalog.LocalLogManager$SharedLogData:300)
[2023-11-28 23:20:25,389] DEBUG [LocalLogManager 2] Node 2: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:20:25,390] DEBUG [LocalLogManager 0] Node 0: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:20:25,390] DEBUG append(batch=LeaderChangeBatch(newLeader=LeaderAndEpoch(leaderId=OptionalInt[2], epoch=3)), nextEndOffset=6) (org.apache.kafka.metalog.LocalLogManager$SharedLogData:276)
[2023-11-28 23:20:25,393] DEBUG [LocalLogManager 2] Node 2: Ignoring LeaderAndEpoch(leaderId=OptionalInt.empty, epoch=2) since it doesn't match the latest known leader LeaderAndEpoch(leaderId=OptionalInt[2], epoch=3) (org.apache.kafka.metalog.LocalLogManager:585)
[2023-11-28 23:20:25,393] DEBUG [LocalLogManager 0] Node 0: Ignoring LeaderAndEpoch(leaderId=OptionalInt.empty, epoch=2) since it doesn't match the latest known leader LeaderAndEpoch(leaderId=OptionalInt[2], epoch=3) (org.apache.kafka.metalog.LocalLogManager:585)
[2023-11-28 23:20:25,399] DEBUG [LocalLogManager 0] Node 0: Executing handleLeaderChange LeaderAndEpoch(leaderId=OptionalInt[2], epoch=3) (org.apache.kafka.metalog.LocalLogManager:578)
[2023-11-28 23:20:25,400] DEBUG [LocalLogManager 0] Node 0: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:20:25,393] DEBUG [LocalLogManager 1] Node 1: Ignoring LeaderAndEpoch(leaderId=OptionalInt.empty, epoch=2) since it doesn't match the latest known leader LeaderAndEpoch(leaderId=OptionalInt[2], epoch=3) (org.apache.kafka.metalog.LocalLogManager:585)
[2023-11-28 23:20:25,393] DEBUG [LocalLogManager 2] Node 2: Executing handleLeaderChange LeaderAndEpoch(leaderId=OptionalInt[2], epoch=3) (org.apache.kafka.metalog.LocalLogManager:578)
[2023-11-28 23:20:25,401] DEBUG [LocalLogManager 2] Node 2: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:20:25,401] DEBUG [QuorumController id=2] Executing handleLeaderChange[3]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:20:25,402] INFO [QuorumController id=2] In the new epoch 3, the leader is (none). (org.apache.kafka.controller.QuorumController:1179)
[2023-11-28 23:20:25,402] DEBUG [QuorumController id=2] Processed handleLeaderChange[3] in 450 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:20:25,402] DEBUG [QuorumController id=2] Executing handleLeaderChange[3]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:20:25,402] INFO [QuorumController id=2] Becoming the active controller at epoch 3, next write offset 7. (org.apache.kafka.controller.QuorumController:1175)
[2023-11-28 23:20:25,403] DEBUG [QuorumController id=2] Processed handleLeaderChange[3] in 489 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:20:25,403] WARN [QuorumController id=2] Performing controller activation. Loaded ZK migration state of NONE. (org.apache.kafka.controller.QuorumController:204)
[2023-11-28 23:20:25,404] DEBUG [QuorumController id=2] Completing read-only operation completeActivation[3](152946851) immediately because the purgatory is empty. (org.apache.kafka.controller.QuorumController:802)
[2023-11-28 23:20:25,404] DEBUG [QuorumController id=2] Processed completeActivation[3](152946851) in 1105 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:20:25,401] INFO [QuorumController id=0] failAll(NotControllerException): failing completeActivation[1](1744804930). (org.apache.kafka.deferred.DeferredEventQueue:83)
[2023-11-28 23:20:25,401] DEBUG [LocalLogManager 1] Node 1: Executing handleLeaderChange LeaderAndEpoch(leaderId=OptionalInt[2], epoch=3) (org.apache.kafka.metalog.LocalLogManager:578)
[2023-11-28 23:20:25,405] DEBUG [LocalLogManager 1] Node 1: running log check. (org.apache.kafka.metalog.LocalLogManager:536)
[2023-11-28 23:20:25,405] DEBUG [QuorumController id=1] Executing handleLeaderChange[3]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:20:25,406] INFO [QuorumController id=1] In the new epoch 3, the leader is (none). (org.apache.kafka.controller.QuorumController:1179)
[2023-11-28 23:20:25,406] DEBUG [QuorumController id=1] Processed handleLeaderChange[3] in 402 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:20:25,406] DEBUG [QuorumController id=1] Executing handleLeaderChange[3]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:20:25,406] INFO [QuorumController id=1] In the new epoch 3, the leader is 2. (org.apache.kafka.controller.QuorumController:1179)
[2023-11-28 23:20:25,406] DEBUG [QuorumController id=1] Processed handleLeaderChange[3] in 413 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:20:25,416] INFO [QuorumController id=0] completeActivation[1]: event failed with NotControllerException in 120110 microseconds. (org.apache.kafka.controller.QuorumController:542)
[2023-11-28 23:20:25,416] DEBUG [QuorumController id=0] Reverting to in-memory snapshot -1 (org.apache.kafka.timeline.SnapshotRegistry:213)
[2023-11-28 23:20:25,416] DEBUG [QuorumController id=0] Deleting in-memory snapshot 0 because we are reverting to -1 (org.apache.kafka.timeline.SnapshotRegistry:219)
[2023-11-28 23:20:25,417] DEBUG [QuorumController id=0] Deleting in-memory snapshot 0 (org.apache.kafka.timeline.SnapshotRegistry:247)
[2023-11-28 23:20:25,418] DEBUG [QuorumController id=0] Deleting in-memory snapshot 4 because we are reverting to -1 (org.apache.kafka.timeline.SnapshotRegistry:219)
[2023-11-28 23:20:25,418] DEBUG [QuorumController id=0] Deleting in-memory snapshot 4 (org.apache.kafka.timeline.SnapshotRegistry:247)
[2023-11-28 23:20:25,421] DEBUG [QuorumController id=0] Executing handleCommit[baseOffset=1]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:20:25,421] INFO [QuorumController id=0] QuorumController#beginShutdown: shutting down event queue. (org.apache.kafka.queue.KafkaEventQueue:492)
[2023-11-28 23:20:25,421] INFO [QuorumController id=1] QuorumController#beginShutdown: shutting down event queue. (org.apache.kafka.queue.KafkaEventQueue:492)
[2023-11-28 23:20:25,422] INFO [QuorumController id=2] QuorumController#beginShutdown: shutting down event queue. (org.apache.kafka.queue.KafkaEventQueue:492)
[2023-11-28 23:20:25,422] DEBUG [QuorumController id=0] KafkaEventQueue#close: Event queue is already shutting down. (org.apache.kafka.queue.KafkaEventQueue:489)
[2023-11-28 23:20:25,423] DEBUG [QuorumController id=0] Replaying commits from the active node up to offset 4 and epoch 1. (org.apache.kafka.controller.QuorumController:1079)
[2023-11-28 23:20:25,424] DEBUG [QuorumController id=0] Creating in-memory snapshot 0 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:20:25,424] INFO [QuorumController id=0] Replayed BeginTransactionRecord(name='Bootstrap records') at offset 1. (org.apache.kafka.controller.OffsetControlManager:387)
[2023-11-28 23:20:25,424] INFO [QuorumController id=0] Replayed a FeatureLevelRecord setting metadata version to 3.7-IV1 (org.apache.kafka.controller.FeatureControlManager:400)
[2023-11-28 23:20:25,424] DEBUG [QuorumController id=0] Replayed a ZkMigrationStateRecord which did not alter the state from NONE. (org.apache.kafka.controller.FeatureControlManager:417)
[2023-11-28 23:20:25,425] INFO [QuorumController id=0] Replayed EndTransactionRecord() at offset 4. (org.apache.kafka.controller.OffsetControlManager:399)
[2023-11-28 23:20:25,425] DEBUG [QuorumController id=0] Deleting in-memory snapshot -1 (org.apache.kafka.timeline.SnapshotRegistry:247)
[2023-11-28 23:20:25,425] DEBUG [QuorumController id=0] Deleting in-memory snapshot 0 (org.apache.kafka.timeline.SnapshotRegistry:247)
[2023-11-28 23:20:25,425] DEBUG [QuorumController id=0] Creating in-memory snapshot 4 (org.apache.kafka.timeline.SnapshotRegistry:203)
[2023-11-28 23:20:25,426] DEBUG [QuorumController id=0] Processed handleCommit[baseOffset=1] in 5187 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:20:25,427] DEBUG [QuorumController id=0] Executing handleLeaderChange[3]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:20:25,427] INFO [QuorumController id=0] In the new epoch 3, the leader is (none). (org.apache.kafka.controller.QuorumController:1179)
[2023-11-28 23:20:25,427] DEBUG [QuorumController id=0] Processed handleLeaderChange[3] in 506 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:20:25,428] DEBUG [QuorumController id=0] Executing handleLeaderChange[3]. (org.apache.kafka.controller.QuorumController:577)
[2023-11-28 23:20:25,428] INFO [QuorumController id=0] In the new epoch 3, the leader is 2. (org.apache.kafka.controller.QuorumController:1179)
[2023-11-28 23:20:25,428] DEBUG [QuorumController id=0] Processed handleLeaderChange[3] in 639 us (org.apache.kafka.controller.QuorumController:510)
[2023-11-28 23:20:25,429] INFO [QuorumController id=0] closed event queue. (org.apache.kafka.queue.KafkaEventQueue:514)
[2023-11-28 23:20:25,430] DEBUG [QuorumController id=1] KafkaEventQueue#close: Event queue is already shutting down. (org.apache.kafka.queue.KafkaEventQueue:489)
[2023-11-28 23:20:25,430] INFO [QuorumController id=1] closed event queue. (org.apache.kafka.queue.KafkaEventQueue:514)
[2023-11-28 23:20:25,430] DEBUG [QuorumController id=2] KafkaEventQueue#close: Event queue is already shutting down. (org.apache.kafka.queue.KafkaEventQueue:489)
[2023-11-28 23:20:25,430] INFO [QuorumController id=2] closed event queue. (org.apache.kafka.queue.KafkaEventQueue:514)
[2023-11-28 23:20:25,431] INFO [LocalLogManager 0] beginShutdown: shutting down event queue. (org.apache.kafka.queue.KafkaEventQueue:492)
[2023-11-28 23:20:25,431] INFO [LocalLogManager 1] beginShutdown: shutting down event queue. (org.apache.kafka.queue.KafkaEventQueue:492)
[2023-11-28 23:20:25,431] DEBUG [LocalLogManager 0] Node 0: beginning shutdown. (org.apache.kafka.metalog.LocalLogManager:637)
[2023-11-28 23:20:25,432] DEBUG [LocalLogManager 1] Node 1: beginning shutdown. (org.apache.kafka.metalog.LocalLogManager:637)
[2023-11-28 23:20:25,432] DEBUG tryAppend(nodeId=0, epoch=3): the given node id does not match the current leader id of OptionalInt[2]. (org.apache.kafka.metalog.LocalLogManager$SharedLogData:246)
[2023-11-28 23:20:25,431] INFO [LocalLogManager 2] beginShutdown: shutting down event queue. (org.apache.kafka.queue.KafkaEventQueue:492)
[2023-11-28 23:20:25,432] DEBUG [LocalLogManager 0] Node 0: closing. (org.apache.kafka.metalog.LocalLogManager:653)
[2023-11-28 23:20:25,433] DEBUG [LocalLogManager 0] beginShutdown: Event queue is already shutting down. (org.apache.kafka.queue.KafkaEventQueue:489)
[2023-11-28 23:20:25,433] DEBUG [LocalLogManager 0] KafkaEventQueue#close: Event queue is already shutting down. (org.apache.kafka.queue.KafkaEventQueue:489)
[2023-11-28 23:20:25,432] DEBUG [LocalLogManager 0] Ignoring call to resign from epoch 3. Either we are not the leader or the provided epoch is smaller than the current epoch 3 (org.apache.kafka.metalog.LocalLogManager:828)
[2023-11-28 23:20:25,432] DEBUG tryAppend(nodeId=1, epoch=3): the given node id does not match the current leader id of OptionalInt[2]. (org.apache.kafka.metalog.LocalLogManager$SharedLogData:246)
[2023-11-28 23:20:25,434] DEBUG [QuorumController id=0] MetaLogManager.Listener: Event queue is already shutting down. (org.apache.kafka.queue.KafkaEventQueue:489)
[2023-11-28 23:20:25,434] INFO [LocalLogManager 0] closed event queue. (org.apache.kafka.queue.KafkaEventQueue:514)
[2023-11-28 23:20:25,433] DEBUG [LocalLogManager 2] Node 2: beginning shutdown. (org.apache.kafka.metalog.LocalLogManager:637)
[2023-11-28 23:20:25,434] DEBUG append(batch=LeaderChangeBatch(newLeader=LeaderAndEpoch(leaderId=OptionalInt.empty, epoch=4)), nextEndOffset=7) (org.apache.kafka.metalog.LocalLogManager$SharedLogData:276)
[2023-11-28 23:20:25,435] INFO Elected new leader: LeaderAndEpoch(leaderId=OptionalInt[2], epoch=5). (org.apache.kafka.metalog.LocalLogManager$SharedLogData:300)
[2023-11-28 23:20:25,435] DEBUG append(batch=LeaderChangeBatch(newLeader=LeaderAndEpoch(leaderId=OptionalInt[2], epoch=5)), nextEndOffset=8) (org.apache.kafka.metalog.LocalLogManager$SharedLogData:276)
[2023-11-28 23:20:25,435] DEBUG [QuorumController id=2] MetaLogManager.Listener: Event queue is already shutting down. (org.apache.kafka.queue.KafkaEventQueue:489)
[2023-11-28 23:20:25,434] DEBUG [LocalLogManager 1] Ignoring call to resign from epoch 3. Either we are not the leader or the provided epoch is smaller than the current epoch 3 (org.apache.kafka.metalog.LocalLogManager:828)
[2023-11-28 23:20:25,438] DEBUG [QuorumController id=1] MetaLogManager.Listener: Event queue is already shutting down. (org.apache.kafka.queue.KafkaEventQueue:489)
[2023-11-28 23:20:25,436] DEBUG [LocalLogManager 1] Node 1: closing. (org.apache.kafka.metalog.LocalLogManager:653)
[2023-11-28 23:20:25,438] DEBUG [LocalLogManager 1] beginShutdown: Event queue is already shutting down. (org.apache.kafka.queue.KafkaEventQueue:489)
[2023-11-28 23:20:25,439] DEBUG [LocalLogManager 1] KafkaEventQueue#close: Event queue is already shutting down. (org.apache.kafka.queue.KafkaEventQueue:489)
[2023-11-28 23:20:25,440] INFO [LocalLogManager 1] closed event queue. (org.apache.kafka.queue.KafkaEventQueue:514)
[2023-11-28 23:20:25,440] DEBUG [LocalLogManager 2] Node 2: closing. (org.apache.kafka.metalog.LocalLogManager:653)
[2023-11-28 23:20:25,440] DEBUG [LocalLogManager 2] beginShutdown: Event queue is already shutting down. (org.apache.kafka.queue.KafkaEventQueue:489)
[2023-11-28 23:20:25,440] DEBUG [LocalLogManager 2] KafkaEventQueue#close: Event queue is already shutting down. (org.apache.kafka.queue.KafkaEventQueue:489)
[2023-11-28 23:20:25,441] INFO [LocalLogManager 2] closed event queue. (org.apache.kafka.queue.KafkaEventQueue:514)