API tools faq
paste
KeithTt

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

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