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/05/04 21:09:00 UTC

[jira] [Commented] (KAFKA-8306) Ensure consistency of checkpointed log start offset and current log end offset

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

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

hachikuji commented on pull request #6652: KAFKA-8306: Initialize log end offset accurately when start offset is non-zero
URL: https://github.com/apache/kafka/pull/6652
 
 
   
 
----------------------------------------------------------------
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


> Ensure consistency of checkpointed log start offset and current log end offset
> ------------------------------------------------------------------------------
>
>                 Key: KAFKA-8306
>                 URL: https://issues.apache.org/jira/browse/KAFKA-8306
>             Project: Kafka
>          Issue Type: Bug
>            Reporter: Jason Gustafson
>            Assignee: Dhruvil Shah
>            Priority: Major
>
> When initializing a log, we may use the checkpointed log start offset. We need to ensure that the log end offset is set consistently with this value (i.e. it must be greater than or equal to it). This may not always be true if the log data is removed or has become corrupted. As a simple experiment, you can try the following steps to reproduce the problem:
>  # Write some data to the partition
>  # Use DeleteRecords to advance log start
>  # Shutdown the broker
>  # Delete the log directory
>  # Restart the broker
> You will see something like this in the logs:
> {code:java}
> [2019-04-29 11:55:21,259] INFO [Log partition=foo-0, dir=/tmp/kafka-logs] Completed load of log with 1 segments, log start offset 10 and log end offset 0 in 36 ms (kafka.log.Log){code}
> This may be the cause of KAFKA-8255, but I am not sure yet.



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