[2022-05-17 08:26:36,015] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
[2022-05-17 08:26:36,526] INFO Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation (org.apache.zookeeper.common.X509Util)
[2022-05-17 08:26:36,884] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka/data] Recovering unflushed segment 0 (kafka.log.LogLoader)
[2022-05-17 08:26:36,891] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:36,892] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka/data] Reloading from producer snapshot and rebuilding producer state from offset 0 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:36,895] INFO Deleted producer state snapshot /opt/kafka/data/__cluster_metadata-0/00000000000000000221.snapshot (kafka.log.SnapshotFile)
[2022-05-17 08:26:36,896] INFO Deleted producer state snapshot /opt/kafka/data/__cluster_metadata-0/00000000000000000223.snapshot (kafka.log.SnapshotFile)
[2022-05-17 08:26:36,898] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka/data] Producer state recovery took 6ms for snapshot load and 0ms for segment recovery from offset 0 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:36,943] INFO [ProducerStateManager partition=__cluster_metadata-0] Wrote producer snapshot at offset 223 with 0 producer ids in 9 ms. (kafka.log.ProducerStateManager)
[2022-05-17 08:26:36,982] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka/data] Loading producer state till offset 223 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:36,982] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka/data] Reloading from producer snapshot and rebuilding producer state from offset 223 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:36,986] INFO [ProducerStateManager partition=__cluster_metadata-0] Loading producer state from snapshot file 'SnapshotFile(/opt/kafka/data/__cluster_metadata-0/00000000000000000223.snapshot,223)' (kafka.log.ProducerStateManager)
[2022-05-17 08:26:36,990] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka/data] Producer state recovery took 8ms for snapshot load and 0ms for segment recovery from offset 223 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:37,343] INFO [raft-expiration-reaper]: Starting (kafka.raft.TimingWheelExpirationService$ExpiredOperationReaper)
[2022-05-17 08:26:37,638] INFO [RaftManager nodeId=1] Completed transition to ResignedState(localId=1, epoch=3, voters=[1], electionTimeoutMs=1547, unackedVoters=[], preferredSuccessors=[]) (org.apache.kafka.raft.QuorumState)
[2022-05-17 08:26:37,650] INFO [RaftManager nodeId=1] Completed transition to CandidateState(localId=1, epoch=4, retries=1, electionTimeoutMs=1462) (org.apache.kafka.raft.QuorumState)
[2022-05-17 08:26:37,664] INFO [RaftManager nodeId=1] Completed transition to Leader(localId=1, epoch=4, epochStartOffset=223, highWatermark=Optional.empty, voterStates={1=ReplicaState(nodeId=1, endOffset=Optional.empty, lastFetchTimestamp=OptionalLong.empty, hasAcknowledgedLeader=true)}) (org.apache.kafka.raft.QuorumState)
[2022-05-17 08:26:37,730] INFO Registered signal handlers for TERM, INT, HUP (org.apache.kafka.common.utils.LoggingSignalHandler)
[2022-05-17 08:26:37,739] INFO [kafka-raft-outbound-request-thread]: Starting (kafka.raft.RaftSendThread)
[2022-05-17 08:26:37,740] INFO [kafka-raft-io-thread]: Starting (kafka.raft.KafkaRaftManager$RaftIoThread)
[2022-05-17 08:26:37,741] INFO Starting controller (kafka.server.ControllerServer)
[2022-05-17 08:26:37,749] INFO [StandardAuthorizer 1] set super.users=User:Applications:f8df59ea-2eeb-4101-89ed-2aa1fb5fc86c,User:CN=onlinesuiteplus-kafka,OU=Services,O=B. Braun Melsungen AG,L=Melsungen,C=DE, default result=DENIED (org.apache.kafka.metadata.authorizer.StandardAuthorizerData)[2022-05-17 08:26:38,282] INFO Updated connection-accept-rate max connection creation rate to 2147483647 (kafka.network.ConnectionQuotas)
[2022-05-17 08:26:38,289] INFO Awaiting socket connections on 0.0.0.0:9091. (kafka.network.DataPlaneAcceptor)
[2022-05-17 08:26:38,367] INFO [SocketServer listenerType=CONTROLLER, nodeId=1] Created data-plane acceptor and processors for endpoint : ListenerName(CONTROLLER) (kafka.network.SocketServer)
[2022-05-17 08:26:38,435] INFO [RaftManager nodeId=1] Registered the listener org.apache.kafka.controller.QuorumController$QuorumMetaLogListener@473509680 (org.apache.kafka.raft.KafkaRaftClient)
[2022-05-17 08:26:38,447] INFO [ThrottledChannelReaper-Fetch]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2022-05-17 08:26:38,453] INFO [ThrottledChannelReaper-Produce]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2022-05-17 08:26:38,454] INFO [ThrottledChannelReaper-Request]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2022-05-17 08:26:38,457] INFO [ThrottledChannelReaper-ControllerMutation]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2022-05-17 08:26:38,460] INFO [Controller 1] Registered new broker: RegisterBrokerRecord(brokerId=1, incarnationId=dbbGioe3T9-bZJEsgJTGIQ, brokerEpoch=0, endPoints=[BrokerEndpoint(name='DEVIN', host='onlinesuiteplus-kafka', port=29092, securityProtocol=0), BrokerEndpoint(name='DOCKER', host='onlinesuiteplus-kafka', port=29093, securityProtocol=1), BrokerEndpoint(name='EXTERNAL', host='localhost', port=9093, securityProtocol=1)], features=[], rack=null, fenced=true) (org.apache.kafka.controller.ClusterControlManager)
[2022-05-17 08:26:38,461] INFO [Controller 1] Unfenced broker: UnfenceBrokerRecord(id=1, epoch=0) (org.apache.kafka.controller.ClusterControlManager)
[2022-05-17 08:26:38,468] INFO [Controller 1] ConfigResource(type=TOPIC, name='ais.register.error'): set configuration message.timestamp.type to LogAppendTime (org.apache.kafka.controller.ConfigurationControlManager)
[2022-05-17 08:26:38,469] INFO [Controller 1] ConfigResource(type=TOPIC, name='ais.register.app'): set configuration message.timestamp.type to LogAppendTime (org.apache.kafka.controller.ConfigurationControlManager)
[2022-05-17 08:26:38,469] INFO [Controller 1] ConfigResource(type=TOPIC, name='ais.register.app'): set configuration retention.ms to 172800000 (org.apache.kafka.controller.ConfigurationControlManager)
[2022-05-17 08:26:38,469] INFO [Controller 1] ConfigResource(type=TOPIC, name='ais.command.app'): set configuration compression.type to uncompressed (org.apache.kafka.controller.ConfigurationControlManager)
[2022-05-17 08:26:38,470] INFO [Controller 1] ConfigResource(type=TOPIC, name='ais.command.app'): set configuration message.timestamp.type to LogAppendTime (org.apache.kafka.controller.ConfigurationControlManager)
[2022-05-17 08:26:38,470] INFO [Controller 1] ConfigResource(type=TOPIC, name='ais.command.app'): set configuration retention.ms to 8640000000 (org.apache.kafka.controller.ConfigurationControlManager)
[2022-05-17 08:26:38,470] INFO [Controller 1] ConfigResource(type=TOPIC, name='ais.meta.app'): set configuration compression.type to uncompressed (org.apache.kafka.controller.ConfigurationControlManager)
[2022-05-17 08:26:38,470] INFO [Controller 1] ConfigResource(type=TOPIC, name='ais.meta.app'): set configuration cleanup.policy to compact (org.apache.kafka.controller.ConfigurationControlManager)
[2022-05-17 08:26:38,470] INFO [Controller 1] ConfigResource(type=TOPIC, name='ais.meta.app'): set configuration max.compaction.lag.ms to 3600000 (org.apache.kafka.controller.ConfigurationControlManager)
[2022-05-17 08:26:38,471] INFO [Controller 1] ConfigResource(type=TOPIC, name='ais.meta.app'): set configuration message.timestamp.type to LogAppendTime (org.apache.kafka.controller.ConfigurationControlManager)
[2022-05-17 08:26:38,471] INFO [Controller 1] ConfigResource(type=TOPIC, name='ais.meta.app'): set configuration segment.bytes to 10485760 (org.apache.kafka.controller.ConfigurationControlManager)
[2022-05-17 08:26:38,471] INFO [Controller 1] ConfigResource(type=TOPIC, name='ais.meta.app'): set configuration retention.ms to -1 (org.apache.kafka.controller.ConfigurationControlManager)
[2022-05-17 08:26:38,471] INFO [Controller 1] ConfigResource(type=TOPIC, name='ais.meta.app'): set configuration segment.index.bytes to 1048576 (org.apache.kafka.controller.ConfigurationControlManager)
[2022-05-17 08:26:38,471] INFO [Controller 1] ConfigResource(type=TOPIC, name='ais.meta.app'): set configuration delete.retention.ms to 60000 (org.apache.kafka.controller.ConfigurationControlManager)
[2022-05-17 08:26:38,472] INFO [Controller 1] Created topic ais.register.error with topic ID n1tEsHq8RSqQIX3u5Bh0eA. (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,475] INFO [Controller 1] Created partition ais.register.error-0 with topic ID n1tEsHq8RSqQIX3u5Bh0eA and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,478] INFO [Controller 1] Created topic ais.register.app with topic ID _xFmib8uS7SF6izdRriBVg. (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,479] INFO [Controller 1] Created partition ais.register.app-0 with topic ID _xFmib8uS7SF6izdRriBVg and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,480] INFO [Controller 1] Created topic ais.command.app with topic ID mgdBOxs5QeaU-7TLMYG4ug. (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,481] INFO [Controller 1] Created partition ais.command.app-0 with topic ID mgdBOxs5QeaU-7TLMYG4ug and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,481] INFO [Controller 1] Created topic ais.meta.app with topic ID l3Jt6hLxSVq5zQfqnpbd7g. (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,486] INFO [Controller 1] Created partition ais.meta.app-0 with topic ID l3Jt6hLxSVq5zQfqnpbd7g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,487] INFO [Controller 1] ConfigResource(type=TOPIC, name='ais.app.f8df59ea-2eeb-4101-89ed-2aa1fb5fc86c'): set configuration message.timestamp.type to LogAppendTime (org.apache.kafka.controller.ConfigurationControlManager)
[2022-05-17 08:26:38,487] INFO [Controller 1] ConfigResource(type=TOPIC, name='ais.app.f8df59ea-2eeb-4101-89ed-2aa1fb5fc86c'): set configuration retention.ms to 8640000000 (org.apache.kafka.controller.ConfigurationControlManager)
[2022-05-17 08:26:38,487] INFO [Controller 1] ConfigResource(type=TOPIC, name='ais.app.f8df59ea-2eeb-4101-89ed-2aa1fb5fc86c'): set configuration segment.bytes to 10485760 (org.apache.kafka.controller.ConfigurationControlManager)
[2022-05-17 08:26:38,488] INFO [Controller 1] ConfigResource(type=TOPIC, name='ais.app.f8df59ea-2eeb-4101-89ed-2aa1fb5fc86c'): set configuration segment.index.bytes to 1048576 (org.apache.kafka.controller.ConfigurationControlManager)
[2022-05-17 08:26:38,488] INFO [Controller 1] Created topic ais.app.f8df59ea-2eeb-4101-89ed-2aa1fb5fc86c with topic ID aY0BpYXAR9-4pym2xa1enQ. (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,488] INFO [Controller 1] Created partition ais.app.f8df59ea-2eeb-4101-89ed-2aa1fb5fc86c-0 with topic ID aY0BpYXAR9-4pym2xa1enQ and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,495] INFO [Controller 1] ConfigResource(type=TOPIC, name='__consumer_offsets'): set configuration compression.type to producer (org.apache.kafka.controller.ConfigurationControlManager)
[2022-05-17 08:26:38,495] INFO [Controller 1] ConfigResource(type=TOPIC, name='__consumer_offsets'): set configuration cleanup.policy to compact (org.apache.kafka.controller.ConfigurationControlManager)
[2022-05-17 08:26:38,496] INFO [Controller 1] ConfigResource(type=TOPIC, name='__consumer_offsets'): set configuration segment.bytes to 104857600 (org.apache.kafka.controller.ConfigurationControlManager)
[2022-05-17 08:26:38,496] INFO [Controller 1] Created topic __consumer_offsets with topic ID GrwIxT-yTi2kAF63Iwbr4g. (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,496] INFO [Controller 1] Created partition __consumer_offsets-0 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,496] INFO [Controller 1] Created partition __consumer_offsets-1 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,496] INFO [Controller 1] Created partition __consumer_offsets-2 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,497] INFO [Controller 1] Created partition __consumer_offsets-3 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,497] INFO [Controller 1] Created partition __consumer_offsets-4 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,497] INFO [Controller 1] Created partition __consumer_offsets-5 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,497] INFO [ExpirationReaper-1-AlterAcls]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2022-05-17 08:26:38,497] INFO [Controller 1] Created partition __consumer_offsets-6 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,497] INFO [Controller 1] Created partition __consumer_offsets-7 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,498] INFO [Controller 1] Created partition __consumer_offsets-8 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,498] INFO [Controller 1] Created partition __consumer_offsets-9 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,498] INFO [Controller 1] Created partition __consumer_offsets-10 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,499] INFO [Controller 1] Created partition __consumer_offsets-11 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,500] INFO [Controller 1] Created partition __consumer_offsets-12 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,500] INFO [Controller 1] Created partition __consumer_offsets-13 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,500] INFO [Controller 1] Created partition __consumer_offsets-14 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,500] INFO [Controller 1] Created partition __consumer_offsets-15 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,501] INFO [Controller 1] Created partition __consumer_offsets-16 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,502] INFO [Controller 1] Created partition __consumer_offsets-17 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,503] INFO [Controller 1] Created partition __consumer_offsets-18 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,503] INFO [Controller 1] Created partition __consumer_offsets-19 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,503] INFO [Controller 1] Created partition __consumer_offsets-20 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,504] INFO [Controller 1] Created partition __consumer_offsets-21 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,504] INFO [Controller 1] Created partition __consumer_offsets-22 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,504] INFO [Controller 1] Created partition __consumer_offsets-23 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,504] INFO [Controller 1] Created partition __consumer_offsets-24 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,505] INFO [Controller 1] Created partition __consumer_offsets-25 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,506] INFO [Controller 1] Created partition __consumer_offsets-26 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,507] INFO [Controller 1] Created partition __consumer_offsets-27 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,507] INFO [Controller 1] Created partition __consumer_offsets-28 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,507] INFO [Controller 1] Created partition __consumer_offsets-29 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,508] INFO [Controller 1] Created partition __consumer_offsets-30 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,508] INFO [Controller 1] Created partition __consumer_offsets-31 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,508] INFO [Controller 1] Created partition __consumer_offsets-32 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,512] INFO [Controller 1] Created partition __consumer_offsets-33 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,513] INFO [Controller 1] Created partition __consumer_offsets-34 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,513] INFO [Controller 1] Created partition __consumer_offsets-35 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,513] INFO [Controller 1] Created partition __consumer_offsets-36 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,513] INFO [Controller 1] Created partition __consumer_offsets-37 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,514] INFO [Controller 1] Created partition __consumer_offsets-38 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,514] INFO [Controller 1] Created partition __consumer_offsets-39 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,514] INFO [Controller 1] Created partition __consumer_offsets-40 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,514] INFO [Controller 1] Created partition __consumer_offsets-41 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,514] INFO [Controller 1] Created partition __consumer_offsets-42 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,515] INFO [Controller 1] Created partition __consumer_offsets-43 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,515] INFO [Controller 1] Created partition __consumer_offsets-44 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,516] INFO [Controller 1] Created partition __consumer_offsets-45 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,516] INFO [Controller 1] Created partition __consumer_offsets-46 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,516] INFO [Controller 1] Created partition __consumer_offsets-47 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,516] INFO [Controller 1] Created partition __consumer_offsets-48 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,516] INFO [Controller 1] Created partition __consumer_offsets-49 with topic ID GrwIxT-yTi2kAF63Iwbr4g and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager)
[2022-05-17 08:26:38,533] INFO [Controller 1] Fenced broker: FenceBrokerRecord(id=1, epoch=0) (org.apache.kafka.controller.ClusterControlManager)
[2022-05-17 08:26:38,534] INFO [Controller 1] Re-registered broker id 1: RegisterBrokerRecord(brokerId=1, incarnationId=Tw8wj6PtTaS_LWgKO5MEyw, brokerEpoch=219, endPoints=[BrokerEndpoint(name='DEVIN', host='onlinesuiteplus-kafka', port=29092, securityProtocol=0), BrokerEndpoint(name='DOCKER', host='onlinesuiteplus-kafka', port=29093, securityProtocol=1), BrokerEndpoint(name='EXTERNAL', host='localhost', port=9093, securityProtocol=1)], features=[], rack=null, fenced=true) (org.apache.kafka.controller.ClusterControlManager)
[2022-05-17 08:26:38,534] INFO [Controller 1] Re-registered broker id 1: RegisterBrokerRecord(brokerId=1, incarnationId=Q1axkZuxSAqRxPfBCuHjGg, brokerEpoch=221, endPoints=[BrokerEndpoint(name='DEVIN', host='onlinesuiteplus-kafka', port=29092, securityProtocol=0), BrokerEndpoint(name='DOCKER', host='onlinesuiteplus-kafka', port=29093, securityProtocol=1), BrokerEndpoint(name='EXTERNAL', host='localhost', port=9093, securityProtocol=1)], features=[], rack=null, fenced=true) (org.apache.kafka.controller.ClusterControlManager)
[2022-05-17 08:26:38,537] INFO [Controller 1] Becoming the active controller at epoch 4, committed offset 222 and committed epoch 3. (org.apache.kafka.controller.QuorumController)
[2022-05-17 08:26:38,544] INFO [SocketServer listenerType=CONTROLLER, nodeId=1] Starting socket server acceptors and processors (kafka.network.SocketServer)
[2022-05-17 08:26:38,553] INFO [SocketServer listenerType=CONTROLLER, nodeId=1] Started data-plane acceptor and processor(s) for endpoint : ListenerName(CONTROLLER) (kafka.network.SocketServer)
[2022-05-17 08:26:38,553] INFO [SocketServer listenerType=CONTROLLER, nodeId=1] Started socket server acceptors and processors (kafka.network.SocketServer)
[2022-05-17 08:26:38,555] INFO [BrokerServer id=1] Transition from SHUTDOWN to STARTING (kafka.server.BrokerServer)
[2022-05-17 08:26:38,557] INFO [BrokerServer id=1] Starting broker (kafka.server.BrokerServer)
[2022-05-17 08:26:38,583] INFO [ThrottledChannelReaper-Fetch]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2022-05-17 08:26:38,584] INFO [ThrottledChannelReaper-Produce]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2022-05-17 08:26:38,584] INFO [ThrottledChannelReaper-Request]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2022-05-17 08:26:38,585] INFO [ThrottledChannelReaper-ControllerMutation]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2022-05-17 08:26:38,638] INFO [BrokerToControllerChannelManager broker=1 name=forwarding]: Starting (kafka.server.BrokerToControllerRequestThread)
[2022-05-17 08:26:38,642] INFO [BrokerToControllerChannelManager broker=1 name=forwarding]: Recorded new controller, from now on will use broker onlinesuiteplus-kafka:9091 (id: 1 rack: null) (kafka.server.BrokerToControllerRequestThread)
[2022-05-17 08:26:38,706] INFO Updated connection-accept-rate max connection creation rate to 2147483647 (kafka.network.ConnectionQuotas)
[2022-05-17 08:26:38,706] INFO Awaiting socket connections on 0.0.0.0:29092. (kafka.network.DataPlaneAcceptor)
[2022-05-17 08:26:38,720] INFO [SocketServer listenerType=BROKER, nodeId=1] Created data-plane acceptor and processors for endpoint : ListenerName(DEVIN) (kafka.network.SocketServer)
[2022-05-17 08:26:38,721] INFO Updated connection-accept-rate max connection creation rate to 2147483647 (kafka.network.ConnectionQuotas)
[2022-05-17 08:26:38,722] INFO Awaiting socket connections on 0.0.0.0:29093. (kafka.network.DataPlaneAcceptor)
[2022-05-17 08:26:39,316] INFO [SocketServer listenerType=BROKER, nodeId=1] Created data-plane acceptor and processors for endpoint : ListenerName(DOCKER) (kafka.network.SocketServer)
[2022-05-17 08:26:39,317] INFO Updated connection-accept-rate max connection creation rate to 2147483647 (kafka.network.ConnectionQuotas)
[2022-05-17 08:26:39,318] INFO Awaiting socket connections on 0.0.0.0:9093. (kafka.network.DataPlaneAcceptor)
[2022-05-17 08:26:39,343] INFO [SocketServer listenerType=BROKER, nodeId=1] Created data-plane acceptor and processors for endpoint : ListenerName(EXTERNAL) (kafka.network.SocketServer)
[2022-05-17 08:26:39,366] INFO [BrokerToControllerChannelManager broker=1 name=alterIsr]: Starting (kafka.server.BrokerToControllerRequestThread)
[2022-05-17 08:26:39,366] INFO [BrokerToControllerChannelManager broker=1 name=alterIsr]: Recorded new controller, from now on will use broker onlinesuiteplus-kafka:9091 (id: 1 rack: null) (kafka.server.BrokerToControllerRequestThread)
[2022-05-17 08:26:39,409] INFO [ExpirationReaper-1-Produce]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2022-05-17 08:26:39,413] INFO [ExpirationReaper-1-Fetch]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2022-05-17 08:26:39,416] INFO [ExpirationReaper-1-DeleteRecords]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2022-05-17 08:26:39,419] INFO [ExpirationReaper-1-ElectLeader]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2022-05-17 08:26:39,450] INFO [ExpirationReaper-1-Heartbeat]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2022-05-17 08:26:39,456] INFO [ExpirationReaper-1-Rebalance]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2022-05-17 08:26:39,535] INFO [RaftManager nodeId=1] Registered the listener kafka.server.metadata.BrokerMetadataListener@1983331412 (org.apache.kafka.raft.KafkaRaftClient)
[2022-05-17 08:26:39,536] INFO [StandardAuthorizer 1] set super.users=User:Applications:f8df59ea-2eeb-4101-89ed-2aa1fb5fc86c,User:CN=onlinesuiteplus-kafka,OU=Services,O=B. Braun Melsungen AG,L=Melsungen,C=DE, default result=DENIED (org.apache.kafka.metadata.authorizer.StandardAuthorizerData)[2022-05-17 08:26:39,547] INFO [BrokerToControllerChannelManager broker=1 name=heartbeat]: Starting (kafka.server.BrokerToControllerRequestThread)[2022-05-17 08:26:39,548] INFO [BrokerToControllerChannelManager broker=1 name=heartbeat]: Recorded new controller, from now on will use broker onlinesuiteplus-kafka:9091 (id: 1 rack: null) (kafka.server.BrokerToControllerRequestThread)
[2022-05-17 08:26:39,554] INFO [BrokerLifecycleManager id=1] Incarnation OW8mtRYiTvSyib7CoKW22Q of broker 1 in cluster NdDjbBv5Qvu_sScOJXkNrw is now STARTING. (kafka.server.BrokerLifecycleManager)
[2022-05-17 08:26:39,599] INFO [ExpirationReaper-1-AlterAcls]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2022-05-17 08:26:39,764] INFO [Controller 1] Re-registered broker id 1: RegisterBrokerRecord(brokerId=1, incarnationId=OW8mtRYiTvSyib7CoKW22Q, brokerEpoch=223, endPoints=[BrokerEndpoint(name='DEVIN', host='onlinesuiteplus-kafka', port=29092, securityProtocol=0), BrokerEndpoint(name='DOCKER', host='onlinesuiteplus-kafka', port=29093, securityProtocol=1), BrokerEndpoint(name='EXTERNAL', host='localhost', port=9093, securityProtocol=1)], features=[], rack=null, fenced=true) (org.apache.kafka.controller.ClusterControlManager)
[2022-05-17 08:26:39,796] INFO [BrokerLifecycleManager id=1] Successfully registered broker 1 with broker epoch 223 (kafka.server.BrokerLifecycleManager)
[2022-05-17 08:26:39,807] INFO [BrokerLifecycleManager id=1] The broker has caught up. Transitioning from STARTING to RECOVERY. (kafka.server.BrokerLifecycleManager)
[2022-05-17 08:26:39,822] INFO [BrokerMetadataListener id=1] Starting to publish metadata events at offset 224. (kafka.server.metadata.BrokerMetadataListener)
[2022-05-17 08:26:39,824] INFO [BrokerMetadataPublisher id=1] Publishing initial metadata at offset OffsetAndEpoch(offset=224, epoch=4). (kafka.server.metadata.BrokerMetadataPublisher)
[2022-05-17 08:26:39,825] INFO [BrokerLifecycleManager id=1] The broker is in RECOVERY. (kafka.server.BrokerLifecycleManager)
[2022-05-17 08:26:39,837] INFO Loading logs from log dirs ArraySeq(/opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:39,839] INFO Skipping recovery for all logs in /opt/kafka/data since clean shutdown file was found (kafka.log.LogManager)
[2022-05-17 08:26:39,855] INFO [LogLoader partition=__consumer_offsets-41, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:39,860] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-41, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=41, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 8ms (1/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:39,866] INFO [LogLoader partition=__consumer_offsets-39, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:39,868] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-39, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=39, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 6ms (2/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:39,872] INFO [LogLoader partition=__consumer_offsets-44, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:39,875] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-44, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=44, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 6ms (3/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:39,879] INFO [LogLoader partition=__consumer_offsets-49, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:39,881] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-49, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=49, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 5ms (4/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:39,886] INFO [LogLoader partition=__consumer_offsets-24, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:39,889] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-24, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=24, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 6ms (5/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:39,894] INFO [LogLoader partition=__consumer_offsets-3, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:39,896] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-3, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=3, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 7ms (6/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:39,902] INFO [LogLoader partition=__consumer_offsets-12, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:39,904] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-12, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=12, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 8ms (7/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:39,909] INFO [LogLoader partition=__consumer_offsets-20, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:39,911] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-20, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=20, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 7ms (8/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:39,916] INFO [LogLoader partition=ais.app.f8df59ea-2eeb-4101-89ed-2aa1fb5fc86c-0, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:39,918] INFO Completed load of Log(dir=/opt/kafka/data/ais.app.f8df59ea-2eeb-4101-89ed-2aa1fb5fc86c-0, topicId=aY0BpYXAR9-4pym2xa1enQ, topic=ais.app.f8df59ea-2eeb-4101-89ed-2aa1fb5fc86c, partition=0, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 6ms (9/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:39,923] INFO [LogLoader partition=__consumer_offsets-13, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:39,925] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-13, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=13, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 6ms (10/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:39,928] INFO [LogLoader partition=__consumer_offsets-18, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:39,930] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-18, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=18, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 4ms (11/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:39,934] INFO [LogLoader partition=__consumer_offsets-14, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:39,936] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-14, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=14, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 5ms (12/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:39,941] INFO [LogLoader partition=__consumer_offsets-6, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:39,943] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-6, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=6, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 6ms (13/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:39,947] INFO [LogLoader partition=__consumer_offsets-8, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:39,948] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-8, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=8, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 5ms (14/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:39,954] INFO [LogLoader partition=__consumer_offsets-31, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:39,958] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-31, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=31, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 9ms (15/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:39,962] INFO [LogLoader partition=__consumer_offsets-4, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:39,964] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-4, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=4, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 6ms (16/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:39,969] INFO [LogLoader partition=__consumer_offsets-33, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:39,970] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-33, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=33, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 6ms (17/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:39,974] INFO [LogLoader partition=__consumer_offsets-10, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:39,976] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-10, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=10, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 5ms (18/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:39,980] INFO [LogLoader partition=__consumer_offsets-23, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:39,988] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-23, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=23, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 12ms (19/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:39,991] INFO [LogLoader partition=__consumer_offsets-16, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:39,993] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-16, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=16, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 4ms (20/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,002] INFO [LogLoader partition=ais.register.app-0, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,005] INFO Completed load of Log(dir=/opt/kafka/data/ais.register.app-0, topicId=_xFmib8uS7SF6izdRriBVg, topic=ais.register.app, partition=0, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 13ms (21/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,009] INFO [LogLoader partition=ais.command.app-0, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,011] INFO Completed load of Log(dir=/opt/kafka/data/ais.command.app-0, topicId=mgdBOxs5QeaU-7TLMYG4ug, topic=ais.command.app, partition=0, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 5ms (22/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,015] INFO [LogLoader partition=__consumer_offsets-29, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,017] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-29, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=29, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 5ms (23/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,024] INFO [LogLoader partition=__consumer_offsets-28, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,025] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-28, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=28, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 8ms (24/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,029] INFO [LogLoader partition=__consumer_offsets-25, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,031] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-25, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=25, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 5ms (25/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,036] INFO [LogLoader partition=__consumer_offsets-21, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,038] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-21, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=21, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 6ms (26/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,042] INFO [LogLoader partition=__consumer_offsets-47, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,043] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-47, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=47, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 5ms (27/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,046] INFO [LogLoader partition=__consumer_offsets-11, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,048] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-11, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=11, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 4ms (28/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,053] INFO [LogLoader partition=__consumer_offsets-37, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,055] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-37, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=37, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 7ms (29/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,059] INFO [LogLoader partition=__consumer_offsets-30, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,061] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-30, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=30, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 5ms (30/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,064] INFO [LogLoader partition=__consumer_offsets-46, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,066] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-46, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=46, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 5ms (31/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,071] INFO [LogLoader partition=__consumer_offsets-34, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,072] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-34, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=34, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 6ms (32/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,076] INFO [LogLoader partition=__consumer_offsets-17, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,077] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-17, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=17, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 5ms (33/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,081] INFO [LogLoader partition=__consumer_offsets-15, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,082] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-15, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=15, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 5ms (34/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,086] INFO [LogLoader partition=ais.register.error-0, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,090] INFO Completed load of Log(dir=/opt/kafka/data/ais.register.error-0, topicId=n1tEsHq8RSqQIX3u5Bh0eA, topic=ais.register.error, partition=0, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 7ms (35/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,094] INFO [LogLoader partition=__consumer_offsets-22, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,095] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-22, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=22, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 5ms (36/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,111] INFO [LogLoader partition=ais.meta.app-0, dir=/opt/kafka/data] Loading producer state till offset 2 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,111] INFO [LogLoader partition=ais.meta.app-0, dir=/opt/kafka/data] Reloading from producer snapshot and rebuilding producer state from offset 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,111] INFO [ProducerStateManager partition=ais.meta.app-0] Loading producer state from snapshot file 'SnapshotFile(/opt/kafka/data/ais.meta.app-0/00000000000000000002.snapshot,2)' (kafka.log.ProducerStateManager)
[2022-05-17 08:26:40,111] INFO [LogLoader partition=ais.meta.app-0, dir=/opt/kafka/data] Producer state recovery took 0ms for snapshot load and 0ms for segment recovery from offset 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,113] INFO Completed load of Log(dir=/opt/kafka/data/ais.meta.app-0, topicId=l3Jt6hLxSVq5zQfqnpbd7g, topic=ais.meta.app, partition=0, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=2) with 1 segments in 17ms (37/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,116] INFO [LogLoader partition=__consumer_offsets-1, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,118] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-1, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=1, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 4ms (38/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,123] INFO [LogLoader partition=__consumer_offsets-32, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,131] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-32, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=32, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 13ms (39/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,135] INFO [LogLoader partition=__consumer_offsets-0, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,136] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-0, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=0, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 5ms (40/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,139] INFO [LogLoader partition=__consumer_offsets-35, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,145] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-35, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=35, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 8ms (41/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,152] INFO [LogLoader partition=__consumer_offsets-26, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,154] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-26, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=26, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 9ms (42/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,158] INFO [LogLoader partition=__consumer_offsets-5, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,160] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-5, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=5, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 6ms (43/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,180] INFO [LogLoader partition=__consumer_offsets-38, dir=/opt/kafka/data] Loading producer state till offset 1 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,180] INFO [LogLoader partition=__consumer_offsets-38, dir=/opt/kafka/data] Reloading from producer snapshot and rebuilding producer state from offset 1 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,181] INFO [ProducerStateManager partition=__consumer_offsets-38] Loading producer state from snapshot file 'SnapshotFile(/opt/kafka/data/__consumer_offsets-38/00000000000000000001.snapshot,1)' (kafka.log.ProducerStateManager)
[2022-05-17 08:26:40,181] INFO [LogLoader partition=__consumer_offsets-38, dir=/opt/kafka/data] Producer state recovery took 1ms for snapshot load and 0ms for segment recovery from offset 1 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,183] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-38, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=38, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=1) with 1 segments in 22ms (44/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,186] INFO [LogLoader partition=__consumer_offsets-7, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,188] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-7, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=7, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 4ms (45/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,192] INFO [LogLoader partition=__consumer_offsets-43, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,194] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-43, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=43, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 5ms (46/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,198] INFO [LogLoader partition=__consumer_offsets-36, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,199] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-36, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=36, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 6ms (47/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,204] INFO [LogLoader partition=__consumer_offsets-45, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,206] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-45, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=45, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 6ms (48/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,209] INFO [LogLoader partition=__consumer_offsets-42, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,211] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-42, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=42, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 4ms (49/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,215] INFO [LogLoader partition=__consumer_offsets-40, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,216] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-40, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=40, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 5ms (50/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,220] INFO [LogLoader partition=__consumer_offsets-9, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,222] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-9, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=9, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 6ms (51/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,226] INFO [LogLoader partition=__consumer_offsets-19, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,228] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-19, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=19, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 5ms (52/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,231] INFO [LogLoader partition=__consumer_offsets-27, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,233] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-27, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=27, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 5ms (53/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,246] INFO [LogLoader partition=__consumer_offsets-48, dir=/opt/kafka/data] Loading producer state till offset 1 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,246] INFO [LogLoader partition=__consumer_offsets-48, dir=/opt/kafka/data] Reloading from producer snapshot and rebuilding producer state from offset 1 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,247] INFO [ProducerStateManager partition=__consumer_offsets-48] Loading producer state from snapshot file 'SnapshotFile(/opt/kafka/data/__consumer_offsets-48/00000000000000000001.snapshot,1)' (kafka.log.ProducerStateManager)
[2022-05-17 08:26:40,247] INFO [LogLoader partition=__consumer_offsets-48, dir=/opt/kafka/data] Producer state recovery took 1ms for snapshot load and 0ms for segment recovery from offset 1 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,249] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-48, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=48, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=1) with 1 segments in 17ms (54/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,253] INFO [LogLoader partition=__consumer_offsets-2, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
[2022-05-17 08:26:40,255] INFO Completed load of Log(dir=/opt/kafka/data/__consumer_offsets-2, topicId=GrwIxT-yTi2kAF63Iwbr4g, topic=__consumer_offsets, partition=2, highWatermark=0, lastStableOffset=0, logStartOffset=0, logEndOffset=0) with 1 segments in 5ms (55/55 loaded in /opt/kafka/data) (kafka.log.LogManager)
[2022-05-17 08:26:40,258] INFO Loaded 55 logs in 421ms. (kafka.log.LogManager)
[2022-05-17 08:26:40,259] INFO Starting log cleanup with a period of 300000 ms. (kafka.log.LogManager)
[2022-05-17 08:26:40,262] INFO Starting log flusher with a default period of 9223372036854775807 ms. (kafka.log.LogManager)
[2022-05-17 08:26:40,322] INFO [LogDirFailureHandler]: Starting (kafka.server.ReplicaManager$LogDirFailureHandler)
[2022-05-17 08:26:40,323] INFO [GroupCoordinator 1]: Starting up. (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,327] INFO [GroupCoordinator 1]: Startup complete. (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,328] INFO [TransactionCoordinator id=1] Starting up. (kafka.coordinator.transaction.TransactionCoordinator)
[2022-05-17 08:26:40,331] INFO [Transaction Marker Channel Manager 1]: Starting (kafka.coordinator.transaction.TransactionMarkerChannelManager)
[2022-05-17 08:26:40,331] INFO [TransactionCoordinator id=1] Startup complete. (kafka.coordinator.transaction.TransactionCoordinator)
[2022-05-17 08:26:40,363] INFO [Partition ais.app.f8df59ea-2eeb-4101-89ed-2aa1fb5fc86c-0 broker=1] Log loaded for partition ais.app.f8df59ea-2eeb-4101-89ed-2aa1fb5fc86c-0 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,365] INFO [Partition ais.register.error-0 broker=1] Log loaded for partition ais.register.error-0 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,366] INFO [Partition __consumer_offsets-13 broker=1] Log loaded for partition __consumer_offsets-13 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,367] INFO [Partition __consumer_offsets-46 broker=1] Log loaded for partition __consumer_offsets-46 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,368] INFO [Partition __consumer_offsets-9 broker=1] Log loaded for partition __consumer_offsets-9 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,370] INFO [Partition __consumer_offsets-42 broker=1] Log loaded for partition __consumer_offsets-42 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,371] INFO [Partition __consumer_offsets-21 broker=1] Log loaded for partition __consumer_offsets-21 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,372] INFO [Partition __consumer_offsets-17 broker=1] Log loaded for partition __consumer_offsets-17 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,373] INFO [Partition __consumer_offsets-30 broker=1] Log loaded for partition __consumer_offsets-30 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,374] INFO [Partition __consumer_offsets-26 broker=1] Log loaded for partition __consumer_offsets-26 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,375] INFO [Partition __consumer_offsets-5 broker=1] Log loaded for partition __consumer_offsets-5 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,377] INFO [Partition __consumer_offsets-38 broker=1] Log loaded for partition __consumer_offsets-38 with initial high watermark 1 (kafka.cluster.Partition)
[2022-05-17 08:26:40,378] INFO [Partition __consumer_offsets-1 broker=1] Log loaded for partition __consumer_offsets-1 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,379] INFO [Partition __consumer_offsets-34 broker=1] Log loaded for partition __consumer_offsets-34 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,380] INFO [Partition __consumer_offsets-16 broker=1] Log loaded for partition __consumer_offsets-16 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,381] INFO [Partition __consumer_offsets-45 broker=1] Log loaded for partition __consumer_offsets-45 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,382] INFO [Partition ais.command.app-0 broker=1] Log loaded for partition ais.command.app-0 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,384] INFO [Partition __consumer_offsets-12 broker=1] Log loaded for partition __consumer_offsets-12 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,385] INFO [Partition __consumer_offsets-41 broker=1] Log loaded for partition __consumer_offsets-41 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,386] INFO [Partition __consumer_offsets-24 broker=1] Log loaded for partition __consumer_offsets-24 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,387] INFO [Partition __consumer_offsets-20 broker=1] Log loaded for partition __consumer_offsets-20 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,387] INFO [Partition __consumer_offsets-49 broker=1] Log loaded for partition __consumer_offsets-49 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,388] INFO [Partition __consumer_offsets-0 broker=1] Log loaded for partition __consumer_offsets-0 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,389] INFO [Partition __consumer_offsets-29 broker=1] Log loaded for partition __consumer_offsets-29 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,391] INFO [Partition __consumer_offsets-25 broker=1] Log loaded for partition __consumer_offsets-25 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,392] INFO [Partition __consumer_offsets-8 broker=1] Log loaded for partition __consumer_offsets-8 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,396] INFO [Partition __consumer_offsets-37 broker=1] Log loaded for partition __consumer_offsets-37 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,398] INFO [Partition __consumer_offsets-4 broker=1] Log loaded for partition __consumer_offsets-4 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,399] INFO [Partition __consumer_offsets-33 broker=1] Log loaded for partition __consumer_offsets-33 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,401] INFO [Partition __consumer_offsets-15 broker=1] Log loaded for partition __consumer_offsets-15 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,403] INFO [Partition __consumer_offsets-48 broker=1] Log loaded for partition __consumer_offsets-48 with initial high watermark 1 (kafka.cluster.Partition)
[2022-05-17 08:26:40,405] INFO [Partition __consumer_offsets-11 broker=1] Log loaded for partition __consumer_offsets-11 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,406] INFO [Partition __consumer_offsets-44 broker=1] Log loaded for partition __consumer_offsets-44 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,407] INFO [Partition ais.meta.app-0 broker=1] Log loaded for partition ais.meta.app-0 with initial high watermark 2 (kafka.cluster.Partition)
[2022-05-17 08:26:40,408] INFO [Partition __consumer_offsets-23 broker=1] Log loaded for partition __consumer_offsets-23 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,411] INFO [Partition __consumer_offsets-19 broker=1] Log loaded for partition __consumer_offsets-19 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,412] INFO [Partition ais.register.app-0 broker=1] Log loaded for partition ais.register.app-0 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,413] INFO [Partition __consumer_offsets-32 broker=1] Log loaded for partition __consumer_offsets-32 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,415] INFO [Partition __consumer_offsets-28 broker=1] Log loaded for partition __consumer_offsets-28 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,417] INFO [Partition __consumer_offsets-7 broker=1] Log loaded for partition __consumer_offsets-7 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,418] INFO [Partition __consumer_offsets-40 broker=1] Log loaded for partition __consumer_offsets-40 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,420] INFO [Partition __consumer_offsets-3 broker=1] Log loaded for partition __consumer_offsets-3 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,421] INFO [Partition __consumer_offsets-36 broker=1] Log loaded for partition __consumer_offsets-36 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,422] INFO [Partition __consumer_offsets-47 broker=1] Log loaded for partition __consumer_offsets-47 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,423] INFO [Partition __consumer_offsets-14 broker=1] Log loaded for partition __consumer_offsets-14 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,424] INFO [Partition __consumer_offsets-43 broker=1] Log loaded for partition __consumer_offsets-43 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,426] INFO [Partition __consumer_offsets-10 broker=1] Log loaded for partition __consumer_offsets-10 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,427] INFO [Partition __consumer_offsets-22 broker=1] Log loaded for partition __consumer_offsets-22 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,429] INFO [Partition __consumer_offsets-18 broker=1] Log loaded for partition __consumer_offsets-18 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,430] INFO [Partition __consumer_offsets-31 broker=1] Log loaded for partition __consumer_offsets-31 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,432] INFO [Partition __consumer_offsets-27 broker=1] Log loaded for partition __consumer_offsets-27 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,434] INFO [Partition __consumer_offsets-39 broker=1] Log loaded for partition __consumer_offsets-39 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,437] INFO [Partition __consumer_offsets-6 broker=1] Log loaded for partition __consumer_offsets-6 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,438] INFO [Partition __consumer_offsets-35 broker=1] Log loaded for partition __consumer_offsets-35 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,439] INFO [Partition __consumer_offsets-2 broker=1] Log loaded for partition __consumer_offsets-2 with initial high watermark 0 (kafka.cluster.Partition)
[2022-05-17 08:26:40,457] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 13 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,458] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-13 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,462] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-13 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,463] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 46 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,463] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-46 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,463] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 9 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,463] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-9 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,463] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 42 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,463] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-42 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,463] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 21 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,463] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-21 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,464] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 17 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,464] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-17 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,464] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 30 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,464] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-30 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,464] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 26 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,464] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-26 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,464] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 5 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,464] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-5 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,464] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 38 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,464] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-38 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,464] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 1 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,464] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-1 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,464] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 34 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,464] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-34 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,464] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 16 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,465] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-16 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,465] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 45 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,465] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-45 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,465] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 12 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,466] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-12 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,466] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 41 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,466] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-41 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,467] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 24 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,467] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-46 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,468] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-9 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,468] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-42 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,469] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-21 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,469] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-17 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,467] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-24 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,470] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 20 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,471] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-30 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,471] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-26 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,471] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-5 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,471] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-38 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,472] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-1 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,472] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-34 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,472] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-16 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,472] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-45 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,472] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-12 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,473] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-41 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,473] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-24 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,471] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-20 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,475] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 49 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,475] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-20 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,475] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-49 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,476] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 0 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,476] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-49 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,476] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-0 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,476] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 29 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,476] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-29 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,476] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-0 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,476] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 25 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,476] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-25 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,476] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 8 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,476] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-8 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,478] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-29 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,478] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-25 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,479] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 37 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,479] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-37 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,479] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-8 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,479] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 4 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,479] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-4 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,479] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-37 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,479] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 33 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,479] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-4 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,479] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-33 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,480] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 15 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,480] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-15 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,480] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-33 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,480] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 48 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,480] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-15 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,480] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-48 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,480] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 11 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,481] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-48 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,481] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-11 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,481] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 44 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,483] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-44 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,483] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 23 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,483] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-23 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,481] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-11 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,484] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 19 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,484] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-19 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,484] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-44 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,484] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 32 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,485] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-32 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,486] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 28 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,486] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-28 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,486] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 7 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,486] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-7 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,486] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 40 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,486] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-40 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,487] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 3 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,487] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-3 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,487] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 36 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,487] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-36 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,487] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 47 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,487] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-47 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,487] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 14 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,487] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-14 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,487] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 43 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,487] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-43 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,487] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 10 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,487] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-10 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,488] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 22 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,488] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-22 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,488] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 18 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,488] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-18 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,488] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 31 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,488] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-31 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,488] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 27 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,488] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-27 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,488] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 39 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,488] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-39 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,489] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 6 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,489] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-6 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,489] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 35 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,485] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-23 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,490] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-19 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,498] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-32 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,498] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-28 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,498] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-7 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,499] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-40 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,500] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-3 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,500] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-36 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,501] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-47 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,501] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-14 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,501] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-43 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,501] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-10 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,501] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-22 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,501] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-18 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,501] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-31 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,501] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-27 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,501] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-39 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,501] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-6 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,489] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-35 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,504] INFO [GroupCoordinator 1]: Resigned as the group coordinator for partition 2 in epoch Some(2) (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:40,504] INFO [GroupMetadataManager brokerId=1] Scheduling unloading of offsets and group metadata from __consumer_offsets-2 (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,512] INFO [BrokerMetadataPublisher id=1] Updating topic __consumer_offsets with new configuration : compression.type -> producer,cleanup.policy -> compact,segment.bytes -> 104857600 (kafka.server.metadata.BrokerMetadataPublisher)
[2022-05-17 08:26:40,517] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-35 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,517] INFO [GroupMetadataManager brokerId=1] Finished unloading __consumer_offsets-2 for coordinator epoch Some(2). Removed 0 cached offsets and 0 cached groups. (kafka.coordinator.group.GroupMetadataManager)
[2022-05-17 08:26:40,562] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@1094bb5a, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,578] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@bedfd9d, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,587] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@5e760e7e, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,599] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@11327730, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,608] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@24495027, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,617] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@40ac4026, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,624] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@2e47a3b3, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,632] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@2c4edabc, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,639] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@42e86f7a, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,646] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@60e7aa71, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,647] INFO [BrokerMetadataPublisher id=1] Updating topic ais.register.error with new configuration : message.timestamp.type -> LogAppendTime (kafka.server.metadata.BrokerMetadataPublisher)
[2022-05-17 08:26:40,654] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@1094bb5a, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,661] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@bedfd9d, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,668] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@5e760e7e, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,674] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@11327730, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,680] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@24495027, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,686] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@40ac4026, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,692] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@2e47a3b3, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,698] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@2c4edabc, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,704] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@42e86f7a, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,710] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@60e7aa71, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,711] INFO [BrokerMetadataPublisher id=1] Updating topic ais.app.f8df59ea-2eeb-4101-89ed-2aa1fb5fc86c with new configuration : message.timestamp.type -> LogAppendTime,segment.bytes -> 10485760,retention.ms -> 8640000000,segment.index.bytes -> 1048576 (kafka.server.metadata.BrokerMetadataPublisher)
[2022-05-17 08:26:40,719] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@1094bb5a, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,726] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@bedfd9d, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,732] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@5e760e7e, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,738] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@11327730, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,751] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@24495027, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,757] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@40ac4026, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,763] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@2e47a3b3, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,768] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@2c4edabc, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,774] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@42e86f7a, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,780] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@60e7aa71, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,780] INFO [BrokerMetadataPublisher id=1] Updating topic ais.command.app with new configuration : compression.type -> uncompressed,message.timestamp.type -> LogAppendTime,retention.ms -> 8640000000 (kafka.server.metadata.BrokerMetadataPublisher)
[2022-05-17 08:26:40,788] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@1094bb5a, updated configs: Set(compression.type) custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,795] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@bedfd9d, updated configs: Set(compression.type) custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,801] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@5e760e7e, updated configs: Set(compression.type) custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,806] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@11327730, updated configs: Set(compression.type) custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,812] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@24495027, updated configs: Set(compression.type) custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,818] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@40ac4026, updated configs: Set(compression.type) custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,825] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@2e47a3b3, updated configs: Set(compression.type) custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,837] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@2c4edabc, updated configs: Set(compression.type) custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,844] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@42e86f7a, updated configs: Set(compression.type) custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,849] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@60e7aa71, updated configs: Set(compression.type) custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,850] INFO [BrokerMetadataPublisher id=1] Updating topic ais.meta.app with new configuration : compression.type -> uncompressed,cleanup.policy -> compact,max.compaction.lag.ms -> 3600000,message.timestamp.type -> LogAppendTime,segment.bytes -> 10485760,retention.ms -> -1,delete.retention.ms -> 60000,segment.index.bytes -> 1048576 (kafka.server.metadata.BrokerMetadataPublisher)
[2022-05-17 08:26:40,856] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@1094bb5a, updated configs: Set(compression.type) custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,861] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@bedfd9d, updated configs: Set(compression.type) custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,866] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@5e760e7e, updated configs: Set(compression.type) custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,871] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@11327730, updated configs: Set(compression.type) custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,877] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@24495027, updated configs: Set(compression.type) custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,882] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@40ac4026, updated configs: Set(compression.type) custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,887] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@2e47a3b3, updated configs: Set(compression.type) custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,891] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@2c4edabc, updated configs: Set(compression.type) custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,896] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@42e86f7a, updated configs: Set(compression.type) custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,901] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@60e7aa71, updated configs: Set(compression.type) custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,902] INFO [BrokerMetadataPublisher id=1] Updating topic ais.register.app with new configuration : message.timestamp.type -> LogAppendTime,retention.ms -> 172800000 (kafka.server.metadata.BrokerMetadataPublisher)
[2022-05-17 08:26:40,907] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@1094bb5a, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,911] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@bedfd9d, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,915] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@5e760e7e, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,919] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@11327730, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,924] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@24495027, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,927] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@40ac4026, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,932] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@2e47a3b3, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,938] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@2c4edabc, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,942] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@42e86f7a, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,946] INFO Reconfiguring org.apache.kafka.common.network.SslChannelBuilder@60e7aa71, updated configs: Set() custom configs: {} (kafka.server.DynamicBrokerConfig)
[2022-05-17 08:26:40,949] ERROR [StandardAuthorizer 1] addAcl error (org.apache.kafka.metadata.authorizer.StandardAuthorizerData)
java.lang.RuntimeException: An ACL with ID toAvM0TbTfWRmS1kjknRaA already exists.
        at org.apache.kafka.metadata.authorizer.StandardAuthorizerData.addAcl(StandardAuthorizerData.java:169)
        at org.apache.kafka.metadata.authorizer.StandardAuthorizer.addAcl(StandardAuthorizer.java:83)
        at kafka.server.metadata.BrokerMetadataPublisher.$anonfun$publish$19(BrokerMetadataPublisher.scala:234)
        at java.base/java.util.LinkedHashMap$LinkedEntrySet.forEach(Unknown Source)
        at kafka.server.metadata.BrokerMetadataPublisher.$anonfun$publish$18(BrokerMetadataPublisher.scala:232)
        at kafka.server.metadata.BrokerMetadataPublisher.$anonfun$publish$18$adapted(BrokerMetadataPublisher.scala:221)
        at scala.Option.foreach(Option.scala:437)
        at kafka.server.metadata.BrokerMetadataPublisher.publish(BrokerMetadataPublisher.scala:221)
        at kafka.server.metadata.BrokerMetadataListener.kafka$server$metadata$BrokerMetadataListener$$publish(BrokerMetadataListener.scala:258)
        at kafka.server.metadata.BrokerMetadataListener$StartPublishingEvent.run(BrokerMetadataListener.scala:241)
        at org.apache.kafka.queue.KafkaEventQueue$EventContext.run(KafkaEventQueue.java:121)
        at org.apache.kafka.queue.KafkaEventQueue$EventHandler.handleEvents(KafkaEventQueue.java:200)
        at org.apache.kafka.queue.KafkaEventQueue$EventHandler.run(KafkaEventQueue.java:173)
        at java.base/java.lang.Thread.run(Unknown Source)
[2022-05-17 08:26:40,954] ERROR [BrokerMetadataPublisher id=1] Error publishing broker metadata at OffsetAndEpoch(offset=224, epoch=4) (kafka.server.metadata.BrokerMetadataPublisher)
java.lang.RuntimeException: An ACL with ID toAvM0TbTfWRmS1kjknRaA already exists.
        at org.apache.kafka.metadata.authorizer.StandardAuthorizerData.addAcl(StandardAuthorizerData.java:169)
        at org.apache.kafka.metadata.authorizer.StandardAuthorizer.addAcl(StandardAuthorizer.java:83)
        at kafka.server.metadata.BrokerMetadataPublisher.$anonfun$publish$19(BrokerMetadataPublisher.scala:234)
        at java.base/java.util.LinkedHashMap$LinkedEntrySet.forEach(Unknown Source)
        at kafka.server.metadata.BrokerMetadataPublisher.$anonfun$publish$18(BrokerMetadataPublisher.scala:232)
        at kafka.server.metadata.BrokerMetadataPublisher.$anonfun$publish$18$adapted(BrokerMetadataPublisher.scala:221)
        at scala.Option.foreach(Option.scala:437)
        at kafka.server.metadata.BrokerMetadataPublisher.publish(BrokerMetadataPublisher.scala:221)
        at kafka.server.metadata.BrokerMetadataListener.kafka$server$metadata$BrokerMetadataListener$$publish(BrokerMetadataListener.scala:258)
        at kafka.server.metadata.BrokerMetadataListener$StartPublishingEvent.run(BrokerMetadataListener.scala:241)
        at org.apache.kafka.queue.KafkaEventQueue$EventContext.run(KafkaEventQueue.java:121)
        at org.apache.kafka.queue.KafkaEventQueue$EventHandler.handleEvents(KafkaEventQueue.java:200)
        at org.apache.kafka.queue.KafkaEventQueue$EventHandler.run(KafkaEventQueue.java:173)
        at java.base/java.lang.Thread.run(Unknown Source)
[2022-05-17 08:26:40,956] INFO [BrokerServer id=1] Transition from STARTING to STARTED (kafka.server.BrokerServer)
[2022-05-17 08:26:40,959] ERROR [BrokerServer id=1] Fatal error during broker startup. Prepare to shutdown (kafka.server.BrokerServer)
java.util.concurrent.ExecutionException: java.lang.RuntimeException: An ACL with ID toAvM0TbTfWRmS1kjknRaA already exists.
        at java.base/java.util.concurrent.CompletableFuture.reportGet(Unknown Source)
        at java.base/java.util.concurrent.CompletableFuture.get(Unknown Source)
        at kafka.server.BrokerServer.startup(BrokerServer.scala:426)
        at kafka.server.KafkaRaftServer.$anonfun$startup$2(KafkaRaftServer.scala:114)
        at kafka.server.KafkaRaftServer.$anonfun$startup$2$adapted(KafkaRaftServer.scala:114)
        at scala.Option.foreach(Option.scala:437)
        at kafka.server.KafkaRaftServer.startup(KafkaRaftServer.scala:114)
        at kafka.Kafka$.main(Kafka.scala:109)
        at kafka.Kafka.main(Kafka.scala)
Caused by: java.lang.RuntimeException: An ACL with ID toAvM0TbTfWRmS1kjknRaA already exists.
        at org.apache.kafka.metadata.authorizer.StandardAuthorizerData.addAcl(StandardAuthorizerData.java:169)
        at org.apache.kafka.metadata.authorizer.StandardAuthorizer.addAcl(StandardAuthorizer.java:83)
        at kafka.server.metadata.BrokerMetadataPublisher.$anonfun$publish$19(BrokerMetadataPublisher.scala:234)
        at java.base/java.util.LinkedHashMap$LinkedEntrySet.forEach(Unknown Source)
        at kafka.server.metadata.BrokerMetadataPublisher.$anonfun$publish$18(BrokerMetadataPublisher.scala:232)
        at kafka.server.metadata.BrokerMetadataPublisher.$anonfun$publish$18$adapted(BrokerMetadataPublisher.scala:221)
        at scala.Option.foreach(Option.scala:437)
        at kafka.server.metadata.BrokerMetadataPublisher.publish(BrokerMetadataPublisher.scala:221)
        at kafka.server.metadata.BrokerMetadataListener.kafka$server$metadata$BrokerMetadataListener$$publish(BrokerMetadataListener.scala:258)
        at kafka.server.metadata.BrokerMetadataListener$StartPublishingEvent.run(BrokerMetadataListener.scala:241)
        at org.apache.kafka.queue.KafkaEventQueue$EventContext.run(KafkaEventQueue.java:121)
        at org.apache.kafka.queue.KafkaEventQueue$EventHandler.handleEvents(KafkaEventQueue.java:200)
        at org.apache.kafka.queue.KafkaEventQueue$EventHandler.run(KafkaEventQueue.java:173)
        at java.base/java.lang.Thread.run(Unknown Source)
[2022-05-17 08:26:40,960] INFO [BrokerServer id=1] Transition from STARTED to SHUTTING_DOWN (kafka.server.BrokerServer)
[2022-05-17 08:26:40,961] INFO [BrokerServer id=1] shutting down (kafka.server.BrokerServer)
[2022-05-17 08:26:40,962] INFO [BrokerMetadataListener id=1] beginShutdown: shutting down event queue. (org.apache.kafka.queue.KafkaEventQueue)
[2022-05-17 08:26:40,963] INFO [BrokerLifecycleManager id=1] Skipping controlled shutdown because we are in state RECOVERY. (kafka.server.BrokerLifecycleManager)
[2022-05-17 08:26:40,964] INFO [BrokerLifecycleManager id=1] beginShutdown: shutting down event queue. (org.apache.kafka.queue.KafkaEventQueue)
[2022-05-17 08:26:40,964] INFO [BrokerLifecycleManager id=1] Transitioning from RECOVERY to SHUTTING_DOWN. (kafka.server.BrokerLifecycleManager)
[2022-05-17 08:26:40,965] INFO [BrokerToControllerChannelManager broker=1 name=heartbeat]: Shutting down (kafka.server.BrokerToControllerRequestThread)
[2022-05-17 08:26:40,966] INFO [BrokerToControllerChannelManager broker=1 name=heartbeat]: Stopped (kafka.server.BrokerToControllerRequestThread)
[2022-05-17 08:26:40,966] INFO [BrokerToControllerChannelManager broker=1 name=heartbeat]: Shutdown completed (kafka.server.BrokerToControllerRequestThread)
[2022-05-17 08:26:40,972] ERROR [BrokerMetadataListener id=1] Unexpected error handling StartPublishingEvent (kafka.server.metadata.BrokerMetadataListener)
java.lang.RuntimeException: An ACL with ID toAvM0TbTfWRmS1kjknRaA already exists.
        at org.apache.kafka.metadata.authorizer.StandardAuthorizerData.addAcl(StandardAuthorizerData.java:169)
        at org.apache.kafka.metadata.authorizer.StandardAuthorizer.addAcl(StandardAuthorizer.java:83)
        at kafka.server.metadata.BrokerMetadataPublisher.$anonfun$publish$19(BrokerMetadataPublisher.scala:234)
        at java.base/java.util.LinkedHashMap$LinkedEntrySet.forEach(Unknown Source)
        at kafka.server.metadata.BrokerMetadataPublisher.$anonfun$publish$18(BrokerMetadataPublisher.scala:232)
        at kafka.server.metadata.BrokerMetadataPublisher.$anonfun$publish$18$adapted(BrokerMetadataPublisher.scala:221)
        at scala.Option.foreach(Option.scala:437)
        at kafka.server.metadata.BrokerMetadataPublisher.publish(BrokerMetadataPublisher.scala:221)
        at kafka.server.metadata.BrokerMetadataListener.kafka$server$metadata$BrokerMetadataListener$$publish(BrokerMetadataListener.scala:258)
        at kafka.server.metadata.BrokerMetadataListener$StartPublishingEvent.run(BrokerMetadataListener.scala:241)
        at org.apache.kafka.queue.KafkaEventQueue$EventContext.run(KafkaEventQueue.java:121)
        at org.apache.kafka.queue.KafkaEventQueue$EventHandler.handleEvents(KafkaEventQueue.java:200)
        at org.apache.kafka.queue.KafkaEventQueue$EventHandler.run(KafkaEventQueue.java:173)
        at java.base/java.lang.Thread.run(Unknown Source)
[2022-05-17 08:26:40,976] INFO [SocketServer listenerType=BROKER, nodeId=1] Stopping socket server request processors (kafka.network.SocketServer)[2022-05-17 08:26:40,977] INFO Broker to controller channel manager for heartbeat shutdown (kafka.server.BrokerToControllerChannelManagerImpl)
[2022-05-17 08:26:40,985] INFO [SocketServer listenerType=BROKER, nodeId=1] Stopped socket server request processors (kafka.network.SocketServer)
[2022-05-17 08:26:40,986] INFO [data-plane Kafka Request Handler on Broker 1], shutting down (kafka.server.KafkaRequestHandlerPool)
[2022-05-17 08:26:40,990] INFO [data-plane Kafka Request Handler on Broker 1], shut down completely (kafka.server.KafkaRequestHandlerPool)
[2022-05-17 08:26:40,990] INFO [ExpirationReaper-1-AlterAcls]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2022-05-17 08:26:41,013] INFO [ExpirationReaper-1-AlterAcls]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2022-05-17 08:26:41,013] INFO [ExpirationReaper-1-AlterAcls]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2022-05-17 08:26:41,016] INFO [KafkaApi-1] Shutdown complete. (kafka.server.KafkaApis)
[2022-05-17 08:26:41,018] INFO [BrokerMetadataListener id=1] closed event queue. (org.apache.kafka.queue.KafkaEventQueue)
[2022-05-17 08:26:41,024] INFO [TransactionCoordinator id=1] Shutting down. (kafka.coordinator.transaction.TransactionCoordinator)
[2022-05-17 08:26:41,034] INFO [Transaction State Manager 1]: Shutdown complete (kafka.coordinator.transaction.TransactionStateManager)
[2022-05-17 08:26:41,034] INFO [Transaction Marker Channel Manager 1]: Shutting down (kafka.coordinator.transaction.TransactionMarkerChannelManager)
[2022-05-17 08:26:41,034] INFO [Transaction Marker Channel Manager 1]: Stopped (kafka.coordinator.transaction.TransactionMarkerChannelManager)
[2022-05-17 08:26:41,035] INFO [Transaction Marker Channel Manager 1]: Shutdown completed (kafka.coordinator.transaction.TransactionMarkerChannelManager)
[2022-05-17 08:26:41,037] INFO [TransactionCoordinator id=1] Shutdown complete. (kafka.coordinator.transaction.TransactionCoordinator)
[2022-05-17 08:26:41,039] INFO [GroupCoordinator 1]: Shutting down. (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:41,040] INFO [ExpirationReaper-1-Heartbeat]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2022-05-17 08:26:41,042] INFO [ExpirationReaper-1-Heartbeat]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2022-05-17 08:26:41,042] INFO [ExpirationReaper-1-Heartbeat]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2022-05-17 08:26:41,045] INFO [ExpirationReaper-1-Rebalance]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2022-05-17 08:26:41,045] INFO [ExpirationReaper-1-Rebalance]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2022-05-17 08:26:41,046] INFO [ExpirationReaper-1-Rebalance]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2022-05-17 08:26:41,047] INFO [GroupCoordinator 1]: Shutdown complete. (kafka.coordinator.group.GroupCoordinator)
[2022-05-17 08:26:41,048] INFO [ReplicaManager broker=1] Shutting down (kafka.server.ReplicaManager)
[2022-05-17 08:26:41,049] INFO [LogDirFailureHandler]: Shutting down (kafka.server.ReplicaManager$LogDirFailureHandler)
[2022-05-17 08:26:41,049] INFO [LogDirFailureHandler]: Stopped (kafka.server.ReplicaManager$LogDirFailureHandler)
[2022-05-17 08:26:41,049] INFO [LogDirFailureHandler]: Shutdown completed (kafka.server.ReplicaManager$LogDirFailureHandler)
[2022-05-17 08:26:41,051] INFO [ReplicaFetcherManager on broker 1] shutting down (kafka.server.ReplicaFetcherManager)
[2022-05-17 08:26:41,053] INFO [ReplicaFetcherManager on broker 1] shutdown completed (kafka.server.ReplicaFetcherManager)
[2022-05-17 08:26:41,054] INFO [ReplicaAlterLogDirsManager on broker 1] shutting down (kafka.server.ReplicaAlterLogDirsManager)
[2022-05-17 08:26:41,054] INFO [ReplicaAlterLogDirsManager on broker 1] shutdown completed (kafka.server.ReplicaAlterLogDirsManager)
[2022-05-17 08:26:41,055] INFO [ExpirationReaper-1-Fetch]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2022-05-17 08:26:41,059] INFO [ExpirationReaper-1-Fetch]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2022-05-17 08:26:41,059] INFO [ExpirationReaper-1-Fetch]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2022-05-17 08:26:41,060] INFO [ExpirationReaper-1-Produce]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2022-05-17 08:26:41,061] INFO [ExpirationReaper-1-Produce]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2022-05-17 08:26:41,061] INFO [ExpirationReaper-1-Produce]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2022-05-17 08:26:41,061] INFO [ExpirationReaper-1-DeleteRecords]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2022-05-17 08:26:41,062] INFO [ExpirationReaper-1-DeleteRecords]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2022-05-17 08:26:41,062] INFO [ExpirationReaper-1-DeleteRecords]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2022-05-17 08:26:41,063] INFO [ExpirationReaper-1-ElectLeader]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2022-05-17 08:26:41,064] INFO [ExpirationReaper-1-ElectLeader]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2022-05-17 08:26:41,064] INFO [ExpirationReaper-1-ElectLeader]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2022-05-17 08:26:41,082] INFO [ReplicaManager broker=1] Shut down completely (kafka.server.ReplicaManager)
[2022-05-17 08:26:41,082] INFO [BrokerToControllerChannelManager broker=1 name=alterIsr]: Shutting down (kafka.server.BrokerToControllerRequestThread)
[2022-05-17 08:26:41,083] INFO [BrokerToControllerChannelManager broker=1 name=alterIsr]: Stopped (kafka.server.BrokerToControllerRequestThread)
[2022-05-17 08:26:41,083] INFO [BrokerToControllerChannelManager broker=1 name=alterIsr]: Shutdown completed (kafka.server.BrokerToControllerRequestThread)
[2022-05-17 08:26:41,084] INFO Broker to controller channel manager for alterIsr shutdown (kafka.server.BrokerToControllerChannelManagerImpl)
[2022-05-17 08:26:41,084] INFO [BrokerToControllerChannelManager broker=1 name=forwarding]: Shutting down (kafka.server.BrokerToControllerRequestThread)
[2022-05-17 08:26:41,085] INFO [BrokerToControllerChannelManager broker=1 name=forwarding]: Stopped (kafka.server.BrokerToControllerRequestThread)[2022-05-17 08:26:41,085] INFO [BrokerToControllerChannelManager broker=1 name=forwarding]: Shutdown completed (kafka.server.BrokerToControllerRequestThread)
[2022-05-17 08:26:41,085] INFO Broker to controller channel manager for forwarding shutdown (kafka.server.BrokerToControllerChannelManagerImpl)
[2022-05-17 08:26:41,086] INFO Shutting down. (kafka.log.LogManager)
[2022-05-17 08:26:41,436] INFO Shutdown complete. (kafka.log.LogManager)
[2022-05-17 08:26:41,437] INFO [ThrottledChannelReaper-Fetch]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2022-05-17 08:26:41,440] INFO [ThrottledChannelReaper-Fetch]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2022-05-17 08:26:41,440] INFO [ThrottledChannelReaper-Fetch]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2022-05-17 08:26:41,440] INFO [ThrottledChannelReaper-Produce]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2022-05-17 08:26:41,441] INFO [ThrottledChannelReaper-Produce]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2022-05-17 08:26:41,441] INFO [ThrottledChannelReaper-Produce]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2022-05-17 08:26:41,441] INFO [ThrottledChannelReaper-Request]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2022-05-17 08:26:41,441] INFO [ThrottledChannelReaper-Request]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2022-05-17 08:26:41,441] INFO [ThrottledChannelReaper-Request]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2022-05-17 08:26:41,441] INFO [ThrottledChannelReaper-ControllerMutation]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)[2022-05-17 08:26:41,442] INFO [ThrottledChannelReaper-ControllerMutation]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2022-05-17 08:26:41,442] INFO [ThrottledChannelReaper-ControllerMutation]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2022-05-17 08:26:41,443] INFO [SocketServer listenerType=BROKER, nodeId=1] Shutting down socket server (kafka.network.SocketServer)
[2022-05-17 08:26:41,473] INFO [SocketServer listenerType=BROKER, nodeId=1] Shutdown completed (kafka.network.SocketServer)
[2022-05-17 08:26:41,475] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics)
[2022-05-17 08:26:41,476] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics)
[2022-05-17 08:26:41,477] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics)
[2022-05-17 08:26:41,479] INFO Broker and topic stats closed (kafka.server.BrokerTopicStats)
[2022-05-17 08:26:41,480] INFO [BrokerLifecycleManager id=1] closed event queue. (org.apache.kafka.queue.KafkaEventQueue)
[2022-05-17 08:26:41,481] INFO App info kafka.server for 1 unregistered (org.apache.kafka.common.utils.AppInfoParser)
[2022-05-17 08:26:41,481] INFO [BrokerServer id=1] shut down completed (kafka.server.BrokerServer)
[2022-05-17 08:26:41,481] INFO [BrokerServer id=1] Transition from SHUTTING_DOWN to SHUTDOWN (kafka.server.BrokerServer)
[2022-05-17 08:26:41,482] ERROR Exiting Kafka. (kafka.Kafka$)
[2022-05-17 08:26:41,483] INFO [kafka-raft-io-thread]: Shutting down (kafka.raft.KafkaRaftManager$RaftIoThread)
[2022-05-17 08:26:41,483] INFO [RaftManager nodeId=1] Beginning graceful shutdown (org.apache.kafka.raft.KafkaRaftClient)
[2022-05-17 08:26:41,484] INFO [RaftManager nodeId=1] Graceful shutdown completed (org.apache.kafka.raft.KafkaRaftClient)
[2022-05-17 08:26:41,484] INFO [kafka-raft-io-thread]: Completed graceful shutdown of RaftClient (kafka.raft.KafkaRaftManager$RaftIoThread)
[2022-05-17 08:26:41,485] INFO [kafka-raft-io-thread]: Stopped (kafka.raft.KafkaRaftManager$RaftIoThread)
[2022-05-17 08:26:41,485] INFO [kafka-raft-io-thread]: Shutdown completed (kafka.raft.KafkaRaftManager$RaftIoThread)
[2022-05-17 08:26:41,489] INFO [kafka-raft-outbound-request-thread]: Shutting down (kafka.raft.RaftSendThread)
[2022-05-17 08:26:41,489] INFO [kafka-raft-outbound-request-thread]: Stopped (kafka.raft.RaftSendThread)
[2022-05-17 08:26:41,489] INFO [kafka-raft-outbound-request-thread]: Shutdown completed (kafka.raft.RaftSendThread)
[2022-05-17 08:26:41,496] INFO [ProducerStateManager partition=__cluster_metadata-0] Wrote producer snapshot at offset 225 with 0 producer ids in 6 ms. (kafka.log.ProducerStateManager)
[2022-05-17 08:26:41,499] INFO [ControllerServer id=1] shutting down (kafka.server.ControllerServer)
[2022-05-17 08:26:41,499] INFO [SocketServer listenerType=CONTROLLER, nodeId=1] Stopping socket server request processors (kafka.network.SocketServer)
[2022-05-17 08:26:41,508] INFO [SocketServer listenerType=CONTROLLER, nodeId=1] Stopped socket server request processors (kafka.network.SocketServer)
[2022-05-17 08:26:41,508] INFO [Controller 1] QuorumController#beginShutdown: shutting down event queue. (org.apache.kafka.queue.KafkaEventQueue)
[2022-05-17 08:26:41,508] ERROR [Controller 1] maybeBalancePartitionLeaders: unable to start processing because of TimeoutException. (org.apache.kafka.controller.QuorumController)
[2022-05-17 08:26:41,508] INFO [SocketServer listenerType=CONTROLLER, nodeId=1] Shutting down socket server (kafka.network.SocketServer)
[2022-05-17 08:26:41,520] INFO [SocketServer listenerType=CONTROLLER, nodeId=1] Shutdown completed (kafka.network.SocketServer)
[2022-05-17 08:26:41,521] INFO [data-plane Kafka Request Handler on Broker 1], shutting down (kafka.server.KafkaRequestHandlerPool)
[2022-05-17 08:26:41,522] INFO [data-plane Kafka Request Handler on Broker 1], shut down completely (kafka.server.KafkaRequestHandlerPool)
[2022-05-17 08:26:41,522] INFO [ExpirationReaper-1-AlterAcls]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2022-05-17 08:26:41,523] INFO [ExpirationReaper-1-AlterAcls]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2022-05-17 08:26:41,523] INFO [ExpirationReaper-1-AlterAcls]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
[2022-05-17 08:26:41,525] INFO [ThrottledChannelReaper-Fetch]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2022-05-17 08:26:41,525] INFO [ThrottledChannelReaper-Fetch]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2022-05-17 08:26:41,525] INFO [ThrottledChannelReaper-Fetch]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2022-05-17 08:26:41,525] INFO [ThrottledChannelReaper-Produce]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2022-05-17 08:26:41,526] INFO [ThrottledChannelReaper-Produce]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2022-05-17 08:26:41,526] INFO [ThrottledChannelReaper-Produce]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2022-05-17 08:26:41,526] INFO [ThrottledChannelReaper-Request]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2022-05-17 08:26:41,526] INFO [ThrottledChannelReaper-Request]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2022-05-17 08:26:41,526] INFO [ThrottledChannelReaper-Request]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2022-05-17 08:26:41,526] INFO [ThrottledChannelReaper-ControllerMutation]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)[2022-05-17 08:26:41,527] INFO [ThrottledChannelReaper-ControllerMutation]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2022-05-17 08:26:41,527] INFO [ThrottledChannelReaper-ControllerMutation]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
[2022-05-17 08:26:41,527] INFO [Controller 1] closed event queue. (org.apache.kafka.queue.KafkaEventQueue)
[2022-05-17 08:26:41,529] INFO App info kafka.server for 1 unregistered (org.apache.kafka.common.utils.AppInfoParser)