You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Ma Tianchi (JIRA)" <ji...@apache.org> on 2017/05/25 13:26:04 UTC

[jira] [Created] (KAFKA-5326) Log offset index resize cause empty index file

Ma Tianchi created KAFKA-5326:
---------------------------------

             Summary: Log offset index  resize cause empty  index file
                 Key: KAFKA-5326
                 URL: https://issues.apache.org/jira/browse/KAFKA-5326
             Project: Kafka
          Issue Type: Bug
          Components: core, log
    Affects Versions: 0.10.2.1
            Reporter: Ma Tianchi


After a log index file lost or be removed when kafka server is running,then some one calls OffsetIndex.resize(newSize: Int) .It will cause a new index file be created but there is no values in it,even though the size is same with old one.
It will do something as below. 
val raf = new RandomAccessFile(file, "rw")
This time file does not exit.It will create a new file.
Then at:
mmap = raf.getChannel().map(FileChannel.MapMode.READ_WRITE, 0, roundedNewSize)
The mmap is created from new file which is empty.
and then:
mmap.position(position)
This make the new index file which size is same with old index file,but there is nothing in it.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)