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

Jun Rao commented on KAFKA-1112:
--------------------------------

Thanks for the patch. A few comments.

1. I am a bit concerned of depending on a potentially corrupted index to look 
for recoveryPoint - 1 in LogSegment.needsRecovery(). If the index points to an 
arbitrary position in FileMessageSet, the offset value that 
FileMessageSet.searchFor() finds  is garbage. If that value happens to be 
larger than targetOffset, we will assume that we find targetOffset, but in fact 
we haven't.

2. LogTest.testCorruptLog(): Is the println statement needed?

3. Could you rebase?

> broker can not start itself after kafka is killed with -9
> ---------------------------------------------------------
>
>                 Key: KAFKA-1112
>                 URL: https://issues.apache.org/jira/browse/KAFKA-1112
>             Project: Kafka
>          Issue Type: Bug
>          Components: log
>    Affects Versions: 0.8, 0.8.1
>            Reporter: Kane Kim
>            Assignee: Jay Kreps
>            Priority: Critical
>         Attachments: KAFKA-1112-v1.patch, KAFKA-1112.out
>
>
> When I kill kafka with -9, broker cannot start itself because of corrupted 
> index logs. I think kafka should try to delete/rebuild indexes itself without 
> manual intervention. 



--
This message was sent by Atlassian JIRA
(v6.1#6144)

Reply via email to