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 Threaded View
Kafka >> mail # user >> Re: LeaderNotAvailableException: reventing the running of kafka-console-producer.bat


Copy link to this message
-
Re: LeaderNotAvailableException: reventing the running of kafka-console-producer.bat
That hash tag points to a commit on Apr 4 and is probably not what you
have. Try "git log" on the checkout that builds your binary. If you can't
figure this out, could you try the latest code in the 0.8 branch and see if
the problem still exists?

Thanks,

Jun
On Sat, Apr 6, 2013 at 10:36 AM, Withers, Robert <[EMAIL PROTECTED]>wrote:

> I am not entirely sure as it has been about a year since I used git.
>  Looking in .git\refs\heads\0.8, I have
> afecc9f23108b100b27017974b132331d6bab8e6.  .git\HEAD says ref:
> refs/heads/0.8.
>
> If this is not what you need, tell me how I can get you the right info.
>
> Thanks,
> Rob
>
>
> ________________________________________
> From: Jun Rao [[EMAIL PROTECTED]]
> Sent: Friday, April 05, 2013 10:10 PM
> To: [EMAIL PROTECTED]
> Subject: 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)

 
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