API tools faq
paste
KeithTt

kafka3 server.log.2022-10-27-16

KeithTt
Nov 3rd, 2022
35
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 105.64 KB | None | 0 0
raw download clone embed print report
  1. [2022-10-27 16:01:55,062] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
  2. [2022-10-27 16:01:55,695] INFO Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation (org.apache.zookeeper.common.X509Util)
  3. [2022-10-27 16:01:56,105] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Recovering unflushed segment 0. 0/1 recovered for __cluster_metadata-0. (kafka.log.LogLoader)
  4. [2022-10-27 16:01:56,107] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
  5. [2022-10-27 16:01:56,108] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Reloading from producer snapshot and rebuilding producer state from offset 0 (kafka.log.UnifiedLog$)
  6. [2022-10-27 16:01:56,110] INFO Deleted producer state snapshot /opt/kafka_2.13-3.3.1/logs/__cluster_metadata-0/00000000000000000357.snapshot (kafka.log.SnapshotFile)
  7. [2022-10-27 16:01:56,111] INFO Deleted producer state snapshot /opt/kafka_2.13-3.3.1/logs/__cluster_metadata-0/00000000000000000419.snapshot (kafka.log.SnapshotFile)
  8. [2022-10-27 16:01:56,113] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Producer state recovery took 4ms for snapshot load and 0ms for segment recovery from offset 0 (kafka.log.UnifiedLog$)
  9. [2022-10-27 16:01:56,177] INFO [ProducerStateManager partition=__cluster_metadata-0] Wrote producer snapshot at offset 419 with 0 producer ids in 3 ms. (kafka.log.ProducerStateManager)
  10. [2022-10-27 16:01:56,201] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Loading producer state till offset 419 with message format version 2 (kafka.log.UnifiedLog$)
  11. [2022-10-27 16:01:56,201] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Reloading from producer snapshot and rebuilding producer state from offset 419 (kafka.log.UnifiedLog$)
  12. [2022-10-27 16:01:56,202] INFO [ProducerStateManager partition=__cluster_metadata-0] Loading producer state from snapshot file 'SnapshotFile(/opt/kafka_2.13-3.3.1/logs/__cluster_metadata-0/00000000000000000419.snapshot,419)' (kafka.log.ProducerStateManager)
  13. [2022-10-27 16:01:56,206] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Producer state recovery took 4ms for snapshot load and 1ms for segment recovery from offset 419 (kafka.log.UnifiedLog$)
  14. [2022-10-27 16:01:56,278] INFO Initialized snapshots with IDs SortedSet() from /opt/kafka_2.13-3.3.1/logs/__cluster_metadata-0 (kafka.raft.KafkaMetadataLog$)
  15. [2022-10-27 16:01:56,323] INFO [raft-expiration-reaper]: Starting (kafka.raft.TimingWheelExpirationService$ExpiredOperationReaper)
  16. [2022-10-27 16:01:56,585] INFO [RaftManager nodeId=1] Completed transition to ResignedState(localId=1, epoch=2, voters=[1], electionTimeoutMs=1672, unackedVoters=[], preferredSuccessors=[]) (org.apache.kafka.raft.QuorumState)
  17. [2022-10-27 16:01:56,590] INFO [RaftManager nodeId=1] Completed transition to CandidateState(localId=1, epoch=3, retries=1, electionTimeoutMs=1820) (org.apache.kafka.raft.QuorumState)
  18. [2022-10-27 16:01:56,599] INFO [RaftManager nodeId=1] Completed transition to Leader(localId=1, epoch=3, epochStartOffset=419, highWatermark=Optional.empty, voterStates={1=ReplicaState(nodeId=1, endOffset=Optional.empty, lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=true)}) (org.apache.kafka.raft.QuorumState)
  19. [2022-10-27 16:01:56,681] INFO Registered signal handlers for TERM, INT, HUP (org.apache.kafka.common.utils.LoggingSignalHandler)
  20. [2022-10-27 16:01:56,686] INFO [kafka-raft-outbound-request-thread]: Starting (kafka.raft.RaftSendThread)
  21. [2022-10-27 16:01:56,686] INFO [kafka-raft-io-thread]: Starting (kafka.raft.KafkaRaftManager$RaftIoThread)
  22. [2022-10-27 16:01:56,687] INFO Starting controller (kafka.server.ControllerServer)
  23. [2022-10-27 16:01:57,096] INFO Updated connection-accept-rate max connection creation rate to 2147483647 (kafka.network.ConnectionQuotas)
  24. [2022-10-27 16:01:57,102] INFO Awaiting socket connections on 0.0.0.0:9096. (kafka.network.DataPlaneAcceptor)
  25. [2022-10-27 16:01:57,132] INFO [SocketServer listenerType=CONTROLLER, nodeId=1] Created data-plane acceptor and processors for endpoint : ListenerName(CONTROLLER) (kafka.network.SocketServer)
  26. [2022-10-27 16:01:57,163] INFO [Controller 1] Creating new QuorumController with clusterId 08G1XXyDSiiK5MnqFUdfYA, authorizer Optional.empty. (org.apache.kafka.controller.QuorumController)
  27. [2022-10-27 16:01:57,166] INFO [RaftManager nodeId=1] Registered the listener org.apache.kafka.controller.QuorumController$QuorumMetaLogListener@1078290145 (org.apache.kafka.raft.KafkaRaftClient)
  28. [2022-10-27 16:01:57,172] INFO [ThrottledChannelReaper-Fetch]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  29. [2022-10-27 16:01:57,172] INFO [ThrottledChannelReaper-Produce]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  30. [2022-10-27 16:01:57,173] INFO [ThrottledChannelReaper-Request]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  31. [2022-10-27 16:01:57,175] INFO [ThrottledChannelReaper-ControllerMutation]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  32. [2022-10-27 16:01:57,178] INFO [Controller 1] Setting metadata.version to 7 (org.apache.kafka.controller.FeatureControlManager)
  33. [2022-10-27 16:01:57,184] INFO [Controller 1] Added new fenced broker: 1 (org.apache.kafka.controller.ClusterControlManager)
  34. [2022-10-27 16:01:57,184] INFO [Controller 1] Registered new broker: RegisterBrokerRecord(brokerId=1, incarnationId=YNd0XS1BSrigt9RSD89Bdw, brokerEpoch=3, endPoints=[BrokerEndpoint(name='PLAINTEXT', host='m-21-7', port=9095, securityProtocol=0)], features=[BrokerFeature(name='metadata.version', minSupportedVersion=1, maxSupportedVersion=7)], rack=null, fenced=true, inControlledShutdown=false) (org.apache.kafka.controller.ClusterControlManager)
  35. [2022-10-27 16:01:57,187] INFO [Controller 1] Unfenced broker: 1 (org.apache.kafka.controller.ClusterControlManager)
  36. [2022-10-27 16:01:57,190] INFO [ExpirationReaper-1-AlterAcls]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  37. [2022-10-27 16:01:57,194] INFO [SocketServer listenerType=CONTROLLER, nodeId=1] Enabling request processing. (kafka.network.SocketServer)
  38. [2022-10-27 16:01:57,197] INFO [BrokerServer id=1] Transition from SHUTDOWN to STARTING (kafka.server.BrokerServer)
  39. [2022-10-27 16:01:57,198] INFO [BrokerServer id=1] Starting broker (kafka.server.BrokerServer)
  40. [2022-10-27 16:01:57,200] INFO [Controller 1] Fenced broker: 1 (org.apache.kafka.controller.ClusterControlManager)
  41. [2022-10-27 16:01:57,200] INFO [Controller 1] Re-registered broker id 1: RegisterBrokerRecord(brokerId=1, incarnationId=debFBP8FSU2_1yfP2I0Hsw, brokerEpoch=357, endPoints=[BrokerEndpoint(name='PLAINTEXT', host='m-21-7', port=9095, securityProtocol=0)], features=[BrokerFeature(name='metadata.version', minSupportedVersion=1, maxSupportedVersion=7)], rack=null, fenced=true, inControlledShutdown=false) (org.apache.kafka.controller.ClusterControlManager)
  42. [2022-10-27 16:01:57,200] INFO [Controller 1] Unfenced broker: 1 (org.apache.kafka.controller.ClusterControlManager)
  43. [2022-10-27 16:01:57,201] INFO [Controller 1] Fenced broker: 1 (org.apache.kafka.controller.ClusterControlManager)
  44. [2022-10-27 16:01:57,203] INFO [Controller 1] Becoming the active controller at epoch 3, committed offset 418, committed epoch 2 (org.apache.kafka.controller.QuorumController)
  45. [2022-10-27 16:01:57,208] INFO [ThrottledChannelReaper-Fetch]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  46. [2022-10-27 16:01:57,208] INFO [ThrottledChannelReaper-Produce]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  47. [2022-10-27 16:01:57,209] INFO [ThrottledChannelReaper-Request]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  48. [2022-10-27 16:01:57,209] INFO [ThrottledChannelReaper-ControllerMutation]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  49. [2022-10-27 16:01:57,254] INFO [BrokerToControllerChannelManager broker=1 name=forwarding]: Starting (kafka.server.BrokerToControllerRequestThread)
  50. [2022-10-27 16:01:57,256] INFO [BrokerToControllerChannelManager broker=1 name=forwarding]: Recorded new controller, from now on will use broker m-21-7:9096 (id: 1 rack: null) (kafka.server.BrokerToControllerRequestThread)
  51. [2022-10-27 16:01:57,294] INFO Updated connection-accept-rate max connection creation rate to 2147483647 (kafka.network.ConnectionQuotas)
  52. [2022-10-27 16:01:57,294] INFO Awaiting socket connections on 0.0.0.0:9095. (kafka.network.DataPlaneAcceptor)
  53. [2022-10-27 16:01:57,303] INFO [SocketServer listenerType=BROKER, nodeId=1] Created data-plane acceptor and processors for endpoint : ListenerName(PLAINTEXT) (kafka.network.SocketServer)
  54. [2022-10-27 16:01:57,310] INFO [BrokerToControllerChannelManager broker=1 name=alterPartition]: Starting (kafka.server.BrokerToControllerRequestThread)
  55. [2022-10-27 16:01:57,311] INFO [BrokerToControllerChannelManager broker=1 name=alterPartition]: Recorded new controller, from now on will use broker m-21-7:9096 (id: 1 rack: null) (kafka.server.BrokerToControllerRequestThread)
  56. [2022-10-27 16:01:57,326] INFO [ExpirationReaper-1-Produce]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  57. [2022-10-27 16:01:57,327] INFO [ExpirationReaper-1-Fetch]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  58. [2022-10-27 16:01:57,328] INFO [ExpirationReaper-1-DeleteRecords]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  59. [2022-10-27 16:01:57,329] INFO [ExpirationReaper-1-ElectLeader]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  60. [2022-10-27 16:01:57,398] INFO [ExpirationReaper-1-Heartbeat]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  61. [2022-10-27 16:01:57,399] INFO [ExpirationReaper-1-Rebalance]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  62. [2022-10-27 16:01:57,482] INFO [RaftManager nodeId=1] Registered the listener kafka.server.metadata.BrokerMetadataListener@1552117142 (org.apache.kafka.raft.KafkaRaftClient)
  63. [2022-10-27 16:01:57,483] INFO [BrokerToControllerChannelManager broker=1 name=heartbeat]: Starting (kafka.server.BrokerToControllerRequestThread)
  64. [2022-10-27 16:01:57,483] INFO [BrokerToControllerChannelManager broker=1 name=heartbeat]: Recorded new controller, from now on will use broker m-21-7:9096 (id: 1 rack: null) (kafka.server.BrokerToControllerRequestThread)
  65. [2022-10-27 16:01:57,490] INFO [BrokerLifecycleManager id=1] Incarnation XsNxSDB8RdKo1mDLdiuGDg of broker 1 in cluster 08G1XXyDSiiK5MnqFUdfYA is now STARTING. (kafka.server.BrokerLifecycleManager)
  66. [2022-10-27 16:01:57,518] INFO [ExpirationReaper-1-AlterAcls]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  67. [2022-10-27 16:01:57,605] INFO [Controller 1] Re-registered broker id 1: RegisterBrokerRecord(brokerId=1, incarnationId=XsNxSDB8RdKo1mDLdiuGDg, brokerEpoch=419, endPoints=[BrokerEndpoint(name='PLAINTEXT', host='m-21-7', port=9095, securityProtocol=0)], features=[BrokerFeature(name='metadata.version', minSupportedVersion=1, maxSupportedVersion=7)], rack=null, fenced=true, inControlledShutdown=false) (org.apache.kafka.controller.ClusterControlManager)
  68. [2022-10-27 16:01:57,640] INFO [BrokerLifecycleManager id=1] Successfully registered broker 1 with broker epoch 419 (kafka.server.BrokerLifecycleManager)
  69. [2022-10-27 16:01:57,648] INFO [BrokerLifecycleManager id=1] The broker has caught up. Transitioning from STARTING to RECOVERY. (kafka.server.BrokerLifecycleManager)
  70. [2022-10-27 16:01:57,651] INFO [BrokerMetadataListener id=1] Starting to publish metadata events at offset 420. (kafka.server.metadata.BrokerMetadataListener)
  71. [2022-10-27 16:01:57,654] INFO [BrokerMetadataPublisher id=1] Publishing initial metadata at offset OffsetAndEpoch(offset=420, epoch=3) with metadata.version 3.3-IV3. (kafka.server.metadata.BrokerMetadataPublisher)
  72. [2022-10-27 16:01:57,655] INFO Loading logs from log dirs ArraySeq(/opt/kafka_2.13-3.3.1/logs) (kafka.log.LogManager)
  73. [2022-10-27 16:01:57,659] INFO Skipping recovery for all logs in /opt/kafka_2.13-3.3.1/logs since clean shutdown file was found (kafka.log.LogManager)
  74. [2022-10-27 16:01:57,660] INFO [BrokerLifecycleManager id=1] The broker is in RECOVERY. (kafka.server.BrokerLifecycleManager)
  75. [2022-10-27 16:01:57,683] INFO Loaded 0 logs in 27ms. (kafka.log.LogManager)
  76. [2022-10-27 16:01:57,683] INFO Starting log cleanup with a period of 300000 ms. (kafka.log.LogManager)
  77. [2022-10-27 16:01:57,685] INFO Starting log flusher with a default period of 9223372036854775807 ms. (kafka.log.LogManager)
  78. [2022-10-27 16:01:57,804] INFO [LogDirFailureHandler]: Starting (kafka.server.ReplicaManager$LogDirFailureHandler)
  79. [2022-10-27 16:01:57,805] INFO [GroupCoordinator 1]: Starting up. (kafka.coordinator.group.GroupCoordinator)
  80. [2022-10-27 16:01:57,807] INFO [GroupCoordinator 1]: Startup complete. (kafka.coordinator.group.GroupCoordinator)
  81. [2022-10-27 16:01:57,807] INFO [TransactionCoordinator id=1] Starting up. (kafka.coordinator.transaction.TransactionCoordinator)
  82. [2022-10-27 16:01:57,810] INFO [TransactionCoordinator id=1] Startup complete. (kafka.coordinator.transaction.TransactionCoordinator)
  83. [2022-10-27 16:01:57,811] INFO [Transaction Marker Channel Manager 1]: Starting (kafka.coordinator.transaction.TransactionMarkerChannelManager)
  84. [2022-10-27 16:01:57,812] INFO [BrokerMetadataPublisher id=1] Updating metadata.version to 7 at offset OffsetAndEpoch(offset=420, epoch=3). (kafka.server.metadata.BrokerMetadataPublisher)
  85. [2022-10-27 16:01:57,823] INFO KafkaConfig values:
  86. advertised.listeners = PLAINTEXT://:9095
  87. alter.config.policy.class.name = null
  88. alter.log.dirs.replication.quota.window.num = 11
  89. alter.log.dirs.replication.quota.window.size.seconds = 1
  90. authorizer.class.name =
  91. auto.create.topics.enable = true
  92. auto.leader.rebalance.enable = true
  93. background.threads = 10
  94. broker.heartbeat.interval.ms = 2000
  95. broker.id = 1
  96. broker.id.generation.enable = true
  97. broker.rack = null
  98. broker.session.timeout.ms = 9000
  99. client.quota.callback.class = null
  100. compression.type = producer
  101. connection.failed.authentication.delay.ms = 100
  102. connections.max.idle.ms = 600000
  103. connections.max.reauth.ms = 0
  104. control.plane.listener.name = null
  105. controlled.shutdown.enable = true
  106. controlled.shutdown.max.retries = 3
  107. controlled.shutdown.retry.backoff.ms = 5000
  108. controller.listener.names = CONTROLLER
  109. controller.quorum.append.linger.ms = 25
  110. controller.quorum.election.backoff.max.ms = 1000
  111. controller.quorum.election.timeout.ms = 1000
  112. controller.quorum.fetch.timeout.ms = 2000
  113. controller.quorum.request.timeout.ms = 2000
  114. controller.quorum.retry.backoff.ms = 20
  115. controller.quorum.voters = [1@172.16.21.7:9096]
  116. controller.quota.window.num = 11
  117. controller.quota.window.size.seconds = 1
  118. controller.socket.timeout.ms = 30000
  119. create.topic.policy.class.name = null
  120. default.replication.factor = 1
  121. delegation.token.expiry.check.interval.ms = 3600000
  122. delegation.token.expiry.time.ms = 86400000
  123. delegation.token.master.key = null
  124. delegation.token.max.lifetime.ms = 604800000
  125. delegation.token.secret.key = null
  126. delete.records.purgatory.purge.interval.requests = 1
  127. delete.topic.enable = true
  128. early.start.listeners = null
  129. fetch.max.bytes = 57671680
  130. fetch.purgatory.purge.interval.requests = 1000
  131. group.initial.rebalance.delay.ms = 3000
  132. group.max.session.timeout.ms = 1800000
  133. group.max.size = 2147483647
  134. group.min.session.timeout.ms = 6000
  135. initial.broker.registration.timeout.ms = 60000
  136. inter.broker.listener.name = PLAINTEXT
  137. inter.broker.protocol.version = 3.3-IV3
  138. kafka.metrics.polling.interval.secs = 10
  139. kafka.metrics.reporters = []
  140. leader.imbalance.check.interval.seconds = 300
  141. leader.imbalance.per.broker.percentage = 10
  142. listener.security.protocol.map = CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT,SSL:SSL,SASL_PLAINTEXT:SASL_PLAINTEXT,SASL_SSL:SASL_SSL
  143. listeners = PLAINTEXT://:9095,CONTROLLER://:9096
  144. log.cleaner.backoff.ms = 15000
  145. log.cleaner.dedupe.buffer.size = 134217728
  146. log.cleaner.delete.retention.ms = 86400000
  147. log.cleaner.enable = true
  148. log.cleaner.io.buffer.load.factor = 0.9
  149. log.cleaner.io.buffer.size = 524288
  150. log.cleaner.io.max.bytes.per.second = 1.7976931348623157E308
  151. log.cleaner.max.compaction.lag.ms = 9223372036854775807
  152. log.cleaner.min.cleanable.ratio = 0.5
  153. log.cleaner.min.compaction.lag.ms = 0
  154. log.cleaner.threads = 1
  155. log.cleanup.policy = [delete]
  156. log.dir = /tmp/kafka-logs
  157. log.dirs = /opt/kafka_2.13-3.3.1/logs
  158. log.flush.interval.messages = 9223372036854775807
  159. log.flush.interval.ms = null
  160. log.flush.offset.checkpoint.interval.ms = 60000
  161. log.flush.scheduler.interval.ms = 9223372036854775807
  162. log.flush.start.offset.checkpoint.interval.ms = 60000
  163. log.index.interval.bytes = 4096
  164. log.index.size.max.bytes = 10485760
  165. log.message.downconversion.enable = true
  166. log.message.format.version = 3.0-IV1
  167. log.message.timestamp.difference.max.ms = 9223372036854775807
  168. log.message.timestamp.type = CreateTime
  169. log.preallocate = false
  170. log.retention.bytes = -1
  171. log.retention.check.interval.ms = 300000
  172. log.retention.hours = 168
  173. log.retention.minutes = null
  174. log.retention.ms = null
  175. log.roll.hours = 168
  176. log.roll.jitter.hours = 0
  177. log.roll.jitter.ms = null
  178. log.roll.ms = null
  179. log.segment.bytes = 1073741824
  180. log.segment.delete.delay.ms = 60000
  181. max.connection.creation.rate = 2147483647
  182. max.connections = 2147483647
  183. max.connections.per.ip = 2147483647
  184. max.connections.per.ip.overrides =
  185. max.incremental.fetch.session.cache.slots = 1000
  186. message.max.bytes = 1048588
  187. metadata.log.dir = null
  188. metadata.log.max.record.bytes.between.snapshots = 20971520
  189. metadata.log.segment.bytes = 1073741824
  190. metadata.log.segment.min.bytes = 8388608
  191. metadata.log.segment.ms = 604800000
  192. metadata.max.idle.interval.ms = 500
  193. metadata.max.retention.bytes = -1
  194. metadata.max.retention.ms = 604800000
  195. metric.reporters = []
  196. metrics.num.samples = 2
  197. metrics.recording.level = INFO
  198. metrics.sample.window.ms = 30000
  199. min.insync.replicas = 1
  200. node.id = 1
  201. num.io.threads = 8
  202. num.network.threads = 3
  203. num.partitions = 1
  204. num.recovery.threads.per.data.dir = 1
  205. num.replica.alter.log.dirs.threads = null
  206. num.replica.fetchers = 1
  207. offset.metadata.max.bytes = 4096
  208. offsets.commit.required.acks = -1
  209. offsets.commit.timeout.ms = 5000
  210. offsets.load.buffer.size = 5242880
  211. offsets.retention.check.interval.ms = 600000
  212. offsets.retention.minutes = 10080
  213. offsets.topic.compression.codec = 0
  214. offsets.topic.num.partitions = 50
  215. offsets.topic.replication.factor = 1
  216. offsets.topic.segment.bytes = 104857600
  217. password.encoder.cipher.algorithm = AES/CBC/PKCS5Padding
  218. password.encoder.iterations = 4096
  219. password.encoder.key.length = 128
  220. password.encoder.keyfactory.algorithm = null
  221. password.encoder.old.secret = null
  222. password.encoder.secret = null
  223. principal.builder.class = class org.apache.kafka.common.security.authenticator.DefaultKafkaPrincipalBuilder
  224. process.roles = [broker, controller]
  225. producer.purgatory.purge.interval.requests = 1000
  226. queued.max.request.bytes = -1
  227. queued.max.requests = 500
  228. quota.window.num = 11
  229. quota.window.size.seconds = 1
  230. remote.log.index.file.cache.total.size.bytes = 1073741824
  231. remote.log.manager.task.interval.ms = 30000
  232. remote.log.manager.task.retry.backoff.max.ms = 30000
  233. remote.log.manager.task.retry.backoff.ms = 500
  234. remote.log.manager.task.retry.jitter = 0.2
  235. remote.log.manager.thread.pool.size = 10
  236. remote.log.metadata.manager.class.name = null
  237. remote.log.metadata.manager.class.path = null
  238. remote.log.metadata.manager.impl.prefix = null
  239. remote.log.metadata.manager.listener.name = null
  240. remote.log.reader.max.pending.tasks = 100
  241. remote.log.reader.threads = 10
  242. remote.log.storage.manager.class.name = null
  243. remote.log.storage.manager.class.path = null
  244. remote.log.storage.manager.impl.prefix = null
  245. remote.log.storage.system.enable = false
  246. replica.fetch.backoff.ms = 1000
  247. replica.fetch.max.bytes = 1048576
  248. replica.fetch.min.bytes = 1
  249. replica.fetch.response.max.bytes = 10485760
  250. replica.fetch.wait.max.ms = 500
  251. replica.high.watermark.checkpoint.interval.ms = 5000
  252. replica.lag.time.max.ms = 30000
  253. replica.selector.class = null
  254. replica.socket.receive.buffer.bytes = 65536
  255. replica.socket.timeout.ms = 30000
  256. replication.quota.window.num = 11
  257. replication.quota.window.size.seconds = 1
  258. request.timeout.ms = 30000
  259. reserved.broker.max.id = 1000
  260. sasl.client.callback.handler.class = null
  261. sasl.enabled.mechanisms = [GSSAPI]
  262. sasl.jaas.config = null
  263. sasl.kerberos.kinit.cmd = /usr/bin/kinit
  264. sasl.kerberos.min.time.before.relogin = 60000
  265. sasl.kerberos.principal.to.local.rules = [DEFAULT]
  266. sasl.kerberos.service.name = null
  267. sasl.kerberos.ticket.renew.jitter = 0.05
  268. sasl.kerberos.ticket.renew.window.factor = 0.8
  269. sasl.login.callback.handler.class = null
  270. sasl.login.class = null
  271. sasl.login.connect.timeout.ms = null
  272. sasl.login.read.timeout.ms = null
  273. sasl.login.refresh.buffer.seconds = 300
  274. sasl.login.refresh.min.period.seconds = 60
  275. sasl.login.refresh.window.factor = 0.8
  276. sasl.login.refresh.window.jitter = 0.05
  277. sasl.login.retry.backoff.max.ms = 10000
  278. sasl.login.retry.backoff.ms = 100
  279. sasl.mechanism.controller.protocol = GSSAPI
  280. sasl.mechanism.inter.broker.protocol = GSSAPI
  281. sasl.oauthbearer.clock.skew.seconds = 30
  282. sasl.oauthbearer.expected.audience = null
  283. sasl.oauthbearer.expected.issuer = null
  284. sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
  285. sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
  286. sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
  287. sasl.oauthbearer.jwks.endpoint.url = null
  288. sasl.oauthbearer.scope.claim.name = scope
  289. sasl.oauthbearer.sub.claim.name = sub
  290. sasl.oauthbearer.token.endpoint.url = null
  291. sasl.server.callback.handler.class = null
  292. sasl.server.max.receive.size = 524288
  293. security.inter.broker.protocol = PLAINTEXT
  294. security.providers = null
  295. socket.connection.setup.timeout.max.ms = 30000
  296. socket.connection.setup.timeout.ms = 10000
  297. socket.listen.backlog.size = 50
  298. socket.receive.buffer.bytes = 102400
  299. socket.request.max.bytes = 104857600
  300. socket.send.buffer.bytes = 102400
  301. ssl.cipher.suites = []
  302. ssl.client.auth = none
  303. ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
  304. ssl.endpoint.identification.algorithm = https
  305. ssl.engine.factory.class = null
  306. ssl.key.password = null
  307. ssl.keymanager.algorithm = SunX509
  308. ssl.keystore.certificate.chain = null
  309. ssl.keystore.key = null
  310. ssl.keystore.location = null
  311. ssl.keystore.password = null
  312. ssl.keystore.type = JKS
  313. ssl.principal.mapping.rules = DEFAULT
  314. ssl.protocol = TLSv1.3
  315. ssl.provider = null
  316. ssl.secure.random.implementation = null
  317. ssl.trustmanager.algorithm = PKIX
  318. ssl.truststore.certificates = null
  319. ssl.truststore.location = null
  320. ssl.truststore.password = null
  321. ssl.truststore.type = JKS
  322. transaction.abort.timed.out.transaction.cleanup.interval.ms = 10000
  323. transaction.max.timeout.ms = 900000
  324. transaction.remove.expired.transaction.cleanup.interval.ms = 3600000
  325. transaction.state.log.load.buffer.size = 5242880
  326. transaction.state.log.min.isr = 1
  327. transaction.state.log.num.partitions = 50
  328. transaction.state.log.replication.factor = 1
  329. transaction.state.log.segment.bytes = 104857600
  330. transactional.id.expiration.ms = 604800000
  331. unclean.leader.election.enable = false
  332. zookeeper.clientCnxnSocket = null
  333. zookeeper.connect = null
  334. zookeeper.connection.timeout.ms = null
  335. zookeeper.max.in.flight.requests = 10
  336. zookeeper.session.timeout.ms = 18000
  337. zookeeper.set.acl = false
  338. zookeeper.ssl.cipher.suites = null
  339. zookeeper.ssl.client.enable = false
  340. zookeeper.ssl.crl.enable = false
  341. zookeeper.ssl.enabled.protocols = null
  342. zookeeper.ssl.endpoint.identification.algorithm = HTTPS
  343. zookeeper.ssl.keystore.location = null
  344. zookeeper.ssl.keystore.password = null
  345. zookeeper.ssl.keystore.type = null
  346. zookeeper.ssl.ocsp.enable = false
  347. zookeeper.ssl.protocol = TLSv1.2
  348. zookeeper.ssl.truststore.location = null
  349. zookeeper.ssl.truststore.password = null
  350. zookeeper.ssl.truststore.type = null
  351. (kafka.server.KafkaConfig)
  352. [2022-10-27 16:01:57,834] INFO [SocketServer listenerType=BROKER, nodeId=1] Enabling request processing. (kafka.network.SocketServer)
  353. [2022-10-27 16:01:57,838] 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 419. (org.apache.kafka.controller.BrokerHeartbeatManager)
  354. [2022-10-27 16:01:57,843] INFO [Controller 1] Unfenced broker: 1 (org.apache.kafka.controller.ClusterControlManager)
  355. [2022-10-27 16:01:57,871] INFO [BrokerLifecycleManager id=1] The broker has been unfenced. Transitioning from RECOVERY to RUNNING. (kafka.server.BrokerLifecycleManager)
  356. [2022-10-27 16:01:57,871] INFO [BrokerServer id=1] Transition from STARTING to STARTED (kafka.server.BrokerServer)
  357. [2022-10-27 16:01:57,872] INFO Kafka version: 3.3.1 (org.apache.kafka.common.utils.AppInfoParser)
  358. [2022-10-27 16:01:57,872] INFO Kafka commitId: e23c59d00e687ff5 (org.apache.kafka.common.utils.AppInfoParser)
  359. [2022-10-27 16:01:57,872] INFO Kafka startTimeMs: 1666857717872 (org.apache.kafka.common.utils.AppInfoParser)
  360. [2022-10-27 16:01:57,874] INFO [KafkaRaftServer nodeId=1] Kafka Server started (kafka.server.KafkaRaftServer)
  361. [2022-10-27 16:01:59,120] INFO Terminating process due to signal SIGINT (org.apache.kafka.common.utils.LoggingSignalHandler)
  362. [2022-10-27 16:01:59,123] INFO [BrokerServer id=1] Transition from STARTED to SHUTTING_DOWN (kafka.server.BrokerServer)
  363. [2022-10-27 16:01:59,124] INFO [BrokerServer id=1] shutting down (kafka.server.BrokerServer)
  364. [2022-10-27 16:01:59,126] INFO [BrokerLifecycleManager id=1] Beginning controlled shutdown. (kafka.server.BrokerLifecycleManager)
  365. [2022-10-27 16:01:59,128] INFO [Controller 1] Unfenced broker 1 has requested and been granted an immediate shutdown. (org.apache.kafka.controller.BrokerHeartbeatManager)
  366. [2022-10-27 16:01:59,128] INFO [Controller 1] Fenced broker: 1 (org.apache.kafka.controller.ClusterControlManager)
  367. [2022-10-27 16:01:59,156] INFO [BrokerLifecycleManager id=1] The controller has asked us to exit controlled shutdown. (kafka.server.BrokerLifecycleManager)
  368. [2022-10-27 16:01:59,157] INFO [BrokerLifecycleManager id=1] beginShutdown: shutting down event queue. (org.apache.kafka.queue.KafkaEventQueue)
  369. [2022-10-27 16:01:59,158] INFO [BrokerLifecycleManager id=1] Transitioning from PENDING_CONTROLLED_SHUTDOWN to SHUTTING_DOWN. (kafka.server.BrokerLifecycleManager)
  370. [2022-10-27 16:01:59,159] INFO [BrokerToControllerChannelManager broker=1 name=heartbeat]: Shutting down (kafka.server.BrokerToControllerRequestThread)
  371. [2022-10-27 16:01:59,159] INFO [BrokerMetadataListener id=1] beginShutdown: shutting down event queue. (org.apache.kafka.queue.KafkaEventQueue)
  372. [2022-10-27 16:01:59,160] INFO [BrokerToControllerChannelManager broker=1 name=heartbeat]: Shutdown completed (kafka.server.BrokerToControllerRequestThread)
  373. [2022-10-27 16:01:59,160] INFO [BrokerToControllerChannelManager broker=1 name=heartbeat]: Stopped (kafka.server.BrokerToControllerRequestThread)
  374. [2022-10-27 16:01:59,161] INFO [SocketServer listenerType=BROKER, nodeId=1] Stopping socket server request processors (kafka.network.SocketServer)
  375. [2022-10-27 16:01:59,169] INFO Broker to controller channel manager for heartbeat shutdown (kafka.server.BrokerToControllerChannelManagerImpl)
  376. [2022-10-27 16:01:59,174] INFO [SocketServer listenerType=BROKER, nodeId=1] Stopped socket server request processors (kafka.network.SocketServer)
  377. [2022-10-27 16:01:59,176] INFO [data-plane Kafka Request Handler on Broker 1], shutting down (kafka.server.KafkaRequestHandlerPool)
  378. [2022-10-27 16:01:59,179] INFO [data-plane Kafka Request Handler on Broker 1], shut down completely (kafka.server.KafkaRequestHandlerPool)
  379. [2022-10-27 16:01:59,180] INFO [ExpirationReaper-1-AlterAcls]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  380. [2022-10-27 16:01:59,182] INFO [ExpirationReaper-1-AlterAcls]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  381. [2022-10-27 16:01:59,182] INFO [ExpirationReaper-1-AlterAcls]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  382. [2022-10-27 16:01:59,183] INFO [KafkaApi-1] Shutdown complete. (kafka.server.KafkaApis)
  383. [2022-10-27 16:01:59,186] INFO [BrokerMetadataListener id=1] closed event queue. (org.apache.kafka.queue.KafkaEventQueue)
  384. [2022-10-27 16:01:59,192] INFO [TransactionCoordinator id=1] Shutting down. (kafka.coordinator.transaction.TransactionCoordinator)
  385. [2022-10-27 16:01:59,194] INFO [Transaction State Manager 1]: Shutdown complete (kafka.coordinator.transaction.TransactionStateManager)
  386. [2022-10-27 16:01:59,194] INFO [Transaction Marker Channel Manager 1]: Shutting down (kafka.coordinator.transaction.TransactionMarkerChannelManager)
  387. [2022-10-27 16:01:59,194] INFO [Transaction Marker Channel Manager 1]: Stopped (kafka.coordinator.transaction.TransactionMarkerChannelManager)
  388. [2022-10-27 16:01:59,194] INFO [Transaction Marker Channel Manager 1]: Shutdown completed (kafka.coordinator.transaction.TransactionMarkerChannelManager)
  389. [2022-10-27 16:01:59,198] INFO [TransactionCoordinator id=1] Shutdown complete. (kafka.coordinator.transaction.TransactionCoordinator)
  390. [2022-10-27 16:01:59,199] INFO [GroupCoordinator 1]: Shutting down. (kafka.coordinator.group.GroupCoordinator)
  391. [2022-10-27 16:01:59,200] INFO [ExpirationReaper-1-Heartbeat]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  392. [2022-10-27 16:01:59,201] INFO [ExpirationReaper-1-Heartbeat]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  393. [2022-10-27 16:01:59,201] INFO [ExpirationReaper-1-Heartbeat]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  394. [2022-10-27 16:01:59,201] INFO [ExpirationReaper-1-Rebalance]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  395. [2022-10-27 16:01:59,202] INFO [ExpirationReaper-1-Rebalance]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  396. [2022-10-27 16:01:59,202] INFO [ExpirationReaper-1-Rebalance]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  397. [2022-10-27 16:01:59,203] INFO [GroupCoordinator 1]: Shutdown complete. (kafka.coordinator.group.GroupCoordinator)
  398. [2022-10-27 16:01:59,204] INFO [ReplicaManager broker=1] Shutting down (kafka.server.ReplicaManager)
  399. [2022-10-27 16:01:59,204] INFO [LogDirFailureHandler]: Shutting down (kafka.server.ReplicaManager$LogDirFailureHandler)
  400. [2022-10-27 16:01:59,204] INFO [LogDirFailureHandler]: Stopped (kafka.server.ReplicaManager$LogDirFailureHandler)
  401. [2022-10-27 16:01:59,204] INFO [LogDirFailureHandler]: Shutdown completed (kafka.server.ReplicaManager$LogDirFailureHandler)
  402. [2022-10-27 16:01:59,205] INFO [ReplicaFetcherManager on broker 1] shutting down (kafka.server.ReplicaFetcherManager)
  403. [2022-10-27 16:01:59,206] INFO [ReplicaFetcherManager on broker 1] shutdown completed (kafka.server.ReplicaFetcherManager)
  404. [2022-10-27 16:01:59,207] INFO [ReplicaAlterLogDirsManager on broker 1] shutting down (kafka.server.ReplicaAlterLogDirsManager)
  405. [2022-10-27 16:01:59,207] INFO [ReplicaAlterLogDirsManager on broker 1] shutdown completed (kafka.server.ReplicaAlterLogDirsManager)
  406. [2022-10-27 16:01:59,207] INFO [ExpirationReaper-1-Fetch]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  407. [2022-10-27 16:01:59,208] INFO [ExpirationReaper-1-Fetch]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  408. [2022-10-27 16:01:59,208] INFO [ExpirationReaper-1-Fetch]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  409. [2022-10-27 16:01:59,208] INFO [ExpirationReaper-1-Produce]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  410. [2022-10-27 16:01:59,209] INFO [ExpirationReaper-1-Produce]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  411. [2022-10-27 16:01:59,209] INFO [ExpirationReaper-1-Produce]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  412. [2022-10-27 16:01:59,209] INFO [ExpirationReaper-1-DeleteRecords]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  413. [2022-10-27 16:01:59,210] INFO [ExpirationReaper-1-DeleteRecords]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  414. [2022-10-27 16:01:59,210] INFO [ExpirationReaper-1-DeleteRecords]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  415. [2022-10-27 16:01:59,210] INFO [ExpirationReaper-1-ElectLeader]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  416. [2022-10-27 16:01:59,210] INFO [ExpirationReaper-1-ElectLeader]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  417. [2022-10-27 16:01:59,210] INFO [ExpirationReaper-1-ElectLeader]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  418. [2022-10-27 16:01:59,212] INFO [ReplicaManager broker=1] Shut down completely (kafka.server.ReplicaManager)
  419. [2022-10-27 16:01:59,212] INFO [BrokerToControllerChannelManager broker=1 name=alterPartition]: Shutting down (kafka.server.BrokerToControllerRequestThread)
  420. [2022-10-27 16:01:59,212] INFO [BrokerToControllerChannelManager broker=1 name=alterPartition]: Stopped (kafka.server.BrokerToControllerRequestThread)
  421. [2022-10-27 16:01:59,212] INFO [BrokerToControllerChannelManager broker=1 name=alterPartition]: Shutdown completed (kafka.server.BrokerToControllerRequestThread)
  422. [2022-10-27 16:01:59,213] INFO Broker to controller channel manager for alterPartition shutdown (kafka.server.BrokerToControllerChannelManagerImpl)
  423. [2022-10-27 16:01:59,213] INFO [BrokerToControllerChannelManager broker=1 name=forwarding]: Shutting down (kafka.server.BrokerToControllerRequestThread)
  424. [2022-10-27 16:01:59,213] INFO [BrokerToControllerChannelManager broker=1 name=forwarding]: Stopped (kafka.server.BrokerToControllerRequestThread)
  425. [2022-10-27 16:01:59,213] INFO [BrokerToControllerChannelManager broker=1 name=forwarding]: Shutdown completed (kafka.server.BrokerToControllerRequestThread)
  426. [2022-10-27 16:01:59,214] INFO Broker to controller channel manager for forwarding shutdown (kafka.server.BrokerToControllerChannelManagerImpl)
  427. [2022-10-27 16:01:59,214] INFO Shutting down. (kafka.log.LogManager)
  428. [2022-10-27 16:01:59,237] INFO [BrokerMetadataListener id=1] Not processing HandleCommitsEvent because the event queue is closed. (kafka.server.metadata.BrokerMetadataListener)
  429. [2022-10-27 16:01:59,293] INFO Shutdown complete. (kafka.log.LogManager)
  430. [2022-10-27 16:01:59,293] INFO [ThrottledChannelReaper-Fetch]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  431. [2022-10-27 16:01:59,295] INFO [ThrottledChannelReaper-Fetch]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  432. [2022-10-27 16:01:59,295] INFO [ThrottledChannelReaper-Fetch]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  433. [2022-10-27 16:01:59,295] INFO [ThrottledChannelReaper-Produce]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  434. [2022-10-27 16:01:59,295] INFO [ThrottledChannelReaper-Produce]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  435. [2022-10-27 16:01:59,295] INFO [ThrottledChannelReaper-Produce]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  436. [2022-10-27 16:01:59,296] INFO [ThrottledChannelReaper-Request]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  437. [2022-10-27 16:01:59,296] INFO [ThrottledChannelReaper-Request]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  438. [2022-10-27 16:01:59,296] INFO [ThrottledChannelReaper-Request]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  439. [2022-10-27 16:01:59,296] INFO [ThrottledChannelReaper-ControllerMutation]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  440. [2022-10-27 16:01:59,296] INFO [ThrottledChannelReaper-ControllerMutation]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  441. [2022-10-27 16:01:59,296] INFO [ThrottledChannelReaper-ControllerMutation]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  442. [2022-10-27 16:01:59,297] INFO [SocketServer listenerType=BROKER, nodeId=1] Shutting down socket server (kafka.network.SocketServer)
  443. [2022-10-27 16:01:59,317] INFO [SocketServer listenerType=BROKER, nodeId=1] Shutdown completed (kafka.network.SocketServer)
  444. [2022-10-27 16:01:59,318] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics)
  445. [2022-10-27 16:01:59,318] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics)
  446. [2022-10-27 16:01:59,318] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics)
  447. [2022-10-27 16:01:59,320] INFO Broker and topic stats closed (kafka.server.BrokerTopicStats)
  448. [2022-10-27 16:01:59,321] INFO [BrokerLifecycleManager id=1] closed event queue. (org.apache.kafka.queue.KafkaEventQueue)
  449. [2022-10-27 16:01:59,321] INFO App info kafka.server for 1 unregistered (org.apache.kafka.common.utils.AppInfoParser)
  450. [2022-10-27 16:01:59,322] INFO [BrokerServer id=1] shut down completed (kafka.server.BrokerServer)
  451. [2022-10-27 16:01:59,322] INFO [BrokerServer id=1] Transition from SHUTTING_DOWN to SHUTDOWN (kafka.server.BrokerServer)
  452. [2022-10-27 16:01:59,322] INFO [raft-expiration-reaper]: Shutting down (kafka.raft.TimingWheelExpirationService$ExpiredOperationReaper)
  453. [2022-10-27 16:01:59,333] INFO [raft-expiration-reaper]: Shutdown completed (kafka.raft.TimingWheelExpirationService$ExpiredOperationReaper)
  454. [2022-10-27 16:01:59,333] INFO [raft-expiration-reaper]: Stopped (kafka.raft.TimingWheelExpirationService$ExpiredOperationReaper)
  455. [2022-10-27 16:01:59,334] INFO [kafka-raft-io-thread]: Shutting down (kafka.raft.KafkaRaftManager$RaftIoThread)
  456. [2022-10-27 16:01:59,334] INFO [RaftManager nodeId=1] Beginning graceful shutdown (org.apache.kafka.raft.KafkaRaftClient)
  457. [2022-10-27 16:01:59,335] INFO [RaftManager nodeId=1] Graceful shutdown completed (org.apache.kafka.raft.KafkaRaftClient)
  458. [2022-10-27 16:01:59,335] INFO [kafka-raft-io-thread]: Completed graceful shutdown of RaftClient (kafka.raft.KafkaRaftManager$RaftIoThread)
  459. [2022-10-27 16:01:59,336] INFO [kafka-raft-io-thread]: Stopped (kafka.raft.KafkaRaftManager$RaftIoThread)
  460. [2022-10-27 16:01:59,336] INFO [kafka-raft-io-thread]: Shutdown completed (kafka.raft.KafkaRaftManager$RaftIoThread)
  461. [2022-10-27 16:01:59,337] INFO [kafka-raft-outbound-request-thread]: Shutting down (kafka.raft.RaftSendThread)
  462. [2022-10-27 16:01:59,338] INFO [kafka-raft-outbound-request-thread]: Shutdown completed (kafka.raft.RaftSendThread)
  463. [2022-10-27 16:01:59,338] INFO [kafka-raft-outbound-request-thread]: Stopped (kafka.raft.RaftSendThread)
  464. [2022-10-27 16:01:59,340] INFO [ProducerStateManager partition=__cluster_metadata-0] Wrote producer snapshot at offset 427 with 0 producer ids in 1 ms. (kafka.log.ProducerStateManager)
  465. [2022-10-27 16:01:59,348] INFO [ControllerServer id=1] shutting down (kafka.server.ControllerServer)
  466. [2022-10-27 16:01:59,349] INFO [SocketServer listenerType=CONTROLLER, nodeId=1] Stopping socket server request processors (kafka.network.SocketServer)
  467. [2022-10-27 16:01:59,353] INFO [SocketServer listenerType=CONTROLLER, nodeId=1] Stopped socket server request processors (kafka.network.SocketServer)
  468. [2022-10-27 16:01:59,353] INFO [Controller 1] QuorumController#beginShutdown: shutting down event queue. (org.apache.kafka.queue.KafkaEventQueue)
  469. [2022-10-27 16:01:59,353] ERROR [Controller 1] writeNoOpRecord: unable to start processing because of TimeoutException. (org.apache.kafka.controller.QuorumController)
  470. [2022-10-27 16:01:59,353] INFO [SocketServer listenerType=CONTROLLER, nodeId=1] Shutting down socket server (kafka.network.SocketServer)
  471. [2022-10-27 16:01:59,361] INFO [SocketServer listenerType=CONTROLLER, nodeId=1] Shutdown completed (kafka.network.SocketServer)
  472. [2022-10-27 16:01:59,361] INFO [data-plane Kafka Request Handler on Broker 1], shutting down (kafka.server.KafkaRequestHandlerPool)
  473. [2022-10-27 16:01:59,361] INFO [data-plane Kafka Request Handler on Broker 1], shut down completely (kafka.server.KafkaRequestHandlerPool)
  474. [2022-10-27 16:01:59,362] INFO [ExpirationReaper-1-AlterAcls]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  475. [2022-10-27 16:01:59,362] INFO [ExpirationReaper-1-AlterAcls]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  476. [2022-10-27 16:01:59,362] INFO [ExpirationReaper-1-AlterAcls]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  477. [2022-10-27 16:01:59,363] INFO [ThrottledChannelReaper-Fetch]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  478. [2022-10-27 16:01:59,363] INFO [ThrottledChannelReaper-Fetch]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  479. [2022-10-27 16:01:59,363] INFO [ThrottledChannelReaper-Fetch]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  480. [2022-10-27 16:01:59,363] INFO [ThrottledChannelReaper-Produce]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  481. [2022-10-27 16:01:59,363] INFO [ThrottledChannelReaper-Produce]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  482. [2022-10-27 16:01:59,363] INFO [ThrottledChannelReaper-Produce]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  483. [2022-10-27 16:01:59,363] INFO [ThrottledChannelReaper-Request]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  484. [2022-10-27 16:01:59,363] INFO [ThrottledChannelReaper-Request]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  485. [2022-10-27 16:01:59,363] INFO [ThrottledChannelReaper-Request]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  486. [2022-10-27 16:01:59,363] INFO [ThrottledChannelReaper-ControllerMutation]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  487. [2022-10-27 16:01:59,364] INFO [ThrottledChannelReaper-ControllerMutation]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  488. [2022-10-27 16:01:59,364] INFO [ThrottledChannelReaper-ControllerMutation]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  489. [2022-10-27 16:01:59,364] INFO [Controller 1] closed event queue. (org.apache.kafka.queue.KafkaEventQueue)
  490. [2022-10-27 16:01:59,365] INFO App info kafka.server for 1 unregistered (org.apache.kafka.common.utils.AppInfoParser)
  491. [2022-10-27 16:04:13,390] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
  492. [2022-10-27 16:04:13,715] INFO Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation (org.apache.zookeeper.common.X509Util)
  493. [2022-10-27 16:04:13,914] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Recovering unflushed segment 0. 0/1 recovered for __cluster_metadata-0. (kafka.log.LogLoader)
  494. [2022-10-27 16:04:13,916] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
  495. [2022-10-27 16:04:13,917] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Reloading from producer snapshot and rebuilding producer state from offset 0 (kafka.log.UnifiedLog$)
  496. [2022-10-27 16:04:13,918] INFO Deleted producer state snapshot /opt/kafka_2.13-3.3.1/logs/__cluster_metadata-0/00000000000000000419.snapshot (kafka.log.SnapshotFile)
  497. [2022-10-27 16:04:13,919] INFO Deleted producer state snapshot /opt/kafka_2.13-3.3.1/logs/__cluster_metadata-0/00000000000000000427.snapshot (kafka.log.SnapshotFile)
  498. [2022-10-27 16:04:13,920] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Producer state recovery took 3ms for snapshot load and 0ms for segment recovery from offset 0 (kafka.log.UnifiedLog$)
  499. [2022-10-27 16:04:13,968] INFO [ProducerStateManager partition=__cluster_metadata-0] Wrote producer snapshot at offset 427 with 0 producer ids in 4 ms. (kafka.log.ProducerStateManager)
  500. [2022-10-27 16:04:13,988] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Loading producer state till offset 427 with message format version 2 (kafka.log.UnifiedLog$)
  501. [2022-10-27 16:04:13,988] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Reloading from producer snapshot and rebuilding producer state from offset 427 (kafka.log.UnifiedLog$)
  502. [2022-10-27 16:04:13,989] INFO [ProducerStateManager partition=__cluster_metadata-0] Loading producer state from snapshot file 'SnapshotFile(/opt/kafka_2.13-3.3.1/logs/__cluster_metadata-0/00000000000000000427.snapshot,427)' (kafka.log.ProducerStateManager)
  503. [2022-10-27 16:04:13,992] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Producer state recovery took 4ms for snapshot load and 0ms for segment recovery from offset 427 (kafka.log.UnifiedLog$)
  504. [2022-10-27 16:04:14,058] INFO Initialized snapshots with IDs SortedSet() from /opt/kafka_2.13-3.3.1/logs/__cluster_metadata-0 (kafka.raft.KafkaMetadataLog$)
  505. [2022-10-27 16:04:14,095] INFO [raft-expiration-reaper]: Starting (kafka.raft.TimingWheelExpirationService$ExpiredOperationReaper)
  506. [2022-10-27 16:04:14,287] INFO [RaftManager nodeId=1] Completed transition to ResignedState(localId=1, epoch=3, voters=[1], electionTimeoutMs=1999, unackedVoters=[], preferredSuccessors=[]) (org.apache.kafka.raft.QuorumState)
  507. [2022-10-27 16:04:14,293] INFO [RaftManager nodeId=1] Completed transition to CandidateState(localId=1, epoch=4, retries=1, electionTimeoutMs=1957) (org.apache.kafka.raft.QuorumState)
  508. [2022-10-27 16:04:14,301] INFO [RaftManager nodeId=1] Completed transition to Leader(localId=1, epoch=4, epochStartOffset=427, highWatermark=Optional.empty, voterStates={1=ReplicaState(nodeId=1, endOffset=Optional.empty, lastFetchTimestamp=-1, lastCaughtUpTimestamp=-1, hasAcknowledgedLeader=true)}) (org.apache.kafka.raft.QuorumState)
  509. [2022-10-27 16:04:14,380] INFO Registered signal handlers for TERM, INT, HUP (org.apache.kafka.common.utils.LoggingSignalHandler)
  510. [2022-10-27 16:04:14,385] INFO [kafka-raft-outbound-request-thread]: Starting (kafka.raft.RaftSendThread)
  511. [2022-10-27 16:04:14,385] INFO [kafka-raft-io-thread]: Starting (kafka.raft.KafkaRaftManager$RaftIoThread)
  512. [2022-10-27 16:04:14,386] INFO Starting controller (kafka.server.ControllerServer)
  513. [2022-10-27 16:04:14,764] INFO Updated connection-accept-rate max connection creation rate to 2147483647 (kafka.network.ConnectionQuotas)
  514. [2022-10-27 16:04:14,771] INFO Awaiting socket connections on 0.0.0.0:9096. (kafka.network.DataPlaneAcceptor)
  515. [2022-10-27 16:04:14,798] INFO [SocketServer listenerType=CONTROLLER, nodeId=1] Created data-plane acceptor and processors for endpoint : ListenerName(CONTROLLER) (kafka.network.SocketServer)
  516. [2022-10-27 16:04:14,825] INFO [Controller 1] Creating new QuorumController with clusterId 08G1XXyDSiiK5MnqFUdfYA, authorizer Optional.empty. (org.apache.kafka.controller.QuorumController)
  517. [2022-10-27 16:04:14,827] INFO [RaftManager nodeId=1] Registered the listener org.apache.kafka.controller.QuorumController$QuorumMetaLogListener@799307124 (org.apache.kafka.raft.KafkaRaftClient)
  518. [2022-10-27 16:04:14,834] INFO [ThrottledChannelReaper-Fetch]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  519. [2022-10-27 16:04:14,834] INFO [ThrottledChannelReaper-Produce]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  520. [2022-10-27 16:04:14,836] INFO [ThrottledChannelReaper-Request]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  521. [2022-10-27 16:04:14,837] INFO [Controller 1] Setting metadata.version to 7 (org.apache.kafka.controller.FeatureControlManager)
  522. [2022-10-27 16:04:14,837] INFO [ThrottledChannelReaper-ControllerMutation]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  523. [2022-10-27 16:04:14,845] INFO [Controller 1] Added new fenced broker: 1 (org.apache.kafka.controller.ClusterControlManager)
  524. [2022-10-27 16:04:14,845] INFO [Controller 1] Registered new broker: RegisterBrokerRecord(brokerId=1, incarnationId=YNd0XS1BSrigt9RSD89Bdw, brokerEpoch=3, endPoints=[BrokerEndpoint(name='PLAINTEXT', host='m-21-7', port=9095, securityProtocol=0)], features=[BrokerFeature(name='metadata.version', minSupportedVersion=1, maxSupportedVersion=7)], rack=null, fenced=true, inControlledShutdown=false) (org.apache.kafka.controller.ClusterControlManager)
  525. [2022-10-27 16:04:14,849] INFO [Controller 1] Unfenced broker: 1 (org.apache.kafka.controller.ClusterControlManager)
  526. [2022-10-27 16:04:14,852] INFO [ExpirationReaper-1-AlterAcls]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  527. [2022-10-27 16:04:14,856] INFO [SocketServer listenerType=CONTROLLER, nodeId=1] Enabling request processing. (kafka.network.SocketServer)
  528. [2022-10-27 16:04:14,859] INFO [BrokerServer id=1] Transition from SHUTDOWN to STARTING (kafka.server.BrokerServer)
  529. [2022-10-27 16:04:14,860] INFO [BrokerServer id=1] Starting broker (kafka.server.BrokerServer)
  530. [2022-10-27 16:04:14,863] INFO [Controller 1] Fenced broker: 1 (org.apache.kafka.controller.ClusterControlManager)
  531. [2022-10-27 16:04:14,863] INFO [Controller 1] Re-registered broker id 1: RegisterBrokerRecord(brokerId=1, incarnationId=debFBP8FSU2_1yfP2I0Hsw, brokerEpoch=357, endPoints=[BrokerEndpoint(name='PLAINTEXT', host='m-21-7', port=9095, securityProtocol=0)], features=[BrokerFeature(name='metadata.version', minSupportedVersion=1, maxSupportedVersion=7)], rack=null, fenced=true, inControlledShutdown=false) (org.apache.kafka.controller.ClusterControlManager)
  532. [2022-10-27 16:04:14,864] INFO [Controller 1] Unfenced broker: 1 (org.apache.kafka.controller.ClusterControlManager)
  533. [2022-10-27 16:04:14,865] INFO [Controller 1] Fenced broker: 1 (org.apache.kafka.controller.ClusterControlManager)
  534. [2022-10-27 16:04:14,866] INFO [Controller 1] Re-registered broker id 1: RegisterBrokerRecord(brokerId=1, incarnationId=XsNxSDB8RdKo1mDLdiuGDg, brokerEpoch=419, endPoints=[BrokerEndpoint(name='PLAINTEXT', host='m-21-7', port=9095, securityProtocol=0)], features=[BrokerFeature(name='metadata.version', minSupportedVersion=1, maxSupportedVersion=7)], rack=null, fenced=true, inControlledShutdown=false) (org.apache.kafka.controller.ClusterControlManager)
  535. [2022-10-27 16:04:14,866] INFO [Controller 1] Unfenced broker: 1 (org.apache.kafka.controller.ClusterControlManager)
  536. [2022-10-27 16:04:14,866] INFO [Controller 1] Fenced broker: 1 (org.apache.kafka.controller.ClusterControlManager)
  537. [2022-10-27 16:04:14,867] INFO [Controller 1] Becoming the active controller at epoch 4, committed offset 426, committed epoch 3 (org.apache.kafka.controller.QuorumController)
  538. [2022-10-27 16:04:14,870] INFO [ThrottledChannelReaper-Fetch]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  539. [2022-10-27 16:04:14,870] INFO [ThrottledChannelReaper-Produce]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  540. [2022-10-27 16:04:14,871] INFO [ThrottledChannelReaper-Request]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  541. [2022-10-27 16:04:14,871] INFO [ThrottledChannelReaper-ControllerMutation]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  542. [2022-10-27 16:04:14,899] INFO [BrokerToControllerChannelManager broker=1 name=forwarding]: Starting (kafka.server.BrokerToControllerRequestThread)
  543. [2022-10-27 16:04:14,901] INFO [BrokerToControllerChannelManager broker=1 name=forwarding]: Recorded new controller, from now on will use broker m-21-7:9096 (id: 1 rack: null) (kafka.server.BrokerToControllerRequestThread)
  544. [2022-10-27 16:04:14,928] INFO Updated connection-accept-rate max connection creation rate to 2147483647 (kafka.network.ConnectionQuotas)
  545. [2022-10-27 16:04:14,928] INFO Awaiting socket connections on 0.0.0.0:9095. (kafka.network.DataPlaneAcceptor)
  546. [2022-10-27 16:04:14,936] INFO [SocketServer listenerType=BROKER, nodeId=1] Created data-plane acceptor and processors for endpoint : ListenerName(PLAINTEXT) (kafka.network.SocketServer)
  547. [2022-10-27 16:04:14,941] INFO [BrokerToControllerChannelManager broker=1 name=alterPartition]: Starting (kafka.server.BrokerToControllerRequestThread)
  548. [2022-10-27 16:04:14,942] INFO [BrokerToControllerChannelManager broker=1 name=alterPartition]: Recorded new controller, from now on will use broker m-21-7:9096 (id: 1 rack: null) (kafka.server.BrokerToControllerRequestThread)
  549. [2022-10-27 16:04:14,955] INFO [ExpirationReaper-1-Produce]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  550. [2022-10-27 16:04:14,956] INFO [ExpirationReaper-1-Fetch]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  551. [2022-10-27 16:04:14,957] INFO [ExpirationReaper-1-DeleteRecords]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  552. [2022-10-27 16:04:14,958] INFO [ExpirationReaper-1-ElectLeader]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  553. [2022-10-27 16:04:14,977] INFO [ExpirationReaper-1-Heartbeat]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  554. [2022-10-27 16:04:14,978] INFO [ExpirationReaper-1-Rebalance]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  555. [2022-10-27 16:04:15,049] INFO [RaftManager nodeId=1] Registered the listener kafka.server.metadata.BrokerMetadataListener@2032696831 (org.apache.kafka.raft.KafkaRaftClient)
  556. [2022-10-27 16:04:15,049] INFO [BrokerToControllerChannelManager broker=1 name=heartbeat]: Starting (kafka.server.BrokerToControllerRequestThread)
  557. [2022-10-27 16:04:15,050] INFO [BrokerToControllerChannelManager broker=1 name=heartbeat]: Recorded new controller, from now on will use broker m-21-7:9096 (id: 1 rack: null) (kafka.server.BrokerToControllerRequestThread)
  558. [2022-10-27 16:04:15,055] INFO [BrokerLifecycleManager id=1] Incarnation 06vIPRb4TXilQikLFFcU3w of broker 1 in cluster 08G1XXyDSiiK5MnqFUdfYA is now STARTING. (kafka.server.BrokerLifecycleManager)
  559. [2022-10-27 16:04:15,080] INFO [ExpirationReaper-1-AlterAcls]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  560. [2022-10-27 16:04:15,144] INFO [Controller 1] Re-registered broker id 1: RegisterBrokerRecord(brokerId=1, incarnationId=06vIPRb4TXilQikLFFcU3w, brokerEpoch=427, endPoints=[BrokerEndpoint(name='PLAINTEXT', host='m-21-7', port=9095, securityProtocol=0)], features=[BrokerFeature(name='metadata.version', minSupportedVersion=1, maxSupportedVersion=7)], rack=null, fenced=true, inControlledShutdown=false) (org.apache.kafka.controller.ClusterControlManager)
  561. [2022-10-27 16:04:15,177] INFO [BrokerLifecycleManager id=1] Successfully registered broker 1 with broker epoch 427 (kafka.server.BrokerLifecycleManager)
  562. [2022-10-27 16:04:15,185] INFO [BrokerLifecycleManager id=1] The broker has caught up. Transitioning from STARTING to RECOVERY. (kafka.server.BrokerLifecycleManager)
  563. [2022-10-27 16:04:15,189] INFO [BrokerMetadataListener id=1] Starting to publish metadata events at offset 428. (kafka.server.metadata.BrokerMetadataListener)
  564. [2022-10-27 16:04:15,191] INFO [BrokerMetadataPublisher id=1] Publishing initial metadata at offset OffsetAndEpoch(offset=428, epoch=4) with metadata.version 3.3-IV3. (kafka.server.metadata.BrokerMetadataPublisher)
  565. [2022-10-27 16:04:15,191] INFO Loading logs from log dirs ArraySeq(/opt/kafka_2.13-3.3.1/logs) (kafka.log.LogManager)
  566. [2022-10-27 16:04:15,193] INFO Skipping recovery for all logs in /opt/kafka_2.13-3.3.1/logs since clean shutdown file was found (kafka.log.LogManager)
  567. [2022-10-27 16:04:15,198] INFO [BrokerLifecycleManager id=1] The broker is in RECOVERY. (kafka.server.BrokerLifecycleManager)
  568. [2022-10-27 16:04:15,206] INFO Loaded 0 logs in 14ms. (kafka.log.LogManager)
  569. [2022-10-27 16:04:15,206] INFO Starting log cleanup with a period of 300000 ms. (kafka.log.LogManager)
  570. [2022-10-27 16:04:15,208] INFO Starting log flusher with a default period of 9223372036854775807 ms. (kafka.log.LogManager)
  571. [2022-10-27 16:04:15,350] INFO [LogDirFailureHandler]: Starting (kafka.server.ReplicaManager$LogDirFailureHandler)
  572. [2022-10-27 16:04:15,350] INFO [GroupCoordinator 1]: Starting up. (kafka.coordinator.group.GroupCoordinator)
  573. [2022-10-27 16:04:15,352] INFO [GroupCoordinator 1]: Startup complete. (kafka.coordinator.group.GroupCoordinator)
  574. [2022-10-27 16:04:15,352] INFO [TransactionCoordinator id=1] Starting up. (kafka.coordinator.transaction.TransactionCoordinator)
  575. [2022-10-27 16:04:15,353] INFO [TransactionCoordinator id=1] Startup complete. (kafka.coordinator.transaction.TransactionCoordinator)
  576. [2022-10-27 16:04:15,354] INFO [Transaction Marker Channel Manager 1]: Starting (kafka.coordinator.transaction.TransactionMarkerChannelManager)
  577. [2022-10-27 16:04:15,355] INFO [BrokerMetadataPublisher id=1] Updating metadata.version to 7 at offset OffsetAndEpoch(offset=428, epoch=4). (kafka.server.metadata.BrokerMetadataPublisher)
  578. [2022-10-27 16:04:15,375] INFO KafkaConfig values:
  579. advertised.listeners = PLAINTEXT://:9095
  580. alter.config.policy.class.name = null
  581. alter.log.dirs.replication.quota.window.num = 11
  582. alter.log.dirs.replication.quota.window.size.seconds = 1
  583. authorizer.class.name =
  584. auto.create.topics.enable = true
  585. auto.leader.rebalance.enable = true
  586. background.threads = 10
  587. broker.heartbeat.interval.ms = 2000
  588. broker.id = 1
  589. broker.id.generation.enable = true
  590. broker.rack = null
  591. broker.session.timeout.ms = 9000
  592. client.quota.callback.class = null
  593. compression.type = producer
  594. connection.failed.authentication.delay.ms = 100
  595. connections.max.idle.ms = 600000
  596. connections.max.reauth.ms = 0
  597. control.plane.listener.name = null
  598. controlled.shutdown.enable = true
  599. controlled.shutdown.max.retries = 3
  600. controlled.shutdown.retry.backoff.ms = 5000
  601. controller.listener.names = CONTROLLER
  602. controller.quorum.append.linger.ms = 25
  603. controller.quorum.election.backoff.max.ms = 1000
  604. controller.quorum.election.timeout.ms = 1000
  605. controller.quorum.fetch.timeout.ms = 2000
  606. controller.quorum.request.timeout.ms = 2000
  607. controller.quorum.retry.backoff.ms = 20
  608. controller.quorum.voters = [1@172.16.21.7:9096]
  609. controller.quota.window.num = 11
  610. controller.quota.window.size.seconds = 1
  611. controller.socket.timeout.ms = 30000
  612. create.topic.policy.class.name = null
  613. default.replication.factor = 1
  614. delegation.token.expiry.check.interval.ms = 3600000
  615. delegation.token.expiry.time.ms = 86400000
  616. delegation.token.master.key = null
  617. delegation.token.max.lifetime.ms = 604800000
  618. delegation.token.secret.key = null
  619. delete.records.purgatory.purge.interval.requests = 1
  620. delete.topic.enable = true
  621. early.start.listeners = null
  622. fetch.max.bytes = 57671680
  623. fetch.purgatory.purge.interval.requests = 1000
  624. group.initial.rebalance.delay.ms = 3000
  625. group.max.session.timeout.ms = 1800000
  626. group.max.size = 2147483647
  627. group.min.session.timeout.ms = 6000
  628. initial.broker.registration.timeout.ms = 60000
  629. inter.broker.listener.name = PLAINTEXT
  630. inter.broker.protocol.version = 3.3-IV3
  631. kafka.metrics.polling.interval.secs = 10
  632. kafka.metrics.reporters = []
  633. leader.imbalance.check.interval.seconds = 300
  634. leader.imbalance.per.broker.percentage = 10
  635. listener.security.protocol.map = CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT,SSL:SSL,SASL_PLAINTEXT:SASL_PLAINTEXT,SASL_SSL:SASL_SSL
  636. listeners = PLAINTEXT://:9095,CONTROLLER://:9096
  637. log.cleaner.backoff.ms = 15000
  638. log.cleaner.dedupe.buffer.size = 134217728
  639. log.cleaner.delete.retention.ms = 86400000
  640. log.cleaner.enable = true
  641. log.cleaner.io.buffer.load.factor = 0.9
  642. log.cleaner.io.buffer.size = 524288
  643. log.cleaner.io.max.bytes.per.second = 1.7976931348623157E308
  644. log.cleaner.max.compaction.lag.ms = 9223372036854775807
  645. log.cleaner.min.cleanable.ratio = 0.5
  646. log.cleaner.min.compaction.lag.ms = 0
  647. log.cleaner.threads = 1
  648. log.cleanup.policy = [delete]
  649. log.dir = /tmp/kafka-logs
  650. log.dirs = /opt/kafka_2.13-3.3.1/logs
  651. log.flush.interval.messages = 9223372036854775807
  652. log.flush.interval.ms = null
  653. log.flush.offset.checkpoint.interval.ms = 60000
  654. log.flush.scheduler.interval.ms = 9223372036854775807
  655. log.flush.start.offset.checkpoint.interval.ms = 60000
  656. log.index.interval.bytes = 4096
  657. log.index.size.max.bytes = 10485760
  658. log.message.downconversion.enable = true
  659. log.message.format.version = 3.0-IV1
  660. log.message.timestamp.difference.max.ms = 9223372036854775807
  661. log.message.timestamp.type = CreateTime
  662. log.preallocate = false
  663. log.retention.bytes = -1
  664. log.retention.check.interval.ms = 300000
  665. log.retention.hours = 168
  666. log.retention.minutes = null
  667. log.retention.ms = null
  668. log.roll.hours = 168
  669. log.roll.jitter.hours = 0
  670. log.roll.jitter.ms = null
  671. log.roll.ms = null
  672. log.segment.bytes = 1073741824
  673. log.segment.delete.delay.ms = 60000
  674. max.connection.creation.rate = 2147483647
  675. max.connections = 2147483647
  676. max.connections.per.ip = 2147483647
  677. max.connections.per.ip.overrides =
  678. max.incremental.fetch.session.cache.slots = 1000
  679. message.max.bytes = 1048588
  680. metadata.log.dir = null
  681. metadata.log.max.record.bytes.between.snapshots = 20971520
  682. metadata.log.segment.bytes = 1073741824
  683. metadata.log.segment.min.bytes = 8388608
  684. metadata.log.segment.ms = 604800000
  685. metadata.max.idle.interval.ms = 500
  686. metadata.max.retention.bytes = -1
  687. metadata.max.retention.ms = 604800000
  688. metric.reporters = []
  689. metrics.num.samples = 2
  690. metrics.recording.level = INFO
  691. metrics.sample.window.ms = 30000
  692. min.insync.replicas = 1
  693. node.id = 1
  694. num.io.threads = 8
  695. num.network.threads = 3
  696. num.partitions = 1
  697. num.recovery.threads.per.data.dir = 1
  698. num.replica.alter.log.dirs.threads = null
  699. num.replica.fetchers = 1
  700. offset.metadata.max.bytes = 4096
  701. offsets.commit.required.acks = -1
  702. offsets.commit.timeout.ms = 5000
  703. offsets.load.buffer.size = 5242880
  704. offsets.retention.check.interval.ms = 600000
  705. offsets.retention.minutes = 10080
  706. offsets.topic.compression.codec = 0
  707. offsets.topic.num.partitions = 50
  708. offsets.topic.replication.factor = 1
  709. offsets.topic.segment.bytes = 104857600
  710. password.encoder.cipher.algorithm = AES/CBC/PKCS5Padding
  711. password.encoder.iterations = 4096
  712. password.encoder.key.length = 128
  713. password.encoder.keyfactory.algorithm = null
  714. password.encoder.old.secret = null
  715. password.encoder.secret = null
  716. principal.builder.class = class org.apache.kafka.common.security.authenticator.DefaultKafkaPrincipalBuilder
  717. process.roles = [broker, controller]
  718. producer.purgatory.purge.interval.requests = 1000
  719. queued.max.request.bytes = -1
  720. queued.max.requests = 500
  721. quota.window.num = 11
  722. quota.window.size.seconds = 1
  723. remote.log.index.file.cache.total.size.bytes = 1073741824
  724. remote.log.manager.task.interval.ms = 30000
  725. remote.log.manager.task.retry.backoff.max.ms = 30000
  726. remote.log.manager.task.retry.backoff.ms = 500
  727. remote.log.manager.task.retry.jitter = 0.2
  728. remote.log.manager.thread.pool.size = 10
  729. remote.log.metadata.manager.class.name = null
  730. remote.log.metadata.manager.class.path = null
  731. remote.log.metadata.manager.impl.prefix = null
  732. remote.log.metadata.manager.listener.name = null
  733. remote.log.reader.max.pending.tasks = 100
  734. remote.log.reader.threads = 10
  735. remote.log.storage.manager.class.name = null
  736. remote.log.storage.manager.class.path = null
  737. remote.log.storage.manager.impl.prefix = null
  738. remote.log.storage.system.enable = false
  739. replica.fetch.backoff.ms = 1000
  740. replica.fetch.max.bytes = 1048576
  741. replica.fetch.min.bytes = 1
  742. replica.fetch.response.max.bytes = 10485760
  743. replica.fetch.wait.max.ms = 500
  744. replica.high.watermark.checkpoint.interval.ms = 5000
  745. replica.lag.time.max.ms = 30000
  746. replica.selector.class = null
  747. replica.socket.receive.buffer.bytes = 65536
  748. replica.socket.timeout.ms = 30000
  749. replication.quota.window.num = 11
  750. replication.quota.window.size.seconds = 1
  751. request.timeout.ms = 30000
  752. reserved.broker.max.id = 1000
  753. sasl.client.callback.handler.class = null
  754. sasl.enabled.mechanisms = [GSSAPI]
  755. sasl.jaas.config = null
  756. sasl.kerberos.kinit.cmd = /usr/bin/kinit
  757. sasl.kerberos.min.time.before.relogin = 60000
  758. sasl.kerberos.principal.to.local.rules = [DEFAULT]
  759. sasl.kerberos.service.name = null
  760. sasl.kerberos.ticket.renew.jitter = 0.05
  761. sasl.kerberos.ticket.renew.window.factor = 0.8
  762. sasl.login.callback.handler.class = null
  763. sasl.login.class = null
  764. sasl.login.connect.timeout.ms = null
  765. sasl.login.read.timeout.ms = null
  766. sasl.login.refresh.buffer.seconds = 300
  767. sasl.login.refresh.min.period.seconds = 60
  768. sasl.login.refresh.window.factor = 0.8
  769. sasl.login.refresh.window.jitter = 0.05
  770. sasl.login.retry.backoff.max.ms = 10000
  771. sasl.login.retry.backoff.ms = 100
  772. sasl.mechanism.controller.protocol = GSSAPI
  773. sasl.mechanism.inter.broker.protocol = GSSAPI
  774. sasl.oauthbearer.clock.skew.seconds = 30
  775. sasl.oauthbearer.expected.audience = null
  776. sasl.oauthbearer.expected.issuer = null
  777. sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
  778. sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
  779. sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
  780. sasl.oauthbearer.jwks.endpoint.url = null
  781. sasl.oauthbearer.scope.claim.name = scope
  782. sasl.oauthbearer.sub.claim.name = sub
  783. sasl.oauthbearer.token.endpoint.url = null
  784. sasl.server.callback.handler.class = null
  785. sasl.server.max.receive.size = 524288
  786. security.inter.broker.protocol = PLAINTEXT
  787. security.providers = null
  788. socket.connection.setup.timeout.max.ms = 30000
  789. socket.connection.setup.timeout.ms = 10000
  790. socket.listen.backlog.size = 50
  791. socket.receive.buffer.bytes = 102400
  792. socket.request.max.bytes = 104857600
  793. socket.send.buffer.bytes = 102400
  794. ssl.cipher.suites = []
  795. ssl.client.auth = none
  796. ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
  797. ssl.endpoint.identification.algorithm = https
  798. ssl.engine.factory.class = null
  799. ssl.key.password = null
  800. ssl.keymanager.algorithm = SunX509
  801. ssl.keystore.certificate.chain = null
  802. ssl.keystore.key = null
  803. ssl.keystore.location = null
  804. ssl.keystore.password = null
  805. ssl.keystore.type = JKS
  806. ssl.principal.mapping.rules = DEFAULT
  807. ssl.protocol = TLSv1.3
  808. ssl.provider = null
  809. ssl.secure.random.implementation = null
  810. ssl.trustmanager.algorithm = PKIX
  811. ssl.truststore.certificates = null
  812. ssl.truststore.location = null
  813. ssl.truststore.password = null
  814. ssl.truststore.type = JKS
  815. transaction.abort.timed.out.transaction.cleanup.interval.ms = 10000
  816. transaction.max.timeout.ms = 900000
  817. transaction.remove.expired.transaction.cleanup.interval.ms = 3600000
  818. transaction.state.log.load.buffer.size = 5242880
  819. transaction.state.log.min.isr = 1
  820. transaction.state.log.num.partitions = 50
  821. transaction.state.log.replication.factor = 1
  822. transaction.state.log.segment.bytes = 104857600
  823. transactional.id.expiration.ms = 604800000
  824. unclean.leader.election.enable = false
  825. zookeeper.clientCnxnSocket = null
  826. zookeeper.connect = null
  827. zookeeper.connection.timeout.ms = null
  828. zookeeper.max.in.flight.requests = 10
  829. zookeeper.session.timeout.ms = 18000
  830. zookeeper.set.acl = false
  831. zookeeper.ssl.cipher.suites = null
  832. zookeeper.ssl.client.enable = false
  833. zookeeper.ssl.crl.enable = false
  834. zookeeper.ssl.enabled.protocols = null
  835. zookeeper.ssl.endpoint.identification.algorithm = HTTPS
  836. zookeeper.ssl.keystore.location = null
  837. zookeeper.ssl.keystore.password = null
  838. zookeeper.ssl.keystore.type = null
  839. zookeeper.ssl.ocsp.enable = false
  840. zookeeper.ssl.protocol = TLSv1.2
  841. zookeeper.ssl.truststore.location = null
  842. zookeeper.ssl.truststore.password = null
  843. zookeeper.ssl.truststore.type = null
  844. (kafka.server.KafkaConfig)
  845. [2022-10-27 16:04:15,381] INFO [SocketServer listenerType=BROKER, nodeId=1] Enabling request processing. (kafka.network.SocketServer)
  846. [2022-10-27 16:04:15,384] 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 427. (org.apache.kafka.controller.BrokerHeartbeatManager)
  847. [2022-10-27 16:04:15,389] INFO [Controller 1] Unfenced broker: 1 (org.apache.kafka.controller.ClusterControlManager)
  848. [2022-10-27 16:04:15,401] INFO [BrokerLifecycleManager id=1] The broker has been unfenced. Transitioning from RECOVERY to RUNNING. (kafka.server.BrokerLifecycleManager)
  849. [2022-10-27 16:04:15,402] INFO [BrokerServer id=1] Transition from STARTING to STARTED (kafka.server.BrokerServer)
  850. [2022-10-27 16:04:15,403] INFO Kafka version: 3.3.1 (org.apache.kafka.common.utils.AppInfoParser)
  851. [2022-10-27 16:04:15,403] INFO Kafka commitId: e23c59d00e687ff5 (org.apache.kafka.common.utils.AppInfoParser)
  852. [2022-10-27 16:04:15,403] INFO Kafka startTimeMs: 1666857855402 (org.apache.kafka.common.utils.AppInfoParser)
  853. [2022-10-27 16:04:15,404] INFO [KafkaRaftServer nodeId=1] Kafka Server started (kafka.server.KafkaRaftServer)
  854. [2022-10-27 16:24:59,858] INFO Terminating process due to signal SIGTERM (org.apache.kafka.common.utils.LoggingSignalHandler)
  855. [2022-10-27 16:24:59,858] INFO Terminating process due to signal SIGTERM (org.apache.kafka.common.utils.LoggingSignalHandler)
  856. [2022-10-27 16:24:59,861] INFO [BrokerServer id=1] Transition from STARTED to SHUTTING_DOWN (kafka.server.BrokerServer)
  857. [2022-10-27 16:24:59,862] INFO [BrokerServer id=1] shutting down (kafka.server.BrokerServer)
  858. [2022-10-27 16:24:59,864] INFO [BrokerLifecycleManager id=1] Beginning controlled shutdown. (kafka.server.BrokerLifecycleManager)
  859. [2022-10-27 16:24:59,864] INFO [Controller 1] Unfenced broker 1 has requested and been granted an immediate shutdown. (org.apache.kafka.controller.BrokerHeartbeatManager)
  860. [2022-10-27 16:24:59,865] INFO [Controller 1] Fenced broker: 1 (org.apache.kafka.controller.ClusterControlManager)
  861. [2022-10-27 16:24:59,892] INFO [BrokerLifecycleManager id=1] The controller has asked us to exit controlled shutdown. (kafka.server.BrokerLifecycleManager)
  862. [2022-10-27 16:24:59,893] INFO [BrokerLifecycleManager id=1] beginShutdown: shutting down event queue. (org.apache.kafka.queue.KafkaEventQueue)
  863. [2022-10-27 16:24:59,893] INFO [BrokerLifecycleManager id=1] Transitioning from PENDING_CONTROLLED_SHUTDOWN to SHUTTING_DOWN. (kafka.server.BrokerLifecycleManager)
  864. [2022-10-27 16:24:59,894] INFO [BrokerToControllerChannelManager broker=1 name=heartbeat]: Shutting down (kafka.server.BrokerToControllerRequestThread)
  865. [2022-10-27 16:24:59,894] INFO [BrokerMetadataListener id=1] beginShutdown: shutting down event queue. (org.apache.kafka.queue.KafkaEventQueue)
  866. [2022-10-27 16:24:59,895] INFO [BrokerToControllerChannelManager broker=1 name=heartbeat]: Shutdown completed (kafka.server.BrokerToControllerRequestThread)
  867. [2022-10-27 16:24:59,895] INFO [BrokerToControllerChannelManager broker=1 name=heartbeat]: Stopped (kafka.server.BrokerToControllerRequestThread)
  868. [2022-10-27 16:24:59,896] INFO [SocketServer listenerType=BROKER, nodeId=1] Stopping socket server request processors (kafka.network.SocketServer)
  869. [2022-10-27 16:24:59,902] INFO Broker to controller channel manager for heartbeat shutdown (kafka.server.BrokerToControllerChannelManagerImpl)
  870. [2022-10-27 16:24:59,907] INFO [SocketServer listenerType=BROKER, nodeId=1] Stopped socket server request processors (kafka.network.SocketServer)
  871. [2022-10-27 16:24:59,907] INFO [data-plane Kafka Request Handler on Broker 1], shutting down (kafka.server.KafkaRequestHandlerPool)
  872. [2022-10-27 16:24:59,910] INFO [data-plane Kafka Request Handler on Broker 1], shut down completely (kafka.server.KafkaRequestHandlerPool)
  873. [2022-10-27 16:24:59,910] INFO [ExpirationReaper-1-AlterAcls]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  874. [2022-10-27 16:24:59,912] INFO [ExpirationReaper-1-AlterAcls]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  875. [2022-10-27 16:24:59,912] INFO [ExpirationReaper-1-AlterAcls]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  876. [2022-10-27 16:24:59,913] INFO [KafkaApi-1] Shutdown complete. (kafka.server.KafkaApis)
  877. [2022-10-27 16:24:59,914] INFO [BrokerMetadataListener id=1] closed event queue. (org.apache.kafka.queue.KafkaEventQueue)
  878. [2022-10-27 16:24:59,938] INFO [TransactionCoordinator id=1] Shutting down. (kafka.coordinator.transaction.TransactionCoordinator)
  879. [2022-10-27 16:24:59,939] INFO [Transaction State Manager 1]: Shutdown complete (kafka.coordinator.transaction.TransactionStateManager)
  880. [2022-10-27 16:24:59,939] INFO [Transaction Marker Channel Manager 1]: Shutting down (kafka.coordinator.transaction.TransactionMarkerChannelManager)
  881. [2022-10-27 16:24:59,939] INFO [Transaction Marker Channel Manager 1]: Stopped (kafka.coordinator.transaction.TransactionMarkerChannelManager)
  882. [2022-10-27 16:24:59,939] INFO [Transaction Marker Channel Manager 1]: Shutdown completed (kafka.coordinator.transaction.TransactionMarkerChannelManager)
  883. [2022-10-27 16:24:59,941] INFO [TransactionCoordinator id=1] Shutdown complete. (kafka.coordinator.transaction.TransactionCoordinator)
  884. [2022-10-27 16:24:59,942] INFO [GroupCoordinator 1]: Shutting down. (kafka.coordinator.group.GroupCoordinator)
  885. [2022-10-27 16:24:59,942] INFO [ExpirationReaper-1-Heartbeat]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  886. [2022-10-27 16:24:59,943] INFO [ExpirationReaper-1-Heartbeat]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  887. [2022-10-27 16:24:59,943] INFO [ExpirationReaper-1-Heartbeat]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  888. [2022-10-27 16:24:59,944] INFO [ExpirationReaper-1-Rebalance]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  889. [2022-10-27 16:24:59,944] INFO [ExpirationReaper-1-Rebalance]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  890. [2022-10-27 16:24:59,944] INFO [ExpirationReaper-1-Rebalance]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  891. [2022-10-27 16:24:59,945] INFO [GroupCoordinator 1]: Shutdown complete. (kafka.coordinator.group.GroupCoordinator)
  892. [2022-10-27 16:24:59,946] INFO [ReplicaManager broker=1] Shutting down (kafka.server.ReplicaManager)
  893. [2022-10-27 16:24:59,946] INFO [LogDirFailureHandler]: Shutting down (kafka.server.ReplicaManager$LogDirFailureHandler)
  894. [2022-10-27 16:24:59,946] INFO [LogDirFailureHandler]: Stopped (kafka.server.ReplicaManager$LogDirFailureHandler)
  895. [2022-10-27 16:24:59,946] INFO [LogDirFailureHandler]: Shutdown completed (kafka.server.ReplicaManager$LogDirFailureHandler)
  896. [2022-10-27 16:24:59,947] INFO [ReplicaFetcherManager on broker 1] shutting down (kafka.server.ReplicaFetcherManager)
  897. [2022-10-27 16:24:59,948] INFO [ReplicaFetcherManager on broker 1] shutdown completed (kafka.server.ReplicaFetcherManager)
  898. [2022-10-27 16:24:59,949] INFO [ReplicaAlterLogDirsManager on broker 1] shutting down (kafka.server.ReplicaAlterLogDirsManager)
  899. [2022-10-27 16:24:59,949] INFO [ReplicaAlterLogDirsManager on broker 1] shutdown completed (kafka.server.ReplicaAlterLogDirsManager)
  900. [2022-10-27 16:24:59,949] INFO [ExpirationReaper-1-Fetch]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  901. [2022-10-27 16:24:59,950] INFO [ExpirationReaper-1-Fetch]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  902. [2022-10-27 16:24:59,950] INFO [ExpirationReaper-1-Fetch]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  903. [2022-10-27 16:24:59,950] INFO [ExpirationReaper-1-Produce]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  904. [2022-10-27 16:24:59,950] INFO [ExpirationReaper-1-Produce]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  905. [2022-10-27 16:24:59,950] INFO [ExpirationReaper-1-Produce]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  906. [2022-10-27 16:24:59,951] INFO [ExpirationReaper-1-DeleteRecords]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  907. [2022-10-27 16:24:59,951] INFO [ExpirationReaper-1-DeleteRecords]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  908. [2022-10-27 16:24:59,951] INFO [ExpirationReaper-1-DeleteRecords]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  909. [2022-10-27 16:24:59,952] INFO [ExpirationReaper-1-ElectLeader]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  910. [2022-10-27 16:24:59,952] INFO [ExpirationReaper-1-ElectLeader]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  911. [2022-10-27 16:24:59,952] INFO [ExpirationReaper-1-ElectLeader]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  912. [2022-10-27 16:24:59,953] INFO [ReplicaManager broker=1] Shut down completely (kafka.server.ReplicaManager)
  913. [2022-10-27 16:24:59,954] INFO [BrokerToControllerChannelManager broker=1 name=alterPartition]: Shutting down (kafka.server.BrokerToControllerRequestThread)
  914. [2022-10-27 16:24:59,954] INFO [BrokerToControllerChannelManager broker=1 name=alterPartition]: Stopped (kafka.server.BrokerToControllerRequestThread)
  915. [2022-10-27 16:24:59,954] INFO [BrokerToControllerChannelManager broker=1 name=alterPartition]: Shutdown completed (kafka.server.BrokerToControllerRequestThread)
  916. [2022-10-27 16:24:59,954] INFO Broker to controller channel manager for alterPartition shutdown (kafka.server.BrokerToControllerChannelManagerImpl)
  917. [2022-10-27 16:24:59,955] INFO [BrokerToControllerChannelManager broker=1 name=forwarding]: Shutting down (kafka.server.BrokerToControllerRequestThread)
  918. [2022-10-27 16:24:59,955] INFO [BrokerToControllerChannelManager broker=1 name=forwarding]: Stopped (kafka.server.BrokerToControllerRequestThread)
  919. [2022-10-27 16:24:59,955] INFO [BrokerToControllerChannelManager broker=1 name=forwarding]: Shutdown completed (kafka.server.BrokerToControllerRequestThread)
  920. [2022-10-27 16:24:59,955] INFO Broker to controller channel manager for forwarding shutdown (kafka.server.BrokerToControllerChannelManagerImpl)
  921. [2022-10-27 16:24:59,956] INFO Shutting down. (kafka.log.LogManager)
  922. [2022-10-27 16:24:59,965] INFO Shutdown complete. (kafka.log.LogManager)
  923. [2022-10-27 16:24:59,965] INFO [ThrottledChannelReaper-Fetch]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  924. [2022-10-27 16:24:59,966] INFO [ThrottledChannelReaper-Fetch]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  925. [2022-10-27 16:24:59,966] INFO [ThrottledChannelReaper-Fetch]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  926. [2022-10-27 16:24:59,967] INFO [ThrottledChannelReaper-Produce]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  927. [2022-10-27 16:24:59,967] INFO [ThrottledChannelReaper-Produce]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  928. [2022-10-27 16:24:59,967] INFO [ThrottledChannelReaper-Produce]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  929. [2022-10-27 16:24:59,967] INFO [ThrottledChannelReaper-Request]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  930. [2022-10-27 16:24:59,967] INFO [ThrottledChannelReaper-Request]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  931. [2022-10-27 16:24:59,967] INFO [ThrottledChannelReaper-Request]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  932. [2022-10-27 16:24:59,967] INFO [ThrottledChannelReaper-ControllerMutation]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  933. [2022-10-27 16:24:59,967] INFO [ThrottledChannelReaper-ControllerMutation]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  934. [2022-10-27 16:24:59,967] INFO [ThrottledChannelReaper-ControllerMutation]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  935. [2022-10-27 16:24:59,968] INFO [SocketServer listenerType=BROKER, nodeId=1] Shutting down socket server (kafka.network.SocketServer)
  936. [2022-10-27 16:24:59,982] INFO [SocketServer listenerType=BROKER, nodeId=1] Shutdown completed (kafka.network.SocketServer)
  937. [2022-10-27 16:24:59,983] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics)
  938. [2022-10-27 16:24:59,983] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics)
  939. [2022-10-27 16:24:59,983] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics)
  940. [2022-10-27 16:24:59,984] INFO Broker and topic stats closed (kafka.server.BrokerTopicStats)
  941. [2022-10-27 16:24:59,985] INFO [BrokerLifecycleManager id=1] closed event queue. (org.apache.kafka.queue.KafkaEventQueue)
  942. [2022-10-27 16:24:59,985] INFO App info kafka.server for 1 unregistered (org.apache.kafka.common.utils.AppInfoParser)
  943. [2022-10-27 16:24:59,986] INFO [BrokerServer id=1] shut down completed (kafka.server.BrokerServer)
  944. [2022-10-27 16:24:59,986] INFO [BrokerServer id=1] Transition from SHUTTING_DOWN to SHUTDOWN (kafka.server.BrokerServer)
  945. [2022-10-27 16:24:59,986] INFO [raft-expiration-reaper]: Shutting down (kafka.raft.TimingWheelExpirationService$ExpiredOperationReaper)
  946. [2022-10-27 16:25:00,172] INFO [raft-expiration-reaper]: Shutdown completed (kafka.raft.TimingWheelExpirationService$ExpiredOperationReaper)
  947. [2022-10-27 16:25:00,172] INFO [raft-expiration-reaper]: Stopped (kafka.raft.TimingWheelExpirationService$ExpiredOperationReaper)
  948. [2022-10-27 16:25:00,172] INFO [kafka-raft-io-thread]: Shutting down (kafka.raft.KafkaRaftManager$RaftIoThread)
  949. [2022-10-27 16:25:00,172] INFO [RaftManager nodeId=1] Beginning graceful shutdown (org.apache.kafka.raft.KafkaRaftClient)
  950. [2022-10-27 16:25:00,174] INFO [RaftManager nodeId=1] Graceful shutdown completed (org.apache.kafka.raft.KafkaRaftClient)
  951. [2022-10-27 16:25:00,175] INFO [kafka-raft-io-thread]: Completed graceful shutdown of RaftClient (kafka.raft.KafkaRaftManager$RaftIoThread)
  952. [2022-10-27 16:25:00,175] INFO [kafka-raft-io-thread]: Stopped (kafka.raft.KafkaRaftManager$RaftIoThread)
  953. [2022-10-27 16:25:00,175] INFO [kafka-raft-io-thread]: Shutdown completed (kafka.raft.KafkaRaftManager$RaftIoThread)
  954. [2022-10-27 16:25:00,178] INFO [kafka-raft-outbound-request-thread]: Shutting down (kafka.raft.RaftSendThread)
  955. [2022-10-27 16:25:00,178] INFO [kafka-raft-outbound-request-thread]: Shutdown completed (kafka.raft.RaftSendThread)
  956. [2022-10-27 16:25:00,178] INFO [kafka-raft-outbound-request-thread]: Stopped (kafka.raft.RaftSendThread)
  957. [2022-10-27 16:25:00,181] INFO [ProducerStateManager partition=__cluster_metadata-0] Wrote producer snapshot at offset 2920 with 0 producer ids in 1 ms. (kafka.log.ProducerStateManager)
  958. [2022-10-27 16:25:00,197] INFO [ControllerServer id=1] shutting down (kafka.server.ControllerServer)
  959. [2022-10-27 16:25:00,197] INFO [SocketServer listenerType=CONTROLLER, nodeId=1] Stopping socket server request processors (kafka.network.SocketServer)
  960. [2022-10-27 16:25:00,202] INFO [SocketServer listenerType=CONTROLLER, nodeId=1] Stopped socket server request processors (kafka.network.SocketServer)
  961. [2022-10-27 16:25:00,202] INFO [Controller 1] QuorumController#beginShutdown: shutting down event queue. (org.apache.kafka.queue.KafkaEventQueue)
  962. [2022-10-27 16:25:00,202] ERROR [Controller 1] writeNoOpRecord: unable to start processing because of TimeoutException. (org.apache.kafka.controller.QuorumController)
  963. [2022-10-27 16:25:00,202] INFO [SocketServer listenerType=CONTROLLER, nodeId=1] Shutting down socket server (kafka.network.SocketServer)
  964. [2022-10-27 16:25:00,212] INFO [SocketServer listenerType=CONTROLLER, nodeId=1] Shutdown completed (kafka.network.SocketServer)
  965. [2022-10-27 16:25:00,213] INFO [data-plane Kafka Request Handler on Broker 1], shutting down (kafka.server.KafkaRequestHandlerPool)
  966. [2022-10-27 16:25:00,213] INFO [data-plane Kafka Request Handler on Broker 1], shut down completely (kafka.server.KafkaRequestHandlerPool)
  967. [2022-10-27 16:25:00,214] INFO [ExpirationReaper-1-AlterAcls]: Shutting down (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  968. [2022-10-27 16:25:00,214] INFO [ExpirationReaper-1-AlterAcls]: Stopped (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  969. [2022-10-27 16:25:00,214] INFO [ExpirationReaper-1-AlterAcls]: Shutdown completed (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  970. [2022-10-27 16:25:00,215] INFO [ThrottledChannelReaper-Fetch]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  971. [2022-10-27 16:25:00,215] INFO [ThrottledChannelReaper-Fetch]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  972. [2022-10-27 16:25:00,215] INFO [ThrottledChannelReaper-Fetch]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  973. [2022-10-27 16:25:00,215] INFO [ThrottledChannelReaper-Produce]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  974. [2022-10-27 16:25:00,216] INFO [ThrottledChannelReaper-Produce]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  975. [2022-10-27 16:25:00,216] INFO [ThrottledChannelReaper-Produce]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  976. [2022-10-27 16:25:00,216] INFO [ThrottledChannelReaper-Request]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  977. [2022-10-27 16:25:00,216] INFO [ThrottledChannelReaper-Request]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  978. [2022-10-27 16:25:00,216] INFO [ThrottledChannelReaper-Request]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  979. [2022-10-27 16:25:00,216] INFO [ThrottledChannelReaper-ControllerMutation]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  980. [2022-10-27 16:25:00,216] INFO [ThrottledChannelReaper-ControllerMutation]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  981. [2022-10-27 16:25:00,216] INFO [ThrottledChannelReaper-ControllerMutation]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
  982. [2022-10-27 16:25:00,216] INFO [Controller 1] closed event queue. (org.apache.kafka.queue.KafkaEventQueue)
  983. [2022-10-27 16:25:00,218] INFO App info kafka.server for 1 unregistered (org.apache.kafka.common.utils.AppInfoParser)
  984. [2022-10-27 16:25:02,117] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
  985. [2022-10-27 16:25:02,504] INFO Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation (org.apache.zookeeper.common.X509Util)
  986. [2022-10-27 16:25:02,722] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Recovering unflushed segment 0. 0/1 recovered for __cluster_metadata-0. (kafka.log.LogLoader)
  987. [2022-10-27 16:25:02,724] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
  988. [2022-10-27 16:25:02,725] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Reloading from producer snapshot and rebuilding producer state from offset 0 (kafka.log.UnifiedLog$)
  989. [2022-10-27 16:25:02,726] INFO Deleted producer state snapshot /opt/kafka_2.13-3.3.1/logs/__cluster_metadata-0/00000000000000000427.snapshot (kafka.log.SnapshotFile)
  990. [2022-10-27 16:25:02,727] INFO Deleted producer state snapshot /opt/kafka_2.13-3.3.1/logs/__cluster_metadata-0/00000000000000002920.snapshot (kafka.log.SnapshotFile)
  991. [2022-10-27 16:25:02,728] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Producer state recovery took 3ms for snapshot load and 0ms for segment recovery from offset 0 (kafka.log.UnifiedLog$)
  992. [2022-10-27 16:25:02,806] INFO [ProducerStateManager partition=__cluster_metadata-0] Wrote producer snapshot at offset 2920 with 0 producer ids in 4 ms. (kafka.log.ProducerStateManager)
  993. [2022-10-27 16:25:02,831] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Loading producer state till offset 2920 with message format version 2 (kafka.log.UnifiedLog$)
  994. [2022-10-27 16:25:02,831] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Reloading from producer snapshot and rebuilding producer state from offset 2920 (kafka.log.UnifiedLog$)
  995. [2022-10-27 16:25:02,832] INFO [ProducerStateManager partition=__cluster_metadata-0] Loading producer state from snapshot file 'SnapshotFile(/opt/kafka_2.13-3.3.1/logs/__cluster_metadata-0/00000000000000002920.snapshot,2920)' (kafka.log.ProducerStateManager)
  996. [2022-10-27 16:25:02,835] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Producer state recovery took 4ms for snapshot load and 0ms for segment recovery from offset 2920 (kafka.log.UnifiedLog$)
  997. [2022-10-27 16:25:02,915] INFO Initialized snapshots with IDs SortedSet() from /opt/kafka_2.13-3.3.1/logs/__cluster_metadata-0 (kafka.raft.KafkaMetadataLog$)
  998. [2022-10-27 16:25:02,967] INFO [raft-expiration-reaper]: Starting (kafka.raft.TimingWheelExpirationService$ExpiredOperationReaper)
  999. [2022-10-27 16:25:03,133] ERROR Exiting Kafka due to fatal exception (kafka.Kafka$)
  1000. java.lang.IllegalStateException: Configured voter set: [1, 2, 3, 4, 5] is different from the voter set read from the state file: [1]. Check if the quorum configuration is up to date, or wipe out the local state file if necessary
  1001. at org.apache.kafka.raft.QuorumState.initialize(QuorumState.java:132)
  1002. at org.apache.kafka.raft.KafkaRaftClient.initialize(KafkaRaftClient.java:369)
  1003. at kafka.raft.KafkaRaftManager.buildRaftClient(RaftManager.scala:200)
  1004. at kafka.raft.KafkaRaftManager.<init>(RaftManager.scala:127)
  1005. at kafka.server.KafkaRaftServer.<init>(KafkaRaftServer.scala:83)
  1006. at kafka.Kafka$.buildServer(Kafka.scala:79)
  1007. at kafka.Kafka$.main(Kafka.scala:87)
  1008. at kafka.Kafka.main(Kafka.scala)
  1009. [2022-10-27 16:25:04,986] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
  1010. [2022-10-27 16:25:05,308] INFO Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation (org.apache.zookeeper.common.X509Util)
  1011. [2022-10-27 16:25:05,502] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Recovering unflushed segment 0. 0/1 recovered for __cluster_metadata-0. (kafka.log.LogLoader)
  1012. [2022-10-27 16:25:05,503] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
  1013. [2022-10-27 16:25:05,504] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Reloading from producer snapshot and rebuilding producer state from offset 0 (kafka.log.UnifiedLog$)
  1014. [2022-10-27 16:25:05,505] INFO Deleted producer state snapshot /opt/kafka_2.13-3.3.1/logs/__cluster_metadata-0/00000000000000002920.snapshot (kafka.log.SnapshotFile)
  1015. [2022-10-27 16:25:05,507] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Producer state recovery took 3ms for snapshot load and 0ms for segment recovery from offset 0 (kafka.log.UnifiedLog$)
  1016. [2022-10-27 16:25:05,565] INFO [ProducerStateManager partition=__cluster_metadata-0] Wrote producer snapshot at offset 2920 with 0 producer ids in 4 ms. (kafka.log.ProducerStateManager)
  1017. [2022-10-27 16:25:05,587] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Loading producer state till offset 2920 with message format version 2 (kafka.log.UnifiedLog$)
  1018. [2022-10-27 16:25:05,587] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Reloading from producer snapshot and rebuilding producer state from offset 2920 (kafka.log.UnifiedLog$)
  1019. [2022-10-27 16:25:05,588] INFO [ProducerStateManager partition=__cluster_metadata-0] Loading producer state from snapshot file 'SnapshotFile(/opt/kafka_2.13-3.3.1/logs/__cluster_metadata-0/00000000000000002920.snapshot,2920)' (kafka.log.ProducerStateManager)
  1020. [2022-10-27 16:25:05,590] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Producer state recovery took 3ms for snapshot load and 0ms for segment recovery from offset 2920 (kafka.log.UnifiedLog$)
  1021. [2022-10-27 16:25:05,640] INFO Initialized snapshots with IDs SortedSet() from /opt/kafka_2.13-3.3.1/logs/__cluster_metadata-0 (kafka.raft.KafkaMetadataLog$)
  1022. [2022-10-27 16:25:05,676] INFO [raft-expiration-reaper]: Starting (kafka.raft.TimingWheelExpirationService$ExpiredOperationReaper)
  1023. [2022-10-27 16:25:05,817] ERROR Exiting Kafka due to fatal exception (kafka.Kafka$)
  1024. java.lang.IllegalStateException: Configured voter set: [1, 2, 3, 4, 5] is different from the voter set read from the state file: [1]. Check if the quorum configuration is up to date, or wipe out the local state file if necessary
  1025. at org.apache.kafka.raft.QuorumState.initialize(QuorumState.java:132)
  1026. at org.apache.kafka.raft.KafkaRaftClient.initialize(KafkaRaftClient.java:369)
  1027. at kafka.raft.KafkaRaftManager.buildRaftClient(RaftManager.scala:200)
  1028. at kafka.raft.KafkaRaftManager.<init>(RaftManager.scala:127)
  1029. at kafka.server.KafkaRaftServer.<init>(KafkaRaftServer.scala:83)
  1030. at kafka.Kafka$.buildServer(Kafka.scala:79)
  1031. at kafka.Kafka$.main(Kafka.scala:87)
  1032. at kafka.Kafka.main(Kafka.scala)
  1033. [2022-10-27 16:25:07,383] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
  1034. [2022-10-27 16:25:07,697] INFO Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation (org.apache.zookeeper.common.X509Util)
  1035. [2022-10-27 16:25:07,894] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Recovering unflushed segment 0. 0/1 recovered for __cluster_metadata-0. (kafka.log.LogLoader)
  1036. [2022-10-27 16:25:07,895] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
  1037. [2022-10-27 16:25:07,896] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Reloading from producer snapshot and rebuilding producer state from offset 0 (kafka.log.UnifiedLog$)
  1038. [2022-10-27 16:25:07,898] INFO Deleted producer state snapshot /opt/kafka_2.13-3.3.1/logs/__cluster_metadata-0/00000000000000002920.snapshot (kafka.log.SnapshotFile)
  1039. [2022-10-27 16:25:07,899] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Producer state recovery took 3ms for snapshot load and 0ms for segment recovery from offset 0 (kafka.log.UnifiedLog$)
  1040. [2022-10-27 16:25:07,958] INFO [ProducerStateManager partition=__cluster_metadata-0] Wrote producer snapshot at offset 2920 with 0 producer ids in 3 ms. (kafka.log.ProducerStateManager)
  1041. [2022-10-27 16:25:07,975] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Loading producer state till offset 2920 with message format version 2 (kafka.log.UnifiedLog$)
  1042. [2022-10-27 16:25:07,976] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Reloading from producer snapshot and rebuilding producer state from offset 2920 (kafka.log.UnifiedLog$)
  1043. [2022-10-27 16:25:07,977] INFO [ProducerStateManager partition=__cluster_metadata-0] Loading producer state from snapshot file 'SnapshotFile(/opt/kafka_2.13-3.3.1/logs/__cluster_metadata-0/00000000000000002920.snapshot,2920)' (kafka.log.ProducerStateManager)
  1044. [2022-10-27 16:25:07,980] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Producer state recovery took 3ms for snapshot load and 0ms for segment recovery from offset 2920 (kafka.log.UnifiedLog$)
  1045. [2022-10-27 16:25:08,045] INFO Initialized snapshots with IDs SortedSet() from /opt/kafka_2.13-3.3.1/logs/__cluster_metadata-0 (kafka.raft.KafkaMetadataLog$)
  1046. [2022-10-27 16:25:08,095] INFO [raft-expiration-reaper]: Starting (kafka.raft.TimingWheelExpirationService$ExpiredOperationReaper)
  1047. [2022-10-27 16:25:08,295] ERROR Exiting Kafka due to fatal exception (kafka.Kafka$)
  1048. java.lang.IllegalStateException: Configured voter set: [1, 2, 3, 4, 5] is different from the voter set read from the state file: [1]. Check if the quorum configuration is up to date, or wipe out the local state file if necessary
  1049. at org.apache.kafka.raft.QuorumState.initialize(QuorumState.java:132)
  1050. at org.apache.kafka.raft.KafkaRaftClient.initialize(KafkaRaftClient.java:369)
  1051. at kafka.raft.KafkaRaftManager.buildRaftClient(RaftManager.scala:200)
  1052. at kafka.raft.KafkaRaftManager.<init>(RaftManager.scala:127)
  1053. at kafka.server.KafkaRaftServer.<init>(KafkaRaftServer.scala:83)
  1054. at kafka.Kafka$.buildServer(Kafka.scala:79)
  1055. at kafka.Kafka$.main(Kafka.scala:87)
  1056. at kafka.Kafka.main(Kafka.scala)
  1057. [2022-10-27 16:25:09,881] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
  1058. [2022-10-27 16:25:10,191] INFO Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation (org.apache.zookeeper.common.X509Util)
  1059. [2022-10-27 16:25:10,382] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Recovering unflushed segment 0. 0/1 recovered for __cluster_metadata-0. (kafka.log.LogLoader)
  1060. [2022-10-27 16:25:10,384] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
  1061. [2022-10-27 16:25:10,385] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Reloading from producer snapshot and rebuilding producer state from offset 0 (kafka.log.UnifiedLog$)
  1062. [2022-10-27 16:25:10,386] INFO Deleted producer state snapshot /opt/kafka_2.13-3.3.1/logs/__cluster_metadata-0/00000000000000002920.snapshot (kafka.log.SnapshotFile)
  1063. [2022-10-27 16:25:10,387] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Producer state recovery took 2ms for snapshot load and 0ms for segment recovery from offset 0 (kafka.log.UnifiedLog$)
  1064. [2022-10-27 16:25:10,447] INFO [ProducerStateManager partition=__cluster_metadata-0] Wrote producer snapshot at offset 2920 with 0 producer ids in 4 ms. (kafka.log.ProducerStateManager)
  1065. [2022-10-27 16:25:10,469] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Loading producer state till offset 2920 with message format version 2 (kafka.log.UnifiedLog$)
  1066. [2022-10-27 16:25:10,469] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Reloading from producer snapshot and rebuilding producer state from offset 2920 (kafka.log.UnifiedLog$)
  1067. [2022-10-27 16:25:10,470] INFO [ProducerStateManager partition=__cluster_metadata-0] Loading producer state from snapshot file 'SnapshotFile(/opt/kafka_2.13-3.3.1/logs/__cluster_metadata-0/00000000000000002920.snapshot,2920)' (kafka.log.ProducerStateManager)
  1068. [2022-10-27 16:25:10,473] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Producer state recovery took 4ms for snapshot load and 0ms for segment recovery from offset 2920 (kafka.log.UnifiedLog$)
  1069. [2022-10-27 16:25:10,545] INFO Initialized snapshots with IDs SortedSet() from /opt/kafka_2.13-3.3.1/logs/__cluster_metadata-0 (kafka.raft.KafkaMetadataLog$)
  1070. [2022-10-27 16:25:10,584] INFO [raft-expiration-reaper]: Starting (kafka.raft.TimingWheelExpirationService$ExpiredOperationReaper)
  1071. [2022-10-27 16:25:10,724] ERROR Exiting Kafka due to fatal exception (kafka.Kafka$)
  1072. java.lang.IllegalStateException: Configured voter set: [1, 2, 3, 4, 5] is different from the voter set read from the state file: [1]. Check if the quorum configuration is up to date, or wipe out the local state file if necessary
  1073. at org.apache.kafka.raft.QuorumState.initialize(QuorumState.java:132)
  1074. at org.apache.kafka.raft.KafkaRaftClient.initialize(KafkaRaftClient.java:369)
  1075. at kafka.raft.KafkaRaftManager.buildRaftClient(RaftManager.scala:200)
  1076. at kafka.raft.KafkaRaftManager.<init>(RaftManager.scala:127)
  1077. at kafka.server.KafkaRaftServer.<init>(KafkaRaftServer.scala:83)
  1078. at kafka.Kafka$.buildServer(Kafka.scala:79)
  1079. at kafka.Kafka$.main(Kafka.scala:87)
  1080. at kafka.Kafka.main(Kafka.scala)
  1081. [2022-10-27 16:25:12,371] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
  1082. [2022-10-27 16:25:12,689] INFO Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation (org.apache.zookeeper.common.X509Util)
  1083. [2022-10-27 16:25:12,891] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Recovering unflushed segment 0. 0/1 recovered for __cluster_metadata-0. (kafka.log.LogLoader)
  1084. [2022-10-27 16:25:12,893] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
  1085. [2022-10-27 16:25:12,894] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Reloading from producer snapshot and rebuilding producer state from offset 0 (kafka.log.UnifiedLog$)
  1086. [2022-10-27 16:25:12,895] INFO Deleted producer state snapshot /opt/kafka_2.13-3.3.1/logs/__cluster_metadata-0/00000000000000002920.snapshot (kafka.log.SnapshotFile)
  1087. [2022-10-27 16:25:12,897] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Producer state recovery took 2ms for snapshot load and 1ms for segment recovery from offset 0 (kafka.log.UnifiedLog$)
  1088. [2022-10-27 16:25:12,955] INFO [ProducerStateManager partition=__cluster_metadata-0] Wrote producer snapshot at offset 2920 with 0 producer ids in 3 ms. (kafka.log.ProducerStateManager)
  1089. [2022-10-27 16:25:12,973] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Loading producer state till offset 2920 with message format version 2 (kafka.log.UnifiedLog$)
  1090. [2022-10-27 16:25:12,973] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Reloading from producer snapshot and rebuilding producer state from offset 2920 (kafka.log.UnifiedLog$)
  1091. [2022-10-27 16:25:12,973] INFO [ProducerStateManager partition=__cluster_metadata-0] Loading producer state from snapshot file 'SnapshotFile(/opt/kafka_2.13-3.3.1/logs/__cluster_metadata-0/00000000000000002920.snapshot,2920)' (kafka.log.ProducerStateManager)
  1092. [2022-10-27 16:25:12,975] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Producer state recovery took 2ms for snapshot load and 0ms for segment recovery from offset 2920 (kafka.log.UnifiedLog$)
  1093. [2022-10-27 16:25:13,024] INFO Initialized snapshots with IDs SortedSet() from /opt/kafka_2.13-3.3.1/logs/__cluster_metadata-0 (kafka.raft.KafkaMetadataLog$)
  1094. [2022-10-27 16:25:13,062] INFO [raft-expiration-reaper]: Starting (kafka.raft.TimingWheelExpirationService$ExpiredOperationReaper)
  1095. [2022-10-27 16:25:13,204] ERROR Exiting Kafka due to fatal exception (kafka.Kafka$)
  1096. java.lang.IllegalStateException: Configured voter set: [1, 2, 3, 4, 5] is different from the voter set read from the state file: [1]. Check if the quorum configuration is up to date, or wipe out the local state file if necessary
  1097. at org.apache.kafka.raft.QuorumState.initialize(QuorumState.java:132)
  1098. at org.apache.kafka.raft.KafkaRaftClient.initialize(KafkaRaftClient.java:369)
  1099. at kafka.raft.KafkaRaftManager.buildRaftClient(RaftManager.scala:200)
  1100. at kafka.raft.KafkaRaftManager.<init>(RaftManager.scala:127)
  1101. at kafka.server.KafkaRaftServer.<init>(KafkaRaftServer.scala:83)
  1102. at kafka.Kafka$.buildServer(Kafka.scala:79)
  1103. at kafka.Kafka$.main(Kafka.scala:87)
  1104. at kafka.Kafka.main(Kafka.scala)
  1105. [2022-10-27 16:25:14,888] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
  1106. [2022-10-27 16:25:15,216] INFO Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation (org.apache.zookeeper.common.X509Util)
  1107. [2022-10-27 16:25:15,415] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Recovering unflushed segment 0. 0/1 recovered for __cluster_metadata-0. (kafka.log.LogLoader)
  1108. [2022-10-27 16:25:15,417] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
  1109. [2022-10-27 16:25:15,417] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Reloading from producer snapshot and rebuilding producer state from offset 0 (kafka.log.UnifiedLog$)
  1110. [2022-10-27 16:25:15,419] INFO Deleted producer state snapshot /opt/kafka_2.13-3.3.1/logs/__cluster_metadata-0/00000000000000002920.snapshot (kafka.log.SnapshotFile)
  1111. [2022-10-27 16:25:15,420] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Producer state recovery took 3ms for snapshot load and 0ms for segment recovery from offset 0 (kafka.log.UnifiedLog$)
  1112. [2022-10-27 16:25:15,483] INFO [ProducerStateManager partition=__cluster_metadata-0] Wrote producer snapshot at offset 2920 with 0 producer ids in 4 ms. (kafka.log.ProducerStateManager)
  1113. [2022-10-27 16:25:15,508] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Loading producer state till offset 2920 with message format version 2 (kafka.log.UnifiedLog$)
  1114. [2022-10-27 16:25:15,509] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Reloading from producer snapshot and rebuilding producer state from offset 2920 (kafka.log.UnifiedLog$)
  1115. [2022-10-27 16:25:15,510] INFO [ProducerStateManager partition=__cluster_metadata-0] Loading producer state from snapshot file 'SnapshotFile(/opt/kafka_2.13-3.3.1/logs/__cluster_metadata-0/00000000000000002920.snapshot,2920)' (kafka.log.ProducerStateManager)
  1116. [2022-10-27 16:25:15,515] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka_2.13-3.3.1/logs] Producer state recovery took 6ms for snapshot load and 0ms for segment recovery from offset 2920 (kafka.log.UnifiedLog$)
  1117. [2022-10-27 16:25:15,580] INFO Initialized snapshots with IDs SortedSet() from /opt/kafka_2.13-3.3.1/logs/__cluster_metadata-0 (kafka.raft.KafkaMetadataLog$)
  1118. [2022-10-27 16:25:15,617] INFO [raft-expiration-reaper]: Starting (kafka.raft.TimingWheelExpirationService$ExpiredOperationReaper)
  1119. [2022-10-27 16:25:15,757] ERROR Exiting Kafka due to fatal exception (kafka.Kafka$)
  1120. java.lang.IllegalStateException: Configured voter set: [1, 2, 3, 4, 5] is different from the voter set read from the state file: [1]. Check if the quorum configuration is up to date, or wipe out the local state file if necessary
  1121. at org.apache.kafka.raft.QuorumState.initialize(QuorumState.java:132)
  1122. at org.apache.kafka.raft.KafkaRaftClient.initialize(KafkaRaftClient.java:369)
  1123. at kafka.raft.KafkaRaftManager.buildRaftClient(RaftManager.scala:200)
  1124. at kafka.raft.KafkaRaftManager.<init>(RaftManager.scala:127)
  1125. at kafka.server.KafkaRaftServer.<init>(KafkaRaftServer.scala:83)
  1126. at kafka.Kafka$.buildServer(Kafka.scala:79)
  1127. at kafka.Kafka$.main(Kafka.scala:87)
  1128. at kafka.Kafka.main(Kafka.scala)
  1129.  
Tags: kafka3
Add Comment
Please, Sign In to add comment
Public Pastes
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!