[ https://issues.apache.org/jira/browse/KAFKA-2903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ismael Juma updated KAFKA-2903: ------------------------------- Summary: FileRecords.read doesn't handle size > sizeInBytes when start is not zero (was: FileMessageSet's read method maybe has problem when start is not zero) > FileRecords.read doesn't handle size > sizeInBytes when start is not zero > ------------------------------------------------------------------------- > > Key: KAFKA-2903 > URL: https://issues.apache.org/jira/browse/KAFKA-2903 > Project: Kafka > Issue Type: Bug > Components: log > Affects Versions: 0.10.2.0, 0.11.0.0, 1.0.0 > 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.4.14#64029)