Home Explore Help
Sign In
cecf
/
deploy
5
0
Fork 0
Files Issues 0 Pull Requests 0 Wiki
Branch: master
Branches Tags
deploy
/
kafka-ha
/
kafka-broker_log.log

kafka-broker_log.log 9.9 KB
Permalink History Raw

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990 
  1. KAFKA_CFG_ADVERTISED_LISTENERS: BROKER://kafka-broker-0.kafka-headless.observe.svc.cluster.local:9092,EXTERNAL://20.46.101.13:31052
    2. 

  2. openjdk version "17.0.9" 2023-10-17
    3. 

  3. OpenJDK Runtime Environment Temurin-17.0.9+9 (build 17.0.9+9)
    4. 

  4. OpenJDK 64-Bit Server VM Temurin-17.0.9+9 (build 17.0.9+9, mixed mode, sharing)
    5. 

  5. Picked up JAVA_TOOL_OPTIONS:  -Xms7000m -Xmx7000m
    6. 

  6. [2024-10-28 03:44:38,322] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
    7. 

  7. [2024-10-28 03:44:38,608] INFO Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation (org.apache.zookeeper.common.X509Util)
    8. 

  8. [2024-10-28 03:44:38,759] INFO Registered signal handlers for TERM, INT, HUP (org.apache.kafka.common.utils.LoggingSignalHandler)
    9. 

  9. [2024-10-28 03:44:38,763] INFO [BrokerServer id=1000] Transition from SHUTDOWN to STARTING (kafka.server.BrokerServer)
    10. 

  10. [2024-10-28 03:44:38,764] INFO [SharedServer id=1000] Starting SharedServer (kafka.server.SharedServer)
    11. 

  11. [2024-10-28 03:44:38,830] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka/data] Recovering unflushed segment 0. 0/1 recovered for __cluster_metadata-0. (kafka.log.LogLoader)
    12. 

  12. [2024-10-28 03:44:38,831] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
    13. 

  13. [2024-10-28 03:44:38,832] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka/data] Reloading from producer snapshot and rebuilding producer state from offset 0 (kafka.log.UnifiedLog$)
    14. 

  14. [2024-10-28 03:44:38,832] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka/data] Producer state recovery took 0ms for snapshot load and 0ms for segment recovery from offset 0 (kafka.log.UnifiedLog$)
    15. 

  15. [2024-10-28 03:44:38,845] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka/data] Loading producer state till offset 0 with message format version 2 (kafka.log.UnifiedLog$)
    16. 

  16. [2024-10-28 03:44:38,845] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka/data] Reloading from producer snapshot and rebuilding producer state from offset 0 (kafka.log.UnifiedLog$)
    17. 

  17. [2024-10-28 03:44:38,845] INFO [LogLoader partition=__cluster_metadata-0, dir=/opt/kafka/data] Producer state recovery took 0ms for snapshot load and 0ms for segment recovery from offset 0 (kafka.log.UnifiedLog$)
    18. 

  18. [2024-10-28 03:44:38,883] INFO Initialized snapshots with IDs SortedSet() from /opt/kafka/data/__cluster_metadata-0 (kafka.raft.KafkaMetadataLog$)
    19. 

  19. [2024-10-28 03:44:38,911] INFO [raft-expiration-reaper]: Starting (kafka.raft.TimingWheelExpirationService$ExpiredOperationReaper)
    20. 

  20. [2024-10-28 03:44:39,054] ERROR [SharedServer id=1000] Got exception while starting SharedServer (kafka.server.SharedServer)
    21. 

  21. java.lang.IllegalStateException: Configured voter set: [0, 1, 2] is different from the voter set read from the state file: [0]. Check if the quorum configuration is up to date, or wipe out the local state file if necessary
    22. 

  22. 	at org.apache.kafka.raft.QuorumState.initialize(QuorumState.java:132)
    23. 

  23. 	at org.apache.kafka.raft.KafkaRaftClient.initialize(KafkaRaftClient.java:375)
    24. 

  24. 	at kafka.raft.KafkaRaftManager.buildRaftClient(RaftManager.scala:248)
    25. 

  25. 	at kafka.raft.KafkaRaftManager.<init>(RaftManager.scala:174)
    26. 

  26. 	at kafka.server.SharedServer.start(SharedServer.scala:260)
    27. 

  27. 	at kafka.server.SharedServer.startForBroker(SharedServer.scala:122)
    28. 

  28. 	at kafka.server.BrokerServer.startup(BrokerServer.scala:175)
    29. 

  29. 	at kafka.server.KafkaRaftServer.$anonfun$startup$2(KafkaRaftServer.scala:96)
    30. 

  30. 	at kafka.server.KafkaRaftServer.$anonfun$startup$2$adapted(KafkaRaftServer.scala:96)
    31. 

  31. 	at scala.Option.foreach(Option.scala:437)
    32. 

  32. 	at kafka.server.KafkaRaftServer.startup(KafkaRaftServer.scala:96)
    33. 

  33. 	at kafka.Kafka$.main(Kafka.scala:113)
    34. 

  34. 	at kafka.Kafka.main(Kafka.scala)
    35. 

  35. [2024-10-28 03:44:39,056] INFO [BrokerServer id=1000] Starting broker (kafka.server.BrokerServer)
    36. 

  36. [2024-10-28 03:44:39,077] INFO [broker-1000-ThrottledChannelReaper-Fetch]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
    37. 

  37. [2024-10-28 03:44:39,077] INFO [broker-1000-ThrottledChannelReaper-Produce]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
    38. 

  38. [2024-10-28 03:44:39,078] INFO [broker-1000-ThrottledChannelReaper-Request]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
    39. 

  39. [2024-10-28 03:44:39,079] INFO [broker-1000-ThrottledChannelReaper-ControllerMutation]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
    40. 

  40. [2024-10-28 03:44:39,119] INFO [BrokerServer id=1000] Waiting for controller quorum voters future (kafka.server.BrokerServer)
    41. 

  41. [2024-10-28 03:44:39,119] INFO [BrokerServer id=1000] Finished waiting for controller quorum voters future (kafka.server.BrokerServer)
    42. 

  42. [2024-10-28 03:44:39,123] INFO [BrokerServer id=1000] Transition from STARTING to STARTED (kafka.server.BrokerServer)
    43. 

  43. [2024-10-28 03:44:39,125] ERROR [BrokerServer id=1000] Fatal error during broker startup. Prepare to shutdown (kafka.server.BrokerServer)
    44. 

  44. java.lang.NullPointerException: Cannot invoke "kafka.raft.RaftManager.leaderAndEpoch()" because the return value of "kafka.server.RaftControllerNodeProvider.raftManager()" is null
    45. 

  45. 	at kafka.server.RaftControllerNodeProvider.getControllerInfo(BrokerToControllerChannelManager.scala:129)
    46. 

  46. 	at kafka.server.BrokerToControllerChannelManagerImpl.newRequestThread(BrokerToControllerChannelManager.scala:242)
    47. 

  47. 	at kafka.server.BrokerToControllerChannelManagerImpl.<init>(BrokerToControllerChannelManager.scala:184)
    48. 

  48. 	at kafka.server.BrokerServer.startup(BrokerServer.scala:225)
    49. 

  49. 	at kafka.server.KafkaRaftServer.$anonfun$startup$2(KafkaRaftServer.scala:96)
    50. 

  50. 	at kafka.server.KafkaRaftServer.$anonfun$startup$2$adapted(KafkaRaftServer.scala:96)
    51. 

  51. 	at scala.Option.foreach(Option.scala:437)
    52. 

  52. 	at kafka.server.KafkaRaftServer.startup(KafkaRaftServer.scala:96)
    53. 

  53. 	at kafka.Kafka$.main(Kafka.scala:113)
    54. 

  54. 	at kafka.Kafka.main(Kafka.scala)
    55. 

  55. [2024-10-28 03:44:39,126] INFO [BrokerServer id=1000] Transition from STARTED to SHUTTING_DOWN (kafka.server.BrokerServer)
    56. 

  56. [2024-10-28 03:44:39,126] INFO [BrokerServer id=1000] shutting down (kafka.server.BrokerServer)
    57. 

  57. [2024-10-28 03:44:39,130] INFO [BrokerLifecycleManager id=1000] Skipping controlled shutdown because we are in state NOT_RUNNING. (kafka.server.BrokerLifecycleManager)
    58. 

  58. [2024-10-28 03:44:39,131] INFO [BrokerLifecycleManager id=1000] beginShutdown: shutting down event queue. (org.apache.kafka.queue.KafkaEventQueue)
    59. 

  59. [2024-10-28 03:44:39,132] INFO [BrokerLifecycleManager id=1000] Transitioning from NOT_RUNNING to SHUTTING_DOWN. (kafka.server.BrokerLifecycleManager)
    60. 

  60. [2024-10-28 03:44:39,136] INFO Shutting down. (kafka.log.LogManager)
    61. 

  61. [2024-10-28 03:44:42,003] INFO Shutdown complete. (kafka.log.LogManager)
    62. 

  62. [2024-10-28 03:44:42,007] INFO [broker-1000-ThrottledChannelReaper-Fetch]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
    63. 

  63. [2024-10-28 03:44:42,009] INFO [broker-1000-ThrottledChannelReaper-Fetch]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
    64. 

  64. [2024-10-28 03:44:42,009] INFO [broker-1000-ThrottledChannelReaper-Fetch]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
    65. 

  65. [2024-10-28 03:44:42,009] INFO [broker-1000-ThrottledChannelReaper-Produce]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
    66. 

  66. [2024-10-28 03:44:42,009] INFO [broker-1000-ThrottledChannelReaper-Produce]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
    67. 

  67. [2024-10-28 03:44:42,009] INFO [broker-1000-ThrottledChannelReaper-Produce]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
    68. 

  68. [2024-10-28 03:44:42,010] INFO [broker-1000-ThrottledChannelReaper-Request]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
    69. 

  69. [2024-10-28 03:44:42,010] INFO [broker-1000-ThrottledChannelReaper-Request]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
    70. 

  70. [2024-10-28 03:44:42,010] INFO [broker-1000-ThrottledChannelReaper-Request]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
    71. 

  71. [2024-10-28 03:44:42,010] INFO [broker-1000-ThrottledChannelReaper-ControllerMutation]: Shutting down (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
    72. 

  72. [2024-10-28 03:44:42,011] INFO [broker-1000-ThrottledChannelReaper-ControllerMutation]: Stopped (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
    73. 

  73. [2024-10-28 03:44:42,011] INFO [broker-1000-ThrottledChannelReaper-ControllerMutation]: Shutdown completed (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
    74. 

  74. [2024-10-28 03:44:42,017] INFO Broker and topic stats closed (kafka.server.BrokerTopicStats)
    75. 

  75. [2024-10-28 03:44:42,017] INFO [BrokerLifecycleManager id=1000] closed event queue. (org.apache.kafka.queue.KafkaEventQueue)
    76. 

  76. [2024-10-28 03:44:42,018] INFO [BrokerServer id=1000] shut down completed (kafka.server.BrokerServer)
    77. 

  77. [2024-10-28 03:44:42,018] INFO [BrokerServer id=1000] Transition from SHUTTING_DOWN to SHUTDOWN (kafka.server.BrokerServer)
    78. 

  78. [2024-10-28 03:44:42,018] ERROR Exiting Kafka due to fatal exception during startup. (kafka.Kafka$)
    79. 

  79. java.lang.NullPointerException: Cannot invoke "kafka.raft.RaftManager.leaderAndEpoch()" because the return value of "kafka.server.RaftControllerNodeProvider.raftManager()" is null
    80. 

  80. 	at kafka.server.RaftControllerNodeProvider.getControllerInfo(BrokerToControllerChannelManager.scala:129)
    81. 

  81. 	at kafka.server.BrokerToControllerChannelManagerImpl.newRequestThread(BrokerToControllerChannelManager.scala:242)
    82. 

  82. 	at kafka.server.BrokerToControllerChannelManagerImpl.<init>(BrokerToControllerChannelManager.scala:184)
    83. 

  83. 	at kafka.server.BrokerServer.startup(BrokerServer.scala:225)
    84. 

  84. 	at kafka.server.KafkaRaftServer.$anonfun$startup$2(KafkaRaftServer.scala:96)
    85. 

  85. 	at kafka.server.KafkaRaftServer.$anonfun$startup$2$adapted(KafkaRaftServer.scala:96)
    86. 

  86. 	at scala.Option.foreach(Option.scala:437)
    87. 

  87. 	at kafka.server.KafkaRaftServer.startup(KafkaRaftServer.scala:96)
    88. 

  88. 	at kafka.Kafka$.main(Kafka.scala:113)
    89. 

  89. 	at kafka.Kafka.main(Kafka.scala)
    90. 

  90. [2024-10-28 03:44:42,023] INFO App info kafka.server for 1000 unregistered (org.apache.kafka.common.utils.AppInfoParser)
    91.