[2022-09-30 17:28:13,722] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$) [2022-09-30 17:28:14,276] INFO Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation (org.apache.zookeeper.common.X509Util) [2022-09-30 17:28:14,607] INFO [LogLoader partition=__cluster_metadata-0, dir=/tmp/kraft-combined-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2022-09-30 17:28:14,607] INFO [LogLoader partition=__cluster_metadata-0, dir=/tmp/kraft-combined-logs] Reloading from producer snapshot and rebuilding producer state from offset 0 (kafka.log.UnifiedLog$) [2022-09-30 17:28:14,609] INFO [LogLoader partition=__cluster_metadata-0, dir=/tmp/kraft-combined-logs] Producer state recovery took 2ms for snapshot load and 0ms for segment recovery from offset 0 (kafka.log.UnifiedLog$) [2022-09-30 17:28:14,700] INFO Initialized snapshots with IDs SortedSet() from /tmp/kraft-combined-logs/__cluster_metadata-0 (kafka.raft.KafkaMetadataLog$) [2022-09-30 17:28:14,816] INFO [raft-expiration-reaper]: Starting (kafka.raft.TimingWheelExpirationService$ExpiredOperationReaper) [2022-09-30 17:28:15,128] INFO [RaftManager nodeId=1] Completed transition to Unattached(epoch=0, voters=[1], electionTimeoutMs=1508) (org.apache.kafka.raft.QuorumState) [2022-09-30 17:28:15,150] INFO [RaftManager nodeId=1] Completed transition to CandidateState(localId=1, epoch=1, retries=1, electionTimeoutMs=1186) (org.apache.kafka.raft.QuorumState) [2022-09-30 17:28:15,196] INFO [RaftManager nodeId=1] Completed transition to Leader(localId=1, epoch=1, epochStartOffset=0, highWatermark=Optional.empty, voterStates={1=ReplicaState(nodeId=1, endOffset=Optional.empty, lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=true)}) (org.apache.kafka.raft.QuorumState) [2022-09-30 17:28:15,370] INFO Registered signal handlers for TERM, INT, HUP (org.apache.kafka.common.utils.LoggingSignalHandler) [2022-09-30 17:28:15,376] INFO Starting controller (kafka.server.ControllerServer) [2022-09-30 17:28:15,386] INFO [kafka-raft-outbound-request-thread]: Starting (kafka.raft.RaftSendThread) [2022-09-30 17:28:15,398] INFO [kafka-raft-io-thread]: Starting (kafka.raft.KafkaRaftManager$RaftIoThread) [2022-09-30 17:28:16,123] INFO Updated connection-accept-rate max connection creation rate to 2147483647 (kafka.network.ConnectionQuotas) [2022-09-30 17:28:16,129] INFO Awaiting socket connections on 0.0.0.0:9093. (kafka.network.DataPlaneAcceptor) [2022-09-30 17:28:16,219] INFO [SocketServer listenerType=CONTROLLER, nodeId=1] Created data-plane acceptor and processors for endpoint : ListenerName(CONTROLLER) (kafka.network.SocketServer) [2022-09-30 17:28:16,277] INFO [Controller 1] Creating new QuorumController with clusterId ioGBNME3Sn6swjyfc7D0PQ, authorizer Optional.empty. (org.apache.kafka.controller.QuorumController) [2022-09-30 17:28:16,287] INFO [RaftManager nodeId=1] Registered the listener org.apache.kafka.controller.QuorumController$QuorumMetaLogListener@2144609649 (org.apache.kafka.raft.KafkaRaftClient) [2022-09-30 17:28:16,318] INFO [ThrottledChannelReaper-Fetch]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2022-09-30 17:28:16,318] INFO [ThrottledChannelReaper-Produce]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2022-09-30 17:28:16,320] INFO [ThrottledChannelReaper-ControllerMutation]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2022-09-30 17:28:16,318] INFO [ThrottledChannelReaper-Request]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2022-09-30 17:28:16,370] INFO [SocketServer listenerType=CONTROLLER, nodeId=1] Enabling request processing. (kafka.network.SocketServer) [2022-09-30 17:28:16,427] INFO [ExpirationReaper-1-AlterAcls]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2022-09-30 17:28:16,444] INFO [BrokerServer id=1] Transition from SHUTDOWN to STARTING (kafka.server.BrokerServer) [2022-09-30 17:28:16,447] INFO [BrokerServer id=1] Starting broker (kafka.server.BrokerServer) [2022-09-30 17:28:16,444] INFO [Controller 1] Becoming the active controller at epoch 1, committed offset -1, committed epoch -1 (org.apache.kafka.controller.QuorumController) [2022-09-30 17:28:16,462] INFO [Controller 1] The metadata log appears to be empty. Appending 1 bootstrap record(s) at metadata.version 3.3-IV3 from the binary bootstrap metadata file: /tmp/kraft-combined-logs/bootstrap.checkpoint. (org.apache.kafka.controller.QuorumController) [2022-09-30 17:28:16,464] INFO [Controller 1] Setting metadata.version to 7 (org.apache.kafka.controller.FeatureControlManager) [2022-09-30 17:28:16,496] INFO [ThrottledChannelReaper-Fetch]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2022-09-30 17:28:16,510] INFO [ThrottledChannelReaper-ControllerMutation]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2022-09-30 17:28:16,496] INFO [ThrottledChannelReaper-Request]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2022-09-30 17:28:16,496] INFO [ThrottledChannelReaper-Produce]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2022-09-30 17:28:16,541] INFO [BrokerToControllerChannelManager broker=1 name=forwarding]: Starting (kafka.server.BrokerToControllerRequestThread) [2022-09-30 17:28:16,543] INFO [BrokerToControllerChannelManager broker=1 name=forwarding]: Recorded new controller, from now on will use broker localhost:9093 (id: 1 rack: null) (kafka.server.BrokerToControllerRequestThread) [2022-09-30 17:28:16,617] INFO Updated connection-accept-rate max connection creation rate to 2147483647 (kafka.network.ConnectionQuotas) [2022-09-30 17:28:16,619] INFO Awaiting socket connections on 0.0.0.0:9092. (kafka.network.DataPlaneAcceptor) [2022-09-30 17:28:16,633] INFO [SocketServer listenerType=BROKER, nodeId=1] Created data-plane acceptor and processors for endpoint : ListenerName(PLAINTEXT) (kafka.network.SocketServer) [2022-09-30 17:28:16,659] INFO [BrokerToControllerChannelManager broker=1 name=alterPartition]: Starting (kafka.server.BrokerToControllerRequestThread) [2022-09-30 17:28:16,659] INFO [BrokerToControllerChannelManager broker=1 name=alterPartition]: Recorded new controller, from now on will use broker localhost:9093 (id: 1 rack: null) (kafka.server.BrokerToControllerRequestThread) [2022-09-30 17:28:16,670] INFO [ExpirationReaper-1-Produce]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2022-09-30 17:28:16,670] INFO [ExpirationReaper-1-Fetch]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2022-09-30 17:28:16,670] INFO [ExpirationReaper-1-DeleteRecords]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2022-09-30 17:28:16,671] INFO [ExpirationReaper-1-ElectLeader]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2022-09-30 17:28:16,693] INFO [ExpirationReaper-1-Heartbeat]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2022-09-30 17:28:16,695] INFO [ExpirationReaper-1-Rebalance]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2022-09-30 17:28:16,753] INFO [RaftManager nodeId=1] Registered the listener kafka.server.metadata.BrokerMetadataListener@437286818 (org.apache.kafka.raft.KafkaRaftClient) [2022-09-30 17:28:16,757] INFO [BrokerLifecycleManager id=1] Incarnation Ng-MVLc7Td-h0IBBPioE-Q of broker 1 in cluster ioGBNME3Sn6swjyfc7D0PQ is now STARTING. (kafka.server.BrokerLifecycleManager) [2022-09-30 17:28:16,760] INFO [BrokerToControllerChannelManager broker=1 name=heartbeat]: Starting (kafka.server.BrokerToControllerRequestThread) [2022-09-30 17:28:16,761] INFO [BrokerToControllerChannelManager broker=1 name=heartbeat]: Recorded new controller, from now on will use broker localhost:9093 (id: 1 rack: null) (kafka.server.BrokerToControllerRequestThread) [2022-09-30 17:28:16,846] INFO [ExpirationReaper-1-AlterAcls]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2022-09-30 17:28:16,894] INFO [Controller 1] Added new fenced broker: 1 (org.apache.kafka.controller.ClusterControlManager) [2022-09-30 17:28:16,895] INFO [Controller 1] Registered new broker: RegisterBrokerRecord(brokerId=1, incarnationId=Ng-MVLc7Td-h0IBBPioE-Q, brokerEpoch=2, endPoints=[BrokerEndpoint(name='PLAINTEXT', host='localhost', port=9092, securityProtocol=0)], features=[BrokerFeature(name='metadata.version', minSupportedVersion=1, maxSupportedVersion=7)], rack=null, fenced=true, inControlledShutdown=false) (org.apache.kafka.controller.ClusterControlManager) [2022-09-30 17:28:16,927] INFO [BrokerLifecycleManager id=1] Successfully registered broker 1 with broker epoch 2 (kafka.server.BrokerLifecycleManager) [2022-09-30 17:28:16,937] INFO [BrokerLifecycleManager id=1] The broker has caught up. Transitioning from STARTING to RECOVERY. (kafka.server.BrokerLifecycleManager) [2022-09-30 17:28:16,940] INFO [BrokerMetadataListener id=1] Starting to publish metadata events at offset 2. (kafka.server.metadata.BrokerMetadataListener) [2022-09-30 17:28:16,942] INFO [BrokerMetadataPublisher id=1] Publishing initial metadata at offset OffsetAndEpoch(offset=2, epoch=1) with metadata.version 3.3-IV3. (kafka.server.metadata.BrokerMetadataPublisher) [2022-09-30 17:28:16,943] INFO Loading logs from log dirs ArraySeq(/tmp/kraft-combined-logs) (kafka.log.LogManager) [2022-09-30 17:28:16,945] INFO Attempting recovery for all logs in /tmp/kraft-combined-logs since no clean shutdown file was found (kafka.log.LogManager) [2022-09-30 17:28:16,956] INFO Loaded 0 logs in 13ms. (kafka.log.LogManager) [2022-09-30 17:28:16,956] INFO Starting log cleanup with a period of 300000 ms. (kafka.log.LogManager) [2022-09-30 17:28:16,960] INFO [BrokerLifecycleManager id=1] The broker is in RECOVERY. (kafka.server.BrokerLifecycleManager) [2022-09-30 17:28:17,021] INFO Starting log flusher with a default period of 9223372036854775807 ms. (kafka.log.LogManager) [2022-09-30 17:28:17,249] INFO [GroupCoordinator 1]: Starting up. (kafka.coordinator.group.GroupCoordinator) [2022-09-30 17:28:17,261] INFO [LogDirFailureHandler]: Starting (kafka.server.ReplicaManager$LogDirFailureHandler) [2022-09-30 17:28:17,261] INFO [GroupCoordinator 1]: Startup complete. (kafka.coordinator.group.GroupCoordinator) [2022-09-30 17:28:17,262] INFO [TransactionCoordinator id=1] Starting up. (kafka.coordinator.transaction.TransactionCoordinator) [2022-09-30 17:28:17,268] INFO [TransactionCoordinator id=1] Startup complete. (kafka.coordinator.transaction.TransactionCoordinator) [2022-09-30 17:28:17,273] INFO [BrokerMetadataPublisher id=1] Updating metadata.version to 7 at offset OffsetAndEpoch(offset=2, epoch=1). (kafka.server.metadata.BrokerMetadataPublisher) [2022-09-30 17:28:17,292] INFO KafkaConfig values: advertised.listeners = PLAINTEXT://localhost:9092 alter.config.policy.class.name = null alter.log.dirs.replication.quota.window.num = 11 alter.log.dirs.replication.quota.window.size.seconds = 1 authorizer.class.name = auto.create.topics.enable = true auto.leader.rebalance.enable = true background.threads = 10 broker.heartbeat.interval.ms = 2000 broker.id = 1 broker.id.generation.enable = true broker.rack = null broker.session.timeout.ms = 9000 client.quota.callback.class = null compression.type = producer connection.failed.authentication.delay.ms = 100 connections.max.idle.ms = 600000 connections.max.reauth.ms = 0 control.plane.listener.name = null controlled.shutdown.enable = true controlled.shutdown.max.retries = 3 controlled.shutdown.retry.backoff.ms = 5000 controller.listener.names = CONTROLLER controller.quorum.append.linger.ms = 25 controller.quorum.election.backoff.max.ms = 1000 controller.quorum.election.timeout.ms = 1000 controller.quorum.fetch.timeout.ms = 2000 controller.quorum.request.timeout.ms = 2000 controller.quorum.retry.backoff.ms = 20 controller.quorum.voters = [1@localhost:9093] controller.quota.window.num = 11 controller.quota.window.size.seconds = 1 controller.socket.timeout.ms = 30000 create.topic.policy.class.name = null default.replication.factor = 1 delegation.token.expiry.check.interval.ms = 3600000 delegation.token.expiry.time.ms = 86400000 delegation.token.master.key = null delegation.token.max.lifetime.ms = 604800000 delegation.token.secret.key = null delete.records.purgatory.purge.interval.requests = 1 delete.topic.enable = true early.start.listeners = null fetch.max.bytes = 57671680 fetch.purgatory.purge.interval.requests = 1000 group.initial.rebalance.delay.ms = 3000 group.max.session.timeout.ms = 1800000 group.max.size = 2147483647 group.min.session.timeout.ms = 6000 initial.broker.registration.timeout.ms = 60000 inter.broker.listener.name = PLAINTEXT inter.broker.protocol.version = 3.3-IV3 kafka.metrics.polling.interval.secs = 10 kafka.metrics.reporters = [] leader.imbalance.check.interval.seconds = 300 leader.imbalance.per.broker.percentage = 10 listener.security.protocol.map = CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT,SSL:SSL,SASL_PLAINTEXT:SASL_PLAINTEXT,SASL_SSL:SASL_SSL listeners = PLAINTEXT://:9092,CONTROLLER://:9093 log.cleaner.backoff.ms = 15000 log.cleaner.dedupe.buffer.size = 134217728 log.cleaner.delete.retention.ms = 86400000 log.cleaner.enable = true log.cleaner.io.buffer.load.factor = 0.9 log.cleaner.io.buffer.size = 524288 log.cleaner.io.max.bytes.per.second = 1.7976931348623157E308 log.cleaner.max.compaction.lag.ms = 9223372036854775807 log.cleaner.min.cleanable.ratio = 0.5 log.cleaner.min.compaction.lag.ms = 0 log.cleaner.threads = 1 log.cleanup.policy = [delete] log.dir = /tmp/kafka-logs log.dirs = /tmp/kraft-combined-logs log.flush.interval.messages = 9223372036854775807 log.flush.interval.ms = null log.flush.offset.checkpoint.interval.ms = 60000 log.flush.scheduler.interval.ms = 9223372036854775807 log.flush.start.offset.checkpoint.interval.ms = 60000 log.index.interval.bytes = 4096 log.index.size.max.bytes = 10485760 log.message.downconversion.enable = true log.message.format.version = 3.0-IV1 log.message.timestamp.difference.max.ms = 9223372036854775807 log.message.timestamp.type = CreateTime log.preallocate = false log.retention.bytes = -1 log.retention.check.interval.ms = 300000 log.retention.hours = 168 log.retention.minutes = null log.retention.ms = null log.roll.hours = 168 log.roll.jitter.hours = 0 log.roll.jitter.ms = null log.roll.ms = null log.segment.bytes = 1073741824 log.segment.delete.delay.ms = 60000 max.connection.creation.rate = 2147483647 max.connections = 2147483647 max.connections.per.ip = 2147483647 max.connections.per.ip.overrides = max.incremental.fetch.session.cache.slots = 1000 message.max.bytes = 1048588 metadata.log.dir = null metadata.log.max.record.bytes.between.snapshots = 20971520 metadata.log.segment.bytes = 1073741824 metadata.log.segment.min.bytes = 8388608 metadata.log.segment.ms = 604800000 metadata.max.idle.interval.ms = 500 metadata.max.retention.bytes = -1 metadata.max.retention.ms = 604800000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 min.insync.replicas = 1 node.id = 1 num.io.threads = 8 num.network.threads = 3 num.partitions = 1 num.recovery.threads.per.data.dir = 1 num.replica.alter.log.dirs.threads = null num.replica.fetchers = 1 offset.metadata.max.bytes = 4096 offsets.commit.required.acks = -1 offsets.commit.timeout.ms = 5000 offsets.load.buffer.size = 5242880 offsets.retention.check.interval.ms = 600000 offsets.retention.minutes = 10080 offsets.topic.compression.codec = 0 offsets.topic.num.partitions = 50 offsets.topic.replication.factor = 1 offsets.topic.segment.bytes = 104857600 password.encoder.cipher.algorithm = AES/CBC/PKCS5Padding password.encoder.iterations = 4096 password.encoder.key.length = 128 password.encoder.keyfactory.algorithm = null password.encoder.old.secret = null password.encoder.secret = null principal.builder.class = class org.apache.kafka.common.security.authenticator.DefaultKafkaPrincipalBuilder process.roles = [broker, controller] producer.purgatory.purge.interval.requests = 1000 queued.max.request.bytes = -1 queued.max.requests = 500 quota.window.num = 11 quota.window.size.seconds = 1 remote.log.index.file.cache.total.size.bytes = 1073741824 remote.log.manager.task.interval.ms = 30000 remote.log.manager.task.retry.backoff.max.ms = 30000 remote.log.manager.task.retry.backoff.ms = 500 remote.log.manager.task.retry.jitter = 0.2 remote.log.manager.thread.pool.size = 10 remote.log.metadata.manager.class.name = null remote.log.metadata.manager.class.path = null remote.log.metadata.manager.impl.prefix = null remote.log.metadata.manager.listener.name = null remote.log.reader.max.pending.tasks = 100 remote.log.reader.threads = 10 remote.log.storage.manager.class.name = null remote.log.storage.manager.class.path = null remote.log.storage.manager.impl.prefix = null remote.log.storage.system.enable = false replica.fetch.backoff.ms = 1000 replica.fetch.max.bytes = 1048576 replica.fetch.min.bytes = 1 replica.fetch.response.max.bytes = 10485760 replica.fetch.wait.max.ms = 500 replica.high.watermark.checkpoint.interval.ms = 5000 replica.lag.time.max.ms = 30000 replica.selector.class = null replica.socket.receive.buffer.bytes = 65536 replica.socket.timeout.ms = 30000 replication.quota.window.num = 11 replication.quota.window.size.seconds = 1 request.timeout.ms = 30000 reserved.broker.max.id = 1000 sasl.client.callback.handler.class = null sasl.enabled.mechanisms = [GSSAPI] sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.principal.to.local.rules = [DEFAULT] sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism.controller.protocol = GSSAPI sasl.mechanism.inter.broker.protocol = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null sasl.server.callback.handler.class = null sasl.server.max.receive.size = 524288 security.inter.broker.protocol = PLAINTEXT security.providers = null socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 socket.listen.backlog.size = 50 socket.receive.buffer.bytes = 102400 socket.request.max.bytes = 104857600 socket.send.buffer.bytes = 102400 ssl.cipher.suites = [] ssl.client.auth = none ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.principal.mapping.rules = DEFAULT ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.abort.timed.out.transaction.cleanup.interval.ms = 10000 transaction.max.timeout.ms = 900000 transaction.remove.expired.transaction.cleanup.interval.ms = 3600000 transaction.state.log.load.buffer.size = 5242880 transaction.state.log.min.isr = 1 transaction.state.log.num.partitions = 50 transaction.state.log.replication.factor = 1 transaction.state.log.segment.bytes = 104857600 transactional.id.expiration.ms = 604800000 unclean.leader.election.enable = false zookeeper.clientCnxnSocket = null zookeeper.connect = null zookeeper.connection.timeout.ms = null zookeeper.max.in.flight.requests = 10 zookeeper.session.timeout.ms = 18000 zookeeper.set.acl = false zookeeper.ssl.cipher.suites = null zookeeper.ssl.client.enable = false zookeeper.ssl.crl.enable = false zookeeper.ssl.enabled.protocols = null zookeeper.ssl.endpoint.identification.algorithm = HTTPS zookeeper.ssl.keystore.location = null zookeeper.ssl.keystore.password = null zookeeper.ssl.keystore.type = null zookeeper.ssl.ocsp.enable = false zookeeper.ssl.protocol = TLSv1.2 zookeeper.ssl.truststore.location = null zookeeper.ssl.truststore.password = null zookeeper.ssl.truststore.type = null (kafka.server.KafkaConfig) [2022-09-30 17:28:17,297] INFO [SocketServer listenerType=BROKER, nodeId=1] Enabling request processing. (kafka.network.SocketServer) [2022-09-30 17:28:17,307] INFO [Controller 1] The request from broker 1 to unfence has been granted because it has caught up with the offset of it's register broker record 2. (org.apache.kafka.controller.BrokerHeartbeatManager) [2022-09-30 17:28:17,309] INFO [Transaction Marker Channel Manager 1]: Starting (kafka.coordinator.transaction.TransactionMarkerChannelManager) [2022-09-30 17:28:17,326] INFO [Controller 1] Unfenced broker: 1 (org.apache.kafka.controller.ClusterControlManager) [2022-09-30 17:28:17,368] INFO [BrokerLifecycleManager id=1] The broker has been unfenced. Transitioning from RECOVERY to RUNNING. (kafka.server.BrokerLifecycleManager) [2022-09-30 17:28:17,370] INFO [BrokerServer id=1] Transition from STARTING to STARTED (kafka.server.BrokerServer) [2022-09-30 17:28:17,371] INFO Kafka version: 3.3.0 (org.apache.kafka.common.utils.AppInfoParser) [2022-09-30 17:28:17,371] INFO Kafka commitId: 9d1f9f77642d7e95 (org.apache.kafka.common.utils.AppInfoParser) [2022-09-30 17:28:17,371] INFO Kafka startTimeMs: 1664558897370 (org.apache.kafka.common.utils.AppInfoParser) [2022-09-30 17:28:17,372] INFO [KafkaRaftServer nodeId=1] Kafka Server started (kafka.server.KafkaRaftServer) [2022-09-30 17:28:17,476] INFO [Controller 1] CreateTopics result(s): CreatableTopic(name='topicwithoutdots', numPartitions=-1, replicationFactor=-1, assignments=[], configs=[]): SUCCESS (org.apache.kafka.controller.ReplicationControlManager) [2022-09-30 17:28:17,476] INFO [Controller 1] Created topic topicwithoutdots with topic ID SpVoQ0qjSFmlAxDBzDnwwA. (org.apache.kafka.controller.ReplicationControlManager) [2022-09-30 17:28:17,477] INFO [Controller 1] Created partition topicwithoutdots-0 with topic ID SpVoQ0qjSFmlAxDBzDnwwA and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) [2022-09-30 17:28:17,509] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions Set(topicwithoutdots-0) (kafka.server.ReplicaFetcherManager) [2022-09-30 17:28:17,527] INFO [LogLoader partition=topicwithoutdots-0, dir=/tmp/kraft-combined-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2022-09-30 17:28:17,531] INFO Created log for partition topicwithoutdots-0 in /tmp/kraft-combined-logs/topicwithoutdots-0 with properties {} (kafka.log.LogManager) [2022-09-30 17:28:17,532] INFO [Partition topicwithoutdots-0 broker=1] No checkpointed highwatermark is found for partition topicwithoutdots-0 (kafka.cluster.Partition) [2022-09-30 17:28:17,533] INFO [Partition topicwithoutdots-0 broker=1] Log loaded for partition topicwithoutdots-0 with initial high watermark 0 (kafka.cluster.Partition) [2022-09-30 17:28:20,052] INFO [Controller 1] Removed topic topicwithoutdots with ID SpVoQ0qjSFmlAxDBzDnwwA. (org.apache.kafka.controller.ReplicationControlManager) [2022-09-30 17:28:20,110] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions Set(topicwithoutdots-0) (kafka.server.ReplicaFetcherManager) [2022-09-30 17:28:20,110] INFO [ReplicaAlterLogDirsManager on broker 1] Removed fetcher for partitions Set(topicwithoutdots-0) (kafka.server.ReplicaAlterLogDirsManager) [2022-09-30 17:28:20,118] INFO Log for partition topicwithoutdots-0 is renamed to /tmp/kraft-combined-logs/topicwithoutdots-0.13e4ce0a40e44e3faced9d160ee2417e-delete and is scheduled for deletion (kafka.log.LogManager) [2022-09-30 17:28:20,133] INFO [GroupCoordinator 1]: Removed 0 offsets associated with deleted partitions: topicwithoutdots-0. (kafka.coordinator.group.GroupCoordinator) [2022-09-30 17:28:20,138] INFO [BrokerMetadataPublisher id=1] Updating topic topicwithoutdots with new configuration : (kafka.server.metadata.BrokerMetadataPublisher) [2022-09-30 17:28:22,568] INFO [Controller 1] CreateTopics result(s): CreatableTopic(name='topicwithoutdots', numPartitions=-1, replicationFactor=-1, assignments=[], configs=[]): SUCCESS (org.apache.kafka.controller.ReplicationControlManager) [2022-09-30 17:28:22,569] INFO [Controller 1] Created topic topicwithoutdots with topic ID 21DW0GWGRne10gnfVtOmxQ. (org.apache.kafka.controller.ReplicationControlManager) [2022-09-30 17:28:22,569] INFO [Controller 1] Created partition topicwithoutdots-0 with topic ID 21DW0GWGRne10gnfVtOmxQ and PartitionRegistration(replicas=[1], isr=[1], removingReplicas=[], addingReplicas=[], leader=1, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0). (org.apache.kafka.controller.ReplicationControlManager) [2022-09-30 17:28:22,596] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions Set(topicwithoutdots-0) (kafka.server.ReplicaFetcherManager) [2022-09-30 17:28:22,600] INFO [LogLoader partition=topicwithoutdots-0, dir=/tmp/kraft-combined-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$) [2022-09-30 17:28:22,601] INFO Created log for partition topicwithoutdots-0 in /tmp/kraft-combined-logs/topicwithoutdots-0 with properties {} (kafka.log.LogManager) [2022-09-30 17:28:22,601] INFO [Partition topicwithoutdots-0 broker=1] No checkpointed highwatermark is found for partition topicwithoutdots-0 (kafka.cluster.Partition) [2022-09-30 17:28:22,601] INFO [Partition topicwithoutdots-0 broker=1] Log loaded for partition topicwithoutdots-0 with initial high watermark 0 (kafka.cluster.Partition) [2022-09-30 17:28:23,944] INFO Terminating process due to signal SIGTERM (org.apache.kafka.common.utils.LoggingSignalHandler) [2022-09-30 17:28:23,946] INFO [BrokerServer id=1] Transition from STARTED to SHUTTING_DOWN (kafka.server.BrokerServer) [2022-09-30 17:28:23,947] INFO [BrokerServer id=1] shutting down (kafka.server.BrokerServer) [2022-09-30 17:28:23,952] INFO [BrokerLifecycleManager id=1] Beginning controlled shutdown. (kafka.server.BrokerLifecycleManager) [2022-09-30 17:28:23,954] INFO [Controller 1] Unfenced broker 1 has requested and been granted a controlled shutdown. (org.apache.kafka.controller.BrokerHeartbeatManager) [2022-09-30 17:28:23,957] INFO [Controller 1] enterControlledShutdown[1]: changing 1 partition(s) (org.apache.kafka.controller.ReplicationControlManager) [2022-09-30 17:28:23,986] INFO [BrokerLifecycleManager id=1] The broker is in PENDING_CONTROLLED_SHUTDOWN state, still waiting for the active controller. (kafka.server.BrokerLifecycleManager) [2022-09-30 17:28:24,038] INFO [Controller 1] The request from broker 1 to shut down has been granted since the lowest active offset 9223372036854775807 is now greater than the broker's controlled shutdown offset 24. (org.apache.kafka.controller.BrokerHeartbeatManager) [2022-09-30 17:28:24,038] INFO [Controller 1] handleBrokerFenced: changing 1 partition(s) (org.apache.kafka.controller.ReplicationControlManager) [2022-09-30 17:28:24,039] INFO [Controller 1] Fenced broker: 1 (org.apache.kafka.controller.ClusterControlManager) [2022-09-30 17:28:24,067] INFO [BrokerLifecycleManager id=1] The controller has asked us to exit controlled shutdown. (kafka.server.BrokerLifecycleManager) [2022-09-30 17:28:24,067] INFO [BrokerLifecycleManager id=1] beginShutdown: shutting down event queue. (org.apache.kafka.queue.KafkaEventQueue) [2022-09-30 17:28:24,068] INFO [BrokerLifecycleManager id=1] Transitioning from PENDING_CONTROLLED_SHUTDOWN to SHUTTING_DOWN. (kafka.server.BrokerLifecycleManager) [2022-09-30 17:28:24,068] INFO [BrokerToControllerChannelManager broker=1 name=heartbeat]: Shutting down (kafka.server.BrokerToControllerRequestThread) [2022-09-30 17:28:24,069] INFO [BrokerMetadataListener id=1] beginShutdown: shutting down event queue. (org.apache.kafka.queue.KafkaEventQueue) [2022-09-30 17:28:24,069] INFO [BrokerToControllerChannelManager broker=1 name=heartbeat]: Shutdown completed (kafka.server.BrokerToControllerRequestThread) [2022-09-30 17:28:24,070] INFO [SocketServer listenerType=BROKER, nodeId=1] Stopping socket server request processors (kafka.network.SocketServer) [2022-09-30 17:28:24,070] INFO [BrokerToControllerChannelManager broker=1 name=heartbeat]: Stopped (kafka.server.BrokerToControllerRequestThread) [2022-09-30 17:28:24,084] INFO Broker to controller channel manager for heartbeat shutdown (kafka.server.BrokerToControllerChannelManagerImpl) [2022-09-30 17:28:24,088] INFO [SocketServer listenerType=BROKER, nodeId=1] Stopped socket server request processors (kafka.network.SocketServer) [2022-09-30 17:28:24,089] INFO [data-plane Kafka Request Handler on Broker 1], shutting down (kafka.server.KafkaRequestHandlerPool) [2022-09-30 17:28:24,094] INFO [data-plane Kafka Request Handler on Broker 1], shut down completely (kafka.server.KafkaRequestHandlerPool) [2022-09-30 17:28:24,094] INFO [ExpirationReaper-1-AlterAcls]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2022-09-30 17:28:24,096] INFO [ExpirationReaper-1-AlterAcls]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2022-09-30 17:28:24,097] INFO [ExpirationReaper-1-AlterAcls]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2022-09-30 17:28:24,097] INFO [KafkaApi-1] Shutdown complete. (kafka.server.KafkaApis) [2022-09-30 17:28:24,098] INFO [BrokerMetadataListener id=1] closed event queue. (org.apache.kafka.queue.KafkaEventQueue) [2022-09-30 17:28:24,106] INFO [TransactionCoordinator id=1] Shutting down. (kafka.coordinator.transaction.TransactionCoordinator) [2022-09-30 17:28:24,109] INFO [Transaction State Manager 1]: Shutdown complete (kafka.coordinator.transaction.TransactionStateManager) [2022-09-30 17:28:24,109] INFO [Transaction Marker Channel Manager 1]: Shutting down (kafka.coordinator.transaction.TransactionMarkerChannelManager) [2022-09-30 17:28:24,109] INFO [Transaction Marker Channel Manager 1]: Stopped (kafka.coordinator.transaction.TransactionMarkerChannelManager) [2022-09-30 17:28:24,109] INFO [Transaction Marker Channel Manager 1]: Shutdown completed (kafka.coordinator.transaction.TransactionMarkerChannelManager) [2022-09-30 17:28:24,111] INFO [TransactionCoordinator id=1] Shutdown complete. (kafka.coordinator.transaction.TransactionCoordinator) [2022-09-30 17:28:24,112] INFO [GroupCoordinator 1]: Shutting down. (kafka.coordinator.group.GroupCoordinator) [2022-09-30 17:28:24,113] INFO [ExpirationReaper-1-Heartbeat]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2022-09-30 17:28:24,117] INFO [ExpirationReaper-1-Heartbeat]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2022-09-30 17:28:24,117] INFO [ExpirationReaper-1-Heartbeat]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2022-09-30 17:28:24,117] INFO [ExpirationReaper-1-Rebalance]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2022-09-30 17:28:24,120] INFO [ExpirationReaper-1-Rebalance]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2022-09-30 17:28:24,120] INFO [ExpirationReaper-1-Rebalance]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2022-09-30 17:28:24,121] INFO [GroupCoordinator 1]: Shutdown complete. (kafka.coordinator.group.GroupCoordinator) [2022-09-30 17:28:24,122] INFO [ReplicaManager broker=1] Shutting down (kafka.server.ReplicaManager) [2022-09-30 17:28:24,122] INFO [LogDirFailureHandler]: Shutting down (kafka.server.ReplicaManager$LogDirFailureHandler) [2022-09-30 17:28:24,123] INFO [LogDirFailureHandler]: Stopped (kafka.server.ReplicaManager$LogDirFailureHandler) [2022-09-30 17:28:24,123] INFO [LogDirFailureHandler]: Shutdown completed (kafka.server.ReplicaManager$LogDirFailureHandler) [2022-09-30 17:28:24,124] INFO [ReplicaFetcherManager on broker 1] shutting down (kafka.server.ReplicaFetcherManager) [2022-09-30 17:28:24,125] INFO [ReplicaFetcherManager on broker 1] shutdown completed (kafka.server.ReplicaFetcherManager) [2022-09-30 17:28:24,126] INFO [ReplicaAlterLogDirsManager on broker 1] shutting down (kafka.server.ReplicaAlterLogDirsManager) [2022-09-30 17:28:24,126] INFO [ReplicaAlterLogDirsManager on broker 1] shutdown completed (kafka.server.ReplicaAlterLogDirsManager) [2022-09-30 17:28:24,126] INFO [ExpirationReaper-1-Fetch]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2022-09-30 17:28:24,127] INFO [ExpirationReaper-1-Fetch]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2022-09-30 17:28:24,127] INFO [ExpirationReaper-1-Fetch]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2022-09-30 17:28:24,127] INFO [ExpirationReaper-1-Produce]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2022-09-30 17:28:24,131] INFO [ExpirationReaper-1-Produce]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2022-09-30 17:28:24,131] INFO [ExpirationReaper-1-Produce]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2022-09-30 17:28:24,131] INFO [ExpirationReaper-1-DeleteRecords]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2022-09-30 17:28:24,132] INFO [ExpirationReaper-1-DeleteRecords]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2022-09-30 17:28:24,132] INFO [ExpirationReaper-1-DeleteRecords]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2022-09-30 17:28:24,133] INFO [ExpirationReaper-1-ElectLeader]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2022-09-30 17:28:24,134] INFO [ExpirationReaper-1-ElectLeader]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2022-09-30 17:28:24,135] INFO [ExpirationReaper-1-ElectLeader]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2022-09-30 17:28:24,140] INFO [ReplicaManager broker=1] Shut down completely (kafka.server.ReplicaManager) [2022-09-30 17:28:24,140] INFO [BrokerToControllerChannelManager broker=1 name=alterPartition]: Shutting down (kafka.server.BrokerToControllerRequestThread) [2022-09-30 17:28:24,141] INFO [BrokerToControllerChannelManager broker=1 name=alterPartition]: Stopped (kafka.server.BrokerToControllerRequestThread) [2022-09-30 17:28:24,141] INFO [BrokerToControllerChannelManager broker=1 name=alterPartition]: Shutdown completed (kafka.server.BrokerToControllerRequestThread) [2022-09-30 17:28:24,141] INFO Broker to controller channel manager for alterPartition shutdown (kafka.server.BrokerToControllerChannelManagerImpl) [2022-09-30 17:28:24,142] INFO [BrokerToControllerChannelManager broker=1 name=forwarding]: Shutting down (kafka.server.BrokerToControllerRequestThread) [2022-09-30 17:28:24,142] INFO [BrokerToControllerChannelManager broker=1 name=forwarding]: Stopped (kafka.server.BrokerToControllerRequestThread) [2022-09-30 17:28:24,142] INFO [BrokerToControllerChannelManager broker=1 name=forwarding]: Shutdown completed (kafka.server.BrokerToControllerRequestThread) [2022-09-30 17:28:24,143] INFO Broker to controller channel manager for forwarding shutdown (kafka.server.BrokerToControllerChannelManagerImpl) [2022-09-30 17:28:24,144] INFO Shutting down. (kafka.log.LogManager) [2022-09-30 17:28:24,175] INFO Shutdown complete. (kafka.log.LogManager) [2022-09-30 17:28:24,176] INFO [ThrottledChannelReaper-Fetch]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2022-09-30 17:28:24,177] INFO [ThrottledChannelReaper-Fetch]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2022-09-30 17:28:24,177] INFO [ThrottledChannelReaper-Fetch]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2022-09-30 17:28:24,179] INFO [ThrottledChannelReaper-Produce]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2022-09-30 17:28:24,179] INFO [ThrottledChannelReaper-Produce]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2022-09-30 17:28:24,179] INFO [ThrottledChannelReaper-Produce]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2022-09-30 17:28:24,180] INFO [ThrottledChannelReaper-Request]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2022-09-30 17:28:24,180] INFO [ThrottledChannelReaper-Request]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2022-09-30 17:28:24,180] INFO [ThrottledChannelReaper-Request]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2022-09-30 17:28:24,180] INFO [ThrottledChannelReaper-ControllerMutation]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2022-09-30 17:28:24,180] INFO [ThrottledChannelReaper-ControllerMutation]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2022-09-30 17:28:24,180] INFO [ThrottledChannelReaper-ControllerMutation]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2022-09-30 17:28:24,181] INFO [SocketServer listenerType=BROKER, nodeId=1] Shutting down socket server (kafka.network.SocketServer) [2022-09-30 17:28:24,210] INFO [SocketServer listenerType=BROKER, nodeId=1] Shutdown completed (kafka.network.SocketServer) [2022-09-30 17:28:24,213] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [2022-09-30 17:28:24,213] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [2022-09-30 17:28:24,213] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [2022-09-30 17:28:24,215] INFO Broker and topic stats closed (kafka.server.BrokerTopicStats) [2022-09-30 17:28:24,215] INFO [BrokerLifecycleManager id=1] closed event queue. (org.apache.kafka.queue.KafkaEventQueue) [2022-09-30 17:28:24,216] INFO App info kafka.server for 1 unregistered (org.apache.kafka.common.utils.AppInfoParser) [2022-09-30 17:28:24,216] INFO [BrokerServer id=1] shut down completed (kafka.server.BrokerServer) [2022-09-30 17:28:24,216] INFO [BrokerServer id=1] Transition from SHUTTING_DOWN to SHUTDOWN (kafka.server.BrokerServer) [2022-09-30 17:28:24,216] INFO [raft-expiration-reaper]: Shutting down (kafka.raft.TimingWheelExpirationService$ExpiredOperationReaper) [2022-09-30 17:28:24,334] INFO [raft-expiration-reaper]: Shutdown completed (kafka.raft.TimingWheelExpirationService$ExpiredOperationReaper) [2022-09-30 17:28:24,334] INFO [raft-expiration-reaper]: Stopped (kafka.raft.TimingWheelExpirationService$ExpiredOperationReaper) [2022-09-30 17:28:24,334] INFO [kafka-raft-io-thread]: Shutting down (kafka.raft.KafkaRaftManager$RaftIoThread) [2022-09-30 17:28:24,334] INFO [RaftManager nodeId=1] Beginning graceful shutdown (org.apache.kafka.raft.KafkaRaftClient) [2022-09-30 17:28:24,336] INFO [RaftManager nodeId=1] Graceful shutdown completed (org.apache.kafka.raft.KafkaRaftClient) [2022-09-30 17:28:24,336] INFO [kafka-raft-io-thread]: Completed graceful shutdown of RaftClient (kafka.raft.KafkaRaftManager$RaftIoThread) [2022-09-30 17:28:24,336] INFO [kafka-raft-io-thread]: Stopped (kafka.raft.KafkaRaftManager$RaftIoThread) [2022-09-30 17:28:24,337] INFO [kafka-raft-io-thread]: Shutdown completed (kafka.raft.KafkaRaftManager$RaftIoThread) [2022-09-30 17:28:24,338] INFO [kafka-raft-outbound-request-thread]: Shutting down (kafka.raft.RaftSendThread) [2022-09-30 17:28:24,338] INFO [kafka-raft-outbound-request-thread]: Stopped (kafka.raft.RaftSendThread) [2022-09-30 17:28:24,339] INFO [kafka-raft-outbound-request-thread]: Shutdown completed (kafka.raft.RaftSendThread) [2022-09-30 17:28:24,342] INFO [ProducerStateManager partition=__cluster_metadata-0] Wrote producer snapshot at offset 28 with 0 producer ids in 2 ms. (kafka.log.ProducerStateManager) [2022-09-30 17:28:24,348] INFO [ControllerServer id=1] shutting down (kafka.server.ControllerServer) [2022-09-30 17:28:24,348] INFO [SocketServer listenerType=CONTROLLER, nodeId=1] Stopping socket server request processors (kafka.network.SocketServer) [2022-09-30 17:28:24,353] INFO [SocketServer listenerType=CONTROLLER, nodeId=1] Stopped socket server request processors (kafka.network.SocketServer) [2022-09-30 17:28:24,353] INFO [Controller 1] QuorumController#beginShutdown: shutting down event queue. (org.apache.kafka.queue.KafkaEventQueue) [2022-09-30 17:28:24,353] ERROR [Controller 1] writeNoOpRecord: unable to start processing because of TimeoutException. (org.apache.kafka.controller.QuorumController) [2022-09-30 17:28:24,353] ERROR [Controller 1] maybeBalancePartitionLeaders: unable to start processing because of TimeoutException. (org.apache.kafka.controller.QuorumController) [2022-09-30 17:28:24,353] INFO [SocketServer listenerType=CONTROLLER, nodeId=1] Shutting down socket server (kafka.network.SocketServer) [2022-09-30 17:28:24,365] INFO [SocketServer listenerType=CONTROLLER, nodeId=1] Shutdown completed (kafka.network.SocketServer) [2022-09-30 17:28:24,366] INFO [data-plane Kafka Request Handler on Broker 1], shutting down (kafka.server.KafkaRequestHandlerPool) [2022-09-30 17:28:24,367] INFO [data-plane Kafka Request Handler on Broker 1], shut down completely (kafka.server.KafkaRequestHandlerPool) [2022-09-30 17:28:24,368] INFO [ExpirationReaper-1-AlterAcls]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2022-09-30 17:28:24,373] INFO [ExpirationReaper-1-AlterAcls]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2022-09-30 17:28:24,373] INFO [ExpirationReaper-1-AlterAcls]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper) [2022-09-30 17:28:24,374] INFO [ThrottledChannelReaper-Fetch]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2022-09-30 17:28:24,374] INFO [ThrottledChannelReaper-Fetch]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2022-09-30 17:28:24,374] INFO [ThrottledChannelReaper-Fetch]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2022-09-30 17:28:24,374] INFO [ThrottledChannelReaper-Produce]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2022-09-30 17:28:24,374] INFO [ThrottledChannelReaper-Produce]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2022-09-30 17:28:24,374] INFO [ThrottledChannelReaper-Produce]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2022-09-30 17:28:24,374] INFO [ThrottledChannelReaper-Request]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2022-09-30 17:28:24,379] INFO [ThrottledChannelReaper-Request]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2022-09-30 17:28:24,379] INFO [ThrottledChannelReaper-Request]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2022-09-30 17:28:24,379] INFO [ThrottledChannelReaper-ControllerMutation]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2022-09-30 17:28:24,380] INFO [ThrottledChannelReaper-ControllerMutation]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2022-09-30 17:28:24,380] INFO [ThrottledChannelReaper-ControllerMutation]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper) [2022-09-30 17:28:24,380] INFO [Controller 1] closed event queue. (org.apache.kafka.queue.KafkaEventQueue) [2022-09-30 17:28:24,382] INFO App info kafka.server for 1 unregistered (org.apache.kafka.common.utils.AppInfoParser)