Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Plain View
Kafka >> mail # user >> Re: LeaderNotAvailableException: reventing the running of kafka-console-producer.bat


+
Jun Rao 2013-04-05, 04:03
Copy link to this message
-
Re: LeaderNotAvailableException: reventing the running of kafka-console-producer.bat
The following is the problem. The broker fails to become the leader. Do you
know the revision of the code you are using so that we know the exact line
that's causing the problem?

Thanks,

Jun

[2013-04-05 10:21:09,660] ERROR Replica Manager on Broker 0: Error
processing le
aderAndISR request Name: LeaderAndIsrRequest; Version: 0; CorrelationId: 7;
Clie
ntId: ; AckTimeoutMs: 1000 ms; ControllerEpoch: 1; PartitionStateInfo:
(test,0)
-> PartitionStateInfo(LeaderIsrAndControllerEpoch({ "ISR":"0",
"leader":"0", "le
aderEpoch":"0" },1),1); Leaders:
id:0,host:MERD7-178041.echostar.com<http://merd7-178041.echostar.com/>,port:9092
(
kafka.server.ReplicaManager)
java.util.NoSuchElementException: key not found: \tmp\kafka-logs
        at scala.collection.MapLike$class.default(MapLike.scala:223)
        at scala.collection.immutable.Map$Map1.default(Map.scala:93)
        at scala.collection.MapLike$class.apply(MapLike.scala:134)
        at scala.collection.immutable.Map$Map1.apply(Map.scala:93)
        at kafka.cluster.Partition.getOrCreateReplica(Partition.scala:81)
        at kafka.cluster.Partition$$anonfun$2.apply(Partition.scala:145)
        at kafka.cluster.Partition$$anonfun$2.apply(Partition.scala:145)
On Fri, Apr 5, 2013 at 9:35 AM, Withers, Robert <[EMAIL PROTECTED]>wrote:

> I deleted all ZK and Kafka data and reran the ZK and one server.  I got
> some log traffic at this point.  It looks like the server is elected
> Leader.  The ZK is on port 2181 and the server is on port 9092.
>
> [2013-04-05 10:17:35,523] INFO 0 successfully elected as leader
> (kafka.server.Zo
> okeeperLeaderElector)
> [2013-04-05 10:17:35,623] INFO New leader is 0
> (kafka.server.ZookeeperLeaderElec
> tor$LeaderChangeListener)
>
> In ZK:
> [2013-04-05 10:17:35,131] INFO Got user-level KeeperException when
> processing se
> ssionid:0x13ddafd0fc40000 type:create cxid:0x4 zxid:0xfffffffffffffffe
> txntype:u
> nknown reqpath:n/a Error Path:/brokers Error:KeeperErrorCode = NoNode for
> /broke
> rs (org.apache.zookeeper.server.PrepRequestProcessor)
> [2013-04-05 10:17:35,238] INFO Got user-level KeeperException when
> processing se
> ssionid:0x13ddafd0fc40000 type:create cxid:0xa zxid:0xfffffffffffffffe
> txntype:u
> nknown reqpath:n/a Error Path:/config Error:KeeperErrorCode = NoNode for
> /config
>  (org.apache.zookeeper.server.PrepRequestProcessor)
> [2013-04-05 10:17:35,528] INFO Got user-level KeeperException when
> processing se
> ssionid:0x13ddafd0fc40000 type:setData cxid:0x15 zxid:0xfffffffffffffffe
> txntype
> :unknown reqpath:n/a Error Path:/controller_epoch Error:KeeperErrorCode =
> NoNode
>  for /controller_epoch (org.apache.zookeeper.server.PrepRequestProcessor)
>
> In server:
> [2013-04-05 10:17:34,983] INFO Client
> environment:java.io.tmpdir=C:\Users\ROBERT
> ~1.WIT\AppData\Local\Temp\ (org.apache.zookeeper.ZooKeeper)
> [2013-04-05 10:17:34,983] INFO Client environment:java.compiler=<NA>
> (org.apache
> .zookeeper.ZooKeeper)
> [2013-04-05 10:17:34,988] INFO Client environment:os.name=Windows 7
> (org.apache.
> zookeeper.ZooKeeper)
> [2013-04-05 10:17:34,988] INFO Client environment:os.arch=amd64
> (org.apache.zook
> eeper.ZooKeeper)
> [2013-04-05 10:17:34,989] INFO Client environment:os.version=6.1
> (org.apache.zoo
> keeper.ZooKeeper)
> [2013-04-05 10:17:34,993] INFO Client environment:user.name=Robert.Withers
> (org.
> apache.zookeeper.ZooKeeper)
> [2013-04-05 10:17:34,994] INFO Client
> environment:user.home=C:\Users\Robert.With
> ers (org.apache.zookeeper.ZooKeeper)
> [2013-04-05 10:17:34,994] INFO Client
> environment:user.dir=C:\Users\Robert.Withe
> rs\kafka-trunk\bin (org.apache.zookeeper.ZooKeeper)
> [2013-04-05 10:17:34,999] INFO Initiating client connection,
> connectString=local
> host:2181 sessionTimeout=6000 watcher=org.I0Itec.zkclient.ZkClient@5da33470(org
> .apache.zookeeper.ZooKeeper)
> [2013-04-05 10:17:35,012] INFO Opening socket connection to server
> localhost/127
> .0.0.1:2181 (org.apache.zookeeper.ClientCnxn)
> [2013-04-05 10:17:35,014] INFO Socket connection established to

 
+
Jun Rao 2013-04-05, 16:02
+
Shawn Hagwood 2013-04-05, 16:51
+
Jun Rao 2013-04-08, 05:00
+
Jun Rao 2013-04-22, 03:34
+
Jun Rao 2013-04-26, 04:08
+
Rob Withers 2013-04-26, 04:17
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB