BUG REPORT
- Please describe the issue you observed:
In org.apache.rocketmq.store.index.IndexFile#putKey
if (this.indexHeader.getIndexCount() <= 1) {
this.indexHeader.setBeginPhyOffset(phyOffset);
this.indexHeader.setBeginTimestamp(storeTimestamp);
}
When the second message is added to the IndexFile, beginPhyOffset and beginTimestamp will still be updated because it satisfies indexCount less than or equal to 1
if (this.indexHeader.getIndexCount() < 1) {
this.indexHeader.setBeginPhyOffset(phyOffset);
this.indexHeader.setBeginTimestamp(storeTimestamp);
}
- Please tell us about your environment:
version:4.9.3
BUG REPORT
In
org.apache.rocketmq.store.index.IndexFile#putKeyWhen the second message is added to the IndexFile, beginPhyOffset and beginTimestamp will still be updated because it satisfies indexCount less than or equal to 1
version:4.9.3