[2016-04-14 17:01:01,708] DEBUG preRegister called. Server=com.sun.jmx.mbeanserver.JmxMBeanServer@66d3c617, name=log4j:logger=kafka.controller (kafka.controller) [2016-04-14 17:01:12,360] INFO [Controller 0]: Controller starting up (kafka.controller.KafkaController) [2016-04-14 17:01:12,407] INFO [Controller 0]: Broker 0 starting become controller state transition (kafka.controller.KafkaController) [2016-04-14 17:01:12,414] INFO [Controller 0]: Initialized controller epoch to 1 and zk version 0 (kafka.controller.KafkaController) [2016-04-14 17:01:12,422] INFO [Controller 0]: Controller 0 incremented epoch to 2 (kafka.controller.KafkaController) [2016-04-14 17:01:12,424] DEBUG [Controller 0]: Registering IsrChangeNotificationListener (kafka.controller.KafkaController) [2016-04-14 17:01:12,483] INFO [Controller 0]: Partitions undergoing preferred replica election: (kafka.controller.KafkaController) [2016-04-14 17:01:12,484] INFO [Controller 0]: Partitions that completed preferred replica election: (kafka.controller.KafkaController) [2016-04-14 17:01:12,485] INFO [Controller 0]: Resuming preferred replica election for partitions: (kafka.controller.KafkaController) [2016-04-14 17:01:12,489] INFO [Controller 0]: Partitions being reassigned: Map() (kafka.controller.KafkaController) [2016-04-14 17:01:12,489] INFO [Controller 0]: Partitions already reassigned: List() (kafka.controller.KafkaController) [2016-04-14 17:01:12,491] INFO [Controller 0]: Resuming reassignment of partitions: Map() (kafka.controller.KafkaController) [2016-04-14 17:01:12,496] INFO [Controller 0]: List of topics to be deleted: (kafka.controller.KafkaController) [2016-04-14 17:01:12,497] INFO [Controller 0]: List of topics ineligible for deletion: test (kafka.controller.KafkaController) [2016-04-14 17:01:12,500] INFO [Controller 0]: Currently active brokers in the cluster: Set() (kafka.controller.KafkaController) [2016-04-14 17:01:12,501] INFO [Controller 0]: Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController) [2016-04-14 17:01:12,501] INFO [Controller 0]: Current list of topics in the cluster: Set(test) (kafka.controller.KafkaController) [2016-04-14 17:01:12,509] INFO [Replica state machine on controller 0]: Started replica state machine with initial state -> Map([Topic=test,Partition=0,Replica=0] -> ReplicaDeletionIneligible) (kafka.controller.ReplicaStateMachine) [2016-04-14 17:01:12,529] DEBUG [OfflinePartitionLeaderSelector]: No broker in ISR is alive for [test,0]. Pick the leader from the alive assigned replicas: (kafka.controller.OfflinePartitionLeaderSelector) [2016-04-14 17:01:12,542] INFO [Partition state machine on Controller 0]: Started partition state machine with initial state -> Map([test,0] -> OfflinePartition) (kafka.controller.PartitionStateMachine) [2016-04-14 17:01:12,545] INFO [Controller 0]: Broker 0 is ready to serve as the new controller with epoch 2 (kafka.controller.KafkaController) [2016-04-14 17:01:12,547] INFO [Controller 0]: Starting preferred replica leader election for partitions (kafka.controller.KafkaController) [2016-04-14 17:01:12,548] INFO [Partition state machine on Controller 0]: Invoking state change to OnlinePartition for partitions (kafka.controller.PartitionStateMachine) [2016-04-14 17:01:12,559] INFO [Controller 0]: starting the partition rebalance scheduler (kafka.controller.KafkaController) [2016-04-14 17:01:12,561] INFO [Controller 0]: Controller startup complete (kafka.controller.KafkaController) [2016-04-14 17:01:12,646] INFO [BrokerChangeListener on Controller 0]: Broker change listener fired for path /brokers/ids with children 0 (kafka.controller.ReplicaStateMachine$BrokerChangeListener) [2016-04-14 17:01:12,685] INFO [BrokerChangeListener on Controller 0]: Newly added brokers: 0, deleted brokers: , all live brokers: 0 (kafka.controller.ReplicaStateMachine$BrokerChangeListener) [2016-04-14 17:01:12,686] DEBUG [Channel manager on controller 0]: Controller 0 trying to connect to broker 0 (kafka.controller.ControllerChannelManager) [2016-04-14 17:01:12,707] INFO [Controller-0-to-broker-0-send-thread], Starting (kafka.controller.RequestSendThread) [2016-04-14 17:01:12,708] INFO [Controller 0]: New broker startup callback for 0 (kafka.controller.KafkaController) [2016-04-14 17:01:12,741] INFO [Replica state machine on controller 0]: Invoking state change to OnlineReplica for replicas [Topic=test,Partition=0,Replica=0] (kafka.controller.ReplicaStateMachine) [2016-04-14 17:01:12,763] DEBUG [OfflinePartitionLeaderSelector]: Some broker in ISR is alive for [test,0]. Select 0 from ISR 0 to be the leader. (kafka.controller.OfflinePartitionLeaderSelector) [2016-04-14 17:01:12,764] INFO [OfflinePartitionLeaderSelector]: Selected new leader and ISR {"leader":0,"leader_epoch":1,"isr":[0]} for offline partition [test,0] (kafka.controller.OfflinePartitionLeaderSelector) [2016-04-14 17:01:12,772] DEBUG [Partition state machine on Controller 0]: After leader election, leader cache is updated to Map([test,0] -> (Leader:0,ISR:0,LeaderEpoch:1,ControllerEpoch:2)) (kafka.controller.PartitionStateMachine) [2016-04-14 17:01:17,567] TRACE [Controller 0]: checking need to trigger partition rebalance (kafka.controller.KafkaController) [2016-04-14 17:01:17,572] DEBUG [Controller 0]: preferred replicas by broker Map(0 -> Map([test,0] -> List(0))) (kafka.controller.KafkaController) [2016-04-14 17:01:17,575] DEBUG [Controller 0]: topics not in preferred replica Map() (kafka.controller.KafkaController) [2016-04-14 17:01:17,576] TRACE [Controller 0]: leader imbalance ratio for broker 0 is 0.000000 (kafka.controller.KafkaController) [2016-04-14 17:01:42,752] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker Node(0, srvs010.ac.aixigo.de, 9092) was unsuccessful (kafka.controller.RequestSendThread) java.net.SocketTimeoutException: Failed to connect within 30000 ms at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:228) at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:172) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:171) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) [2016-04-14 17:02:13,056] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker Node(0, srvs010.ac.aixigo.de, 9092) was unsuccessful (kafka.controller.RequestSendThread) java.net.SocketTimeoutException: Failed to connect within 30000 ms at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:228) at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:172) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:171) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) [2016-04-14 17:02:43,358] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker Node(0, srvs010.ac.aixigo.de, 9092) was unsuccessful (kafka.controller.RequestSendThread) java.net.SocketTimeoutException: Failed to connect within 30000 ms at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:228) at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:172) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:171) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) [2016-04-14 17:03:13,659] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker Node(0, srvs010.ac.aixigo.de, 9092) was unsuccessful (kafka.controller.RequestSendThread) java.net.SocketTimeoutException: Failed to connect within 30000 ms at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:228) at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:172) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:171) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) [2016-04-14 17:03:43,961] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker Node(0, srvs010.ac.aixigo.de, 9092) was unsuccessful (kafka.controller.RequestSendThread) java.net.SocketTimeoutException: Failed to connect within 30000 ms at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:228) at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:172) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:171) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) [2016-04-14 17:04:14,264] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker Node(0, srvs010.ac.aixigo.de, 9092) was unsuccessful (kafka.controller.RequestSendThread) java.net.SocketTimeoutException: Failed to connect within 30000 ms at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:228) at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:172) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:171) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) [2016-04-14 17:04:44,566] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker Node(0, srvs010.ac.aixigo.de, 9092) was unsuccessful (kafka.controller.RequestSendThread) java.net.SocketTimeoutException: Failed to connect within 30000 ms at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:228) at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:172) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:171) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) [2016-04-14 17:05:14,868] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker Node(0, srvs010.ac.aixigo.de, 9092) was unsuccessful (kafka.controller.RequestSendThread) java.net.SocketTimeoutException: Failed to connect within 30000 ms at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:228) at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:172) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:171) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) [2016-04-14 17:05:45,171] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker Node(0, srvs010.ac.aixigo.de, 9092) was unsuccessful (kafka.controller.RequestSendThread) java.net.SocketTimeoutException: Failed to connect within 30000 ms at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:228) at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:172) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:171) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) [2016-04-14 17:06:15,473] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker Node(0, srvs010.ac.aixigo.de, 9092) was unsuccessful (kafka.controller.RequestSendThread) java.net.SocketTimeoutException: Failed to connect within 30000 ms at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:228) at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:172) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:171) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) [2016-04-14 17:06:17,568] TRACE [Controller 0]: checking need to trigger partition rebalance (kafka.controller.KafkaController) [2016-04-14 17:06:17,568] DEBUG [Controller 0]: preferred replicas by broker Map(0 -> Map([test,0] -> List(0))) (kafka.controller.KafkaController) [2016-04-14 17:06:17,568] DEBUG [Controller 0]: topics not in preferred replica Map() (kafka.controller.KafkaController) [2016-04-14 17:06:17,568] TRACE [Controller 0]: leader imbalance ratio for broker 0 is 0.000000 (kafka.controller.KafkaController) [2016-04-14 17:06:45,775] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker Node(0, srvs010.ac.aixigo.de, 9092) was unsuccessful (kafka.controller.RequestSendThread) java.net.SocketTimeoutException: Failed to connect within 30000 ms at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:228) at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:172) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:171) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) [2016-04-14 17:07:12,721] DEBUG [Controller 0]: Controller resigning, broker id 0 (kafka.controller.KafkaController) [2016-04-14 17:07:12,722] DEBUG [Controller 0]: De-registering IsrChangeNotificationListener (kafka.controller.KafkaController) [2016-04-14 17:07:12,725] INFO [Partition state machine on Controller 0]: Stopped partition state machine (kafka.controller.PartitionStateMachine) [2016-04-14 17:07:12,725] INFO [Replica state machine on controller 0]: Stopped replica state machine (kafka.controller.ReplicaStateMachine) [2016-04-14 17:07:12,727] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker Node(0, srvs010.ac.aixigo.de, 9092) was unsuccessful (kafka.controller.RequestSendThread) java.nio.channels.ClosedSelectorException at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:83) at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) at org.apache.kafka.common.network.Selector.select(Selector.java:425) at org.apache.kafka.common.network.Selector.poll(Selector.java:254) at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:256) at kafka.utils.NetworkClientBlockingOps$.recurse$1(NetworkClientBlockingOps.scala:128) at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntilFound$extension(NetworkClientBlockingOps.scala:139) at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:105) at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:58) at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:225) at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:172) at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:171) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) [2016-04-14 17:07:12,728] INFO [Controller-0-to-broker-0-send-thread], Shutting down (kafka.controller.RequestSendThread) [2016-04-14 17:07:12,728] INFO [Controller-0-to-broker-0-send-thread], Stopped (kafka.controller.RequestSendThread) [2016-04-14 17:07:12,728] INFO [Controller-0-to-broker-0-send-thread], Shutdown completed (kafka.controller.RequestSendThread) [2016-04-14 17:07:12,729] INFO [Controller 0]: Broker 0 resigned as the controller (kafka.controller.KafkaController)