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 >> [0.8] exception running on windows when attempting to send to an uncreated topic


+
Rob Withers 2013-05-09, 06:04
+
Jun Rao 2013-05-09, 15:00
+
Rob Withers 2013-05-11, 00:38
+
Jun Rao 2013-05-11, 04:54
+
Rob Withers 2013-05-11, 04:57
+
Rob Withers 2013-05-10, 06:28
Copy link to this message
-
Re: [0.8] exception running on windows when attempting to send to an uncreated topic
Did you see my last comment in
https://issues.apache.org/jira/browse/KAFKA-876 ?

Thanks,

Jun
On Thu, May 9, 2013 at 11:27 PM, Rob Withers <[EMAIL PROTECTED]> wrote:

> Thanks, Jun. Adding that jar got me further along but there is an issue
> with the following, probably a windows issue.  I ran twice, once after the
> other was done.  Here are the exceptions I got in each run:thanks,
> rob
>
> first run:
>   {2013-05-09 23:52:14,358} DEBUG [kafka-request-handler-1]
> (Logging.scala:59) - Error while fetching metadata for partition
> [robert_v_2x0,0]
>   kafka.common.LeaderNotAvailableException: No leader exists for partition
> 0
>
>   {2013-05-09 23:52:15,369} ERROR [kafka-request-handler-1]
> (ReplicaManager.scala:229) - Error on broker 0 while processing
> LeaderAndIsr request correlationId 5 received from controller 1 epoch 1 for
> partition (robert_v_2x0,0)
>   java.util.NoSuchElementException: key not found: \tmp\kafka0-logs
>
>   {2013-05-09 23:52:16,995} ERROR [local-vat] (Logging.scala:96) - Failed
> to send requests for topics robert_v_2x0 with correlation ids in [0,11]
>   java.lang.reflect.InvocationTargetException
>   Caused by: kafka.common.FailedToSendMessageException: Failed to send
> messages after 3 tries.
>
>
> second run:
>   {2013-05-10 00:03:39,674} DEBUG [Thread-1] (Logging.scala:51) -
> Partition map for /brokers/topics/robert_v_2x0 is Map(0 -> List(0))
>
>   {2013-05-10 00:03:40,062} ERROR [kafka-request-handler-0]
> (ReplicaManager.scala:229) - Error on broker 0 while processing
> LeaderAndIsr request correlationId 0 received from controller 0 epoch 4 for
> partition (robert_v_2x0,0)
>   java.util.NoSuchElementException: key not found: \tmp\kafka0-logs
>   {2013-05-10 00:03:40,341} ERROR [kafka-request-handler-1]
> (ReplicaManager.scala:229) - Error on broker 0 while processing
> LeaderAndIsr request correlationId 1 received from controller 0 epoch 4 for
> partition (robert_v_2x0,0)
>   java.util.NoSuchElementException: key not found: \tmp\kafka0-logs
>   {2013-05-10 00:03:42,689} ERROR [kafka-request-handler-0]
> (ReplicaManager.scala:229) - Error on broker 0 while processing
> LeaderAndIsr request correlationId 0 received from controller 1 epoch 5 for
> partition (robert_v_2x0,0)
>   java.util.NoSuchElementException: key not found: \tmp\kafka0-logs
>
>   {2013-05-10 00:03:57,937} DEBUG [kafka-processor-9092-1]
> (Logging.scala:51) - Closing connection from /192.168.1.100:52261
>   java.lang.reflect.InvocationTargetException
>   Caused by: kafka.common.FailedToSendMessageException: Failed to send
> messages after 3 tries.
>
>
> {2013-05-09 23:52:14,347}  INFO [ZkClient-EventThread-35-localhost:2181]
> (Logging.scala:67) - [Controller 1]: New topic creation callback for
> [robert_v_2x0,0]
> {2013-05-09 23:52:14,349} DEBUG [kafka-request-handler-1]
> (Logging.scala:51) - replicas = List(0), in sync replicas = List(), leader
> = None
> {2013-05-09 23:52:14,358} DEBUG [kafka-request-handler-1]
> (Logging.scala:59) - Error while fetching metadata for partition
> [robert_v_2x0,0]
> kafka.common.LeaderNotAvailableException: No leader exists for partition 0
>     at kafka.admin.AdminUtils$$anonfun$3.apply(AdminUtils.scala:122)
>     at kafka.admin.AdminUtils$$anonfun$3.apply(AdminUtils.scala:104)
>     at
> scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
>     at
> scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
>     at
> scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61)
>     at scala.collection.immutable.List.foreach(List.scala:45)
>     at
> scala.collection.TraversableLike$class.map(TraversableLike.scala:206)
>     at scala.collection.immutable.List.map(List.scala:45)
>     at
> kafka.admin.AdminUtils$.kafka$admin$AdminUtils$$fetchTopicMetadataFromZk(AdminUtils.scala:104)
>     at
> kafka.admin.AdminUtils$.fetchTopicMetadataFromZk(AdminUtils.scala:93)
>     at
> kafka.server.KafkaApis$$anonfun$handleTopicMetadataRequest$1.apply(KafkaApis.scala:417)

 
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