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)