Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- Class org.apache.samza.test.integration.TestStatefulTask
- all > org.apache.samza.test.integration > TestStatefulTask
- 1
- tests
- 1
- failures
- 1m2.49s
- duration
- 0%
- successful
- Failed tests
- Tests
- Standard output
- Standard error
- 2014-03-27 23:57:56 VerifiableProperties [INFO] Verifying properties
- 2014-03-27 23:57:56 VerifiableProperties [INFO] Property metadata.broker.list is overridden to localhost:53077,localhost:45727,localhost:36283
- 2014-03-27 23:57:56 VerifiableProperties [INFO] Property producer.type is overridden to sync
- 2014-03-27 23:57:56 VerifiableProperties [INFO] Property request.required.acks is overridden to -1
- 2014-03-27 23:57:56 VerifiableProperties [INFO] Property serializer.class is overridden to kafka.serializer.StringEncoder
- 2014-03-27 23:57:57 ZooKeeperServer [INFO] Server environment:zookeeper.version=3.3.3-1203054, built on 11/17/2011 05:47 GMT
- 2014-03-27 23:57:57 ZooKeeperServer [INFO] Server environment:host.name=localhost.localdomain
- 2014-03-27 23:57:57 ZooKeeperServer [INFO] Server environment:java.version=1.6.0_32
- 2014-03-27 23:57:57 ZooKeeperServer [INFO] Server environment:java.vendor=Sun Microsystems Inc.
- 2014-03-27 23:57:57 ZooKeeperServer [INFO] Server environment:java.home=/usr/java/jdk1.6.0_32/jre
- 2014-03-27 23:57:57 ZooKeeperServer [INFO] Server environment:java.class.path=/home/cloudera/Samza/test/incubator-samza/samza-test/build/classes/test:/home/cloudera/Samza/test/incubator-samza/samza-test/build/resources/test:/home/cloudera/Samza/test/incubator-samza/samza-test/build/classes/main:/home/cloudera/Samza/test/incubator-samza/samza-test/build/resources/main:/home/cloudera/Samza/test/incubator-samza/samza-kafka/lib/kafka_2.10-0.8.1-SNAPSHOT-test.jar:/home/cloudera/Samza/test/incubator-samza/samza-api/build/libs/samza-api-0.7.0.jar:/home/cloudera/Samza/test/incubator-samza/samza-kv/build/libs/samza-kv_2.10-0.7.0.jar:/home/cloudera/Samza/test/incubator-samza/samza-core/build/libs/samza-core_2.10-0.7.0.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/org.scala-lang/scala-library/2.10.2/jar/6ba65d12cd09d441083262d6f73d2257fec7c663/scala-library-2.10.2.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/org.clapper/grizzled-slf4j_2.10/1.0.1/jar/d8f077e85b5bd94c1593b999b7e6e6b0229ce4e9/grizzled-slf4j_2.10-1.0.1.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/net.sf.jopt-simple/jopt-simple/3.2/jar/d625f12ba08083c8c16dcedd5396ec730e9e77ab/jopt-simple-3.2.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/javax.mail/mail/1.4/jar/1aa1579ae5ecd41920c4f355b0a9ef40b68315dd/mail-1.4.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/junit/junit/4.8.1/jar/f2975548f836416306ef1dee748d956f04733915/junit-4.8.1.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/org.apache.kafka/kafka_2.10/0.8.1/jar/e02ec8d14a189a6e80890b4ca93dcb27c5a2dbf6/kafka_2.10-0.8.1.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/com.101tec/zkclient/0.3/jar/dedcf2b53fb742adba7080ac3aed781694ba616e/zkclient-0.3.jar:/home/cloudera/Samza/test/incubator-samza/samza-kafka/build/libs/samza-kafka_2.10-0.7.0.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/org.slf4j/slf4j-simple/1.6.2/jar/95bfd2d7c46bca76886989fcbb1d1b58dfbfd0a6/slf4j-simple-1.6.2.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/org.slf4j/slf4j-api/1.7.2/jar/81d61b7f33ebeab314e07de0cc596f8e858d97/slf4j-api-1.7.2.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/org.codehaus.jackson/jackson-core-asl/1.8.5/jar/713a5564acb9a5467521bbb53221ab8e1fe65039/jackson-core-asl-1.8.5.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/org.codehaus.jackson/jackson-mapper-asl/1.8.5/jar/56439095aa051521c5abb330235820c66886b5e5/jackson-mapper-asl-1.8.5.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/org.codehaus.jackson/jackson-jaxrs/1.8.5/jar/9a808075c5a0422536b9b9209e4da8f887daf693/jackson-jaxrs-1.8.5.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/org.fusesource.leveldbjni/leveldbjni-all/1.8/bundle/707350a2eeb1fa2ed77a32ddb3893ed308e941db/leveldbjni-all-1.8.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/javax.activation/activation/1.1/jar/e6cb541461c2834bdea3eb920f1884d1eb508b50/activation-1.1.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/jline/jline/0.9.94/jar/99a18e9a44834afdebc467294e1138364c207402/jline-0.9.94.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/log4j/log4j/1.2.15/jar/f0a0d2e29ed910808c33135a3a5a51bba6358f7b/log4j-1.2.15.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/org.apache.zookeeper/zookeeper/3.3.4/jar/6471e17c92181da9e143559c4c4779925a5e6eb0/zookeeper-3.3.4.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/com.yammer.metrics/metrics-annotation/2.2.0/jar/62962b54c490a95c0bb255fa93b0ddd6cc36dd4b/metrics-annotation-2.2.0.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/com.yammer.metrics/metrics-core/2.2.0/jar/f82c035cfa786d3cbec362c38c22a5f5b1bc8724/metrics-core-2.2.0.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/org.xerial.snappy/snappy-java/1.0.5/bundle/10cb4550360a0ec6b80f09a5209d00b6058e82bf/snappy-java-1.0.5.jar:/home/cloudera/Samza/test/incubator-samza/samza-serializers/build/libs/samza-serializers_2.10-0.7.0.jar
- 2014-03-27 23:57:57 ZooKeeperServer [INFO] Server environment:java.library.path=/usr/java/jdk1.6.0_32/jre/lib/amd64/server:/usr/java/jdk1.6.0_32/jre/lib/amd64:/usr/java/jdk1.6.0_32/jre/../lib/amd64:/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib
- 2014-03-27 23:57:57 ZooKeeperServer [INFO] Server environment:java.io.tmpdir=/tmp
- 2014-03-27 23:57:57 ZooKeeperServer [INFO] Server environment:java.compiler=<NA>
- 2014-03-27 23:57:57 ZooKeeperServer [INFO] Server environment:os.name=Linux
- 2014-03-27 23:57:57 ZooKeeperServer [INFO] Server environment:os.arch=amd64
- 2014-03-27 23:57:57 ZooKeeperServer [INFO] Server environment:os.version=2.6.32-358.18.1.el6.x86_64
- 2014-03-27 23:57:57 ZooKeeperServer [INFO] Server environment:user.name=cloudera
- 2014-03-27 23:57:57 ZooKeeperServer [INFO] Server environment:user.home=/home/cloudera
- 2014-03-27 23:57:57 ZooKeeperServer [INFO] Server environment:user.dir=/home/cloudera/Samza/test/incubator-samza/samza-test
- 2014-03-27 23:57:57 ZooKeeperServer [INFO] Created server with tickTime 500 minSessionTimeout 1000 maxSessionTimeout 10000 datadir /tmp/kafka-468491/version-2 snapdir /tmp/kafka-533758/version-2
- 2014-03-27 23:57:57 NIOServerCnxn [INFO] binding to port /127.0.0.1:58388
- 2014-03-27 23:57:57 FileTxnSnapLog [INFO] Snapshotting: 0
- 2014-03-27 23:57:57 VerifiableProperties [INFO] Verifying properties
- 2014-03-27 23:57:57 VerifiableProperties [INFO] Property broker.id is overridden to 0
- 2014-03-27 23:57:57 VerifiableProperties [INFO] Property host.name is overridden to localhost
- 2014-03-27 23:57:57 VerifiableProperties [INFO] Property log.dir is overridden to /tmp/kafka-800287
- 2014-03-27 23:57:57 VerifiableProperties [INFO] Property port is overridden to 53077
- 2014-03-27 23:57:57 VerifiableProperties [INFO] Property replica.socket.timeout.ms is overridden to 1500
- 2014-03-27 23:57:57 VerifiableProperties [INFO] Property zookeeper.connect is overridden to 127.0.0.1:58388
- 2014-03-27 23:57:57 KafkaServer [INFO] [Kafka Server 0], starting
- 2014-03-27 23:57:57 KafkaServer [INFO] [Kafka Server 0], Connecting to zookeeper on 127.0.0.1:58388
- 2014-03-27 23:57:57 ZkEventThread [INFO] Starting ZkClient event thread.
- 2014-03-27 23:57:57 ZooKeeper [INFO] Client environment:zookeeper.version=3.3.3-1203054, built on 11/17/2011 05:47 GMT
- 2014-03-27 23:57:57 ZooKeeper [INFO] Client environment:host.name=localhost.localdomain
- 2014-03-27 23:57:57 ZooKeeper [INFO] Client environment:java.version=1.6.0_32
- 2014-03-27 23:57:57 ZooKeeper [INFO] Client environment:java.vendor=Sun Microsystems Inc.
- 2014-03-27 23:57:57 ZooKeeper [INFO] Client environment:java.home=/usr/java/jdk1.6.0_32/jre
- 2014-03-27 23:57:57 ZooKeeper [INFO] Client environment:java.class.path=/home/cloudera/Samza/test/incubator-samza/samza-test/build/classes/test:/home/cloudera/Samza/test/incubator-samza/samza-test/build/resources/test:/home/cloudera/Samza/test/incubator-samza/samza-test/build/classes/main:/home/cloudera/Samza/test/incubator-samza/samza-test/build/resources/main:/home/cloudera/Samza/test/incubator-samza/samza-kafka/lib/kafka_2.10-0.8.1-SNAPSHOT-test.jar:/home/cloudera/Samza/test/incubator-samza/samza-api/build/libs/samza-api-0.7.0.jar:/home/cloudera/Samza/test/incubator-samza/samza-kv/build/libs/samza-kv_2.10-0.7.0.jar:/home/cloudera/Samza/test/incubator-samza/samza-core/build/libs/samza-core_2.10-0.7.0.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/org.scala-lang/scala-library/2.10.2/jar/6ba65d12cd09d441083262d6f73d2257fec7c663/scala-library-2.10.2.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/org.clapper/grizzled-slf4j_2.10/1.0.1/jar/d8f077e85b5bd94c1593b999b7e6e6b0229ce4e9/grizzled-slf4j_2.10-1.0.1.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/net.sf.jopt-simple/jopt-simple/3.2/jar/d625f12ba08083c8c16dcedd5396ec730e9e77ab/jopt-simple-3.2.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/javax.mail/mail/1.4/jar/1aa1579ae5ecd41920c4f355b0a9ef40b68315dd/mail-1.4.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/junit/junit/4.8.1/jar/f2975548f836416306ef1dee748d956f04733915/junit-4.8.1.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/org.apache.kafka/kafka_2.10/0.8.1/jar/e02ec8d14a189a6e80890b4ca93dcb27c5a2dbf6/kafka_2.10-0.8.1.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/com.101tec/zkclient/0.3/jar/dedcf2b53fb742adba7080ac3aed781694ba616e/zkclient-0.3.jar:/home/cloudera/Samza/test/incubator-samza/samza-kafka/build/libs/samza-kafka_2.10-0.7.0.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/org.slf4j/slf4j-simple/1.6.2/jar/95bfd2d7c46bca76886989fcbb1d1b58dfbfd0a6/slf4j-simple-1.6.2.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/org.slf4j/slf4j-api/1.7.2/jar/81d61b7f33ebeab314e07de0cc596f8e858d97/slf4j-api-1.7.2.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/org.codehaus.jackson/jackson-core-asl/1.8.5/jar/713a5564acb9a5467521bbb53221ab8e1fe65039/jackson-core-asl-1.8.5.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/org.codehaus.jackson/jackson-mapper-asl/1.8.5/jar/56439095aa051521c5abb330235820c66886b5e5/jackson-mapper-asl-1.8.5.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/org.codehaus.jackson/jackson-jaxrs/1.8.5/jar/9a808075c5a0422536b9b9209e4da8f887daf693/jackson-jaxrs-1.8.5.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/org.fusesource.leveldbjni/leveldbjni-all/1.8/bundle/707350a2eeb1fa2ed77a32ddb3893ed308e941db/leveldbjni-all-1.8.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/javax.activation/activation/1.1/jar/e6cb541461c2834bdea3eb920f1884d1eb508b50/activation-1.1.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/jline/jline/0.9.94/jar/99a18e9a44834afdebc467294e1138364c207402/jline-0.9.94.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/log4j/log4j/1.2.15/jar/f0a0d2e29ed910808c33135a3a5a51bba6358f7b/log4j-1.2.15.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/org.apache.zookeeper/zookeeper/3.3.4/jar/6471e17c92181da9e143559c4c4779925a5e6eb0/zookeeper-3.3.4.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/com.yammer.metrics/metrics-annotation/2.2.0/jar/62962b54c490a95c0bb255fa93b0ddd6cc36dd4b/metrics-annotation-2.2.0.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/com.yammer.metrics/metrics-core/2.2.0/jar/f82c035cfa786d3cbec362c38c22a5f5b1bc8724/metrics-core-2.2.0.jar:/home/cloudera/.gradle/caches/artifacts-24/filestore/org.xerial.snappy/snappy-java/1.0.5/bundle/10cb4550360a0ec6b80f09a5209d00b6058e82bf/snappy-java-1.0.5.jar:/home/cloudera/Samza/test/incubator-samza/samza-serializers/build/libs/samza-serializers_2.10-0.7.0.jar
- 2014-03-27 23:57:57 ZooKeeper [INFO] Client environment:java.library.path=/usr/java/jdk1.6.0_32/jre/lib/amd64/server:/usr/java/jdk1.6.0_32/jre/lib/amd64:/usr/java/jdk1.6.0_32/jre/../lib/amd64:/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib
- 2014-03-27 23:57:57 ZooKeeper [INFO] Client environment:java.io.tmpdir=/tmp
- 2014-03-27 23:57:57 ZooKeeper [INFO] Client environment:java.compiler=<NA>
- 2014-03-27 23:57:57 ZooKeeper [INFO] Client environment:os.name=Linux
- 2014-03-27 23:57:57 ZooKeeper [INFO] Client environment:os.arch=amd64
- 2014-03-27 23:57:57 ZooKeeper [INFO] Client environment:os.version=2.6.32-358.18.1.el6.x86_64
- 2014-03-27 23:57:57 ZooKeeper [INFO] Client environment:user.name=cloudera
- 2014-03-27 23:57:57 ZooKeeper [INFO] Client environment:user.home=/home/cloudera
- 2014-03-27 23:57:57 ZooKeeper [INFO] Client environment:user.dir=/home/cloudera/Samza/test/incubator-samza/samza-test
- 2014-03-27 23:57:57 ZooKeeper [INFO] Initiating client connection, connectString=127.0.0.1:58388 sessionTimeout=6000 watcher=org.I0Itec.zkclient.ZkClient@396cbd97
- 2014-03-27 23:57:57 ClientCnxn [INFO] Opening socket connection to server /127.0.0.1:58388
- 2014-03-27 23:57:57 NIOServerCnxn [INFO] Accepted socket connection from /127.0.0.1:34245
- 2014-03-27 23:57:57 ClientCnxn [INFO] Socket connection established to localhost.localdomain/127.0.0.1:58388, initiating session
- 2014-03-27 23:57:57 NIOServerCnxn [INFO] Client attempting to establish new session at /127.0.0.1:34245
- 2014-03-27 23:57:57 FileTxnLog [INFO] Creating new log file: log.1
- 2014-03-27 23:57:57 ClientCnxn [INFO] Session establishment complete on server localhost.localdomain/127.0.0.1:58388, sessionid = 0x145077b11ca0000, negotiated timeout = 6000
- 2014-03-27 23:57:57 ZkClient [INFO] zookeeper state changed (SyncConnected)
- 2014-03-27 23:57:57 NIOServerCnxn [INFO] Established session 0x145077b11ca0000 with negotiated timeout 6000 for client /127.0.0.1:34245
- 2014-03-27 23:57:57 PrepRequestProcessor [INFO] Got user-level KeeperException when processing sessionid:0x145077b11ca0000 type:create cxid:0x4 zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a Error Path:/brokers Error:KeeperErrorCode = NoNode for /brokers
- 2014-03-27 23:57:57 PrepRequestProcessor [INFO] Got user-level KeeperException when processing sessionid:0x145077b11ca0000 type:create cxid:0xa zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a Error Path:/config Error:KeeperErrorCode = NoNode for /config
- 2014-03-27 23:57:57 PrepRequestProcessor [INFO] Got user-level KeeperException when processing sessionid:0x145077b11ca0000 type:create cxid:0x10 zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a Error Path:/admin Error:KeeperErrorCode = NoNode for /admin
- 2014-03-27 23:57:57 LogManager [INFO] Starting log cleanup with a period of 300000 ms.
- 2014-03-27 23:57:57 LogManager [INFO] Starting log flusher with a default period of 9223372036854775807 ms.
- 2014-03-27 23:57:57 Acceptor [INFO] Awaiting socket connections on localhost:53077.
- 2014-03-27 23:57:57 SocketServer [INFO] [Socket Server on Broker 0], Started
- 2014-03-27 23:57:58 Mx4jLoader$ [INFO] Will not load MX4J, mx4j-tools.jar is not in the classpath
- 2014-03-27 23:57:58 KafkaController [INFO] [Controller 0]: Controller starting up
- 2014-03-27 23:57:58 ZookeeperLeaderElector [INFO] 0 successfully elected as leader
- 2014-03-27 23:57:58 KafkaController [INFO] [Controller 0]: Broker 0 starting become controller state transition
- 2014-03-27 23:57:58 PrepRequestProcessor [INFO] Got user-level KeeperException when processing sessionid:0x145077b11ca0000 type:setData cxid:0x1a zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a Error Path:/controller_epoch Error:KeeperErrorCode = NoNode for /controller_epoch
- 2014-03-27 23:57:58 KafkaController [INFO] [Controller 0]: Controller 0 incremented epoch to 1
- 2014-03-27 23:57:58 KafkaController [INFO] [Controller 0]: Partitions undergoing preferred replica election:
- 2014-03-27 23:57:58 KafkaController [INFO] [Controller 0]: Partitions that completed preferred replica election:
- 2014-03-27 23:57:58 KafkaController [INFO] [Controller 0]: Resuming preferred replica election for partitions:
- 2014-03-27 23:57:58 KafkaController [INFO] [Controller 0]: Partitions being reassigned: Map()
- 2014-03-27 23:57:58 KafkaController [INFO] [Controller 0]: Partitions already reassigned: List()
- 2014-03-27 23:57:58 KafkaController [INFO] [Controller 0]: Resuming reassignment of partitions: Map()
- 2014-03-27 23:57:58 KafkaController [INFO] [Controller 0]: List of topics to be deleted:
- 2014-03-27 23:57:58 KafkaController [INFO] [Controller 0]: List of topics ineligible for deletion:
- 2014-03-27 23:57:58 KafkaController [INFO] [Controller 0]: Currently active brokers in the cluster: Set()
- 2014-03-27 23:57:58 KafkaController [INFO] [Controller 0]: Currently shutting brokers in the cluster: Set()
- 2014-03-27 23:57:58 KafkaController [INFO] [Controller 0]: Current list of topics in the cluster: Set()
- 2014-03-27 23:57:58 ReplicaStateMachine [INFO] [Replica state machine on controller 0]: Started replica state machine with initial state -> Map()
- 2014-03-27 23:57:58 PartitionStateMachine [INFO] [Partition state machine on Controller 0]: Started partition state machine with initial state -> Map()
- 2014-03-27 23:57:58 KafkaController [INFO] [Controller 0]: Broker 0 is ready to serve as the new controller with epoch 1
- 2014-03-27 23:57:58 KafkaController [INFO] [Controller 0]: Starting preferred replica leader election for partitions
- 2014-03-27 23:57:58 PartitionStateMachine [INFO] [Partition state machine on Controller 0]: Invoking state change to OnlinePartition for partitions
- 2014-03-27 23:57:58 KafkaController [INFO] [Controller 0]: Controller startup complete
- 2014-03-27 23:57:58 TopicDeletionManager$DeleteTopicsThread [INFO] [delete-topics-thread], Starting
- 2014-03-27 23:57:58 ZkUtils$ [INFO] Registered broker 0 at path /brokers/ids/0 with address localhost:53077.
- 2014-03-27 23:57:58 KafkaServer [INFO] [Kafka Server 0], started
- 2014-03-27 23:57:58 VerifiableProperties [INFO] Verifying properties
- 2014-03-27 23:57:58 VerifiableProperties [INFO] Property broker.id is overridden to 1
- 2014-03-27 23:57:58 VerifiableProperties [INFO] Property host.name is overridden to localhost
- 2014-03-27 23:57:58 VerifiableProperties [INFO] Property log.dir is overridden to /tmp/kafka-718481
- 2014-03-27 23:57:58 VerifiableProperties [INFO] Property port is overridden to 45727
- 2014-03-27 23:57:58 VerifiableProperties [INFO] Property replica.socket.timeout.ms is overridden to 1500
- 2014-03-27 23:57:58 VerifiableProperties [INFO] Property zookeeper.connect is overridden to 127.0.0.1:58388
- 2014-03-27 23:57:58 KafkaServer [INFO] [Kafka Server 1], starting
- 2014-03-27 23:57:58 KafkaServer [INFO] [Kafka Server 1], Connecting to zookeeper on 127.0.0.1:58388
- 2014-03-27 23:57:58 ZooKeeper [INFO] Initiating client connection, connectString=127.0.0.1:58388 sessionTimeout=6000 watcher=org.I0Itec.zkclient.ZkClient@31ca1a68
- 2014-03-27 23:57:58 ZkEventThread [INFO] Starting ZkClient event thread.
- 2014-03-27 23:57:58 ClientCnxn [INFO] Opening socket connection to server /127.0.0.1:58388
- 2014-03-27 23:57:58 NIOServerCnxn [INFO] Accepted socket connection from /127.0.0.1:34246
- 2014-03-27 23:57:58 ClientCnxn [INFO] Socket connection established to localhost.localdomain/127.0.0.1:58388, initiating session
- 2014-03-27 23:57:58 NIOServerCnxn [INFO] Client attempting to establish new session at /127.0.0.1:34246
- 2014-03-27 23:57:58 NIOServerCnxn [INFO] Established session 0x145077b11ca0001 with negotiated timeout 6000 for client /127.0.0.1:34246
- 2014-03-27 23:57:58 ClientCnxn [INFO] Session establishment complete on server localhost.localdomain/127.0.0.1:58388, sessionid = 0x145077b11ca0001, negotiated timeout = 6000
- 2014-03-27 23:57:58 ZkClient [INFO] zookeeper state changed (SyncConnected)
- 2014-03-27 23:57:58 LogManager [INFO] Starting log cleanup with a period of 300000 ms.
- 2014-03-27 23:57:58 LogManager [INFO] Starting log flusher with a default period of 9223372036854775807 ms.
- 2014-03-27 23:57:58 Acceptor [INFO] Awaiting socket connections on localhost:45727.
- 2014-03-27 23:57:58 SocketServer [INFO] [Socket Server on Broker 1], Started
- 2014-03-27 23:57:58 ControllerEpochListener [INFO] [ControllerEpochListener on 1]: Initialized controller epoch to 1 and zk version 0
- 2014-03-27 23:57:58 Mx4jLoader$ [INFO] Will not load MX4J, mx4j-tools.jar is not in the classpath
- 2014-03-27 23:57:58 KafkaController [INFO] [Controller 1]: Controller starting up
- 2014-03-27 23:57:58 PrepRequestProcessor [INFO] Got user-level KeeperException when processing sessionid:0x145077b11ca0001 type:create cxid:0xc zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a Error Path:/controller Error:KeeperErrorCode = NodeExists for /controller
- 2014-03-27 23:57:58 ZkUtils$ [INFO] conflict in /controller data: {"version":1,"brokerid":1,"timestamp":"1395989878638"} stored data: {"version":1,"brokerid":0,"timestamp":"1395989878272"}
- 2014-03-27 23:57:58 ZookeeperLeaderElector$LeaderChangeListener [INFO] New leader is 0
- 2014-03-27 23:57:58 TopicDeletionManager [INFO] Waiting for signal to start or continue topic deletion
- 2014-03-27 23:57:58 ControllerEpochListener [INFO] [ControllerEpochListener on 0]: Initialized controller epoch to 1 and zk version 0
- 2014-03-27 23:57:58 ReplicaStateMachine$BrokerChangeListener [INFO] [BrokerChangeListener on Controller 0]: Broker change listener fired for path /brokers/ids with children 0
- 2014-03-27 23:57:58 KafkaController [INFO] [Controller 1]: Controller startup complete
- 2014-03-27 23:57:58 ZkUtils$ [INFO] Registered broker 1 at path /brokers/ids/1 with address localhost:45727.
- 2014-03-27 23:57:58 KafkaServer [INFO] [Kafka Server 1], started
- 2014-03-27 23:57:58 VerifiableProperties [INFO] Verifying properties
- 2014-03-27 23:57:58 VerifiableProperties [INFO] Property broker.id is overridden to 2
- 2014-03-27 23:57:58 VerifiableProperties [INFO] Property host.name is overridden to localhost
- 2014-03-27 23:57:58 VerifiableProperties [INFO] Property log.dir is overridden to /tmp/kafka-318049
- 2014-03-27 23:57:58 VerifiableProperties [INFO] Property port is overridden to 36283
- 2014-03-27 23:57:58 VerifiableProperties [INFO] Property replica.socket.timeout.ms is overridden to 1500
- 2014-03-27 23:57:58 VerifiableProperties [INFO] Property zookeeper.connect is overridden to 127.0.0.1:58388
- 2014-03-27 23:57:58 KafkaServer [INFO] [Kafka Server 2], starting
- 2014-03-27 23:57:58 KafkaServer [INFO] [Kafka Server 2], Connecting to zookeeper on 127.0.0.1:58388
- 2014-03-27 23:57:58 ZooKeeper [INFO] Initiating client connection, connectString=127.0.0.1:58388 sessionTimeout=6000 watcher=org.I0Itec.zkclient.ZkClient@53933acb
- 2014-03-27 23:57:58 ZkEventThread [INFO] Starting ZkClient event thread.
- 2014-03-27 23:57:58 ClientCnxn [INFO] Opening socket connection to server /127.0.0.1:58388
- 2014-03-27 23:57:58 NIOServerCnxn [INFO] Accepted socket connection from /127.0.0.1:34247
- 2014-03-27 23:57:58 ClientCnxn [INFO] Socket connection established to localhost.localdomain/127.0.0.1:58388, initiating session
- 2014-03-27 23:57:58 NIOServerCnxn [INFO] Client attempting to establish new session at /127.0.0.1:34247
- 2014-03-27 23:57:58 NIOServerCnxn [INFO] Established session 0x145077b11ca0002 with negotiated timeout 6000 for client /127.0.0.1:34247
- 2014-03-27 23:57:58 ClientCnxn [INFO] Session establishment complete on server localhost.localdomain/127.0.0.1:58388, sessionid = 0x145077b11ca0002, negotiated timeout = 6000
- 2014-03-27 23:57:58 ZkClient [INFO] zookeeper state changed (SyncConnected)
- 2014-03-27 23:57:58 LogManager [INFO] Starting log cleanup with a period of 300000 ms.
- 2014-03-27 23:57:58 LogManager [INFO] Starting log flusher with a default period of 9223372036854775807 ms.
- 2014-03-27 23:57:59 Acceptor [INFO] Awaiting socket connections on localhost:36283.
- 2014-03-27 23:57:59 SocketServer [INFO] [Socket Server on Broker 2], Started
- 2014-03-27 23:57:59 ControllerEpochListener [INFO] [ControllerEpochListener on 2]: Initialized controller epoch to 1 and zk version 0
- 2014-03-27 23:57:59 Mx4jLoader$ [INFO] Will not load MX4J, mx4j-tools.jar is not in the classpath
- 2014-03-27 23:57:59 KafkaController [INFO] [Controller 2]: Controller starting up
- 2014-03-27 23:57:59 ReplicaStateMachine$BrokerChangeListener [INFO] [BrokerChangeListener on Controller 0]: Newly added brokers: 0, deleted brokers: , all live brokers: 0
- 2014-03-27 23:57:59 PrepRequestProcessor [INFO] Got user-level KeeperException when processing sessionid:0x145077b11ca0002 type:create cxid:0xc zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a Error Path:/controller Error:KeeperErrorCode = NodeExists for /controller
- 2014-03-27 23:57:59 ZkUtils$ [INFO] conflict in /controller data: {"version":1,"brokerid":2,"timestamp":"1395989879021"} stored data: {"version":1,"brokerid":0,"timestamp":"1395989878272"}
- 2014-03-27 23:57:59 RequestSendThread [INFO] [Controller-0-to-broker-0-send-thread], Controller 0 connected to id:0,host:localhost,port:53077 for sending state change requests
- 2014-03-27 23:57:59 KafkaController [INFO] [Controller 0]: New broker startup callback for 0
- 2014-03-27 23:57:59 RequestSendThread [INFO] [Controller-0-to-broker-0-send-thread], Starting
- 2014-03-27 23:57:59 ReplicaStateMachine$BrokerChangeListener [INFO] [BrokerChangeListener on Controller 0]: Broker change listener fired for path /brokers/ids with children 1,0
- 2014-03-27 23:57:59 KafkaController [INFO] [Controller 2]: Controller startup complete
- 2014-03-27 23:57:59 ZkUtils$ [INFO] Registered broker 2 at path /brokers/ids/2 with address localhost:36283.
- 2014-03-27 23:57:59 KafkaServer [INFO] [Kafka Server 2], started
- 2014-03-27 23:57:59 ZooKeeper [INFO] Initiating client connection, connectString=127.0.0.1:58388/ sessionTimeout=6000 watcher=org.I0Itec.zkclient.ZkClient@5f0275fa
- 2014-03-27 23:57:59 ZkEventThread [INFO] Starting ZkClient event thread.
- 2014-03-27 23:57:59 ClientCnxn [INFO] Opening socket connection to server /127.0.0.1:58388
- 2014-03-27 23:57:59 NIOServerCnxn [INFO] Accepted socket connection from /127.0.0.1:34249
- 2014-03-27 23:57:59 ClientCnxn [INFO] Socket connection established to localhost.localdomain/127.0.0.1:58388, initiating session
- 2014-03-27 23:57:59 NIOServerCnxn [INFO] Client attempting to establish new session at /127.0.0.1:34249
- 2014-03-27 23:57:59 NIOServerCnxn [INFO] Established session 0x145077b11ca0003 with negotiated timeout 6000 for client /127.0.0.1:34249
- 2014-03-27 23:57:59 ClientCnxn [INFO] Session establishment complete on server localhost.localdomain/127.0.0.1:58388, sessionid = 0x145077b11ca0003, negotiated timeout = 6000
- 2014-03-27 23:57:59 ZkClient [INFO] zookeeper state changed (SyncConnected)
- 2014-03-27 23:57:59 ReplicaStateMachine$BrokerChangeListener [INFO] [BrokerChangeListener on Controller 0]: Newly added brokers: 1, deleted brokers: , all live brokers: 1,0
- 2014-03-27 23:57:59 RequestSendThread [INFO] [Controller-0-to-broker-1-send-thread], Controller 0 connected to id:1,host:localhost,port:45727 for sending state change requests
- 2014-03-27 23:57:59 KafkaController [INFO] [Controller 0]: New broker startup callback for 1
- 2014-03-27 23:57:59 ReplicaStateMachine$BrokerChangeListener [INFO] [BrokerChangeListener on Controller 0]: Broker change listener fired for path /brokers/ids with children 2,1,0
- 2014-03-27 23:57:59 RequestSendThread [INFO] [Controller-0-to-broker-1-send-thread], Starting
- 2014-03-27 23:57:59 PrepRequestProcessor [INFO] Got user-level KeeperException when processing sessionid:0x145077b11ca0003 type:setData cxid:0x3 zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a Error Path:/config/topics/input Error:KeeperErrorCode = NoNode for /config/topics/input
- 2014-03-27 23:57:59 PrepRequestProcessor [INFO] Got user-level KeeperException when processing sessionid:0x145077b11ca0003 type:create cxid:0x4 zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a Error Path:/config/topics Error:KeeperErrorCode = NodeExists for /config/topics
- 2014-03-27 23:57:59 AdminUtils$ [INFO] Topic creation {"version":1,"partitions":{"0":[0,2,1]}}
- 2014-03-27 23:57:59 PrepRequestProcessor [INFO] Got user-level KeeperException when processing sessionid:0x145077b11ca0003 type:setData cxid:0x9 zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a Error Path:/config/topics/mystore Error:KeeperErrorCode = NoNode for /config/topics/mystore
- 2014-03-27 23:57:59 PrepRequestProcessor [INFO] Got user-level KeeperException when processing sessionid:0x145077b11ca0003 type:create cxid:0xa zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a Error Path:/config/topics Error:KeeperErrorCode = NodeExists for /config/topics
- 2014-03-27 23:57:59 AdminUtils$ [INFO] Topic creation {"version":1,"partitions":{"0":[0,1,2]}}
- 2014-03-27 23:57:59 VerifiableProperties [INFO] Verifying properties
- 2014-03-27 23:57:59 VerifiableProperties [INFO] Property client.id is overridden to some-job-name
- 2014-03-27 23:57:59 VerifiableProperties [INFO] Property metadata.broker.list is overridden to localhost:53077,localhost:45727,localhost:36283
- 2014-03-27 23:57:59 VerifiableProperties [INFO] Property request.timeout.ms is overridden to 6000
- 2014-03-27 23:57:59 ReplicaStateMachine$BrokerChangeListener [INFO] [BrokerChangeListener on Controller 0]: Newly added brokers: 2, deleted brokers: , all live brokers: 2,1,0
- 2014-03-27 23:57:59 RequestSendThread [INFO] [Controller-0-to-broker-2-send-thread], Controller 0 connected to id:2,host:localhost,port:36283 for sending state change requests
- 2014-03-27 23:57:59 KafkaController [INFO] [Controller 0]: New broker startup callback for 2
- 2014-03-27 23:57:59 RequestSendThread [INFO] [Controller-0-to-broker-2-send-thread], Starting
- 2014-03-27 23:57:59 ClientUtils$ [INFO] Fetching metadata from broker id:0,host:localhost,port:53077 with correlation id 0 for 2 topic(s) Set(mystore, input)
- 2014-03-27 23:57:59 SyncProducer [INFO] Connected to localhost:53077 for producing
- 2014-03-27 23:57:59 PartitionStateMachine$TopicChangeListener [INFO] [TopicChangeListener on Controller 0]: New topics: [Set(input, mystore)], deleted topics: [Set()], new partition replica assignment [Map([mystore,0] -> List(0, 1, 2), [input,0] -> List(0, 2, 1))]
- 2014-03-27 23:57:59 KafkaController [INFO] [Controller 0]: New topic creation callback for [mystore,0],[input,0]
- 2014-03-27 23:57:59 KafkaController [INFO] [Controller 0]: New partition creation callback for [mystore,0],[input,0]
- 2014-03-27 23:57:59 PartitionStateMachine [INFO] [Partition state machine on Controller 0]: Invoking state change to NewPartition for partitions [mystore,0],[input,0]
- 2014-03-27 23:57:59 ReplicaStateMachine [INFO] [Replica state machine on controller 0]: Invoking state change to NewReplica for replicas [Topic=mystore,Partition=0,Replica=2],[Topic=input,Partition=0,Replica=2],[Topic=input,Partition=0,Replica=1],[Topic=input,Partition=0,Replica=0],[Topic=mystore,Partition=0,Replica=0],[Topic=mystore,Partition=0,Replica=1]
- 2014-03-27 23:57:59 PartitionStateMachine [INFO] [Partition state machine on Controller 0]: Invoking state change to OnlinePartition for partitions [mystore,0],[input,0]
- 2014-03-27 23:57:59 PrepRequestProcessor [INFO] Got user-level KeeperException when processing sessionid:0x145077b11ca0000 type:create cxid:0x53 zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a Error Path:/brokers/topics/mystore/partitions/0 Error:KeeperErrorCode = NoNode for /brokers/topics/mystore/partitions/0
- 2014-03-27 23:57:59 PrepRequestProcessor [INFO] Got user-level KeeperException when processing sessionid:0x145077b11ca0000 type:create cxid:0x54 zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a Error Path:/brokers/topics/mystore/partitions Error:KeeperErrorCode = NoNode for /brokers/topics/mystore/partitions
- 2014-03-27 23:57:59 PrepRequestProcessor [INFO] Got user-level KeeperException when processing sessionid:0x145077b11ca0000 type:create cxid:0x58 zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a Error Path:/brokers/topics/input/partitions/0 Error:KeeperErrorCode = NoNode for /brokers/topics/input/partitions/0
- 2014-03-27 23:57:59 PrepRequestProcessor [INFO] Got user-level KeeperException when processing sessionid:0x145077b11ca0000 type:create cxid:0x59 zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a Error Path:/brokers/topics/input/partitions Error:KeeperErrorCode = NoNode for /brokers/topics/input/partitions
- 2014-03-27 23:58:00 SyncProducer [INFO] Disconnecting from localhost:53077
- 2014-03-27 23:58:00 ReplicaStateMachine [INFO] [Replica state machine on controller 0]: Invoking state change to OnlineReplica for replicas [Topic=mystore,Partition=0,Replica=2],[Topic=input,Partition=0,Replica=2],[Topic=input,Partition=0,Replica=1],[Topic=input,Partition=0,Replica=0],[Topic=mystore,Partition=0,Replica=0],[Topic=mystore,Partition=0,Replica=1]
- 2014-03-27 23:58:00 ReplicaFetcherManager [INFO] [ReplicaFetcherManager on broker 0] Removed fetcher for partitions [mystore,0],[input,0]
- 2014-03-27 23:58:00 Processor [INFO] Closing socket connection to /127.0.0.1.
- 2014-03-27 23:58:00 Log [INFO] Completed load of log mystore-0 with log end offset 0
- 2014-03-27 23:58:00 LogManager [INFO] Created log for partition [mystore,0] in /tmp/kafka-318049 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 -> 9223372036854775807, min.cleanable.dirty.ratio -> 0.5, retention.ms -> 604800000}.
- 2014-03-27 23:58:00 Partition [WARN] Partition [mystore,0] on broker 2: No checkpointed highwatermark is found for partition [mystore,0]
- 2014-03-27 23:58:00 Log [INFO] Completed load of log mystore-0 with log end offset 0
- 2014-03-27 23:58:00 Log [INFO] Completed load of log mystore-0 with log end offset 0
- 2014-03-27 23:58:00 LogManager [INFO] Created log for partition [mystore,0] in /tmp/kafka-800287 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 -> 9223372036854775807, min.cleanable.dirty.ratio -> 0.5, retention.ms -> 604800000}.
- 2014-03-27 23:58:00 LogManager [INFO] Created log for partition [mystore,0] in /tmp/kafka-718481 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 -> 9223372036854775807, min.cleanable.dirty.ratio -> 0.5, retention.ms -> 604800000}.
- 2014-03-27 23:58:00 Partition [WARN] Partition [mystore,0] on broker 1: No checkpointed highwatermark is found for partition [mystore,0]
- 2014-03-27 23:58:00 Partition [WARN] Partition [mystore,0] on broker 0: No checkpointed highwatermark is found for partition [mystore,0]
- 2014-03-27 23:58:00 Log [INFO] Completed load of log input-0 with log end offset 0
- 2014-03-27 23:58:00 LogManager [INFO] Created log for partition [input,0] in /tmp/kafka-718481 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 -> 9223372036854775807, min.cleanable.dirty.ratio -> 0.5, retention.ms -> 604800000}.
- 2014-03-27 23:58:00 Partition [WARN] Partition [input,0] on broker 1: No checkpointed highwatermark is found for partition [input,0]
- 2014-03-27 23:58:00 Log [INFO] Completed load of log input-0 with log end offset 0
- 2014-03-27 23:58:00 LogManager [INFO] Created log for partition [input,0] in /tmp/kafka-318049 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 -> 9223372036854775807, min.cleanable.dirty.ratio -> 0.5, retention.ms -> 604800000}.
- 2014-03-27 23:58:00 Partition [WARN] Partition [input,0] on broker 2: No checkpointed highwatermark is found for partition [input,0]
- 2014-03-27 23:58:00 ReplicaFetcherManager [INFO] [ReplicaFetcherManager on broker 2] Removed fetcher for partitions [mystore,0],[input,0]
- 2014-03-27 23:58:00 ReplicaFetcherManager [INFO] [ReplicaFetcherManager on broker 1] Removed fetcher for partitions [mystore,0],[input,0]
- 2014-03-27 23:58:00 Log [INFO] Truncating log mystore-0 to offset 0.
- 2014-03-27 23:58:00 Log [INFO] Truncating log mystore-0 to offset 0.
- 2014-03-27 23:58:00 Log [INFO] Truncating log input-0 to offset 0.
- 2014-03-27 23:58:00 Log [INFO] Completed load of log input-0 with log end offset 0
- 2014-03-27 23:58:00 LogManager [INFO] Created log for partition [input,0] in /tmp/kafka-800287 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 -> 9223372036854775807, min.cleanable.dirty.ratio -> 0.5, retention.ms -> 604800000}.
- 2014-03-27 23:58:00 Partition [WARN] Partition [input,0] on broker 0: No checkpointed highwatermark is found for partition [input,0]
- 2014-03-27 23:58:00 Log [INFO] Truncating log input-0 to offset 0.
- 2014-03-27 23:58:00 ReplicaFetcherThread [INFO] [ReplicaFetcherThread-0-0], Starting
- 2014-03-27 23:58:00 ReplicaFetcherThread [INFO] [ReplicaFetcherThread-0-0], Starting
- 2014-03-27 23:58:00 ReplicaFetcherManager [INFO] [ReplicaFetcherManager on broker 1] Added fetcher for partitions ArrayBuffer([[input,0], initOffset 0 to broker id:0,host:localhost,port:53077] , [[mystore,0], initOffset 0 to broker id:0,host:localhost,port:53077] )
- 2014-03-27 23:58:00 ReplicaFetcherManager [INFO] [ReplicaFetcherManager on broker 2] Added fetcher for partitions ArrayBuffer([[input,0], initOffset 0 to broker id:0,host:localhost,port:53077] , [[mystore,0], initOffset 0 to broker id:0,host:localhost,port:53077] )
- 2014-03-27 23:58:00 VerifiableProperties [INFO] Verifying properties
- 2014-03-27 23:58:00 VerifiableProperties [INFO] Property client.id is overridden to some-job-name
- 2014-03-27 23:58:00 VerifiableProperties [INFO] Property metadata.broker.list is overridden to localhost:53077,localhost:45727,localhost:36283
- 2014-03-27 23:58:00 VerifiableProperties [INFO] Property request.timeout.ms is overridden to 6000
- 2014-03-27 23:58:00 ClientUtils$ [INFO] Fetching metadata from broker id:2,host:localhost,port:36283 with correlation id 1 for 2 topic(s) Set(mystore, input)
- 2014-03-27 23:58:00 SyncProducer [INFO] Connected to localhost:36283 for producing
- 2014-03-27 23:58:00 SyncProducer [INFO] Disconnecting from localhost:36283
- 2014-03-27 23:58:00 Processor [INFO] Closing socket connection to /127.0.0.1.
- 2014-03-27 23:58:01 VerifiableProperties [INFO] Verifying properties
- 2014-03-27 23:58:01 VerifiableProperties [INFO] Property client.id is overridden to samza_admin-hello_stateful_world-1-1395989881098-0
- 2014-03-27 23:58:01 VerifiableProperties [INFO] Property metadata.broker.list is overridden to localhost:53077
- 2014-03-27 23:58:01 VerifiableProperties [INFO] Verifying properties
- 2014-03-27 23:58:01 VerifiableProperties [INFO] Property auto.offset.reset is overridden to largest
- 2014-03-27 23:58:01 VerifiableProperties [INFO] Property client.id is overridden to samza_admin-hello_stateful_world-1-1395989881098-0
- 2014-03-27 23:58:01 VerifiableProperties [INFO] Property group.id is overridden to undefined-samza-consumer-group-a481dbdc-69ae-4c33-915b-3aaaa5b6ed80
- 2014-03-27 23:58:01 VerifiableProperties [INFO] Property zookeeper.connect is overridden to 127.0.0.1:58388
- 2014-03-27 23:58:01 Processor [INFO] Closing socket connection to /127.0.0.1.
- 2014-03-27 23:58:01 VerifiableProperties [INFO] Verifying properties
- 2014-03-27 23:58:01 VerifiableProperties [INFO] Property client.id is overridden to samza_admin-hello_stateful_world-1-1395989881647-1
- 2014-03-27 23:58:01 VerifiableProperties [INFO] Property metadata.broker.list is overridden to localhost:53077
- 2014-03-27 23:58:01 VerifiableProperties [INFO] Verifying properties
- 2014-03-27 23:58:01 VerifiableProperties [INFO] Property auto.offset.reset is overridden to largest
- 2014-03-27 23:58:01 VerifiableProperties [INFO] Property client.id is overridden to samza_admin-hello_stateful_world-1-1395989881647-1
- 2014-03-27 23:58:01 VerifiableProperties [INFO] Property group.id is overridden to undefined-samza-consumer-group-32895409-f607-4b0a-8d2d-0775f6a82422
- 2014-03-27 23:58:01 VerifiableProperties [INFO] Property zookeeper.connect is overridden to 127.0.0.1:58388
- 2014-03-27 23:58:01 Processor [INFO] Closing socket connection to /127.0.0.1.
- 2014-03-27 23:58:01 VerifiableProperties [INFO] Verifying properties
- 2014-03-27 23:58:01 VerifiableProperties [INFO] Property client.id is overridden to samza_consumer-hello_stateful_world-1-1395989881688-2
- 2014-03-27 23:58:01 VerifiableProperties [INFO] Property metadata.broker.list is overridden to localhost:53077
- 2014-03-27 23:58:01 VerifiableProperties [INFO] Verifying properties
- 2014-03-27 23:58:01 VerifiableProperties [INFO] Property auto.offset.reset is overridden to largest
- 2014-03-27 23:58:01 VerifiableProperties [INFO] Property client.id is overridden to samza_consumer-hello_stateful_world-1-1395989881688-2
- 2014-03-27 23:58:01 VerifiableProperties [INFO] Property group.id is overridden to undefined-samza-consumer-group-00c9e1f6-68cd-417b-8366-f59c4b5c8af3
- 2014-03-27 23:58:01 VerifiableProperties [INFO] Property zookeeper.connect is overridden to 127.0.0.1:58388
- 2014-03-27 23:58:01 VerifiableProperties [INFO] Verifying properties
- 2014-03-27 23:58:01 VerifiableProperties [INFO] Property client.id is overridden to samza_producer-hello_stateful_world-1-1395989881873-3
- 2014-03-27 23:58:01 VerifiableProperties [INFO] Property metadata.broker.list is overridden to localhost:53077
- 2014-03-27 23:58:02 Processor [INFO] Closing socket connection to /127.0.0.1.
- 2014-03-27 23:58:02 VerifiableProperties [INFO] Verifying properties
- 2014-03-27 23:58:02 VerifiableProperties [INFO] Property client.id is overridden to samza_consumer-hello_stateful_world-1-1395989882289-4
- 2014-03-27 23:58:02 VerifiableProperties [INFO] Property metadata.broker.list is overridden to localhost:53077
- 2014-03-27 23:58:02 VerifiableProperties [INFO] Verifying properties
- 2014-03-27 23:58:02 VerifiableProperties [INFO] Property auto.offset.reset is overridden to largest
- 2014-03-27 23:58:02 VerifiableProperties [INFO] Property client.id is overridden to samza_consumer-hello_stateful_world-1-1395989882289-4
- 2014-03-27 23:58:02 VerifiableProperties [INFO] Property group.id is overridden to undefined-samza-consumer-group-a4a7a1c0-3c97-49af-a0df-b06fa24e1bff
- 2014-03-27 23:58:02 VerifiableProperties [INFO] Property zookeeper.connect is overridden to 127.0.0.1:58388
- 2014-03-27 23:58:02 ClientUtils$ [INFO] Fetching metadata from broker id:2,host:localhost,port:36283 with correlation id 0 for 1 topic(s) Set(input)
- 2014-03-27 23:58:02 SyncProducer [INFO] Connected to localhost:36283 for producing
- 2014-03-27 23:58:02 SyncProducer [INFO] Disconnecting from localhost:36283
- 2014-03-27 23:58:02 Processor [INFO] Closing socket connection to /127.0.0.1.
- 2014-03-27 23:58:03 SyncProducer [INFO] Connected to localhost:53077 for producing
- 2014-03-27 23:59:03 KafkaServer [INFO] [Kafka Server 0], shutting down
- 2014-03-27 23:59:03 SocketServer [INFO] [Socket Server on Broker 0], Shutting down
- 2014-03-27 23:59:03 SocketServer [INFO] [Socket Server on Broker 0], Shutdown completed
- 2014-03-27 23:59:03 KafkaRequestHandlerPool [INFO] [Kafka Request Handler on Broker 0], shutting down
- 2014-03-27 23:59:03 KafkaRequestHandlerPool [INFO] [Kafka Request Handler on Broker 0], shut down completely
- 2014-03-27 23:59:03 ReplicaManager [INFO] [Replica Manager on Broker 0]: Shut down
- 2014-03-27 23:59:03 ReplicaFetcherManager [INFO] [ReplicaFetcherManager on broker 0] shutting down
- 2014-03-27 23:59:03 ReplicaFetcherManager [INFO] [ReplicaFetcherManager on broker 0] shutdown completed
- 2014-03-27 23:59:03 ReplicaManager [INFO] [Replica Manager on Broker 0]: Shutted down completely
- 2014-03-27 23:59:03 Processor [INFO] Closing socket connection to /127.0.0.1.
- 2014-03-27 23:59:03 RequestSendThread [INFO] [Controller-0-to-broker-2-send-thread], Shutting down
- 2014-03-27 23:59:03 RequestSendThread [INFO] [Controller-0-to-broker-2-send-thread], Stopped
- 2014-03-27 23:59:03 RequestSendThread [INFO] [Controller-0-to-broker-2-send-thread], Shutdown completed
- 2014-03-27 23:59:03 Processor [INFO] Closing socket connection to /127.0.0.1.
- 2014-03-27 23:59:03 RequestSendThread [INFO] [Controller-0-to-broker-1-send-thread], Shutting down
- 2014-03-27 23:59:03 RequestSendThread [INFO] [Controller-0-to-broker-1-send-thread], Stopped
- 2014-03-27 23:59:03 RequestSendThread [INFO] [Controller-0-to-broker-1-send-thread], Shutdown completed
- 2014-03-27 23:59:03 RequestSendThread [INFO] [Controller-0-to-broker-0-send-thread], Shutting down
- 2014-03-27 23:59:03 RequestSendThread [INFO] [Controller-0-to-broker-0-send-thread], Stopped
- 2014-03-27 23:59:03 RequestSendThread [INFO] [Controller-0-to-broker-0-send-thread], Shutdown completed
- 2014-03-27 23:59:03 KafkaController [INFO] [Controller 0]: Controller shutdown complete
- 2014-03-27 23:59:03 ZkEventThread [INFO] Terminate ZkClient event thread.
- 2014-03-27 23:59:03 PrepRequestProcessor [INFO] Processed session termination for sessionid: 0x145077b11ca0000
- 2014-03-27 23:59:03 NIOServerCnxn [INFO] Closed socket connection for client /127.0.0.1:34245 which had sessionid 0x145077b11ca0000
- 2014-03-27 23:59:03 ZooKeeper [INFO] Session: 0x145077b11ca0000 closed
- 2014-03-27 23:59:03 ClientCnxn [INFO] EventThread shut down
- 2014-03-27 23:59:03 KafkaServer [INFO] [Kafka Server 0], shut down completed
- 2014-03-27 23:59:03 PrepRequestProcessor [INFO] Got user-level KeeperException when processing sessionid:0x145077b11ca0002 type:create cxid:0x19 zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a Error Path:/controller Error:KeeperErrorCode = NodeExists for /controller
- 2014-03-27 23:59:03 KafkaServer [INFO] [Kafka Server 1], shutting down
- 2014-03-27 23:59:03 SocketServer [INFO] [Socket Server on Broker 1], Shutting down
- 2014-03-27 23:59:03 SocketServer [INFO] [Socket Server on Broker 1], Shutdown completed
- 2014-03-27 23:59:03 KafkaRequestHandlerPool [INFO] [Kafka Request Handler on Broker 1], shutting down
- 2014-03-27 23:59:03 KafkaRequestHandlerPool [INFO] [Kafka Request Handler on Broker 1], shut down completely
- 2014-03-27 23:59:03 ZookeeperLeaderElector [INFO] 1 successfully elected as leader
- 2014-03-27 23:59:03 KafkaController [INFO] [Controller 1]: Broker 1 starting become controller state transition
- 2014-03-27 23:59:03 KafkaController [INFO] [Controller 1]: Controller 1 incremented epoch to 2
- 2014-03-27 23:59:03 ZkUtils$ [INFO] conflict in /controller data: {"version":1,"brokerid":2,"timestamp":"1395989943562"} stored data: {"version":1,"brokerid":1,"timestamp":"1395989943567"}
- 2014-03-27 23:59:03 ZookeeperLeaderElector$LeaderChangeListener [INFO] New leader is 1
- 2014-03-27 23:59:03 ControllerEpochListener [INFO] [ControllerEpochListener on 2]: Initialized controller epoch to 2 and zk version 1
- 2014-03-27 23:59:03 RequestSendThread [ERROR] [Controller-1-to-broker-1-send-thread], Controller 1's connection to broker id:1,host:localhost,port:45727 was unsuccessful
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.controller.RequestSendThread.connectToBroker(ControllerChannelManager.scala:173)
- at kafka.controller.RequestSendThread.<init>(ControllerChannelManager.scala:118)
- at kafka.controller.ControllerChannelManager.kafka$controller$ControllerChannelManager$$addNewBroker(ControllerChannelManager.scala:87)
- at kafka.controller.ControllerChannelManager$$anonfun$1.apply(ControllerChannelManager.scala:38)
- at kafka.controller.ControllerChannelManager$$anonfun$1.apply(ControllerChannelManager.scala:38)
- at scala.collection.immutable.Set$Set2.foreach(Set.scala:94)
- at kafka.controller.ControllerChannelManager.<init>(ControllerChannelManager.scala:38)
- at kafka.controller.KafkaController.startChannelManager(KafkaController.scala:776)
- at kafka.controller.KafkaController.initializeControllerContext(KafkaController.scala:704)
- at kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:309)
- at kafka.controller.KafkaController$$anonfun$1.apply$mcV$sp(KafkaController.scala:161)
- at kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:63)
- at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply$mcZ$sp(ZookeeperLeaderElector.scala:123)
- at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply(ZookeeperLeaderElector.scala:118)
- at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply(ZookeeperLeaderElector.scala:118)
- at kafka.utils.Utils$.inLock(Utils.scala:538)
- at kafka.server.ZookeeperLeaderElector$LeaderChangeListener.handleDataDeleted(ZookeeperLeaderElector.scala:118)
- at org.I0Itec.zkclient.ZkClient$6.run(ZkClient.java:549)
- at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
- 2014-03-27 23:59:03 RequestSendThread [INFO] [Controller-1-to-broker-2-send-thread], Controller 1 connected to id:2,host:localhost,port:36283 for sending state change requests
- 2014-03-27 23:59:03 RequestSendThread [INFO] [Controller-1-to-broker-2-send-thread], Starting
- 2014-03-27 23:59:03 KafkaController [INFO] [Controller 1]: Partitions undergoing preferred replica election:
- 2014-03-27 23:59:03 KafkaController [INFO] [Controller 1]: Partitions that completed preferred replica election:
- 2014-03-27 23:59:03 KafkaController [INFO] [Controller 1]: Resuming preferred replica election for partitions:
- 2014-03-27 23:59:03 KafkaController [INFO] [Controller 1]: Partitions being reassigned: Map()
- 2014-03-27 23:59:03 KafkaController [INFO] [Controller 1]: Partitions already reassigned: List()
- 2014-03-27 23:59:03 KafkaController [INFO] [Controller 1]: Resuming reassignment of partitions: Map()
- 2014-03-27 23:59:03 KafkaController [INFO] [Controller 1]: List of topics to be deleted:
- 2014-03-27 23:59:03 KafkaController [INFO] [Controller 1]: List of topics ineligible for deletion: input,mystore
- 2014-03-27 23:59:03 KafkaController [INFO] [Controller 1]: Currently active brokers in the cluster: Set(1, 2)
- 2014-03-27 23:59:03 KafkaController [INFO] [Controller 1]: Currently shutting brokers in the cluster: Set()
- 2014-03-27 23:59:03 KafkaController [INFO] [Controller 1]: Current list of topics in the cluster: Set(input, mystore)
- 2014-03-27 23:59:03 RequestSendThread [INFO] [Controller-1-to-broker-1-send-thread], Starting
- 2014-03-27 23:59:03 ReplicaManager [INFO] [Replica Manager on Broker 1]: Shut down
- 2014-03-27 23:59:03 ReplicaFetcherManager [INFO] [ReplicaFetcherManager on broker 1] shutting down
- 2014-03-27 23:59:03 ReplicaFetcherThread [INFO] [ReplicaFetcherThread-0-0], Shutting down
- 2014-03-27 23:59:03 ReplicaStateMachine [INFO] [Replica state machine on controller 1]: Invoking state change to OnlineReplica for replicas [Topic=input,Partition=0,Replica=1],[Topic=mystore,Partition=0,Replica=1],[Topic=input,Partition=0,Replica=2],[Topic=mystore,Partition=0,Replica=2]
- 2014-03-27 23:59:03 logger [WARN] Broker 2 received invalid LeaderAndIsr request with correlation id 0 from controller 1 epoch 2 with an older leader epoch 0 for partition [input,0], current leader epoch is 0
- 2014-03-27 23:59:03 logger [WARN] Broker 2 received invalid LeaderAndIsr request with correlation id 0 from controller 1 epoch 2 with an older leader epoch 0 for partition [mystore,0], current leader epoch is 0
- 2014-03-27 23:59:03 RequestSendThread [ERROR] [Controller-1-to-broker-1-send-thread], Controller 1 epoch 2 failed to send LeaderAndIsr request with correlation id 0 to broker id:1,host:localhost,port:45727. Reconnecting to broker.
- java.nio.channels.ClosedChannelException
- at kafka.network.BlockingChannel.send(BlockingChannel.scala:89)
- at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:132)
- at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:131)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:03 RequestSendThread [ERROR] [Controller-1-to-broker-1-send-thread], Controller 1's connection to broker id:1,host:localhost,port:45727 was unsuccessful
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.controller.RequestSendThread.connectToBroker(ControllerChannelManager.scala:173)
- at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:140)
- at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:131)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:03 ReplicaStateMachine [INFO] [Replica state machine on controller 1]: Started replica state machine with initial state -> Map([Topic=input,Partition=0,Replica=1] -> OnlineReplica, [Topic=mystore,Partition=0,Replica=2] -> OnlineReplica, [Topic=mystore,Partition=0,Replica=1] -> OnlineReplica, [Topic=input,Partition=0,Replica=2] -> OnlineReplica, [Topic=input,Partition=0,Replica=0] -> ReplicaDeletionIneligible, [Topic=mystore,Partition=0,Replica=0] -> ReplicaDeletionIneligible)
- 2014-03-27 23:59:03 OfflinePartitionLeaderSelector [INFO] [OfflinePartitionLeaderSelector]: Selected new leader and ISR {"leader":2,"leader_epoch":1,"isr":[2,1]} for offline partition [input,0]
- 2014-03-27 23:59:04 OfflinePartitionLeaderSelector [INFO] [OfflinePartitionLeaderSelector]: Selected new leader and ISR {"leader":1,"leader_epoch":1,"isr":[1,2]} for offline partition [mystore,0]
- 2014-03-27 23:59:04 ReplicaFetcherManager [INFO] [ReplicaFetcherManager on broker 2] Removed fetcher for partitions [input,0]
- 2014-03-27 23:59:04 ReplicaFetcherManager [INFO] [ReplicaFetcherManager on broker 2] Removed fetcher for partitions [mystore,0]
- 2014-03-27 23:59:04 Log [INFO] Truncating log mystore-0 to offset 0.
- 2014-03-27 23:59:04 PartitionStateMachine [INFO] [Partition state machine on Controller 1]: Started partition state machine with initial state -> Map([input,0] -> OnlinePartition, [mystore,0] -> OnlinePartition)
- 2014-03-27 23:59:04 KafkaController [INFO] [Controller 1]: Broker 1 is ready to serve as the new controller with epoch 2
- 2014-03-27 23:59:04 KafkaController [INFO] [Controller 1]: Starting preferred replica leader election for partitions
- 2014-03-27 23:59:04 PartitionStateMachine [INFO] [Partition state machine on Controller 1]: Invoking state change to OnlinePartition for partitions
- 2014-03-27 23:59:04 ReplicaFetcherManager [INFO] [ReplicaFetcherManager on broker 2] Added fetcher for partitions ArrayBuffer([[mystore,0], initOffset 0 to broker id:1,host:localhost,port:45727] )
- 2014-03-27 23:59:04 ReplicaFetcherThread [INFO] [ReplicaFetcherThread-0-0], Shutting down
- 2014-03-27 23:59:04 ReplicaFetcherThread [INFO] [ReplicaFetcherThread-0-1], Starting
- 2014-03-27 23:59:04 TopicDeletionManager$DeleteTopicsThread [INFO] [delete-topics-thread], Starting
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 0; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.getOrMakeConnection(SimpleConsumer.scala:142)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:69)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 ZookeeperLeaderElector$LeaderChangeListener [INFO] New leader is 1
- 2014-03-27 23:59:04 TopicDeletionManager [INFO] Waiting for signal to start or continue topic deletion
- 2014-03-27 23:59:04 ControllerEpochListener [INFO] [ControllerEpochListener on 1]: Initialized controller epoch to 2 and zk version 1
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 1; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 2; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 3; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 4; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 5; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 6; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 7; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 8; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 9; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 10; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 11; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 12; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 13; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 14; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 15; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 16; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 RequestSendThread [ERROR] [Controller-1-to-broker-1-send-thread], Controller 1 epoch 2 failed to send LeaderAndIsr request with correlation id 0 to broker id:1,host:localhost,port:45727. Reconnecting to broker.
- java.nio.channels.ClosedChannelException
- at kafka.network.BlockingChannel.send(BlockingChannel.scala:89)
- at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:132)
- at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:131)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 RequestSendThread [ERROR] [Controller-1-to-broker-1-send-thread], Controller 1's connection to broker id:1,host:localhost,port:45727 was unsuccessful
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.controller.RequestSendThread.connectToBroker(ControllerChannelManager.scala:173)
- at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:140)
- at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:131)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 17; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 18; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 19; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 20; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 21; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 22; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 23; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 24; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 25; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 26; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 27; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 28; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 29; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 30; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 31; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 32; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 33; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 34; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 35; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 36; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 37; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 38; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 39; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 40; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 41; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 42; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 43; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 44; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 45; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 46; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 47; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 48; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 49; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 50; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 51; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 52; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 53; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 54; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 55; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 56; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 57; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 RequestSendThread [ERROR] [Controller-1-to-broker-1-send-thread], Controller 1 epoch 2 failed to send LeaderAndIsr request with correlation id 0 to broker id:1,host:localhost,port:45727. Reconnecting to broker.
- java.nio.channels.ClosedChannelException
- at kafka.network.BlockingChannel.send(BlockingChannel.scala:89)
- at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:132)
- at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:131)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 RequestSendThread [ERROR] [Controller-1-to-broker-1-send-thread], Controller 1's connection to broker id:1,host:localhost,port:45727 was unsuccessful
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.controller.RequestSendThread.connectToBroker(ControllerChannelManager.scala:173)
- at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:140)
- at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:131)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 58; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 59; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 60; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 61; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 62; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 63; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 64; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 65; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 66; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 67; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 68; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 69; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 70; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 71; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 72; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 73; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [INFO] [ReplicaFetcherThread-0-0], Stopped
- 2014-03-27 23:59:04 ReplicaFetcherThread [INFO] [ReplicaFetcherThread-0-0], Shutdown completed
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 74; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 75; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 76; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [INFO] [ReplicaFetcherThread-0-0], Stopped
- 2014-03-27 23:59:04 ReplicaFetcherThread [INFO] [ReplicaFetcherThread-0-0], Shutdown completed
- 2014-03-27 23:59:04 ReplicaFetcherManager [INFO] [ReplicaFetcherManager on broker 1] shutdown completed
- 2014-03-27 23:59:04 ReplicaManager [INFO] [Replica Manager on Broker 1]: Shutted down completely
- 2014-03-27 23:59:04 Processor [INFO] Closing socket connection to /127.0.0.1.
- 2014-03-27 23:59:04 RequestSendThread [INFO] [Controller-1-to-broker-2-send-thread], Shutting down
- 2014-03-27 23:59:04 RequestSendThread [INFO] [Controller-1-to-broker-2-send-thread], Stopped
- 2014-03-27 23:59:04 RequestSendThread [INFO] [Controller-1-to-broker-2-send-thread], Shutdown completed
- 2014-03-27 23:59:04 RequestSendThread [INFO] [Controller-1-to-broker-1-send-thread], Shutting down
- 2014-03-27 23:59:04 Utils$ [WARN] sleep interrupted
- java.lang.InterruptedException: sleep interrupted
- at java.lang.Thread.sleep(Native Method)
- at kafka.controller.RequestSendThread$$anonfun$liftedTree1$1$1.apply$mcV$sp(ControllerChannelManager.scala:143)
- at kafka.utils.Utils$.swallow(Utils.scala:167)
- at kafka.utils.Logging$class.swallowWarn(Logging.scala:92)
- at kafka.utils.Utils$.swallowWarn(Utils.scala:46)
- at kafka.utils.Logging$class.swallow(Logging.scala:94)
- at kafka.utils.Utils$.swallow(Utils.scala:46)
- at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:143)
- at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:131)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 RequestSendThread [WARN] [Controller-1-to-broker-1-send-thread], Controller 1 fails to send a request to broker id:1,host:localhost,port:45727
- java.nio.channels.ClosedChannelException
- at kafka.network.BlockingChannel.receive(BlockingChannel.scala:97)
- at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:146)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 RequestSendThread [INFO] [Controller-1-to-broker-1-send-thread], Stopped
- 2014-03-27 23:59:04 RequestSendThread [INFO] [Controller-1-to-broker-1-send-thread], Shutdown completed
- 2014-03-27 23:59:04 KafkaController [INFO] [Controller 1]: Controller shutdown complete
- 2014-03-27 23:59:04 ZkEventThread [INFO] Terminate ZkClient event thread.
- 2014-03-27 23:59:04 PrepRequestProcessor [INFO] Processed session termination for sessionid: 0x145077b11ca0001
- 2014-03-27 23:59:04 NIOServerCnxn [INFO] Closed socket connection for client /127.0.0.1:34246 which had sessionid 0x145077b11ca0001
- 2014-03-27 23:59:04 ZookeeperLeaderElector [INFO] 2 successfully elected as leader
- 2014-03-27 23:59:04 KafkaController [INFO] [Controller 2]: Broker 2 starting become controller state transition
- 2014-03-27 23:59:04 KafkaController [INFO] [Controller 2]: Controller 2 incremented epoch to 3
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 77; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 ZooKeeper [INFO] Session: 0x145077b11ca0001 closed
- 2014-03-27 23:59:04 KafkaServer [INFO] [Kafka Server 1], shut down completed
- 2014-03-27 23:59:04 KafkaServer [INFO] [Kafka Server 2], shutting down
- 2014-03-27 23:59:04 SocketServer [INFO] [Socket Server on Broker 2], Shutting down
- 2014-03-27 23:59:04 ClientCnxn [INFO] EventThread shut down
- 2014-03-27 23:59:04 SocketServer [INFO] [Socket Server on Broker 2], Shutdown completed
- 2014-03-27 23:59:04 KafkaRequestHandlerPool [INFO] [Kafka Request Handler on Broker 2], shutting down
- 2014-03-27 23:59:04 KafkaRequestHandlerPool [INFO] [Kafka Request Handler on Broker 2], shut down completely
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 78; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 79; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 80; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 81; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 82; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 83; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 84; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 85; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 86; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 87; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 88; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 89; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 90; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 91; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 92; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 93; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaFetcherThread [ERROR] [ReplicaFetcherThread-0-1], Error in fetch Name: FetchRequest; Version: 0; CorrelationId: 94; ClientId: ReplicaFetcherThread-0-1; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [mystore,0] -> PartitionFetchInfo(0,1048576)
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
- at kafka.consumer.SimpleConsumer.reconnect(SimpleConsumer.scala:57)
- at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
- at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:71)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:109)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:108)
- at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
- at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:107)
- at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:96)
- at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 SimpleConsumer [WARN] Reconnect due to socket error: null
- 2014-03-27 23:59:04 ReplicaManager [INFO] [Replica Manager on Broker 2]: Shut down
- 2014-03-27 23:59:04 ReplicaFetcherManager [INFO] [ReplicaFetcherManager on broker 2] shutting down
- 2014-03-27 23:59:04 ReplicaFetcherThread [INFO] [ReplicaFetcherThread-0-1], Shutting down
- 2014-03-27 23:59:04 ReplicaFetcherThread [INFO] [ReplicaFetcherThread-0-1], Shutdown completed
- 2014-03-27 23:59:04 ReplicaFetcherManager [INFO] [ReplicaFetcherManager on broker 2] shutdown completed
- 2014-03-27 23:59:04 ReplicaManager [INFO] [Replica Manager on Broker 2]: Shutted down completely
- 2014-03-27 23:59:04 ReplicaFetcherThread [INFO] [ReplicaFetcherThread-0-1], Stopped
- 2014-03-27 23:59:04 RequestSendThread [ERROR] [Controller-2-to-broker-2-send-thread], Controller 2's connection to broker id:2,host:localhost,port:36283 was unsuccessful
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.controller.RequestSendThread.connectToBroker(ControllerChannelManager.scala:173)
- at kafka.controller.RequestSendThread.<init>(ControllerChannelManager.scala:118)
- at kafka.controller.ControllerChannelManager.kafka$controller$ControllerChannelManager$$addNewBroker(ControllerChannelManager.scala:87)
- at kafka.controller.ControllerChannelManager$$anonfun$1.apply(ControllerChannelManager.scala:38)
- at kafka.controller.ControllerChannelManager$$anonfun$1.apply(ControllerChannelManager.scala:38)
- at scala.collection.immutable.Set$Set1.foreach(Set.scala:74)
- at kafka.controller.ControllerChannelManager.<init>(ControllerChannelManager.scala:38)
- at kafka.controller.KafkaController.startChannelManager(KafkaController.scala:776)
- at kafka.controller.KafkaController.initializeControllerContext(KafkaController.scala:704)
- at kafka.controller.KafkaController.onControllerFailover(KafkaController.scala:309)
- at kafka.controller.KafkaController$$anonfun$1.apply$mcV$sp(KafkaController.scala:161)
- at kafka.server.ZookeeperLeaderElector.elect(ZookeeperLeaderElector.scala:63)
- at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply$mcZ$sp(ZookeeperLeaderElector.scala:123)
- at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply(ZookeeperLeaderElector.scala:118)
- at kafka.server.ZookeeperLeaderElector$LeaderChangeListener$$anonfun$handleDataDeleted$1.apply(ZookeeperLeaderElector.scala:118)
- at kafka.utils.Utils$.inLock(Utils.scala:538)
- at kafka.server.ZookeeperLeaderElector$LeaderChangeListener.handleDataDeleted(ZookeeperLeaderElector.scala:118)
- at org.I0Itec.zkclient.ZkClient$6.run(ZkClient.java:549)
- at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
- 2014-03-27 23:59:04 KafkaController [INFO] [Controller 2]: Partitions undergoing preferred replica election:
- 2014-03-27 23:59:04 KafkaController [INFO] [Controller 2]: Partitions that completed preferred replica election:
- 2014-03-27 23:59:04 KafkaController [INFO] [Controller 2]: Resuming preferred replica election for partitions:
- 2014-03-27 23:59:04 KafkaController [INFO] [Controller 2]: Partitions being reassigned: Map()
- 2014-03-27 23:59:04 KafkaController [INFO] [Controller 2]: Partitions already reassigned: List()
- 2014-03-27 23:59:04 KafkaController [INFO] [Controller 2]: Resuming reassignment of partitions: Map()
- 2014-03-27 23:59:04 KafkaController [INFO] [Controller 2]: List of topics to be deleted:
- 2014-03-27 23:59:04 KafkaController [INFO] [Controller 2]: List of topics ineligible for deletion: input,mystore
- 2014-03-27 23:59:04 KafkaController [INFO] [Controller 2]: Currently active brokers in the cluster: Set(2)
- 2014-03-27 23:59:04 RequestSendThread [INFO] [Controller-2-to-broker-2-send-thread], Starting
- 2014-03-27 23:59:04 KafkaController [INFO] [Controller 2]: Currently shutting brokers in the cluster: Set()
- 2014-03-27 23:59:04 KafkaController [INFO] [Controller 2]: Current list of topics in the cluster: Set(input, mystore)
- 2014-03-27 23:59:04 ReplicaStateMachine [INFO] [Replica state machine on controller 2]: Invoking state change to OnlineReplica for replicas [Topic=input,Partition=0,Replica=2],[Topic=mystore,Partition=0,Replica=2]
- 2014-03-27 23:59:04 RequestSendThread [ERROR] [Controller-2-to-broker-2-send-thread], Controller 2 epoch 3 failed to send LeaderAndIsr request with correlation id 0 to broker id:2,host:localhost,port:36283. Reconnecting to broker.
- java.nio.channels.ClosedChannelException
- at kafka.network.BlockingChannel.send(BlockingChannel.scala:89)
- at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:132)
- at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:131)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 RequestSendThread [ERROR] [Controller-2-to-broker-2-send-thread], Controller 2's connection to broker id:2,host:localhost,port:36283 was unsuccessful
- java.net.ConnectException: Connection refused
- at sun.nio.ch.Net.connect(Native Method)
- at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:532)
- at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
- at kafka.controller.RequestSendThread.connectToBroker(ControllerChannelManager.scala:173)
- at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:140)
- at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:131)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:04 ReplicaStateMachine [INFO] [Replica state machine on controller 2]: Started replica state machine with initial state -> Map([Topic=input,Partition=0,Replica=1] -> ReplicaDeletionIneligible, [Topic=mystore,Partition=0,Replica=2] -> OnlineReplica, [Topic=mystore,Partition=0,Replica=1] -> ReplicaDeletionIneligible, [Topic=input,Partition=0,Replica=2] -> OnlineReplica, [Topic=input,Partition=0,Replica=0] -> ReplicaDeletionIneligible, [Topic=mystore,Partition=0,Replica=0] -> ReplicaDeletionIneligible)
- 2014-03-27 23:59:05 OfflinePartitionLeaderSelector [INFO] [OfflinePartitionLeaderSelector]: Selected new leader and ISR {"leader":2,"leader_epoch":2,"isr":[2]} for offline partition [mystore,0]
- 2014-03-27 23:59:05 PartitionStateMachine [INFO] [Partition state machine on Controller 2]: Started partition state machine with initial state -> Map([input,0] -> OnlinePartition, [mystore,0] -> OnlinePartition)
- 2014-03-27 23:59:05 KafkaController [INFO] [Controller 2]: Broker 2 is ready to serve as the new controller with epoch 3
- 2014-03-27 23:59:05 KafkaController [INFO] [Controller 2]: Starting preferred replica leader election for partitions
- 2014-03-27 23:59:05 PartitionStateMachine [INFO] [Partition state machine on Controller 2]: Invoking state change to OnlinePartition for partitions
- 2014-03-27 23:59:05 RequestSendThread [INFO] [Controller-2-to-broker-2-send-thread], Shutting down
- 2014-03-27 23:59:05 Utils$ [WARN] sleep interrupted
- java.lang.InterruptedException: sleep interrupted
- at java.lang.Thread.sleep(Native Method)
- at kafka.controller.RequestSendThread$$anonfun$liftedTree1$1$1.apply$mcV$sp(ControllerChannelManager.scala:143)
- at kafka.utils.Utils$.swallow(Utils.scala:167)
- at kafka.utils.Logging$class.swallowWarn(Logging.scala:92)
- at kafka.utils.Utils$.swallowWarn(Utils.scala:46)
- at kafka.utils.Logging$class.swallow(Logging.scala:94)
- at kafka.utils.Utils$.swallow(Utils.scala:46)
- at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:143)
- at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:131)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:05 RequestSendThread [WARN] [Controller-2-to-broker-2-send-thread], Controller 2 fails to send a request to broker id:2,host:localhost,port:36283
- java.nio.channels.ClosedChannelException
- at kafka.network.BlockingChannel.receive(BlockingChannel.scala:97)
- at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:146)
- at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
- 2014-03-27 23:59:05 RequestSendThread [INFO] [Controller-2-to-broker-2-send-thread], Stopped
- 2014-03-27 23:59:05 RequestSendThread [INFO] [Controller-2-to-broker-2-send-thread], Shutdown completed
- 2014-03-27 23:59:05 KafkaController [INFO] [Controller 2]: Controller shutdown complete
- 2014-03-27 23:59:05 PrepRequestProcessor [INFO] Processed session termination for sessionid: 0x145077b11ca0002
- 2014-03-27 23:59:05 NIOServerCnxn [INFO] Closed socket connection for client /127.0.0.1:34247 which had sessionid 0x145077b11ca0002
- 2014-03-27 23:59:05 ZooKeeper [INFO] Session: 0x145077b11ca0002 closed
- 2014-03-27 23:59:05 KafkaServer [INFO] [Kafka Server 2], shut down completed
- 2014-03-27 23:59:05 ClientCnxn [INFO] EventThread shut down
- 2014-03-27 23:59:05 ZkEventThread [INFO] Terminate ZkClient event thread.
- 2014-03-27 23:59:05 PrepRequestProcessor [INFO] Processed session termination for sessionid: 0x145077b11ca0003
- 2014-03-27 23:59:05 TopicDeletionManager$DeleteTopicsThread [INFO] [delete-topics-thread], Starting
- 2014-03-27 23:59:05 TopicDeletionManager [INFO] Waiting for signal to start or continue topic deletion
- 2014-03-27 23:59:05 NIOServerCnxn [INFO] Closed socket connection for client /127.0.0.1:34249 which had sessionid 0x145077b11ca0003
- 2014-03-27 23:59:05 ClientCnxn [INFO] EventThread shut down
- 2014-03-27 23:59:05 ZooKeeper [INFO] Session: 0x145077b11ca0003 closed
- 2014-03-27 23:59:05 PrepRequestProcessor [INFO] PrepRequestProcessor exited loop!
- 2014-03-27 23:59:05 SyncRequestProcessor [INFO] SyncRequestProcessor exited!
- 2014-03-27 23:59:05 FinalRequestProcessor [INFO] shutdown of request processor complete
- 2014-03-27 23:59:05 NIOServerCnxn [INFO] NIOServerCnxn factory exited run method
- 2014-03-27 23:59:05 FinalRequestProcessor [INFO] shutdown of request processor complete
- Generated by Gradle 1.6 at Mar 28, 2014 12:00:31 AM
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement