Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> [0.8] exception running on windows when attempting to send to an uncreated topic


Copy link to this message
-
Re: [0.8] exception running on windows when attempting to send to an uncreated topic
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)
    at kafka.server.KafkaApis$$anonfun$handleTopicMetadataRequest$1.apply(KafkaApis.scala:403)
    at scala.collection.immutable.Set$Set1.foreach(Set.scala:81)
    at kafka.server.KafkaApis.handleTopicMetadataRequest(KafkaApis.scala:402)
    at kafka.server.KafkaApis.handle(KafkaApis.scala:63)
    at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:41)
    at java.lang.Thread.run(Thread.java:722)
{2013-05-09 23:52:14,579}  INFO [local-vat] (Logging.scala:67) - Disconnecting from localhost:9092
{2013-05-09 23:52:14,593}  INFO [kafka-processor-9092-1] (Logging.scala:67) - Closing socket connection to /127.0.0.1.
{2013-05-09 23:52:14,598} DEBUG [local-vat] (Logging.scala:51) - Successfully fetched metadata for 1 topic(s) Set(robert_v_2x0)
{2013-05-09 23:52:14,613}  WARN [local-vat] (Logging.scala:82) - Error while fetching metadata     partition 0    leader: none    replicas:     isr:     isUnderReplicated: false for topic partition [robert_v_2x0,0]: [class kafka.common.LeaderNotAvailableException]
{2013-05-09 23:52:14,626} DEBUG [kafka-processor-9092-1] (Logging.scala:51) - Closing connection from /127.0.0.1:52087
{2013-05-09 23:52:14,628} DEBUG [local-vat] (Logging.scala:51) - Getting broker partition info for topic robert_v_2x0
{2013-05-09 23:52:14,636} DEBUG [local-vat] (Logging.scala:51) - Partition [robert_v_2x0,0] does not have a leader yet
{2013-05-09 23:52:14,675}  INFO [ZkClient-EventThread-35-localhost:2181] (Logging.scala:67) - [Replica state machine on controller 1]: Invoking state change to NewReplica for replicas PartitionAndReplica(robert_v_2x0,0,0)
{2013-05-09 23:52:14,682} DEBUG [local-vat] (Logging.scala:51) - Broker partitions registered for topic: robert_v_2x0 are 0
{2013-05-09 23:52:14,718} DEBUG [local-vat] (Logging.scala:51) - Sending 1 messages with no compression to [robert_v_2x0,0]
{2013-05-09 23:52:14,751}  WARN [local-vat] (Logging.scala:82) - Failed to send data since partitions [robert_v_2x0,0] don't have a leader
{2013-05-09 23:52:14,756} DEBUG [SyncThread:0] (FinalRequestProcessor.java:78) - Processing request:: sessionid:0x13e8cfed52c0001 type:getDate cxid:0x27 zxid:0xfffffffffffffffe txntype:unknown reqpath:/brokers/topics/robert_v_2x0/partitions/0/state
{2013-05-09 23:52:14,757} DEBUG [SyncT