Advertisement
Guest User

Untitled

a guest
May 10th, 2017
221
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  1. kafka_1      | [2017-05-10 10:42:00,411] INFO Opening socket connection to server localhost/0:0:0:0:0:0:0:1:32181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn)
  2. kafka_1      | [2017-05-10 10:42:00,412] INFO Waiting for keeper state SyncConnected (org.I0Itec.zkclient.ZkClient)
  3. zookeeper_1  | [2017-05-10 10:42:00,450] INFO Accepted socket connection from /0:0:0:0:0:0:0:1:34642 (org.apache.zookeeper.server.NIOServerCnxnFactory)
  4. kafka_1      | [2017-05-10 10:42:00,450] INFO Socket connection established to localhost/0:0:0:0:0:0:0:1:32181, initiating session (org.apache.zookeeper.ClientCnxn)
  5. zookeeper_1  | [2017-05-10 10:42:00,455] INFO Client attempting to establish new session at /0:0:0:0:0:0:0:1:34642 (org.apache.zookeeper.server.ZooKeeperServer)
  6. zookeeper_1  | [2017-05-10 10:42:00,461] INFO Established session 0x15bf1f382780001 with negotiated timeout 6000 for client /0:0:0:0:0:0:0:1:34642 (org.apache.zookeeper.server.ZooKeeperServer)
  7. kafka_1      | [2017-05-10 10:42:00,463] INFO Session establishment complete on server localhost/0:0:0:0:0:0:0:1:32181, sessionid = 0x15bf1f382780001, negotiated timeout = 6000 (org.apache.zookeeper.ClientCnxn)
  8. kafka_1      | [2017-05-10 10:42:00,464] INFO zookeeper state changed (SyncConnected) (org.I0Itec.zkclient.ZkClient)
  9. zookeeper_1  | [2017-05-10 10:42:00,494] INFO Got user-level KeeperException when processing sessionid:0x15bf1f382780001 type:create cxid:0x5 zxid:0x5 txntype:-1 reqpath:n/a Error Path:/brokers Error:KeeperErrorCode = NoNode for /brokers (org.apache.zookeeper.server.PrepRequestProcessor)
  10. zookeeper_1  | [2017-05-10 10:42:00,525] INFO Got user-level KeeperException when processing sessionid:0x15bf1f382780001 type:create cxid:0xb zxid:0x9 txntype:-1 reqpath:n/a Error Path:/config Error:KeeperErrorCode = NoNode for /config (org.apache.zookeeper.server.PrepRequestProcessor)
  11. zookeeper_1  | [2017-05-10 10:42:00,552] INFO Got user-level KeeperException when processing sessionid:0x15bf1f382780001 type:create cxid:0x13 zxid:0xe txntype:-1 reqpath:n/a Error Path:/admin Error:KeeperErrorCode = NoNode for /admin (org.apache.zookeeper.server.PrepRequestProcessor)
  12. zookeeper_1  | [2017-05-10 10:42:00,609] INFO Got user-level KeeperException when processing sessionid:0x15bf1f382780001 type:create cxid:0x1b zxid:0x13 txntype:-1 reqpath:n/a Error Path:/cluster Error:KeeperErrorCode = NoNode for /cluster (org.apache.zookeeper.server.PrepRequestProcessor)
  13. kafka_1      | [2017-05-10 10:42:00,628] INFO Cluster ID = PrMjnXLeQ9mz0FrNSYVRyQ (kafka.server.KafkaServer)
  14. kafka_1      | [2017-05-10 10:42:00,633] WARN No meta.properties file under dir /var/lib/kafka/data/meta.properties (kafka.server.BrokerMetadataCheckpoint)
  15. kafka_1      | [2017-05-10 10:42:00,644] INFO [ThrottledRequestReaper-Fetch], Starting  (kafka.server.ClientQuotaManager$ThrottledRequestReaper)
  16. kafka_1      | [2017-05-10 10:42:00,646] INFO [ThrottledRequestReaper-Produce], Starting  (kafka.server.ClientQuotaManager$ThrottledRequestReaper)
  17. kafka_1      | [2017-05-10 10:42:00,672] INFO Loading logs. (kafka.log.LogManager)
  18. kafka_1      | [2017-05-10 10:42:00,676] INFO Logs loading complete in 4 ms. (kafka.log.LogManager)
  19. kafka_1      | [2017-05-10 10:42:00,721] INFO Starting log cleanup with a period of 300000 ms. (kafka.log.LogManager)
  20. kafka_1      | [2017-05-10 10:42:00,737] INFO Starting log flusher with a default period of 9223372036854775807 ms. (kafka.log.LogManager)
  21. kafka_1      | [2017-05-10 10:42:00,739] INFO Starting the log cleaner (kafka.log.LogCleaner)
  22. kafka_1      | [2017-05-10 10:42:00,741] INFO [kafka-log-cleaner-thread-0], Starting  (kafka.log.LogCleaner)
  23. kafka_1      | [2017-05-10 10:42:00,763] INFO Awaiting socket connections on 0.0.0.0:29092. (kafka.network.Acceptor)
  24. kafka_1      | [2017-05-10 10:42:00,766] INFO [Socket Server on Broker 1], Started 1 acceptor threads (kafka.network.SocketServer)
  25. kafka_1      | [2017-05-10 10:42:00,776] INFO [ExpirationReaper-1], Starting  (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  26. kafka_1      | [2017-05-10 10:42:00,776] INFO [ExpirationReaper-1], Starting  (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  27. kafka_1      | [2017-05-10 10:42:00,791] INFO [Controller 1]: Controller starting up (kafka.controller.KafkaController)
  28. kafka_1      | [2017-05-10 10:42:00,797] INFO Creating /controller (is it secure? false) (kafka.utils.ZKCheckedEphemeral)
  29. kafka_1      | [2017-05-10 10:42:00,808] INFO Result of znode creation is: OK (kafka.utils.ZKCheckedEphemeral)
  30. kafka_1      | [2017-05-10 10:42:00,809] INFO 1 successfully elected as leader (kafka.server.ZookeeperLeaderElector)
  31. kafka_1      | [2017-05-10 10:42:00,810] INFO [Controller 1]: Broker 1 starting become controller state transition (kafka.controller.KafkaController)
  32. zookeeper_1  | [2017-05-10 10:42:00,812] INFO Got user-level KeeperException when processing sessionid:0x15bf1f382780001 type:setData cxid:0x25 zxid:0x17 txntype:-1 reqpath:n/a Error Path:/controller_epoch Error:KeeperErrorCode = NoNode for /controller_epoch (org.apache.zookeeper.server.PrepRequestProcessor)
  33. kafka_1      | [2017-05-10 10:42:00,828] INFO [Controller 1]: Controller 1 incremented epoch to 1 (kafka.controller.KafkaController)
  34. kafka_1      | [2017-05-10 10:42:00,830] DEBUG [Controller 1]: Registering IsrChangeNotificationListener (kafka.controller.KafkaController)
  35. kafka_1      | [2017-05-10 10:42:00,841] INFO [Controller 1]: Partitions undergoing preferred replica election:  (kafka.controller.KafkaController)
  36. kafka_1      | [2017-05-10 10:42:00,842] INFO [Controller 1]: Partitions that completed preferred replica election:  (kafka.controller.KafkaController)
  37. kafka_1      | [2017-05-10 10:42:00,842] INFO [Controller 1]: Resuming preferred replica election for partitions:  (kafka.controller.KafkaController)
  38. kafka_1      | [2017-05-10 10:42:00,845] INFO [Controller 1]: Partitions being reassigned: Map() (kafka.controller.KafkaController)
  39. kafka_1      | [2017-05-10 10:42:00,845] INFO [Controller 1]: Partitions already reassigned: Set() (kafka.controller.KafkaController)
  40. kafka_1      | [2017-05-10 10:42:00,847] INFO [Controller 1]: Resuming reassignment of partitions: Map() (kafka.controller.KafkaController)
  41. kafka_1      | [2017-05-10 10:42:00,850] INFO [Controller 1]: List of topics to be deleted:  (kafka.controller.KafkaController)
  42. kafka_1      | [2017-05-10 10:42:00,850] INFO [Controller 1]: List of topics ineligible for deletion:  (kafka.controller.KafkaController)
  43. kafka_1      | [2017-05-10 10:42:00,852] INFO [Controller 1]: Currently active brokers in the cluster: Set() (kafka.controller.KafkaController)
  44. kafka_1      | [2017-05-10 10:42:00,853] INFO [Controller 1]: Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController)
  45. kafka_1      | [2017-05-10 10:42:00,853] INFO [Controller 1]: Current list of topics in the cluster: Set() (kafka.controller.KafkaController)
  46. kafka_1      | [2017-05-10 10:42:00,865] INFO [Replica state machine on controller 1]: Started replica state machine with initial state -> Map() (kafka.controller.ReplicaStateMachine)
  47. kafka_1      | [2017-05-10 10:42:00,867] INFO [Partition state machine on Controller 1]: Started partition state machine with initial state -> Map() (kafka.controller.PartitionStateMachine)
  48. kafka_1      | [2017-05-10 10:42:00,867] INFO [Controller 1]: Broker 1 is ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController)
  49. kafka_1      | [2017-05-10 10:42:00,868] INFO [Controller 1]: Starting preferred replica leader election for partitions  (kafka.controller.KafkaController)
  50. kafka_1      | [2017-05-10 10:42:00,871] INFO [Partition state machine on Controller 1]: Invoking state change to OnlinePartition for partitions  (kafka.controller.PartitionStateMachine)
  51. zookeeper_1  | [2017-05-10 10:42:00,874] INFO Got user-level KeeperException when processing sessionid:0x15bf1f382780001 type:delete cxid:0x36 zxid:0x19 txntype:-1 reqpath:n/a Error Path:/admin/preferred_replica_election Error:KeeperErrorCode = NoNode for /admin/preferred_replica_election (org.apache.zookeeper.server.PrepRequestProcessor)
  52. kafka_1      | [2017-05-10 10:42:00,880] INFO [Controller 1]: starting the partition rebalance scheduler (kafka.controller.KafkaController)
  53. kafka_1      | [2017-05-10 10:42:00,881] INFO [Controller 1]: Controller startup complete (kafka.controller.KafkaController)
  54. kafka_1      | [2017-05-10 10:42:00,885] INFO [ExpirationReaper-1], Starting  (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  55. kafka_1      | [2017-05-10 10:42:00,887] INFO [ExpirationReaper-1], Starting  (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  56. kafka_1      | [2017-05-10 10:42:00,889] INFO [ExpirationReaper-1], Starting  (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  57. kafka_1      | [2017-05-10 10:42:00,899] INFO [GroupCoordinator 1]: Starting up. (kafka.coordinator.GroupCoordinator)
  58. kafka_1      | [2017-05-10 10:42:00,900] INFO [GroupCoordinator 1]: Startup complete. (kafka.coordinator.GroupCoordinator)
  59. kafka_1      | [2017-05-10 10:42:00,901] INFO [Group Metadata Manager on Broker 1]: Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.GroupMetadataManager)
  60. kafka_1      | [2017-05-10 10:42:00,924] INFO Will not load MX4J, mx4j-tools.jar is not in the classpath (kafka.utils.Mx4jLoader$)
  61. kafka_1      | [2017-05-10 10:42:00,952] INFO Creating /brokers/ids/1 (is it secure? false) (kafka.utils.ZKCheckedEphemeral)
  62. zookeeper_1  | [2017-05-10 10:42:00,957] INFO Got user-level KeeperException when processing sessionid:0x15bf1f382780001 type:create cxid:0x41 zxid:0x1a txntype:-1 reqpath:n/a Error Path:/brokers Error:KeeperErrorCode = NodeExists for /brokers (org.apache.zookeeper.server.PrepRequestProcessor)
  63. zookeeper_1  | [2017-05-10 10:42:00,957] INFO Got user-level KeeperException when processing sessionid:0x15bf1f382780001 type:create cxid:0x42 zxid:0x1b txntype:-1 reqpath:n/a Error Path:/brokers/ids Error:KeeperErrorCode = NodeExists for /brokers/ids (org.apache.zookeeper.server.PrepRequestProcessor)
  64. kafka_1      | [2017-05-10 10:42:00,968] INFO New leader is 1 (kafka.server.ZookeeperLeaderElector$LeaderChangeListener)
  65. kafka_1      | [2017-05-10 10:42:00,969] INFO Result of znode creation is: OK (kafka.utils.ZKCheckedEphemeral)
  66. kafka_1      | [2017-05-10 10:42:00,971] INFO Registered broker 1 at path /brokers/ids/1 with addresses: EndPoint(localhost,29092,ListenerName(PLAINTEXT),PLAINTEXT) (kafka.utils.ZkUtils)
  67. kafka_1      | [2017-05-10 10:42:00,971] WARN No meta.properties file under dir /var/lib/kafka/data/meta.properties (kafka.server.BrokerMetadataCheckpoint)
  68. kafka_1      | [2017-05-10 10:42:00,974] INFO [BrokerChangeListener on Controller 1]: Broker change listener fired for path /brokers/ids with children 1 (kafka.controller.ReplicaStateMachine$BrokerChangeListener)
  69. kafka_1      | [2017-05-10 10:42:01,003] INFO Kafka version : 0.10.2.1-cp1 (org.apache.kafka.common.utils.AppInfoParser)
  70. kafka_1      | [2017-05-10 10:42:01,003] INFO Kafka commitId : 4332ed2a2fbf1bcd (org.apache.kafka.common.utils.AppInfoParser)
  71. kafka_1      | [2017-05-10 10:42:01,005] INFO [Kafka Server 1], started (kafka.server.KafkaServer)
  72. kafka_1      | [2017-05-10 10:42:01,041] INFO [BrokerChangeListener on Controller 1]: Newly added brokers: 1, deleted brokers: , all live brokers: 1 (kafka.controller.ReplicaStateMachine$BrokerChangeListener)
  73. kafka_1      | [2017-05-10 10:42:01,043] DEBUG [Channel manager on controller 1]: Controller 1 trying to connect to broker 1 (kafka.controller.ControllerChannelManager)
  74. kafka_1      | [2017-05-10 10:42:01,052] INFO [Controller-1-to-broker-1-send-thread], Starting  (kafka.controller.RequestSendThread)
  75. kafka_1      | [2017-05-10 10:42:01,054] INFO [Controller 1]: New broker startup callback for 1 (kafka.controller.KafkaController)
  76. kafka_1      | [2017-05-10 10:42:01,065] INFO [Controller-1-to-broker-1-send-thread], Controller 1 connected to localhost:29092 (id: 1 rack: null) for sending state change requests (kafka.controller.RequestSendThread)
  77. kafka_1      | [2017-05-10 10:42:01,096] TRACE Controller 1 epoch 1 received response {error_code=0} for a request sent to broker localhost:29092 (id: 1 rack: null) (state.change.logger)
  78. kafka_1      | [2017-05-10 10:42:05,883] TRACE [Controller 1]: checking need to trigger partition rebalance (kafka.controller.KafkaController)
  79. kafka_1      | [2017-05-10 10:42:05,885] DEBUG [Controller 1]: preferred replicas by broker Map() (kafka.controller.KafkaController)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement