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

OffsetManager uses incorrect field for metadata

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 0.9.0.0
    • 0.9.0.0
    • core
    • None

    Description

      java.lang.ClassCastException: java.lang.Long cannot be cast to
      java.lang.String

      at
      kafka.server.OffsetManager$.kafka$server$OffsetManager$$readMessageValue(OffsetManager.scala:576)

      at
      kafka.server.OffsetManager$$anonfun$kafka$server$OffsetManager$$loadOffsets$1$2.apply(OffsetManager.scala:388)

      at
      kafka.server.OffsetManager$$anonfun$kafka$server$OffsetManager$$loadOffsets$1$2.apply(OffsetManager.scala:377)

      at scala.collection.Iterator$class.foreach(Iterator.scala:727)

      at kafka.utils.IteratorTemplate.foreach(IteratorTemplate.scala:32)

      at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)

      at kafka.message.MessageSet.foreach(MessageSet.scala:67)

      at
      kafka.server.OffsetManager.kafka$server$OffsetManager$$loadOffsets$1(OffsetManager.scala:377)

      at
      kafka.server.OffsetManager$$anonfun$loadOffsetsFromLog$1.apply$mcV$sp(OffsetManager.scala:358)

      at
      Saw the following exception.

      kafka.utils.KafkaScheduler$$anonfun$1.apply$mcV$sp(KafkaScheduler.scala:108)

      at kafka.utils.CoreUtils$$anon$1.run(CoreUtils.scala:60)

      at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)

      at java.util.concurrent.FutureTask.run(FutureTask.java:262)

      at
      java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:178)

      at
      java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:292)

      at
      java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)

      at
      java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)

      at java.lang.Thread.run(Thread.java:744)

      Attachments

        1. KAFKA-2117.patch
          1 kB
          Guozhang Wang

        Activity

          People

            guozhang Guozhang Wang
            junrao Jun Rao
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: