Uploaded image for project: 'Apache Storm'
  1. Apache Storm
  2. STORM-1094

kafka offset does not advance when deserializer yields no object

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 0.10.0, 1.0.0, 0.9.6
    • Fix Version/s: 0.10.0
    • Component/s: storm-kafka
    • Labels:

      Description

      If a custom deserializer returns an empty list of objects as a result of deserializing messages from kafka, the partition manager does not advance the kafka offset, and the same message will continue to be deserialized and return nothing. The code works if the deserializer returns null, but not if it returns an empty list.

        Attachments

          Activity

            People

            • Assignee:
              prokopowicz Pete Prokopowicz
              Reporter:
              prokopowicz Pete Prokopowicz
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: