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
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
+
Jun Rao 2013-05-10, 15:58
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