[jira] [Created] (KAFKA-5075) The position in the consumers may be advanced incorrectly when some exception is thrown from consumer.poll()

[Jiangjie Qin (JIRA)]

Jiangjie Qin created KAFKA-5075:
-----------------------------------

             Summary: The position in the consumers may be advanced incorrectly 
when some exception is thrown from consumer.poll()
                 Key: KAFKA-5075
                 URL: https://issues.apache.org/jira/browse/KAFKA-5075
             Project: Kafka
          Issue Type: Bug
            Reporter: Jiangjie Qin


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)