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 2019/03/05 00:30:00 UTC

[jira] [Commented] (KAFKA-7747) Consumer should check for truncation after leader changes

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

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

mumrah commented on pull request #6371: KAFKA-7747 Check for truncation after leader changes
URL: https://github.com/apache/kafka/pull/6371
 
 
   After the client detects a leader change we need to check the offset of the current leader for truncation. 
   
   
   
   TODO expand on this.
   
   ### 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 to 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


> Consumer should check for truncation after leader changes
> ---------------------------------------------------------
>
>                 Key: KAFKA-7747
>                 URL: https://issues.apache.org/jira/browse/KAFKA-7747
>             Project: Kafka
>          Issue Type: Improvement
>          Components: consumer
>            Reporter: Jason Gustafson
>            Assignee: Jason Gustafson
>            Priority: Major
>
> The change is documented in KIP-320: https://cwiki.apache.org/confluence/display/KAFKA/KIP-320%3A+Allow+fetchers+to+detect+and+handle+log+truncation. After a leader change, the consumer needs to verify its current fetch offset



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