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)