Kafka
  1. Kafka
  2. KAFKA-274

Handle corrupted messages cleanly

    Details

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

      Description

      This is related to KAFKA-273 and is filed to improve the code to have more defensive checks against corrupted data. The data could get corrupted either due to a Kafka bug or due to bit flipping on the network. The message iterator should check if the message is valid before trying to decompress it. On the producer side, defensive checks can be turned on to verify the messages before writing those to the socket.

      1. KAFKA-274_v2.patch
        4 kB
        Neha Narkhede
      2. KAFKA-274.patch
        4 kB
        Neha Narkhede

        Issue Links

          Activity

          Tony Stevenson made changes -
          Workflow Apache Kafka Workflow [ 13052185 ] no-reopen-closed, patch-avail [ 13054319 ]
          Tony Stevenson made changes -
          Workflow no-reopen-closed, patch-avail [ 12653688 ] Apache Kafka Workflow [ 13052185 ]
          Jun Rao made changes -
          Status Patch Available [ 10002 ] Resolved [ 5 ]
          Resolution Fixed [ 1 ]
          Neha Narkhede made changes -
          Attachment KAFKA-274_v2.patch [ 12514931 ]
          Neha Narkhede made changes -
          Status In Progress [ 3 ] Patch Available [ 10002 ]
          Neha Narkhede made changes -
          Link This issue is part of KAFKA-273 [ KAFKA-273 ]
          Neha Narkhede made changes -
          Attachment KAFKA-274.patch [ 12514908 ]
          Neha Narkhede made changes -
          Field Original Value New Value
          Status Open [ 1 ] In Progress [ 3 ]
          Neha Narkhede created issue -

            People

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

              Dates

              • Created:
                Updated:
                Resolved:

                Development