fix: commit topic partitions end offsets

[IpShot]

Set topic partitions offsets to the end of logs.

Issue: #193

[ttypic]

Hi @IpShot,

Thank you very much for reporting the issue and providing a solution! However, I believe the fix might be applied in the wrong place. The getMaximumOffset method correctly calculates the maximum offset. The issue seems to occur in the preCommit method, where we specify the offsets to commit.

The actual problem is that the offsets we commit are for the messages we want to read next, rather than the offsets of the messages we have already read. I suggest moving the +1 logic to the updateOffsets method, which is invoked in preCommit.

Thanks again for your help

[IpShot]

Hi @IpShot,

Thank you very much for reporting the issue and providing a solution! However, I believe the fix might be applied in the wrong place. The getMaximumOffset method correctly calculates the maximum offset. The issue seems to occur in the preCommit method, where we specify the offsets to commit.

The actual problem is that the offsets we commit are for the messages we want to read next, rather than the offsets of the messages we have already read. I suggest moving the +1 logic to the updateOffsets method, which is invoked in preCommit.

Thanks again for your help

Thanks for the review. Agree with your point, updated.