Last active
August 29, 2015 14:15
-
-
Save plaflamme/60805bfe15ae0106304a to your computer and use it in GitHub Desktop.
Kafka Cluster Log
This file contains hidden or 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
| 2015-02-18 00:00:09 INFO NIOServerCnxnFactory:94 - binding to port /127.0.0.1:41889 | |
| 2015-02-18 00:00:09 INFO ZooKeeperServer:100 - Server environment:zookeeper.version=3.4.5-cdh4.6.0--1, built on 03/10/2014 21:06 GMT | |
| 2015-02-18 00:00:09 INFO ZooKeeperServer:100 - Server environment:host.name=ziggy | |
| 2015-02-18 00:00:09 INFO ZooKeeperServer:100 - Server environment:java.version=1.7.0_75 | |
| 2015-02-18 00:00:09 INFO ZooKeeperServer:100 - Server environment:java.vendor=Oracle Corporation | |
| 2015-02-18 00:00:09 INFO ZooKeeperServer:100 - Server environment:java.home=/usr/lib/jvm/java-7-openjdk-amd64/jre | |
| 2015-02-18 00:00:09 INFO ZooKeeperServer:100 - Server environment:java.class.path=/usr/share/sbt-launcher-packaging/bin/sbt-launch.jar | |
| 2015-02-18 00:00:09 INFO ZooKeeperServer:100 - Server environment:java.library.path=/usr/java/packages/lib/amd64:/usr/lib/x86_64-linux-gnu/jni:/lib/x86_64-linux-gnu:/usr/lib/x86_64-linux-gnu:/usr/lib/jni:/lib:/usr/lib | |
| 2015-02-18 00:00:09 INFO ZooKeeperServer:100 - Server environment:java.io.tmpdir=/tmp | |
| 2015-02-18 00:00:09 INFO ZooKeeperServer:100 - Server environment:java.compiler=<NA> | |
| 2015-02-18 00:00:09 INFO ZooKeeperServer:100 - Server environment:os.name=Linux | |
| 2015-02-18 00:00:09 INFO ZooKeeperServer:100 - Server environment:os.arch=amd64 | |
| 2015-02-18 00:00:09 INFO ZooKeeperServer:100 - Server environment:os.version=3.13.0-24-generic | |
| 2015-02-18 00:00:09 INFO ZooKeeperServer:100 - Server environment:user.name=philippe | |
| 2015-02-18 00:00:09 INFO ZooKeeperServer:100 - Server environment:user.home=/home/philippe | |
| 2015-02-18 00:00:09 INFO ZooKeeperServer:100 - Server environment:user.dir=/home/philippe/projects/Helpers | |
| 2015-02-18 00:00:09 INFO ZooKeeperServer:162 - Created server with tickTime 500 minSessionTimeout 1000 maxSessionTimeout 10000 datadir /tmp/zk-snapshots1119303980367423717.tmp/version-2 snapdir /tmp/zk-logs5887119434870614289.tmp/version-2 | |
| 2015-02-18 00:00:09 INFO FileTxnSnapLog:273 - Snapshotting: 0x0 to /tmp/zk-logs5887119434870614289.tmp/version-2/snapshot.0 | |
| 2015-02-18 00:00:09 INFO VerifiableProperties:68 - Verifying properties | |
| 2015-02-18 00:00:09 INFO VerifiableProperties:68 - Property broker.id is overridden to 1 | |
| 2015-02-18 00:00:09 INFO VerifiableProperties:68 - Property controlled.shutdown.enable is overridden to true | |
| 2015-02-18 00:00:09 INFO VerifiableProperties:68 - Property host.name is overridden to 127.0.0.1 | |
| 2015-02-18 00:00:09 INFO VerifiableProperties:68 - Property log.dir is overridden to /tmp/kafka-17678236130777308738.tmp | |
| 2015-02-18 00:00:09 INFO VerifiableProperties:68 - Property log.flush.interval.messages is overridden to 1 | |
| 2015-02-18 00:00:09 INFO VerifiableProperties:68 - Property port is overridden to 36383 | |
| 2015-02-18 00:00:09 INFO VerifiableProperties:68 - Property zookeeper.connect is overridden to localhost:41889 | |
| 2015-02-18 00:00:09 INFO KafkaServer:68 - [Kafka Server 1], starting | |
| 2015-02-18 00:00:09 INFO KafkaServer:68 - [Kafka Server 1], Connecting to zookeeper on localhost:41889 | |
| 2015-02-18 00:00:09 INFO ZkEventThread:64 - Starting ZkClient event thread. | |
| 2015-02-18 00:00:09 INFO ZooKeeper:100 - Client environment:zookeeper.version=3.4.5-cdh4.6.0--1, built on 03/10/2014 21:06 GMT | |
| 2015-02-18 00:00:09 INFO ZooKeeper:100 - Client environment:host.name=ziggy | |
| 2015-02-18 00:00:09 INFO ZooKeeper:100 - Client environment:java.version=1.7.0_75 | |
| 2015-02-18 00:00:09 INFO ZooKeeper:100 - Client environment:java.vendor=Oracle Corporation | |
| 2015-02-18 00:00:09 INFO ZooKeeper:100 - Client environment:java.home=/usr/lib/jvm/java-7-openjdk-amd64/jre | |
| 2015-02-18 00:00:09 INFO ZooKeeper:100 - Client environment:java.class.path=/usr/share/sbt-launcher-packaging/bin/sbt-launch.jar | |
| 2015-02-18 00:00:09 INFO ZooKeeper:100 - Client environment:java.library.path=/usr/java/packages/lib/amd64:/usr/lib/x86_64-linux-gnu/jni:/lib/x86_64-linux-gnu:/usr/lib/x86_64-linux-gnu:/usr/lib/jni:/lib:/usr/lib | |
| 2015-02-18 00:00:09 INFO ZooKeeper:100 - Client environment:java.io.tmpdir=/tmp | |
| 2015-02-18 00:00:09 INFO ZooKeeper:100 - Client environment:java.compiler=<NA> | |
| 2015-02-18 00:00:09 INFO ZooKeeper:100 - Client environment:os.name=Linux | |
| 2015-02-18 00:00:09 INFO ZooKeeper:100 - Client environment:os.arch=amd64 | |
| 2015-02-18 00:00:09 INFO ZooKeeper:100 - Client environment:os.version=3.13.0-24-generic | |
| 2015-02-18 00:00:09 INFO ZooKeeper:100 - Client environment:user.name=philippe | |
| 2015-02-18 00:00:09 INFO ZooKeeper:100 - Client environment:user.home=/home/philippe | |
| 2015-02-18 00:00:09 INFO ZooKeeper:100 - Client environment:user.dir=/home/philippe/projects/Helpers | |
| 2015-02-18 00:00:09 INFO ZooKeeper:438 - Initiating client connection, connectString=localhost:41889 sessionTimeout=6000 watcher=org.I0Itec.zkclient.ZkClient@23fe4056 | |
| 2015-02-18 00:00:09 INFO ClientCnxn:973 - Opening socket connection to server localhost/127.0.0.1:41889. Will not attempt to authenticate using SASL (unknown error) | |
| 2015-02-18 00:00:09 INFO ClientCnxn:852 - Socket connection established to localhost/127.0.0.1:41889, initiating session | |
| 2015-02-18 00:00:09 INFO NIOServerCnxnFactory:197 - Accepted socket connection from /127.0.0.1:35516 | |
| 2015-02-18 00:00:09 INFO ZooKeeperServer:839 - Client attempting to establish new session at /127.0.0.1:35516 | |
| 2015-02-18 00:00:09 INFO FileTxnLog:199 - Creating new log file: log.1 | |
| 2015-02-18 00:00:09 INFO ZooKeeperServer:595 - Established session 0x14b9b0ebe340000 with negotiated timeout 6000 for client /127.0.0.1:35516 | |
| 2015-02-18 00:00:09 INFO ClientCnxn:1214 - Session establishment complete on server localhost/127.0.0.1:41889, sessionid = 0x14b9b0ebe340000, negotiated timeout = 6000 | |
| 2015-02-18 00:00:09 INFO ZkClient:449 - zookeeper state changed (SyncConnected) | |
| 2015-02-18 00:00:09 INFO PrepRequestProcessor:627 - Got user-level KeeperException when processing sessionid:0x14b9b0ebe340000 type:create cxid:0x4 zxid:0x3 txntype:-1 reqpath:n/a Error Path:/brokers Error:KeeperErrorCode = NoNode for /brokers | |
| 2015-02-18 00:00:09 INFO PrepRequestProcessor:627 - Got user-level KeeperException when processing sessionid:0x14b9b0ebe340000 type:create cxid:0xa zxid:0x7 txntype:-1 reqpath:n/a Error Path:/config Error:KeeperErrorCode = NoNode for /config | |
| 2015-02-18 00:00:09 INFO PrepRequestProcessor:627 - Got user-level KeeperException when processing sessionid:0x14b9b0ebe340000 type:create cxid:0x10 zxid:0xb txntype:-1 reqpath:n/a Error Path:/admin Error:KeeperErrorCode = NoNode for /admin | |
| 2015-02-18 00:00:10 INFO LogManager:68 - Starting log cleanup with a period of 300000 ms. | |
| 2015-02-18 00:00:10 INFO LogManager:68 - Starting log flusher with a default period of 9223372036854775807 ms. | |
| 2015-02-18 00:00:10 INFO Acceptor:68 - Awaiting socket connections on localhost:36383. | |
| 2015-02-18 00:00:10 INFO SocketServer:68 - [Socket Server on Broker 1], Started | |
| 2015-02-18 00:00:10 INFO Mx4jLoader$:68 - Will not load MX4J, mx4j-tools.jar is not in the classpath | |
| 2015-02-18 00:00:10 INFO KafkaController:68 - [Controller 1]: Controller starting up | |
| 2015-02-18 00:00:10 INFO ZookeeperLeaderElector:68 - 1 successfully elected as leader | |
| 2015-02-18 00:00:10 INFO KafkaController:68 - [Controller 1]: Broker 1 starting become controller state transition | |
| 2015-02-18 00:00:10 INFO PrepRequestProcessor:627 - Got user-level KeeperException when processing sessionid:0x14b9b0ebe340000 type:setData cxid:0x1a zxid:0xf txntype:-1 reqpath:n/a Error Path:/controller_epoch Error:KeeperErrorCode = NoNode for /controller_epoch | |
| 2015-02-18 00:00:10 INFO KafkaController:68 - [Controller 1]: Controller 1 incremented epoch to 1 | |
| 2015-02-18 00:00:10 INFO KafkaController:68 - [Controller 1]: Partitions undergoing preferred replica election: | |
| 2015-02-18 00:00:10 INFO KafkaController:68 - [Controller 1]: Partitions that completed preferred replica election: | |
| 2015-02-18 00:00:10 INFO KafkaController:68 - [Controller 1]: Resuming preferred replica election for partitions: | |
| 2015-02-18 00:00:10 INFO KafkaController:68 - [Controller 1]: Partitions being reassigned: Map() | |
| 2015-02-18 00:00:10 INFO KafkaController:68 - [Controller 1]: Partitions already reassigned: List() | |
| 2015-02-18 00:00:10 INFO KafkaController:68 - [Controller 1]: Resuming reassignment of partitions: Map() | |
| 2015-02-18 00:00:10 INFO KafkaController:68 - [Controller 1]: List of topics to be deleted: | |
| 2015-02-18 00:00:10 INFO KafkaController:68 - [Controller 1]: List of topics ineligible for deletion: | |
| 2015-02-18 00:00:10 INFO KafkaController:68 - [Controller 1]: Currently active brokers in the cluster: Set() | |
| 2015-02-18 00:00:10 INFO KafkaController:68 - [Controller 1]: Currently shutting brokers in the cluster: Set() | |
| 2015-02-18 00:00:10 INFO KafkaController:68 - [Controller 1]: Current list of topics in the cluster: Set() | |
| 2015-02-18 00:00:10 INFO ReplicaStateMachine:68 - [Replica state machine on controller 1]: Started replica state machine with initial state -> Map() | |
| 2015-02-18 00:00:10 INFO PartitionStateMachine:68 - [Partition state machine on Controller 1]: Started partition state machine with initial state -> Map() | |
| 2015-02-18 00:00:10 INFO KafkaController:68 - [Controller 1]: Broker 1 is ready to serve as the new controller with epoch 1 | |
| 2015-02-18 00:00:10 INFO KafkaController:68 - [Controller 1]: Starting preferred replica leader election for partitions | |
| 2015-02-18 00:00:10 INFO PartitionStateMachine:68 - [Partition state machine on Controller 1]: Invoking state change to OnlinePartition for partitions | |
| 2015-02-18 00:00:10 INFO PrepRequestProcessor:627 - Got user-level KeeperException when processing sessionid:0x14b9b0ebe340000 type:delete cxid:0x27 zxid:0x11 txntype:-1 reqpath:n/a Error Path:/admin/preferred_replica_election Error:KeeperErrorCode = NoNode for /admin/preferred_replica_election | |
| 2015-02-18 00:00:10 INFO KafkaController:68 - [Controller 1]: Controller startup complete | |
| 2015-02-18 00:00:10 INFO ZookeeperLeaderElector$LeaderChangeListener:68 - New leader is 1 | |
| 2015-02-18 00:00:10 INFO ControllerEpochListener:68 - [ControllerEpochListener on 1]: Initialized controller epoch to 1 and zk version 0 | |
| 2015-02-18 00:00:10 INFO ZkUtils$:68 - Registered broker 1 at path /brokers/ids/1 with address 127.0.0.1:36383. | |
| 2015-02-18 00:00:10 INFO ReplicaStateMachine$BrokerChangeListener:68 - [BrokerChangeListener on Controller 1]: Broker change listener fired for path /brokers/ids with children 1 | |
| 2015-02-18 00:00:10 INFO KafkaServer:68 - [Kafka Server 1], started | |
| 2015-02-18 00:00:10 INFO VerifiableProperties:68 - Verifying properties | |
| 2015-02-18 00:00:10 INFO VerifiableProperties:68 - Property broker.id is overridden to 2 | |
| 2015-02-18 00:00:10 INFO VerifiableProperties:68 - Property controlled.shutdown.enable is overridden to true | |
| 2015-02-18 00:00:10 INFO VerifiableProperties:68 - Property host.name is overridden to 127.0.0.1 | |
| 2015-02-18 00:00:10 INFO VerifiableProperties:68 - Property log.dir is overridden to /tmp/kafka-27106419727456024027.tmp | |
| 2015-02-18 00:00:10 INFO VerifiableProperties:68 - Property log.flush.interval.messages is overridden to 1 | |
| 2015-02-18 00:00:10 INFO VerifiableProperties:68 - Property port is overridden to 55359 | |
| 2015-02-18 00:00:10 INFO VerifiableProperties:68 - Property zookeeper.connect is overridden to localhost:41889 | |
| 2015-02-18 00:00:10 INFO KafkaServer:68 - [Kafka Server 2], starting | |
| 2015-02-18 00:00:10 INFO KafkaServer:68 - [Kafka Server 2], Connecting to zookeeper on localhost:41889 | |
| 2015-02-18 00:00:10 INFO ZooKeeper:438 - Initiating client connection, connectString=localhost:41889 sessionTimeout=6000 watcher=org.I0Itec.zkclient.ZkClient@4ed9c6dd | |
| 2015-02-18 00:00:10 INFO ZkEventThread:64 - Starting ZkClient event thread. | |
| 2015-02-18 00:00:10 INFO ClientCnxn:973 - Opening socket connection to server localhost/127.0.0.1:41889. Will not attempt to authenticate using SASL (unknown error) | |
| 2015-02-18 00:00:10 INFO ClientCnxn:852 - Socket connection established to localhost/127.0.0.1:41889, initiating session | |
| 2015-02-18 00:00:10 INFO NIOServerCnxnFactory:197 - Accepted socket connection from /127.0.0.1:35517 | |
| 2015-02-18 00:00:10 INFO ZooKeeperServer:839 - Client attempting to establish new session at /127.0.0.1:35517 | |
| 2015-02-18 00:00:10 INFO ZooKeeperServer:595 - Established session 0x14b9b0ebe340001 with negotiated timeout 6000 for client /127.0.0.1:35517 | |
| 2015-02-18 00:00:10 INFO ClientCnxn:1214 - Session establishment complete on server localhost/127.0.0.1:41889, sessionid = 0x14b9b0ebe340001, negotiated timeout = 6000 | |
| 2015-02-18 00:00:10 INFO ZkClient:449 - zookeeper state changed (SyncConnected) | |
| 2015-02-18 00:00:10 INFO LogManager:68 - Starting log cleanup with a period of 300000 ms. | |
| 2015-02-18 00:00:10 INFO LogManager:68 - Starting log flusher with a default period of 9223372036854775807 ms. | |
| 2015-02-18 00:00:10 INFO ReplicaStateMachine$BrokerChangeListener:68 - [BrokerChangeListener on Controller 1]: Newly added brokers: 1, deleted brokers: , all live brokers: 1 | |
| 2015-02-18 00:00:10 INFO Acceptor:68 - Awaiting socket connections on localhost:55359. | |
| 2015-02-18 00:00:10 INFO SocketServer:68 - [Socket Server on Broker 2], Started | |
| 2015-02-18 00:00:10 INFO ControllerEpochListener:68 - [ControllerEpochListener on 2]: Initialized controller epoch to 1 and zk version 0 | |
| 2015-02-18 00:00:10 INFO RequestSendThread:68 - [Controller-1-to-broker-1-send-thread], Controller 1 connected to id:1,host:127.0.0.1,port:36383 for sending state change requests | |
| 2015-02-18 00:00:10 INFO RequestSendThread:68 - [Controller-1-to-broker-1-send-thread], Starting | |
| 2015-02-18 00:00:10 INFO Mx4jLoader$:68 - Will not load MX4J, mx4j-tools.jar is not in the classpath | |
| 2015-02-18 00:00:10 INFO KafkaController:68 - [Controller 2]: Controller starting up | |
| 2015-02-18 00:00:10 INFO PrepRequestProcessor:627 - Got user-level KeeperException when processing sessionid:0x14b9b0ebe340001 type:create cxid:0xc zxid:0x14 txntype:-1 reqpath:n/a Error Path:/controller Error:KeeperErrorCode = NodeExists for /controller | |
| 2015-02-18 00:00:10 INFO KafkaController:68 - [Controller 1]: New broker startup callback for 1 | |
| 2015-02-18 00:00:10 INFO ZkUtils$:68 - conflict in /controller data: {"version":1,"brokerid":2,"timestamp":"1424235610291"} stored data: {"version":1,"brokerid":1,"timestamp":"1424235610136"} | |
| 2015-02-18 00:00:10 INFO KafkaController:68 - [Controller 2]: Controller startup complete | |
| 2015-02-18 00:00:10 INFO ZkUtils$:68 - Registered broker 2 at path /brokers/ids/2 with address 127.0.0.1:55359. | |
| 2015-02-18 00:00:10 INFO KafkaServer:68 - [Kafka Server 2], started | |
| 2015-02-18 00:00:10 INFO ReplicaStateMachine$BrokerChangeListener:68 - [BrokerChangeListener on Controller 1]: Broker change listener fired for path /brokers/ids with children 2,1 | |
| 2015-02-18 00:00:10 INFO ReplicaStateMachine$BrokerChangeListener:68 - [BrokerChangeListener on Controller 1]: Newly added brokers: 2, deleted brokers: , all live brokers: 2,1 | |
| 2015-02-18 00:00:10 INFO RequestSendThread:68 - [Controller-1-to-broker-2-send-thread], Controller 1 connected to id:2,host:127.0.0.1,port:55359 for sending state change requests | |
| 2015-02-18 00:00:10 INFO KafkaController:68 - [Controller 1]: New broker startup callback for 2 | |
| 2015-02-18 00:00:10 INFO RequestSendThread:68 - [Controller-1-to-broker-2-send-thread], Starting | |
| 2015-02-18 00:00:10 INFO PrepRequestProcessor:627 - Got user-level KeeperException when processing sessionid:0x14b9b0ebe340000 type:setData cxid:0x3c zxid:0x16 txntype:-1 reqpath:n/a Error Path:/config/topics/test-bogus Error:KeeperErrorCode = NoNode for /config/topics/test-bogus | |
| 2015-02-18 00:00:10 INFO PrepRequestProcessor:627 - Got user-level KeeperException when processing sessionid:0x14b9b0ebe340000 type:create cxid:0x3d zxid:0x17 txntype:-1 reqpath:n/a Error Path:/config/topics Error:KeeperErrorCode = NodeExists for /config/topics | |
| 2015-02-18 00:00:10 INFO AdminUtils$:68 - Topic creation {"version":1,"partitions":{"0":[1,2]}} | |
| 2015-02-18 00:00:10 INFO PartitionStateMachine$TopicChangeListener:68 - [TopicChangeListener on Controller 1]: New topics: [Set(test-bogus)], deleted topics: [Set()], new partition replica assignment [Map([test-bogus,0] -> List(1, 2))] | |
| 2015-02-18 00:00:10 INFO KafkaController:68 - [Controller 1]: New topic creation callback for [test-bogus,0] | |
| 2015-02-18 00:00:10 INFO KafkaController:68 - [Controller 1]: New partition creation callback for [test-bogus,0] | |
| 2015-02-18 00:00:10 INFO PartitionStateMachine:68 - [Partition state machine on Controller 1]: Invoking state change to NewPartition for partitions [test-bogus,0] | |
| 2015-02-18 00:00:10 INFO ReplicaStateMachine:68 - [Replica state machine on controller 1]: Invoking state change to NewReplica for replicas [Topic=test-bogus,Partition=0,Replica=1],[Topic=test-bogus,Partition=0,Replica=2] | |
| 2015-02-18 00:00:10 INFO PartitionStateMachine:68 - [Partition state machine on Controller 1]: Invoking state change to OnlinePartition for partitions [test-bogus,0] | |
| 2015-02-18 00:00:10 INFO PrepRequestProcessor:627 - Got user-level KeeperException when processing sessionid:0x14b9b0ebe340000 type:create cxid:0x47 zxid:0x1a txntype:-1 reqpath:n/a Error Path:/brokers/topics/test-bogus/partitions/0 Error:KeeperErrorCode = NoNode for /brokers/topics/test-bogus/partitions/0 | |
| 2015-02-18 00:00:10 INFO PrepRequestProcessor:627 - Got user-level KeeperException when processing sessionid:0x14b9b0ebe340000 type:create cxid:0x48 zxid:0x1b txntype:-1 reqpath:n/a Error Path:/brokers/topics/test-bogus/partitions Error:KeeperErrorCode = NoNode for /brokers/topics/test-bogus/partitions | |
| 2015-02-18 00:00:10 INFO ReplicaStateMachine:68 - [Replica state machine on controller 1]: Invoking state change to OnlineReplica for replicas [Topic=test-bogus,Partition=0,Replica=1],[Topic=test-bogus,Partition=0,Replica=2] | |
| 2015-02-18 00:00:10 INFO ReplicaFetcherManager:68 - [ReplicaFetcherManager on broker 1] Removed fetcher for partitions [test-bogus,0] | |
| 2015-02-18 00:00:10 INFO Log:68 - Completed load of log test-bogus-0 with log end offset 0 | |
| 2015-02-18 00:00:10 INFO Log:68 - Completed load of log test-bogus-0 with log end offset 0 | |
| 2015-02-18 00:00:10 INFO LogManager:68 - Created log for partition [test-bogus,0] in /tmp/kafka-27106419727456024027.tmp with properties {segment.index.bytes -> 10485760, file.delete.delay.ms -> 60000, segment.bytes -> 1073741824, flush.ms -> 9223372036854775807, delete.retention.ms -> 86400000, index.interval.bytes -> 4096, retention.bytes -> -1, cleanup.policy -> delete, segment.ms -> 604800000, max.message.bytes -> 1000012, flush.messages -> 1, min.cleanable.dirty.ratio -> 0.5, retention.ms -> 604800000}. | |
| 2015-02-18 00:00:10 INFO LogManager:68 - Created log for partition [test-bogus,0] in /tmp/kafka-17678236130777308738.tmp with properties {segment.index.bytes -> 10485760, file.delete.delay.ms -> 60000, segment.bytes -> 1073741824, flush.ms -> 9223372036854775807, delete.retention.ms -> 86400000, index.interval.bytes -> 4096, retention.bytes -> -1, cleanup.policy -> delete, segment.ms -> 604800000, max.message.bytes -> 1000012, flush.messages -> 1, min.cleanable.dirty.ratio -> 0.5, retention.ms -> 604800000}. | |
| 2015-02-18 00:00:10 WARN Partition:83 - Partition [test-bogus,0] on broker 1: No checkpointed highwatermark is found for partition [test-bogus,0] | |
| 2015-02-18 00:00:10 WARN Partition:83 - Partition [test-bogus,0] on broker 2: No checkpointed highwatermark is found for partition [test-bogus,0] | |
| 2015-02-18 00:00:10 INFO ReplicaFetcherManager:68 - [ReplicaFetcherManager on broker 2] Removed fetcher for partitions [test-bogus,0] | |
| 2015-02-18 00:00:10 INFO Log:68 - Truncating log test-bogus-0 to offset 0. | |
| 2015-02-18 00:00:10 INFO ReplicaFetcherThread:68 - [ReplicaFetcherThread-0-1], Starting | |
| 2015-02-18 00:00:10 INFO ReplicaFetcherManager:68 - [ReplicaFetcherManager on broker 2] Added fetcher for partitions ArrayBuffer([[test-bogus,0], initOffset 0 to broker id:1,host:127.0.0.1,port:36383] ) | |
| 2015-02-18 00:00:15 INFO TestCase:44 - Controller says leader for test-bogus:0 is Broker 1 | |
| 2015-02-18 00:00:15 INFO TestCase:54 - Broker 1 says leader for test-bogus:0 is Broker 1 | |
| 2015-02-18 00:00:15 INFO Processor:68 - Closing socket connection to /127.0.0.1. | |
| 2015-02-18 00:00:15 INFO TestCase:54 - Broker 2 says leader for test-bogus:0 is Broker 1 | |
| 2015-02-18 00:00:15 INFO Processor:68 - Closing socket connection to /127.0.0.1. | |
| 2015-02-18 00:00:15 INFO TestCase:71 - Shutting down LocalKafkaBroker(1,/tmp/kafka-17678236130777308738.tmp,kafka.server.KafkaServer@305674df) | |
| 2015-02-18 00:00:15 INFO KafkaServer:68 - [Kafka Server 1], shutting down | |
| 2015-02-18 00:00:15 INFO KafkaServer:68 - [Kafka Server 1], Starting controlled shutdown | |
| 2015-02-18 00:00:15 INFO KafkaController:68 - [Controller 1]: Shutting down broker 1 | |
| 2015-02-18 00:00:15 INFO PartitionStateMachine:68 - [Partition state machine on Controller 1]: Invoking state change to OnlinePartition for partitions [test-bogus,0] | |
| 2015-02-18 00:00:15 INFO ReplicaFetcherManager:68 - [ReplicaFetcherManager on broker 2] Removed fetcher for partitions [test-bogus,0] | |
| 2015-02-18 00:00:15 INFO ReplicaFetcherThread:68 - [ReplicaFetcherThread-0-1], Shutting down | |
| 2015-02-18 00:00:15 INFO ReplicaFetcherManager:68 - [ReplicaFetcherManager on broker 1] Removed fetcher for partitions [test-bogus,0] | |
| 2015-02-18 00:00:15 INFO Log:68 - Truncating log test-bogus-0 to offset 0. | |
| 2015-02-18 00:00:15 INFO KafkaServer:68 - [Kafka Server 1], Controlled shutdown succeeded | |
| 2015-02-18 00:00:15 INFO Processor:68 - Closing socket connection to /127.0.0.1. | |
| 2015-02-18 00:00:15 INFO SocketServer:68 - [Socket Server on Broker 1], Shutting down | |
| 2015-02-18 00:00:15 INFO SocketServer:68 - [Socket Server on Broker 1], Shutdown completed | |
| 2015-02-18 00:00:15 INFO KafkaRequestHandlerPool:68 - [Kafka Request Handler on Broker 1], shutting down | |
| 2015-02-18 00:00:15 INFO KafkaRequestHandlerPool:68 - [Kafka Request Handler on Broker 1], shut down completely | |
| 2015-02-18 00:00:15 WARN KafkaApis:83 - [KafkaApi-1] Fetch request with correlation id 9 from client ReplicaFetcherThread-0-1 on partition [test-bogus,0] failed due to Leader not local for partition [test-bogus,0] on broker 1 | |
| 2015-02-18 00:00:15 INFO ReplicaManager:68 - [Replica Manager on Broker 1]: Shut down | |
| 2015-02-18 00:00:15 INFO ReplicaFetcherManager:68 - [ReplicaFetcherManager on broker 1] shutting down | |
| 2015-02-18 00:00:15 INFO ReplicaFetcherManager:68 - [ReplicaFetcherManager on broker 1] shutdown completed | |
| 2015-02-18 00:00:15 INFO ReplicaManager:68 - [Replica Manager on Broker 1]: Shutted down completely | |
| 2015-02-18 00:00:15 INFO RequestSendThread:68 - [Controller-1-to-broker-2-send-thread], Shutting down | |
| 2015-02-18 00:00:15 WARN RequestSendThread:89 - [Controller-1-to-broker-2-send-thread], Controller 1 fails to send a request to broker id:2,host:127.0.0.1,port:55359 | |
| java.nio.channels.AsynchronousCloseException | |
| at java.nio.channels.spi.AbstractInterruptibleChannel.end(AbstractInterruptibleChannel.java:205) | |
| at java.nio.channels.Channels$ReadableByteChannelImpl.read(Channels.java:387) | |
| at kafka.utils.Utils$.read(Utils.scala:375) | |
| at kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54) | |
| at kafka.network.Receive$class.readCompletely(Transmission.scala:56) | |
| at kafka.network.BoundedByteBufferReceive.readCompletely(BoundedByteBufferReceive.scala:29) | |
| at kafka.network.BlockingChannel.receive(BlockingChannel.scala:100) | |
| at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:146) | |
| at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) | |
| 2015-02-18 00:00:15 INFO RequestSendThread:68 - [Controller-1-to-broker-2-send-thread], Stopped | |
| 2015-02-18 00:00:15 INFO RequestSendThread:68 - [Controller-1-to-broker-2-send-thread], Shutdown completed | |
| 2015-02-18 00:00:15 INFO RequestSendThread:68 - [Controller-1-to-broker-1-send-thread], Shutting down | |
| 2015-02-18 00:00:15 INFO RequestSendThread:68 - [Controller-1-to-broker-1-send-thread], Stopped | |
| 2015-02-18 00:00:15 INFO RequestSendThread:68 - [Controller-1-to-broker-1-send-thread], Shutdown completed | |
| 2015-02-18 00:00:15 INFO KafkaController:68 - [Controller 1]: Controller shutdown complete | |
| 2015-02-18 00:00:15 INFO ZkEventThread:82 - Terminate ZkClient event thread. | |
| 2015-02-18 00:00:15 INFO PrepRequestProcessor:476 - Processed session termination for sessionid: 0x14b9b0ebe340000 | |
| 2015-02-18 00:00:15 INFO ZooKeeper:684 - Session: 0x14b9b0ebe340000 closed | |
| 2015-02-18 00:00:15 INFO ClientCnxn:512 - EventThread shut down | |
| 2015-02-18 00:00:15 INFO NIOServerCnxn:1001 - Closed socket connection for client /127.0.0.1:35516 which had sessionid 0x14b9b0ebe340000 | |
| 2015-02-18 00:00:15 INFO KafkaServer:68 - [Kafka Server 1], shut down completed | |
| 2015-02-18 00:00:15 INFO ZookeeperLeaderElector:68 - 2 successfully elected as leader | |
| 2015-02-18 00:00:15 INFO KafkaController:68 - [Controller 2]: Broker 2 starting become controller state transition | |
| 2015-02-18 00:00:15 INFO KafkaController:68 - [Controller 2]: Controller 2 incremented epoch to 2 | |
| 2015-02-18 00:00:15 INFO RequestSendThread:68 - [Controller-2-to-broker-2-send-thread], Controller 2 connected to id:2,host:127.0.0.1,port:55359 for sending state change requests | |
| 2015-02-18 00:00:15 INFO RequestSendThread:68 - [Controller-2-to-broker-2-send-thread], Starting | |
| 2015-02-18 00:00:15 INFO KafkaController:68 - [Controller 2]: Partitions undergoing preferred replica election: | |
| 2015-02-18 00:00:15 INFO KafkaController:68 - [Controller 2]: Partitions that completed preferred replica election: | |
| 2015-02-18 00:00:15 INFO KafkaController:68 - [Controller 2]: Resuming preferred replica election for partitions: | |
| 2015-02-18 00:00:15 INFO KafkaController:68 - [Controller 2]: Partitions being reassigned: Map() | |
| 2015-02-18 00:00:15 INFO KafkaController:68 - [Controller 2]: Partitions already reassigned: List() | |
| 2015-02-18 00:00:15 INFO KafkaController:68 - [Controller 2]: Resuming reassignment of partitions: Map() | |
| 2015-02-18 00:00:15 INFO KafkaController:68 - [Controller 2]: List of topics to be deleted: | |
| 2015-02-18 00:00:15 INFO KafkaController:68 - [Controller 2]: List of topics ineligible for deletion: test-bogus | |
| 2015-02-18 00:00:15 INFO KafkaController:68 - [Controller 2]: Currently active brokers in the cluster: Set(2) | |
| 2015-02-18 00:00:15 INFO KafkaController:68 - [Controller 2]: Currently shutting brokers in the cluster: Set() | |
| 2015-02-18 00:00:15 INFO KafkaController:68 - [Controller 2]: Current list of topics in the cluster: Set(test-bogus) | |
| 2015-02-18 00:00:15 INFO ReplicaStateMachine:68 - [Replica state machine on controller 2]: Invoking state change to OnlineReplica for replicas [Topic=test-bogus,Partition=0,Replica=2] | |
| 2015-02-18 00:00:15 INFO ReplicaStateMachine:68 - [Replica state machine on controller 2]: Started replica state machine with initial state -> Map([Topic=test-bogus,Partition=0,Replica=1] -> ReplicaDeletionIneligible, [Topic=test-bogus,Partition=0,Replica=2] -> OnlineReplica) | |
| 2015-02-18 00:00:15 INFO PartitionStateMachine:68 - [Partition state machine on Controller 2]: Started partition state machine with initial state -> Map([test-bogus,0] -> OnlinePartition) | |
| 2015-02-18 00:00:15 INFO KafkaController:68 - [Controller 2]: Broker 2 is ready to serve as the new controller with epoch 2 | |
| 2015-02-18 00:00:15 INFO KafkaController:68 - [Controller 2]: Starting preferred replica leader election for partitions | |
| 2015-02-18 00:00:15 INFO PartitionStateMachine:68 - [Partition state machine on Controller 2]: Invoking state change to OnlinePartition for partitions | |
| 2015-02-18 00:00:15 INFO PrepRequestProcessor:627 - Got user-level KeeperException when processing sessionid:0x14b9b0ebe340001 type:delete cxid:0x29 zxid:0x23 txntype:-1 reqpath:n/a Error Path:/admin/preferred_replica_election Error:KeeperErrorCode = NoNode for /admin/preferred_replica_election | |
| 2015-02-18 00:00:15 INFO ZookeeperLeaderElector$LeaderChangeListener:68 - New leader is 2 | |
| 2015-02-18 00:00:15 INFO ControllerEpochListener:68 - [ControllerEpochListener on 2]: Initialized controller epoch to 2 and zk version 1 | |
| 2015-02-18 00:00:20 INFO TestCase:44 - Controller says leader for test-bogus:0 is Broker 2 | |
| 2015-02-18 00:00:20 INFO TestCase:54 - Broker 2 says leader for test-bogus:0 is Broker 1 | |
| 2015-02-18 00:00:20 INFO Processor:68 - Closing socket connection to /127.0.0.1. |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment