82 lines
31 KiB
Plaintext
82 lines
31 KiB
Plaintext
[2025-05-27 20:15:43,699] INFO [QuorumController id=1] Registering periodic task writeNoOpRecord to run every 500 ms (org.apache.kafka.controller.PeriodicTaskControlManager)
|
|
[2025-05-27 20:15:43,700] INFO [QuorumController id=1] Registering periodic task maybeFenceStaleBroker to run every 1125 ms (org.apache.kafka.controller.PeriodicTaskControlManager)
|
|
[2025-05-27 20:15:43,701] INFO [QuorumController id=1] Registering periodic task electPreferred to run every 300000 ms (org.apache.kafka.controller.PeriodicTaskControlManager)
|
|
[2025-05-27 20:15:43,701] INFO [QuorumController id=1] Registering periodic task electUnclean to run every 300000 ms (org.apache.kafka.controller.PeriodicTaskControlManager)
|
|
[2025-05-27 20:15:43,701] INFO [QuorumController id=1] Registering periodic task expireDelegationTokens to run every 3600000 ms (org.apache.kafka.controller.PeriodicTaskControlManager)
|
|
[2025-05-27 20:15:43,701] INFO [QuorumController id=1] Registering periodic task generatePeriodicPerformanceMessage to run every 60000 ms (org.apache.kafka.controller.PeriodicTaskControlManager)
|
|
[2025-05-27 20:15:43,702] INFO [QuorumController id=1] Creating new QuorumController with clusterId VcD4VONhTsGM90xh5WBCZg (org.apache.kafka.controller.QuorumController)
|
|
[2025-05-27 20:15:45,109] INFO [QuorumController id=1] In the new epoch 1, the leader is (none). (org.apache.kafka.controller.QuorumController)
|
|
[2025-05-27 20:15:45,160] INFO [QuorumController id=1] In the new epoch 1, the leader is 2. (org.apache.kafka.controller.QuorumController)
|
|
[2025-05-27 20:15:45,275] INFO [QuorumController id=1] Replayed BeginTransactionRecord(name='Bootstrap records') at offset 1. (org.apache.kafka.controller.OffsetControlManager)
|
|
[2025-05-27 20:15:45,275] INFO [QuorumController id=1] Replayed a FeatureLevelRecord setting metadata.version to 4.0-IV3 (org.apache.kafka.controller.FeatureControlManager)
|
|
[2025-05-27 20:15:45,276] INFO [QuorumController id=1] Replayed a FeatureLevelRecord setting feature group.version to 1 (org.apache.kafka.controller.FeatureControlManager)
|
|
[2025-05-27 20:15:45,276] INFO [QuorumController id=1] Replayed a FeatureLevelRecord setting feature transaction.version to 2 (org.apache.kafka.controller.FeatureControlManager)
|
|
[2025-05-27 20:15:45,276] INFO [QuorumController id=1] Replayed EndTransactionRecord() at offset 5. (org.apache.kafka.controller.OffsetControlManager)
|
|
[2025-05-27 20:15:45,296] INFO [QuorumController id=1] Replayed initial RegisterBrokerRecord for broker 2: RegisterBrokerRecord(brokerId=2, isMigratingZkBroker=false, incarnationId=5WtO3reJTcmhbqG1JH-dlg, brokerEpoch=6, endPoints=[BrokerEndpoint(name='INTERNAL', host='192.168.0.73', port=9094, securityProtocol=0), BrokerEndpoint(name='EXTERNAL', host='114.110.129.227', port=19092, securityProtocol=0)], features=[BrokerFeature(name='group.version', minSupportedVersion=0, maxSupportedVersion=1), BrokerFeature(name='transaction.version', minSupportedVersion=0, maxSupportedVersion=2), BrokerFeature(name='eligible.leader.replicas.version', minSupportedVersion=0, maxSupportedVersion=1), BrokerFeature(name='kraft.version', minSupportedVersion=0, maxSupportedVersion=1), BrokerFeature(name='metadata.version', minSupportedVersion=7, maxSupportedVersion=25)], rack=null, fenced=true, inControlledShutdown=false, logDirs=[ifcI0CksDfkMPP_O2LpC7g]) (org.apache.kafka.controller.ClusterControlManager)
|
|
[2025-05-27 20:15:45,316] INFO [QuorumController id=1] Replayed initial RegisterBrokerRecord for broker 1: RegisterBrokerRecord(brokerId=1, isMigratingZkBroker=false, incarnationId=d-m3sk0uRiOv4Xb_gjgAMA, brokerEpoch=7, endPoints=[BrokerEndpoint(name='INTERNAL', host='192.168.0.87', port=9094, securityProtocol=0), BrokerEndpoint(name='EXTERNAL', host='114.110.129.227', port=19092, securityProtocol=0)], features=[BrokerFeature(name='group.version', minSupportedVersion=0, maxSupportedVersion=1), BrokerFeature(name='transaction.version', minSupportedVersion=0, maxSupportedVersion=2), BrokerFeature(name='eligible.leader.replicas.version', minSupportedVersion=0, maxSupportedVersion=1), BrokerFeature(name='kraft.version', minSupportedVersion=0, maxSupportedVersion=1), BrokerFeature(name='metadata.version', minSupportedVersion=7, maxSupportedVersion=25)], rack=null, fenced=true, inControlledShutdown=false, logDirs=[ofqKBRdP9magMuiqSEoHfg]) (org.apache.kafka.controller.ClusterControlManager)
|
|
[2025-05-27 20:15:45,316] INFO [QuorumController id=1] Replayed initial RegisterBrokerRecord for broker 3: RegisterBrokerRecord(brokerId=3, isMigratingZkBroker=false, incarnationId=OxI-hxirQOGhx8MvOozl6g, brokerEpoch=8, endPoints=[BrokerEndpoint(name='INTERNAL', host='192.168.0.88', port=9094, securityProtocol=0), BrokerEndpoint(name='EXTERNAL', host='114.110.129.227', port=19092, securityProtocol=0)], features=[BrokerFeature(name='group.version', minSupportedVersion=0, maxSupportedVersion=1), BrokerFeature(name='transaction.version', minSupportedVersion=0, maxSupportedVersion=2), BrokerFeature(name='eligible.leader.replicas.version', minSupportedVersion=0, maxSupportedVersion=1), BrokerFeature(name='kraft.version', minSupportedVersion=0, maxSupportedVersion=1), BrokerFeature(name='metadata.version', minSupportedVersion=7, maxSupportedVersion=25)], rack=null, fenced=true, inControlledShutdown=false, logDirs=[CyGkaTw01x6AL6KDcim5hQ]) (org.apache.kafka.controller.ClusterControlManager)
|
|
[2025-05-27 20:15:45,320] INFO [QuorumController id=1] Replayed RegisterControllerRecord containing ControllerRegistration(id=2, incarnationId=HuTWG0vVSzuDMRTk9TChXw, zkMigrationReady=false, listeners=[Endpoint(listenerName='CONTROLLER', securityProtocol=PLAINTEXT, host='192.168.0.73', port=9093)], supportedFeatures={eligible.leader.replicas.version: 0-1, group.version: 0-1, kraft.version: 0-1, metadata.version: 7-25, transaction.version: 0-2}). (org.apache.kafka.controller.ClusterControlManager)
|
|
[2025-05-27 20:15:45,400] INFO [QuorumController id=1] Replayed RegisterControllerRecord containing ControllerRegistration(id=3, incarnationId=RR3xDlHIQoifXhNAsZg7QQ, zkMigrationReady=false, listeners=[Endpoint(listenerName='CONTROLLER', securityProtocol=PLAINTEXT, host='192.168.0.88', port=9093)], supportedFeatures={eligible.leader.replicas.version: 0-1, group.version: 0-1, kraft.version: 0-1, metadata.version: 7-25, transaction.version: 0-2}). (org.apache.kafka.controller.ClusterControlManager)
|
|
[2025-05-27 20:15:45,400] INFO [QuorumController id=1] Replayed RegisterControllerRecord containing ControllerRegistration(id=1, incarnationId=K3W9NstrSjGCWNgeFAZuLw, zkMigrationReady=false, listeners=[Endpoint(listenerName='CONTROLLER', securityProtocol=PLAINTEXT, host='192.168.0.87', port=9093)], supportedFeatures={eligible.leader.replicas.version: 0-1, group.version: 0-1, kraft.version: 0-1, metadata.version: 7-25, transaction.version: 0-2}). (org.apache.kafka.controller.ClusterControlManager)
|
|
[2025-05-27 20:15:45,454] INFO [QuorumController id=1] Replayed BrokerRegistrationChangeRecord modifying the registration for broker 2: BrokerRegistrationChangeRecord(brokerId=2, brokerEpoch=6, fenced=-1, inControlledShutdown=0, logDirs=[]) (org.apache.kafka.controller.ClusterControlManager)
|
|
[2025-05-27 20:15:45,743] INFO [QuorumController id=1] Replayed BrokerRegistrationChangeRecord modifying the registration for broker 1: BrokerRegistrationChangeRecord(brokerId=1, brokerEpoch=7, fenced=-1, inControlledShutdown=0, logDirs=[]) (org.apache.kafka.controller.ClusterControlManager)
|
|
[2025-05-27 20:15:45,743] INFO [QuorumController id=1] Replayed BrokerRegistrationChangeRecord modifying the registration for broker 3: BrokerRegistrationChangeRecord(brokerId=3, brokerEpoch=8, fenced=-1, inControlledShutdown=0, logDirs=[]) (org.apache.kafka.controller.ClusterControlManager)
|
|
[2025-05-27 20:23:30,813] INFO [QuorumController id=1] Replayed TopicRecord for topic test-topic with topic ID vXuH9_ZNQI2c0R-bVWG_WA. (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:23:30,820] INFO [QuorumController id=1] Replayed PartitionRecord for new partition test-topic-0 with topic ID vXuH9_ZNQI2c0R-bVWG_WA and PartitionRegistration(replicas=[1], directories=[ofqKBRdP9magMuiqSEoHfg], isr=[1], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:24:44,836] INFO [QuorumController id=1] Replaying ProducerIdsRecord ProducerIdsRecord(brokerId=1, brokerEpoch=7, nextProducerId=1000) (org.apache.kafka.controller.ProducerIdControlManager)
|
|
[2025-05-27 20:24:45,335] INFO [QuorumController id=1] Replaying ProducerIdsRecord ProducerIdsRecord(brokerId=3, brokerEpoch=8, nextProducerId=2000) (org.apache.kafka.controller.ProducerIdControlManager)
|
|
[2025-05-27 20:26:03,850] INFO [QuorumController id=1] Replayed TopicRecord for topic __consumer_offsets with topic ID iKTtSMP_Qhe2qNEqoWMbig. (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,851] INFO [QuorumController id=1] Replayed ConfigRecord for ConfigResource(type=TOPIC, name='__consumer_offsets') which set configuration compression.type to producer (org.apache.kafka.controller.ConfigurationControlManager)
|
|
[2025-05-27 20:26:03,851] INFO [QuorumController id=1] Replayed ConfigRecord for ConfigResource(type=TOPIC, name='__consumer_offsets') which set configuration cleanup.policy to compact (org.apache.kafka.controller.ConfigurationControlManager)
|
|
[2025-05-27 20:26:03,851] INFO [QuorumController id=1] Replayed ConfigRecord for ConfigResource(type=TOPIC, name='__consumer_offsets') which set configuration segment.bytes to 104857600 (org.apache.kafka.controller.ConfigurationControlManager)
|
|
[2025-05-27 20:26:03,851] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-0 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[2], directories=[ifcI0CksDfkMPP_O2LpC7g], isr=[2], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,851] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-1 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[3], directories=[CyGkaTw01x6AL6KDcim5hQ], isr=[3], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=3, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,851] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-2 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[1], directories=[ofqKBRdP9magMuiqSEoHfg], isr=[1], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,851] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-3 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[1], directories=[ofqKBRdP9magMuiqSEoHfg], isr=[1], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,852] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-4 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[2], directories=[ifcI0CksDfkMPP_O2LpC7g], isr=[2], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,852] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-5 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[3], directories=[CyGkaTw01x6AL6KDcim5hQ], isr=[3], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=3, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,852] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-6 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[3], directories=[CyGkaTw01x6AL6KDcim5hQ], isr=[3], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=3, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,852] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-7 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[2], directories=[ifcI0CksDfkMPP_O2LpC7g], isr=[2], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,852] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-8 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[1], directories=[ofqKBRdP9magMuiqSEoHfg], isr=[1], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,852] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-9 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[1], directories=[ofqKBRdP9magMuiqSEoHfg], isr=[1], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,852] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-10 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[3], directories=[CyGkaTw01x6AL6KDcim5hQ], isr=[3], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=3, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,852] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-11 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[2], directories=[ifcI0CksDfkMPP_O2LpC7g], isr=[2], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,852] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-12 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[2], directories=[ifcI0CksDfkMPP_O2LpC7g], isr=[2], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,852] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-13 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[1], directories=[ofqKBRdP9magMuiqSEoHfg], isr=[1], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,852] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-14 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[3], directories=[CyGkaTw01x6AL6KDcim5hQ], isr=[3], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=3, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,852] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-15 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[2], directories=[ifcI0CksDfkMPP_O2LpC7g], isr=[2], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,853] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-16 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[3], directories=[CyGkaTw01x6AL6KDcim5hQ], isr=[3], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=3, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,853] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-17 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[1], directories=[ofqKBRdP9magMuiqSEoHfg], isr=[1], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,853] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-18 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[1], directories=[ofqKBRdP9magMuiqSEoHfg], isr=[1], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,853] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-19 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[2], directories=[ifcI0CksDfkMPP_O2LpC7g], isr=[2], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,853] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-20 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[3], directories=[CyGkaTw01x6AL6KDcim5hQ], isr=[3], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=3, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,853] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-21 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[3], directories=[CyGkaTw01x6AL6KDcim5hQ], isr=[3], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=3, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,853] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-22 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[1], directories=[ofqKBRdP9magMuiqSEoHfg], isr=[1], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,853] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-23 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[2], directories=[ifcI0CksDfkMPP_O2LpC7g], isr=[2], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,853] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-24 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[2], directories=[ifcI0CksDfkMPP_O2LpC7g], isr=[2], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,853] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-25 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[1], directories=[ofqKBRdP9magMuiqSEoHfg], isr=[1], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,854] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-26 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[3], directories=[CyGkaTw01x6AL6KDcim5hQ], isr=[3], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=3, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,854] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-27 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[1], directories=[ofqKBRdP9magMuiqSEoHfg], isr=[1], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,854] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-28 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[3], directories=[CyGkaTw01x6AL6KDcim5hQ], isr=[3], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=3, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,854] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-29 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[2], directories=[ifcI0CksDfkMPP_O2LpC7g], isr=[2], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,854] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-30 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[1], directories=[ofqKBRdP9magMuiqSEoHfg], isr=[1], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,854] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-31 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[3], directories=[CyGkaTw01x6AL6KDcim5hQ], isr=[3], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=3, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,854] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-32 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[2], directories=[ifcI0CksDfkMPP_O2LpC7g], isr=[2], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,854] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-33 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[1], directories=[ofqKBRdP9magMuiqSEoHfg], isr=[1], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,854] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-34 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[2], directories=[ifcI0CksDfkMPP_O2LpC7g], isr=[2], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,854] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-35 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[3], directories=[CyGkaTw01x6AL6KDcim5hQ], isr=[3], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=3, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,854] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-36 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[3], directories=[CyGkaTw01x6AL6KDcim5hQ], isr=[3], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=3, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,855] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-37 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[2], directories=[ifcI0CksDfkMPP_O2LpC7g], isr=[2], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,855] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-38 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[1], directories=[ofqKBRdP9magMuiqSEoHfg], isr=[1], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,855] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-39 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[1], directories=[ofqKBRdP9magMuiqSEoHfg], isr=[1], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,855] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-40 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[3], directories=[CyGkaTw01x6AL6KDcim5hQ], isr=[3], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=3, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,855] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-41 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[2], directories=[ifcI0CksDfkMPP_O2LpC7g], isr=[2], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,855] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-42 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[1], directories=[ofqKBRdP9magMuiqSEoHfg], isr=[1], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,855] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-43 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[2], directories=[ifcI0CksDfkMPP_O2LpC7g], isr=[2], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,855] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-44 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[3], directories=[CyGkaTw01x6AL6KDcim5hQ], isr=[3], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=3, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,855] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-45 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[3], directories=[CyGkaTw01x6AL6KDcim5hQ], isr=[3], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=3, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,855] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-46 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[1], directories=[ofqKBRdP9magMuiqSEoHfg], isr=[1], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,855] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-47 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[2], directories=[ifcI0CksDfkMPP_O2LpC7g], isr=[2], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=2, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,855] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-48 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[3], directories=[CyGkaTw01x6AL6KDcim5hQ], isr=[3], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=3, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|
|
[2025-05-27 20:26:03,856] INFO [QuorumController id=1] Replayed PartitionRecord for new partition __consumer_offsets-49 with topic ID iKTtSMP_Qhe2qNEqoWMbig and PartitionRegistration(replicas=[1], directories=[ofqKBRdP9magMuiqSEoHfg], isr=[1], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
|