Home | About | Sematext search-lucene.com search-hadoop.com
 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
Jun Rao 2013-05-10, 15:58
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)