Pengwei created KAFKA-2903:
------------------------------

             Summary: FileMessageSet's read method maybe has problem when start 
is not zero
                 Key: KAFKA-2903
                 URL: https://issues.apache.org/jira/browse/KAFKA-2903
             Project: Kafka
          Issue Type: Bug
          Components: log
            Reporter: Pengwei
            Assignee: Jay Kreps


now the code is :
def read(position: Int, size: Int): FileMessageSet = {
   ..... 
    new FileMessageSet(file,
                       channel,
                       start = this.start + position,
                       end = math.min(this.start + position + size, 
sizeInBytes()))
  }

if this.start is not 0, the end is only the FileMessageSet's size, not the 
actually position of end position.
the end parameter should be:
 end = math.min(this.start + position + size, this.start+sizeInBytes())





--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to