You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/12/13 17:25:00 UTC

[jira] [Commented] (KAFKA-7733) MockConsumer doesn't respect reset strategy

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

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

srdo opened a new pull request #6030: KAFKA-7733: Reset the MockConsumer position according to its reset st…
URL: https://github.com/apache/kafka/pull/6030
 
 
   …rategy if the position is behind the beginning offset
   
   The poll method in MockConsumer will now use the configured reset strategy when it encounters a record with an offset below the beginning offset. 
   
   The poll method will also not clear the records list automatically. Letting the consumer position control which records are returned from poll is more similar to how the real consumer works, so e.g. a test can put a message in the consumer, poll for it, seek to the beginning and get the message out again. If tests need to delete the records entirely, they can still do so through a new method.
   
   ### Committer Checklist (excluded from commit message)
   - [ ] Verify design and implementation 
   - [ ] Verify test coverage and CI build status
   - [ ] Verify documentation (including upgrade notes)
   

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


> MockConsumer doesn't respect reset strategy
> -------------------------------------------
>
>                 Key: KAFKA-7733
>                 URL: https://issues.apache.org/jira/browse/KAFKA-7733
>             Project: Kafka
>          Issue Type: Improvement
>          Components: clients
>            Reporter: Stig Rohde Døssing
>            Assignee: Stig Rohde Døssing
>            Priority: Major
>
> The MockConsumer throws OffsetOutOfRangeException if a record is behind the beginning offset. This is unlike the real consumer, which will use auto.offset.reset to decide whether to seek to the beginning, end or throw an exception.
> It is convenient if the poll method does the offset reset properly, since it allows for testing cases like a consumer requesting offsets from a truncated log.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)