Kafka
  1. Kafka
  2. KAFKA-111

A bug in the iterator of the ByteBufferMessageSet returns incorrect offsets when it encounters a compressed empty message set

    Details

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

      Description

      The deep iterator logic in the ByteBufferMessageSet returns incorrect offsets when it encounters empty compressed data. Ideally, it should be able to decompress the data, figure out that it is somehow empty, skip it and proceed to decoding rest of the data. To make this possible, the manner in which we update the offset to be returned by the iterator, needs to be tweaked.

      1. kafka-111.patch.v3
        3 kB
        Jun Rao
      2. kafka-111.patch.v2
        3 kB
        Jun Rao
      3. KAFKA-111.patch
        3 kB
        Neha Narkhede

        Activity

        Neha Narkhede created issue -
        Neha Narkhede made changes -
        Field Original Value New Value
        Attachment KAFKA-111.patch [ 12490784 ]
        Neha Narkhede made changes -
        Status Open [ 1 ] Patch Available [ 10002 ]
        Jun Rao made changes -
        Attachment kafka-111.patch.v2 [ 12490832 ]
        Jun Rao made changes -
        Attachment kafka-111.patch.v3 [ 12490843 ]
        Jun Rao made changes -
        Status Patch Available [ 10002 ] Resolved [ 5 ]
        Fix Version/s 0.7 [ 12317243 ]
        Resolution Fixed [ 1 ]
        Tony Stevenson made changes -
        Workflow no-reopen-closed, patch-avail [ 12627577 ] Apache Kafka Workflow [ 13052674 ]
        Tony Stevenson made changes -
        Workflow Apache Kafka Workflow [ 13052674 ] no-reopen-closed, patch-avail [ 13055330 ]

          People

          • Assignee:
            Unassigned
            Reporter:
            Neha Narkhede
          • Votes:
            0 Vote for this issue
            Watchers:
            0 Start watching this issue

            Dates

            • Created:
              Updated:
              Resolved:

              Development