Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-2319

After controlled shutdown: IllegalStateException: Kafka scheduler has not been started

    Details

    • Type: Bug
    • Status: Reopened
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: 1.0.1
    • Fix Version/s: None
    • Component/s: None
    • Labels:
      None

      Description

      Running 0.8.2.1, just saw this today at the end of a controlled shutdown. It doesn't happen every time, but I've seen it several times:

      2015-07-07 18:54:28,424  INFO [Thread-4] server.KafkaServer - [Kafka Server 99], Controlled shutdown succeeded
      2015-07-07 18:54:28,425  INFO [Thread-4] network.SocketServer - [Socket Server on Broker 99], Shutting down
      2015-07-07 18:54:28,435  INFO [Thread-4] network.SocketServer - [Socket Server on Broker 99], Shutdown completed
      2015-07-07 18:54:28,435  INFO [Thread-4] server.KafkaRequestHandlerPool - [Kafka Request Handler on Broker 99], shutting down
      2015-07-07 18:54:28,444  INFO [Thread-4] server.KafkaRequestHandlerPool - [Kafka Request Handler on Broker 99], shut down completely
      2015-07-07 18:54:28,649  INFO [Thread-4] server.ReplicaManager - [Replica Manager on Broker 99]: Shut down
      2015-07-07 18:54:28,649  INFO [Thread-4] server.ReplicaFetcherManager - [ReplicaFetcherManager on broker 99] shutting down
      2015-07-07 18:54:28,650  INFO [Thread-4] server.ReplicaFetcherThread - [ReplicaFetcherThread-0-95], Shutting down
      2015-07-07 18:54:28,750  INFO [Thread-4] server.ReplicaFetcherThread - [ReplicaFetcherThread-0-95], Shutdown completed
      2015-07-07 18:54:28,750  INFO [ReplicaFetcherThread-0-95] server.ReplicaFetcherThread - [ReplicaFetcherThread-0-95], Stopped
      2015-07-07 18:54:28,750  INFO [Thread-4] server.ReplicaFetcherThread - [ReplicaFetcherThread-0-98], Shutting down
      2015-07-07 18:54:28,791  INFO [Thread-4] server.ReplicaFetcherThread - [ReplicaFetcherThread-0-98], Shutdown completed
      2015-07-07 18:54:28,791  INFO [ReplicaFetcherThread-0-98] server.ReplicaFetcherThread - [ReplicaFetcherThread-0-98], Stopped
      2015-07-07 18:54:28,791  INFO [Thread-4] server.ReplicaFetcherManager - [ReplicaFetcherManager on broker 99] shutdown completed
      2015-07-07 18:54:28,819  INFO [Thread-4] server.ReplicaManager - [Replica Manager on Broker 99]: Shut down completely
      2015-07-07 18:54:28,826  INFO [Thread-4] log.LogManager - Shutting down.
      2015-07-07 18:54:30,459  INFO [Thread-4] log.LogManager - Shutdown complete.
      2015-07-07 18:54:30,463  WARN [Thread-4] utils.Utils$ - Kafka scheduler has not been started
      java.lang.IllegalStateException: Kafka scheduler has not been started
              at kafka.utils.KafkaScheduler.ensureStarted(KafkaScheduler.scala:114)
              at kafka.utils.KafkaScheduler.shutdown(KafkaScheduler.scala:86)
              at kafka.controller.KafkaController.onControllerResignation(KafkaController.scala:350)
              at kafka.controller.KafkaController.shutdown(KafkaController.scala:664)
              at kafka.server.KafkaServer$$anonfun$shutdown$8.apply$mcV$sp(KafkaServer.scala:285)
              at kafka.utils.Utils$.swallow(Utils.scala:172)
              at kafka.utils.Logging$class.swallowWarn(Logging.scala:92)
              at kafka.utils.Utils$.swallowWarn(Utils.scala:45)
              at kafka.utils.Logging$class.swallow(Logging.scala:94)
              at kafka.utils.Utils$.swallow(Utils.scala:45)
              at kafka.server.KafkaServer.shutdown(KafkaServer.scala:285)
       ...
      

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              jbrosenberg@gmail.com Jason Rosenberg
            • Votes:
              1 Vote for this issue
              Watchers:
              7 Start watching this issue

              Dates

              • Created:
                Updated: