You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@storm.apache.org by "Pete Prokopowicz (JIRA)" <ji...@apache.org> on 2015/10/07 17:18:26 UTC

[jira] [Created] (STORM-1094) kafka offset does not advance when deserializer yields no object

Pete Prokopowicz created STORM-1094:
---------------------------------------

             Summary: kafka offset does not advance when deserializer yields no object 
                 Key: STORM-1094
                 URL: https://issues.apache.org/jira/browse/STORM-1094
             Project: Apache Storm
          Issue Type: Bug
          Components: storm-kafka
    Affects Versions: 0.11.0
            Reporter: Pete Prokopowicz


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.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)