[2013-09-18 11:29:16,042] INFO Verifying properties (kafka.utils.VerifiableProperties:67) [2013-09-18 11:29:16,043] INFO Property broker.id is overridden to 0 (kafka.utils.VerifiableProperties:67) [2013-09-18 11:29:16,044] INFO Property log.dirs is overridden to logDir (kafka.utils.VerifiableProperties:67) [2013-09-18 11:29:16,045] INFO Property zookeeper.connect is overridden to 127.0.01:2181 (kafka.utils.VerifiableProperties:67) [2013-09-18 11:29:16,055] INFO [Kafka Server 0], Starting (kafka.server.KafkaServer:67) [2013-09-18 11:29:16,084] INFO [Log Manager on Broker 0] Starting log cleaner every 600000 ms (kafka.log.LogManager:67) [2013-09-18 11:29:16,092] INFO [Log Manager on Broker 0] Starting log flusher every 3000 ms with the following overrides Map() (kafka.log.LogManager:67) [2013-09-18 11:29:16,132] INFO Awaiting socket connections on 0.0.0.0:6667. (kafka.network.Acceptor:67) [2013-09-18 11:29:16,134] INFO [Socket Server on Broker 0], Started (kafka.network.SocketServer:67) [2013-09-18 11:29:16,145] INFO connecting to ZK: 127.0.01:2181 (kafka.server.KafkaZooKeeper:67) [2013-09-18 11:29:16,208] INFO Registered broker 0 at path /brokers/ids/0 with address 172.19.217.206:6667. (kafka.utils.ZkUtils$:67) [2013-09-18 11:29:16,209] INFO [Kafka Server 0], Connecting to ZK: 127.0.01:2181 (kafka.server.KafkaServer:67) [2013-09-18 11:29:16,337] INFO Will not load MX4J, mx4j-tools.jar is not in the classpath (kafka.utils.Mx4jLoader$:67) [2013-09-18 11:29:16,339] INFO [Controller 0]: Controller starting up (kafka.controller.KafkaController:67) [2013-09-18 11:29:16,347] INFO 0 successfully elected as leader (kafka.server.ZookeeperLeaderElector:67) [2013-09-18 11:29:16,349] INFO [Controller 0]: Broker 0 starting become controller state transition (kafka.controller.KafkaController:67) [2013-09-18 11:29:16,357] INFO [Controller 0]: Controller 0 incremented epoch to 1 (kafka.controller.KafkaController:67) [2013-09-18 11:29:16,494] INFO [Controller-0-to-broker-0-send-thread], Starting (kafka.controller.RequestSendThread:67) [2013-09-18 11:29:16,497] INFO [Controller 0]: Currently active brokers in the cluster: Set(0) (kafka.controller.KafkaController:67) [2013-09-18 11:29:16,499] INFO [Controller 0]: Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController:67) [2013-09-18 11:29:16,500] INFO [Controller 0]: Current list of topics in the cluster: Set() (kafka.controller.KafkaController:67) [2013-09-18 11:29:16,504] INFO [Replica state machine on controller 0]: No state transitions triggered since no partitions are assigned to brokers 0 (kafka.controller.ReplicaStateMachine:67) [2013-09-18 11:29:16,507] INFO [Replica state machine on controller 0]: Invoking state change to OnlineReplica for replicas (kafka.controller.ReplicaStateMachine:67) [2013-09-18 11:29:16,512] INFO [Replica state machine on controller 0]: Started replica state machine with initial state -> Map() (kafka.controller.ReplicaStateMachine:67) [2013-09-18 11:29:16,515] INFO [Partition state machine on Controller 0]: Started partition state machine with initial state -> Map() (kafka.controller.PartitionStateMachine:67) [2013-09-18 11:29:16,518] INFO [Controller 0]: Broker 0 is ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController:67) [2013-09-18 11:29:16,522] INFO [Controller 0]: Partitions being reassigned: Map() (kafka.controller.KafkaController:67) [2013-09-18 11:29:16,523] INFO [Controller 0]: Partitions already reassigned: List() (kafka.controller.KafkaController:67) [2013-09-18 11:29:16,524] INFO [Controller 0]: Resuming reassignment of partitions: Map() (kafka.controller.KafkaController:67) [2013-09-18 11:29:16,527] INFO [Controller 0]: Partitions undergoing preferred replica election: (kafka.controller.KafkaController:67) [2013-09-18 11:29:16,529] INFO [Controller 0]: Partitions that completed preferred replica election: (kafka.controller.KafkaController:67) [2013-09-18 11:29:16,530] INFO [Controller 0]: Resuming preferred replica election for partitions: (kafka.controller.KafkaController:67) [2013-09-18 11:29:16,533] INFO [Controller 0]: Starting preferred replica leader election for partitions (kafka.controller.KafkaController:67) [2013-09-18 11:29:16,537] INFO [Partition state machine on Controller 0]: Invoking state change to OnlinePartition for partitions (kafka.controller.PartitionStateMachine:67) [2013-09-18 11:29:16,544] INFO [Controller 0]: Controller startup complete (kafka.controller.KafkaController:67) [2013-09-18 11:29:16,558] INFO New leader is 0 (kafka.server.ZookeeperLeaderElector$LeaderChangeListener:67) [2013-09-18 11:29:16,563] INFO [ControllerEpochListener on 0]: Initialized controller epoch to 1 and zk version 0 (kafka.controller.ControllerEpochListener:67) [2013-09-18 11:29:16,564] INFO [Kafka Server 0], Started (kafka.server.KafkaServer:67) [2013-09-18 11:29:16,565] INFO [Kafka Server 0], Shutting down (kafka.server.KafkaServer:67) [2013-09-18 11:29:16,568] INFO Closing zookeeper client... (kafka.server.KafkaZooKeeper:67) [2013-09-18 11:29:16,572] INFO [Socket Server on Broker 0], Shutting down (kafka.network.SocketServer:67) [2013-09-18 11:29:16,589] INFO [Socket Server on Broker 0], Shutdown completed (kafka.network.SocketServer:67) [2013-09-18 11:29:16,590] INFO [Kafka Request Handler on Broker 0], shutting down (kafka.server.KafkaRequestHandlerPool:67) [2013-09-18 11:29:16,619] INFO [Kafka Request Handler on Broker 0], shutted down completely (kafka.server.KafkaRequestHandlerPool:67) [2013-09-18 11:29:16,625] INFO Shutdown Kafka scheduler (kafka.utils.KafkaScheduler:67) [2013-09-18 11:29:16,930] INFO [Replica Manager on Broker 0]: Shut down (kafka.server.ReplicaManager:67) [2013-09-18 11:29:16,932] INFO [ReplicaFetcherManager on broker 0] shutting down (kafka.server.ReplicaFetcherManager:67) [2013-09-18 11:29:16,934] INFO [ReplicaFetcherManager on broker 0] shutdown completed (kafka.server.ReplicaFetcherManager:67) [2013-09-18 11:29:16,941] INFO [Replica Manager on Broker 0]: Shutted down completely (kafka.server.ReplicaManager:67) [2013-09-18 11:29:16,957] INFO [Controller-0-to-broker-0-send-thread], Shutting down (kafka.controller.RequestSendThread:67) [2013-09-18 11:29:16,958] INFO [Controller-0-to-broker-0-send-thread], Stopped (kafka.controller.RequestSendThread:67) [2013-09-18 11:29:16,959] INFO [Controller-0-to-broker-0-send-thread], Shutdown completed (kafka.controller.RequestSendThread:67) [2013-09-18 11:29:16,960] INFO [Controller 0]: Controller shutdown complete (kafka.controller.KafkaController:67) [2013-09-18 11:29:16,961] INFO [Kafka Server 0], Shut down completed (kafka.server.KafkaServer:67) [info] Test Starting: testSingleServerStartup(kafka.server.ServerShutdownTest) [info] Test Passed: testSingleServerStartup(kafka.server.ServerShutdownTest) [info] Passed: : Total 1, Failed 0, Errors 0, Passed 1, Skipped 0