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

Cryptic serde error messages in new producer

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Critical
    • Resolution: Fixed
    • 0.10.1.0
    • None
    • producer
    • None

    Description

      One of the motivations for the new serde format is better error reporting. I was running a test on the new mirror maker when I saw this exception -

      java.nio.BufferUnderflowException
      at java.nio.Buffer.nextGetIndex(Buffer.java:480)
      at java.nio.HeapByteBuffer.getInt(HeapByteBuffer.java:336)
      at kafka.common.protocol.types.Type$3.read(Type.java:88)
      at kafka.common.protocol.types.Schema.read(Schema.java:50)
      at kafka.common.protocol.types.ArrayOf.read(ArrayOf.java:30)
      at kafka.common.protocol.types.Schema.read(Schema.java:50)
      at kafka.common.protocol.types.ArrayOf.read(ArrayOf.java:30)
      at kafka.common.protocol.types.Schema.read(Schema.java:50)
      at kafka.clients.producer.internals.Sender.handleResponses(Sender.java:273)
      at kafka.clients.producer.internals.Sender.run(Sender.java:144)
      at kafka.clients.producer.internals.Sender.run(Sender.java:84)
      at java.lang.Thread.run(Thread.java:619)

      I was expecting to see a precise error message about the Request type that serde failed for. Instead it says Type$3 and no information on which field.

      Attachments

        1. KAFKA-1241.patch
          2 kB
          Jay Kreps

        Activity

          People

            jkreps Jay Kreps
            nehanarkhede Neha Narkhede
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: