Kafka, mail # user - Re: LeaderNotAvailableException: reventing the running of kafka-console-producer.bat - 2013-04-06, 04:11
 Search Hadoop and all its subprojects:

Switch to Threaded View
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:
 
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