Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-129

ZK-based producer can throw an unexpceted exception when sending a message

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 0.7
    • Fix Version/s: 0.7
    • Component/s: None
    • Labels:
      None

      Description

      Here is a log trace when that happens.

      2011/08/26 11:25:20.104 FATAL [EmbeddedConsumer] [kafka-embedded-consumer-firehoseActivity-0] [kafka] java.util.NoSuchElementException: None.getjava.util.NoSuchElementException: None.get
      at scala.None$.get(Option.scala:185)
      at scala.None$.get(Option.scala:183)
      at kafka.producer.Producer$$anonfun$3.apply(Producer.scala:115)
      at kafka.producer.Producer$$anonfun$3.apply(Producer.scala:101)
      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.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:34)
      at scala.collection.mutable.WrappedArray.foreach(WrappedArray.scala:32)
      at scala.collection.TraversableLike$class.map(TraversableLike.scala:206)
      at scala.collection.mutable.WrappedArray.map(WrappedArray.scala:32)
      at kafka.producer.Producer.send(Producer.scala:101)
      at kafka.server.EmbeddedConsumer$$anonfun$startNewConsumerThreads$1$$anonfun$apply$1$$anon$1$$anonfun$run$1.apply(KafkaServerStartable.scala:136)
      at kafka.server.EmbeddedConsumer$$anonfun$startNewConsumerThreads$1$$anonfun$apply$1$$anon$1$$anonfun$run$1.apply(KafkaServerStartable.scala:134)
      at scala.collection.Iterator$class.foreach(Iterator.scala:631)
      at kafka.utils.IteratorTemplate.foreach(IteratorTemplate.scala:30)
      at scala.collection.IterableLike$class.foreach(IterableLike.scala:79)
      at kafka.consumer.KafkaMessageStream.foreach(KafkaMessageStream.scala:29)
      at kafka.server.EmbeddedConsumer$$anonfun$startNewConsumerThreads$1$$anonfun$apply$1$$anon$1.run(KafkaServerStartable.scala:134)
      at java.lang.Thread.run(Thread.java:619)

        Attachments

        1. KAFKA-129.patch
          33 kB
          Neha Narkhede
        2. KAFKA-129.patch
          32 kB
          Neha Narkhede
        3. KAFKA-129.patch
          32 kB
          Neha Narkhede

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              junrao Jun Rao
            • Votes:
              0 Vote for this issue
              Watchers:
              0 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: