You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@storm.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/07 17:18:27 UTC

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

    [ https://issues.apache.org/jira/browse/STORM-1094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14947006#comment-14947006 ] 

ASF GitHub Bot commented on STORM-1094:
---------------------------------------

Github user prokopowicz commented on the pull request:

    https://github.com/apache/storm/pull/758#issuecomment-146227524
  
    I issued this JIRA regarding the bug:
    
    https://issues.apache.org/jira/browse/STORM-1094
    
    
    On Tue, Oct 6, 2015 at 3:40 PM, Jungtaek Lim <no...@github.com>
    wrote:
    
    > +1, too.
    > @prokopowicz <https://github.com/prokopowicz>
    > Since this is a bug, I'd like to record this to JIRA issue before merging.
    > Could you file a JIRA, please?
    >
    > —
    > Reply to this email directly or view it on GitHub
    > <https://github.com/apache/storm/pull/758#issuecomment-145993674>.
    >



> 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
>              Labels: patch
>
> 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)