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

ASF GitHub Bot commented on KAFKA-5075:
---------------------------------------

GitHub user lindong28 opened a pull request:

    https://github.com/apache/kafka/pull/2859

    KAFKA-5075; Defer exception to the next pollOnce() if consumer's fetch 
position has already increased

    

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/lindong28/kafka KAFKA-5075

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/kafka/pull/2859.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #2859
    
----
commit a0d358396c94c6252790920fc80d42d60caf6289
Author: Dong Lin <lindon...@gmail.com>
Date:   2017-04-15T22:42:26Z

    KAFKA-5075; Defer exception to the next pollOnce() if consumer's fetch 
position has already increased

----


> Defer exception to the next pollOnce() if consumer's fetch position has 
> already increased
> -----------------------------------------------------------------------------------------
>
>                 Key: KAFKA-5075
>                 URL: https://issues.apache.org/jira/browse/KAFKA-5075
>             Project: Kafka
>          Issue Type: Bug
>          Components: clients, consumer
>    Affects Versions: 0.10.2.0
>            Reporter: Jiangjie Qin
>            Assignee: Dong Lin
>             Fix For: 0.11.0.0
>
>
> In Fetcher.fetchRecords() we iterate over the partition data to collect the 
> ConsumerRecords, after we collect some consumer records from a partition, we 
> advance the position of that partition then move on to the next partition. If 
> the next partition throws exceptions (e.g. OffsetOutOfRangeException), the 
> messages that have already been read out of the buffer will not be delivered 
> to the users. Since the positions of the previous partitions have been be 
> updated, those messages will not be consumed again either.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Reply via email to