Created
May 28, 2017 05:47
-
-
Save Noel-bk/d0fca2ccc6b0b9d2e7176916ac5f276b to your computer and use it in GitHub Desktop.
kafka log4j_output
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| [2017-05-28 14:45:10,181] INFO [Controller 0]: Controller starting up (kafka.controller.KafkaController) | |
| [2017-05-28 14:45:10,215] INFO [Controller 0]: Broker 0 starting become controller state transition (kafka.controller.KafkaController) | |
| [2017-05-28 14:45:10,219] INFO [Controller 0]: Controller 0 incremented epoch to 1 (kafka.controller.KafkaController) | |
| [2017-05-28 14:45:10,220] DEBUG [Controller 0]: Registering IsrChangeNotificationListener (kafka.controller.KafkaController) | |
| [2017-05-28 14:45:10,234] INFO [Controller 0]: Partitions undergoing preferred replica election: (kafka.controller.KafkaController) | |
| [2017-05-28 14:45:10,234] INFO [Controller 0]: Partitions that completed preferred replica election: (kafka.controller.KafkaController) | |
| [2017-05-28 14:45:10,234] INFO [Controller 0]: Resuming preferred replica election for partitions: (kafka.controller.KafkaController) | |
| [2017-05-28 14:45:10,236] INFO [Controller 0]: Partitions being reassigned: Map() (kafka.controller.KafkaController) | |
| [2017-05-28 14:45:10,237] INFO [Controller 0]: Partitions already reassigned: List() (kafka.controller.KafkaController) | |
| [2017-05-28 14:45:10,237] INFO [Controller 0]: Resuming reassignment of partitions: Map() (kafka.controller.KafkaController) | |
| [2017-05-28 14:45:10,239] INFO [Controller 0]: List of topics to be deleted: (kafka.controller.KafkaController) | |
| [2017-05-28 14:45:10,240] INFO [Controller 0]: List of topics ineligible for deletion: (kafka.controller.KafkaController) | |
| [2017-05-28 14:45:10,242] INFO [Controller 0]: Currently active brokers in the cluster: Set() (kafka.controller.KafkaController) | |
| [2017-05-28 14:45:10,243] INFO [Controller 0]: Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController) | |
| [2017-05-28 14:45:10,243] INFO [Controller 0]: Current list of topics in the cluster: Set() (kafka.controller.KafkaController) | |
| [2017-05-28 14:45:10,245] INFO [Replica state machine on controller 0]: Started replica state machine with initial state -> Map() (kafka.controller.ReplicaStateMachine) | |
| [2017-05-28 14:45:10,251] INFO [Partition state machine on Controller 0]: Started partition state machine with initial state -> Map() (kafka.controller.PartitionStateMachine) | |
| [2017-05-28 14:45:10,252] INFO [Controller 0]: Broker 0 is ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController) | |
| [2017-05-28 14:45:10,253] INFO [Controller 0]: Starting preferred replica leader election for partitions (kafka.controller.KafkaController) | |
| [2017-05-28 14:45:10,254] INFO [Partition state machine on Controller 0]: Invoking state change to OnlinePartition for partitions (kafka.controller.PartitionStateMachine) | |
| [2017-05-28 14:45:10,257] INFO [Controller 0]: starting the partition rebalance scheduler (kafka.controller.KafkaController) | |
| [2017-05-28 14:45:10,258] INFO [Controller 0]: Controller startup complete (kafka.controller.KafkaController) | |
| [2017-05-28 14:45:10,336] INFO [BrokerChangeListener on Controller 0]: Broker change listener fired for path /brokers/ids with children 0 (kafka.controller.ReplicaStateMachine$BrokerChangeListener) | |
| [2017-05-28 14:45:10,359] INFO [BrokerChangeListener on Controller 0]: Newly added brokers: 0, deleted brokers: , all live brokers: 0 (kafka.controller.ReplicaStateMachine$BrokerChangeListener) | |
| [2017-05-28 14:45:10,360] DEBUG [Channel manager on controller 0]: Controller 0 trying to connect to broker 0 (kafka.controller.ControllerChannelManager) | |
| [2017-05-28 14:45:10,368] INFO [Controller-0-to-broker-0-send-thread], Starting (kafka.controller.RequestSendThread) | |
| [2017-05-28 14:45:10,368] INFO [Controller 0]: New broker startup callback for 0 (kafka.controller.KafkaController) | |
| [2017-05-28 14:45:11,398] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:11,709] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:12,020] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:12,327] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:12,635] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:12,944] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:13,254] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:13,565] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:13,876] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:14,188] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:14,497] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:14,809] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:15,122] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:15,263] TRACE [Controller 0]: checking need to trigger partition rebalance (kafka.controller.KafkaController) | |
| [2017-05-28 14:45:15,264] DEBUG [Controller 0]: preferred replicas by broker Map() (kafka.controller.KafkaController) | |
| [2017-05-28 14:45:15,432] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:15,741] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:16,052] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:16,365] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:16,676] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:16,983] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:17,291] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:17,603] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:17,913] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:18,227] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:18,535] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:18,844] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:19,156] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:19,466] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:19,779] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:20,089] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:20,397] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:20,706] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:21,018] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:21,326] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:21,637] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:21,946] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:22,254] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:22,566] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:22,819] DEBUG [TopicChangeListener on Controller 0]: Topic change listener fired for path /brokers/topics with children hello-events (kafka.controller.PartitionStateMachine$TopicChangeListener) | |
| [2017-05-28 14:45:22,825] INFO [TopicChangeListener on Controller 0]: New topics: [Set(hello-events)], deleted topics: [Set()], new partition replica assignment [Map([hello-events,0] -> List(0))] (kafka.controller.PartitionStateMachine$TopicChangeListener) | |
| [2017-05-28 14:45:22,826] INFO [Controller 0]: New topic creation callback for [hello-events,0] (kafka.controller.KafkaController) | |
| [2017-05-28 14:45:22,828] INFO [Controller 0]: New partition creation callback for [hello-events,0] (kafka.controller.KafkaController) | |
| [2017-05-28 14:45:22,829] INFO [Partition state machine on Controller 0]: Invoking state change to NewPartition for partitions [hello-events,0] (kafka.controller.PartitionStateMachine) | |
| [2017-05-28 14:45:22,832] INFO [Replica state machine on controller 0]: Invoking state change to NewReplica for replicas [Topic=hello-events,Partition=0,Replica=0] (kafka.controller.ReplicaStateMachine) | |
| [2017-05-28 14:45:22,851] INFO [Partition state machine on Controller 0]: Invoking state change to OnlinePartition for partitions [hello-events,0] (kafka.controller.PartitionStateMachine) | |
| [2017-05-28 14:45:22,852] DEBUG [Partition state machine on Controller 0]: Live assigned replicas for partition [hello-events,0] are: [List(0)] (kafka.controller.PartitionStateMachine) | |
| [2017-05-28 14:45:22,854] DEBUG [Partition state machine on Controller 0]: Initializing leader and isr for partition [hello-events,0] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1) (kafka.controller.PartitionStateMachine) | |
| [2017-05-28 14:45:22,875] INFO [Replica state machine on controller 0]: Invoking state change to OnlineReplica for replicas [Topic=hello-events,Partition=0,Replica=0] (kafka.controller.ReplicaStateMachine) | |
| [2017-05-28 14:45:22,877] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:22,896] DEBUG [TopicChangeListener on Controller 0]: Topic change listener fired for path /brokers/topics with children __consumer_offsets,hello-events (kafka.controller.PartitionStateMachine$TopicChangeListener) | |
| [2017-05-28 14:45:22,900] INFO [TopicChangeListener on Controller 0]: New topics: [Set(__consumer_offsets)], deleted topics: [Set()], new partition replica assignment [Map([__consumer_offsets,0] -> List(0))] (kafka.controller.PartitionStateMachine$TopicChangeListener) | |
| [2017-05-28 14:45:22,900] INFO [Controller 0]: New topic creation callback for [__consumer_offsets,0] (kafka.controller.KafkaController) | |
| [2017-05-28 14:45:22,901] INFO [Controller 0]: New partition creation callback for [__consumer_offsets,0] (kafka.controller.KafkaController) | |
| [2017-05-28 14:45:22,901] INFO [Partition state machine on Controller 0]: Invoking state change to NewPartition for partitions [__consumer_offsets,0] (kafka.controller.PartitionStateMachine) | |
| [2017-05-28 14:45:22,901] INFO [Replica state machine on controller 0]: Invoking state change to NewReplica for replicas [Topic=__consumer_offsets,Partition=0,Replica=0] (kafka.controller.ReplicaStateMachine) | |
| [2017-05-28 14:45:22,902] INFO [Partition state machine on Controller 0]: Invoking state change to OnlinePartition for partitions [__consumer_offsets,0] (kafka.controller.PartitionStateMachine) | |
| [2017-05-28 14:45:22,903] DEBUG [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,0] are: [List(0)] (kafka.controller.PartitionStateMachine) | |
| [2017-05-28 14:45:22,903] DEBUG [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,0] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1) (kafka.controller.PartitionStateMachine) | |
| [2017-05-28 14:45:22,910] INFO [Replica state machine on controller 0]: Invoking state change to OnlineReplica for replicas [Topic=__consumer_offsets,Partition=0,Replica=0] (kafka.controller.ReplicaStateMachine) | |
| [2017-05-28 14:45:23,186] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:23,492] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:23,804] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:24,113] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:24,422] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:24,735] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:25,048] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:25,357] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:25,669] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:25,981] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:26,293] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:26,602] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:26,909] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:27,218] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:27,527] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:27,837] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:28,146] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:28,453] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:28,763] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:29,074] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:29,385] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:29,697] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:30,011] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:30,319] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:30,632] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:30,945] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:31,256] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:31,569] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:31,881] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:32,192] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:32,500] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:32,810] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:33,120] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:33,430] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:33,742] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:34,053] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:34,364] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:34,672] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:34,980] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:35,289] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:35,602] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:35,913] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:36,222] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:36,531] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:36,843] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:37,151] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:37,463] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) | |
| [2017-05-28 14:45:37,772] WARN [Controller-0-to-broker-0-send-thread], Controller 0's connection to broker 218.38.137.28:9092 (id: 0 rack: null) was unsuccessful (kafka.controller.RequestSendThread) | |
| java.io.IOException: Connection to 218.38.137.28:9092 (id: 0 rack: null) failed | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63) | |
| at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59) | |
| at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112) | |
| at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120) | |
| at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59) | |
| at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:233) | |
| at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:182) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:181) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment